ridv/gorealis
1
0
Fork 0
Code Issues Pull requests Projects Releases 23 Packages Wiki Activity Actions

Adding Job Update strategy API to thrift and to generated go binding.

Browse source
This commit is contained in:
Renan DelValle 2018-12-19 16:55:42 -08:00
parent 9a835631b2
commit 926f802987
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
8 changed files with 1542 additions and 958 deletions
Download patch file Download diff file Expand all files Collapse all files

28
auroraAPI.thrift
View file

@ -716,6 +716,31 @@ struct JobUpdateKey {
2: string id 2: string id
} }
/** Limits the amount of active changes being made to instances to groupSize. */
struct QueueJobUpdateStrategy {
1: i32 groupSize
}
/** Similar to Queue strategy but will not start a new group until all instances in an active
* group have finished updating.
*/
struct BatchJobUpdateStrategy {
1: i32 groupSize
}
/** Same as Batch strategy but each time an active group completes, the size of the next active
* group may change.
*/
struct VariableBatchJobUpdateStrategy {
1: list<i32> groupSizes
}
union JobUpdateStrategy {
1: QueueJobUpdateStrategy queueStrategy
2: BatchJobUpdateStrategy batchStrategy
3: VariableBatchJobUpdateStrategy varBatchStrategy
}
/** Job update thresholds and limits. */ /** Job update thresholds and limits. */
struct JobUpdateSettings { struct JobUpdateSettings {
/** Max number of instances being updated at any given moment. */ /** Max number of instances being updated at any given moment. */
@ -755,6 +780,9 @@ struct JobUpdateSettings {
* differs between the old and new task configurations, updates will use the newest configuration. * differs between the old and new task configurations, updates will use the newest configuration.
*/ */
10: optional bool slaAware 10: optional bool slaAware
/** Update strategy to be used for the update. See JobUpdateStrategy for choices. */
11: optional JobUpdateStrategy updateStrategy
} }
/** Event marking a state transition in job update lifecycle. */ /** Event marking a state transition in job update lifecycle. */

638
gen-go/apache/aurora/aurora_admin-remote/aurora_admin-remote.go
View file

@ -166,19 +166,19 @@ func main() {
} }
argvalue0 := flag.Arg(1) argvalue0 := flag.Arg(1)
value0 := argvalue0 value0 := argvalue0
arg354 := flag.Arg(2) arg355 := flag.Arg(2)
mbTrans355 := thrift.NewTMemoryBufferLen(len(arg354)) mbTrans356 := thrift.NewTMemoryBufferLen(len(arg355))
defer mbTrans355.Close() defer mbTrans356.Close()
_, err356 := mbTrans355.WriteString(arg354) _, err357 := mbTrans356.WriteString(arg355)
if err356 != nil { if err357 != nil {
Usage() Usage()
return return
} }
factory357 := thrift.NewTSimpleJSONProtocolFactory() factory358 := thrift.NewTSimpleJSONProtocolFactory()
jsProt358 := factory357.GetProtocol(mbTrans355) jsProt359 := factory358.GetProtocol(mbTrans356)
argvalue1 := aurora.NewResourceAggregate() argvalue1 := aurora.NewResourceAggregate()
err359 := argvalue1.Read(jsProt358) err360 := argvalue1.Read(jsProt359)
if err359 != nil { if err360 != nil {
Usage() Usage()
return return
} }
@ -234,19 +234,19 @@ func main() {
fmt.Fprintln(os.Stderr, "QueryRecovery requires 1 args") fmt.Fprintln(os.Stderr, "QueryRecovery requires 1 args")
flag.Usage() flag.Usage()
} }
arg362 := flag.Arg(1) arg363 := flag.Arg(1)
mbTrans363 := thrift.NewTMemoryBufferLen(len(arg362)) mbTrans364 := thrift.NewTMemoryBufferLen(len(arg363))
defer mbTrans363.Close() defer mbTrans364.Close()
_, err364 := mbTrans363.WriteString(arg362) _, err365 := mbTrans364.WriteString(arg363)
if err364 != nil { if err365 != nil {
Usage() Usage()
return return
} }
factory365 := thrift.NewTSimpleJSONProtocolFactory() factory366 := thrift.NewTSimpleJSONProtocolFactory()
jsProt366 := factory365.GetProtocol(mbTrans363) jsProt367 := factory366.GetProtocol(mbTrans364)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err367 := argvalue0.Read(jsProt366) err368 := argvalue0.Read(jsProt367)
if err367 != nil { if err368 != nil {
Usage() Usage()
return return
} }
@ -259,19 +259,19 @@ func main() {
fmt.Fprintln(os.Stderr, "DeleteRecoveryTasks requires 1 args") fmt.Fprintln(os.Stderr, "DeleteRecoveryTasks requires 1 args")
flag.Usage() flag.Usage()
} }
arg368 := flag.Arg(1) arg369 := flag.Arg(1)
mbTrans369 := thrift.NewTMemoryBufferLen(len(arg368)) mbTrans370 := thrift.NewTMemoryBufferLen(len(arg369))
defer mbTrans369.Close() defer mbTrans370.Close()
_, err370 := mbTrans369.WriteString(arg368) _, err371 := mbTrans370.WriteString(arg369)
if err370 != nil { if err371 != nil {
Usage() Usage()
return return
} }
factory371 := thrift.NewTSimpleJSONProtocolFactory() factory372 := thrift.NewTSimpleJSONProtocolFactory()
jsProt372 := factory371.GetProtocol(mbTrans369) jsProt373 := factory372.GetProtocol(mbTrans370)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err373 := argvalue0.Read(jsProt372) err374 := argvalue0.Read(jsProt373)
if err373 != nil { if err374 != nil {
Usage() Usage()
return return
} }
@ -300,19 +300,19 @@ func main() {
fmt.Fprintln(os.Stderr, "StartMaintenance requires 1 args") fmt.Fprintln(os.Stderr, "StartMaintenance requires 1 args")
flag.Usage() flag.Usage()
} }
arg374 := flag.Arg(1) arg375 := flag.Arg(1)
mbTrans375 := thrift.NewTMemoryBufferLen(len(arg374)) mbTrans376 := thrift.NewTMemoryBufferLen(len(arg375))
defer mbTrans375.Close() defer mbTrans376.Close()
_, err376 := mbTrans375.WriteString(arg374) _, err377 := mbTrans376.WriteString(arg375)
if err376 != nil { if err377 != nil {
Usage() Usage()
return return
} }
factory377 := thrift.NewTSimpleJSONProtocolFactory() factory378 := thrift.NewTSimpleJSONProtocolFactory()
jsProt378 := factory377.GetProtocol(mbTrans375) jsProt379 := factory378.GetProtocol(mbTrans376)
argvalue0 := aurora.NewHosts() argvalue0 := aurora.NewHosts()
err379 := argvalue0.Read(jsProt378) err380 := argvalue0.Read(jsProt379)
if err379 != nil { if err380 != nil {
Usage() Usage()
return return
} }
@ -325,19 +325,19 @@ func main() {
fmt.Fprintln(os.Stderr, "DrainHosts requires 1 args") fmt.Fprintln(os.Stderr, "DrainHosts requires 1 args")
flag.Usage() flag.Usage()
} }
arg380 := flag.Arg(1) arg381 := flag.Arg(1)
mbTrans381 := thrift.NewTMemoryBufferLen(len(arg380)) mbTrans382 := thrift.NewTMemoryBufferLen(len(arg381))
defer mbTrans381.Close() defer mbTrans382.Close()
_, err382 := mbTrans381.WriteString(arg380) _, err383 := mbTrans382.WriteString(arg381)
if err382 != nil { if err383 != nil {
Usage() Usage()
return return
} }
factory383 := thrift.NewTSimpleJSONProtocolFactory() factory384 := thrift.NewTSimpleJSONProtocolFactory()
jsProt384 := factory383.GetProtocol(mbTrans381) jsProt385 := factory384.GetProtocol(mbTrans382)
argvalue0 := aurora.NewHosts() argvalue0 := aurora.NewHosts()
err385 := argvalue0.Read(jsProt384) err386 := argvalue0.Read(jsProt385)
if err385 != nil { if err386 != nil {
Usage() Usage()
return return
} }
@ -350,19 +350,19 @@ func main() {
fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args") fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args")
flag.Usage() flag.Usage()
} }
arg386 := flag.Arg(1) arg387 := flag.Arg(1)
mbTrans387 := thrift.NewTMemoryBufferLen(len(arg386)) mbTrans388 := thrift.NewTMemoryBufferLen(len(arg387))
defer mbTrans387.Close() defer mbTrans388.Close()
_, err388 := mbTrans387.WriteString(arg386) _, err389 := mbTrans388.WriteString(arg387)
if err388 != nil { if err389 != nil {
Usage() Usage()
return return
} }
factory389 := thrift.NewTSimpleJSONProtocolFactory() factory390 := thrift.NewTSimpleJSONProtocolFactory()
jsProt390 := factory389.GetProtocol(mbTrans387) jsProt391 := factory390.GetProtocol(mbTrans388)
argvalue0 := aurora.NewHosts() argvalue0 := aurora.NewHosts()
err391 := argvalue0.Read(jsProt390) err392 := argvalue0.Read(jsProt391)
if err391 != nil { if err392 != nil {
Usage() Usage()
return return
} }
@ -375,19 +375,19 @@ func main() {
fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args") fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args")
flag.Usage() flag.Usage()
} }
arg392 := flag.Arg(1) arg393 := flag.Arg(1)
mbTrans393 := thrift.NewTMemoryBufferLen(len(arg392)) mbTrans394 := thrift.NewTMemoryBufferLen(len(arg393))
defer mbTrans393.Close() defer mbTrans394.Close()
_, err394 := mbTrans393.WriteString(arg392) _, err395 := mbTrans394.WriteString(arg393)
if err394 != nil { if err395 != nil {
Usage() Usage()
return return
} }
factory395 := thrift.NewTSimpleJSONProtocolFactory() factory396 := thrift.NewTSimpleJSONProtocolFactory()
jsProt396 := factory395.GetProtocol(mbTrans393) jsProt397 := factory396.GetProtocol(mbTrans394)
argvalue0 := aurora.NewHosts() argvalue0 := aurora.NewHosts()
err397 := argvalue0.Read(jsProt396) err398 := argvalue0.Read(jsProt397)
if err397 != nil { if err398 != nil {
Usage() Usage()
return return
} }
@ -400,42 +400,42 @@ func main() {
fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args") fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args")
flag.Usage() flag.Usage()
} }
arg398 := flag.Arg(1) arg399 := flag.Arg(1)
mbTrans399 := thrift.NewTMemoryBufferLen(len(arg398)) mbTrans400 := thrift.NewTMemoryBufferLen(len(arg399))
defer mbTrans399.Close() defer mbTrans400.Close()
_, err400 := mbTrans399.WriteString(arg398) _, err401 := mbTrans400.WriteString(arg399)
if err400 != nil { if err401 != nil {
Usage() Usage()
return return
} }
factory401 := thrift.NewTSimpleJSONProtocolFactory() factory402 := thrift.NewTSimpleJSONProtocolFactory()
jsProt402 := factory401.GetProtocol(mbTrans399) jsProt403 := factory402.GetProtocol(mbTrans400)
argvalue0 := aurora.NewHosts() argvalue0 := aurora.NewHosts()
err403 := argvalue0.Read(jsProt402) err404 := argvalue0.Read(jsProt403)
if err403 != nil { if err404 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
arg404 := flag.Arg(2) arg405 := flag.Arg(2)
mbTrans405 := thrift.NewTMemoryBufferLen(len(arg404)) mbTrans406 := thrift.NewTMemoryBufferLen(len(arg405))
defer mbTrans405.Close() defer mbTrans406.Close()
_, err406 := mbTrans405.WriteString(arg404) _, err407 := mbTrans406.WriteString(arg405)
if err406 != nil { if err407 != nil {
Usage() Usage()
return return
} }
factory407 := thrift.NewTSimpleJSONProtocolFactory() factory408 := thrift.NewTSimpleJSONProtocolFactory()
jsProt408 := factory407.GetProtocol(mbTrans405) jsProt409 := factory408.GetProtocol(mbTrans406)
argvalue1 := aurora.NewSlaPolicy() argvalue1 := aurora.NewSlaPolicy()
err409 := argvalue1.Read(jsProt408) err410 := argvalue1.Read(jsProt409)
if err409 != nil { if err410 != nil {
Usage() Usage()
return return
} }
value1 := argvalue1 value1 := argvalue1
argvalue2, err410 := (strconv.ParseInt(flag.Arg(3), 10, 64)) argvalue2, err411 := (strconv.ParseInt(flag.Arg(3), 10, 64))
if err410 != nil { if err411 != nil {
Usage() Usage()
return return
} }
@ -456,19 +456,19 @@ func main() {
fmt.Fprintln(os.Stderr, "TriggerExplicitTaskReconciliation requires 1 args") fmt.Fprintln(os.Stderr, "TriggerExplicitTaskReconciliation requires 1 args")
flag.Usage() flag.Usage()
} }
arg411 := flag.Arg(1) arg412 := flag.Arg(1)
mbTrans412 := thrift.NewTMemoryBufferLen(len(arg411)) mbTrans413 := thrift.NewTMemoryBufferLen(len(arg412))
defer mbTrans412.Close() defer mbTrans413.Close()
_, err413 := mbTrans412.WriteString(arg411) _, err414 := mbTrans413.WriteString(arg412)
if err413 != nil { if err414 != nil {
Usage() Usage()
return return
} }
factory414 := thrift.NewTSimpleJSONProtocolFactory() factory415 := thrift.NewTSimpleJSONProtocolFactory()
jsProt415 := factory414.GetProtocol(mbTrans412) jsProt416 := factory415.GetProtocol(mbTrans413)
argvalue0 := aurora.NewExplicitReconciliationSettings() argvalue0 := aurora.NewExplicitReconciliationSettings()
err416 := argvalue0.Read(jsProt415) err417 := argvalue0.Read(jsProt416)
if err416 != nil { if err417 != nil {
Usage() Usage()
return return
} }
@ -489,19 +489,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PruneTasks requires 1 args") fmt.Fprintln(os.Stderr, "PruneTasks requires 1 args")
flag.Usage() flag.Usage()
} }
arg417 := flag.Arg(1) arg418 := flag.Arg(1)
mbTrans418 := thrift.NewTMemoryBufferLen(len(arg417)) mbTrans419 := thrift.NewTMemoryBufferLen(len(arg418))
defer mbTrans418.Close() defer mbTrans419.Close()
_, err419 := mbTrans418.WriteString(arg417) _, err420 := mbTrans419.WriteString(arg418)
if err419 != nil { if err420 != nil {
Usage() Usage()
return return
} }
factory420 := thrift.NewTSimpleJSONProtocolFactory() factory421 := thrift.NewTSimpleJSONProtocolFactory()
jsProt421 := factory420.GetProtocol(mbTrans418) jsProt422 := factory421.GetProtocol(mbTrans419)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err422 := argvalue0.Read(jsProt421) err423 := argvalue0.Read(jsProt422)
if err422 != nil { if err423 != nil {
Usage() Usage()
return return
} }
@ -514,19 +514,19 @@ func main() {
fmt.Fprintln(os.Stderr, "CreateJob requires 1 args") fmt.Fprintln(os.Stderr, "CreateJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg423 := flag.Arg(1) arg424 := flag.Arg(1)
mbTrans424 := thrift.NewTMemoryBufferLen(len(arg423)) mbTrans425 := thrift.NewTMemoryBufferLen(len(arg424))
defer mbTrans424.Close() defer mbTrans425.Close()
_, err425 := mbTrans424.WriteString(arg423) _, err426 := mbTrans425.WriteString(arg424)
if err425 != nil { if err426 != nil {
Usage() Usage()
return return
} }
factory426 := thrift.NewTSimpleJSONProtocolFactory() factory427 := thrift.NewTSimpleJSONProtocolFactory()
jsProt427 := factory426.GetProtocol(mbTrans424) jsProt428 := factory427.GetProtocol(mbTrans425)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err428 := argvalue0.Read(jsProt427) err429 := argvalue0.Read(jsProt428)
if err428 != nil { if err429 != nil {
Usage() Usage()
return return
} }
@ -539,19 +539,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg429 := flag.Arg(1) arg430 := flag.Arg(1)
mbTrans430 := thrift.NewTMemoryBufferLen(len(arg429)) mbTrans431 := thrift.NewTMemoryBufferLen(len(arg430))
defer mbTrans430.Close() defer mbTrans431.Close()
_, err431 := mbTrans430.WriteString(arg429) _, err432 := mbTrans431.WriteString(arg430)
if err431 != nil { if err432 != nil {
Usage() Usage()
return return
} }
factory432 := thrift.NewTSimpleJSONProtocolFactory() factory433 := thrift.NewTSimpleJSONProtocolFactory()
jsProt433 := factory432.GetProtocol(mbTrans430) jsProt434 := factory433.GetProtocol(mbTrans431)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err434 := argvalue0.Read(jsProt433) err435 := argvalue0.Read(jsProt434)
if err434 != nil { if err435 != nil {
Usage() Usage()
return return
} }
@ -564,19 +564,19 @@ func main() {
fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg435 := flag.Arg(1) arg436 := flag.Arg(1)
mbTrans436 := thrift.NewTMemoryBufferLen(len(arg435)) mbTrans437 := thrift.NewTMemoryBufferLen(len(arg436))
defer mbTrans436.Close() defer mbTrans437.Close()
_, err437 := mbTrans436.WriteString(arg435) _, err438 := mbTrans437.WriteString(arg436)
if err437 != nil { if err438 != nil {
Usage() Usage()
return return
} }
factory438 := thrift.NewTSimpleJSONProtocolFactory() factory439 := thrift.NewTSimpleJSONProtocolFactory()
jsProt439 := factory438.GetProtocol(mbTrans436) jsProt440 := factory439.GetProtocol(mbTrans437)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err440 := argvalue0.Read(jsProt439) err441 := argvalue0.Read(jsProt440)
if err440 != nil { if err441 != nil {
Usage() Usage()
return return
} }
@ -589,19 +589,19 @@ func main() {
fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg441 := flag.Arg(1) arg442 := flag.Arg(1)
mbTrans442 := thrift.NewTMemoryBufferLen(len(arg441)) mbTrans443 := thrift.NewTMemoryBufferLen(len(arg442))
defer mbTrans442.Close() defer mbTrans443.Close()
_, err443 := mbTrans442.WriteString(arg441) _, err444 := mbTrans443.WriteString(arg442)
if err443 != nil { if err444 != nil {
Usage() Usage()
return return
} }
factory444 := thrift.NewTSimpleJSONProtocolFactory() factory445 := thrift.NewTSimpleJSONProtocolFactory()
jsProt445 := factory444.GetProtocol(mbTrans442) jsProt446 := factory445.GetProtocol(mbTrans443)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err446 := argvalue0.Read(jsProt445) err447 := argvalue0.Read(jsProt446)
if err446 != nil { if err447 != nil {
Usage() Usage()
return return
} }
@ -614,36 +614,36 @@ func main() {
fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") fmt.Fprintln(os.Stderr, "RestartShards requires 2 args")
flag.Usage() flag.Usage()
} }
arg447 := flag.Arg(1) arg448 := flag.Arg(1)
mbTrans448 := thrift.NewTMemoryBufferLen(len(arg447)) mbTrans449 := thrift.NewTMemoryBufferLen(len(arg448))
defer mbTrans448.Close() defer mbTrans449.Close()
_, err449 := mbTrans448.WriteString(arg447) _, err450 := mbTrans449.WriteString(arg448)
if err449 != nil { if err450 != nil {
Usage() Usage()
return return
} }
factory450 := thrift.NewTSimpleJSONProtocolFactory() factory451 := thrift.NewTSimpleJSONProtocolFactory()
jsProt451 := factory450.GetProtocol(mbTrans448) jsProt452 := factory451.GetProtocol(mbTrans449)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err452 := argvalue0.Read(jsProt451) err453 := argvalue0.Read(jsProt452)
if err452 != nil { if err453 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
arg453 := flag.Arg(2) arg454 := flag.Arg(2)
mbTrans454 := thrift.NewTMemoryBufferLen(len(arg453)) mbTrans455 := thrift.NewTMemoryBufferLen(len(arg454))
defer mbTrans454.Close() defer mbTrans455.Close()
_, err455 := mbTrans454.WriteString(arg453) _, err456 := mbTrans455.WriteString(arg454)
if err455 != nil { if err456 != nil {
Usage() Usage()
return return
} }
factory456 := thrift.NewTSimpleJSONProtocolFactory() factory457 := thrift.NewTSimpleJSONProtocolFactory()
jsProt457 := factory456.GetProtocol(mbTrans454) jsProt458 := factory457.GetProtocol(mbTrans455)
containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs() containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs()
err458 := containerStruct1.ReadField2(jsProt457) err459 := containerStruct1.ReadField2(jsProt458)
if err458 != nil { if err459 != nil {
Usage() Usage()
return return
} }
@ -657,36 +657,36 @@ func main() {
fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") fmt.Fprintln(os.Stderr, "KillTasks requires 3 args")
flag.Usage() flag.Usage()
} }
arg459 := flag.Arg(1) arg460 := flag.Arg(1)
mbTrans460 := thrift.NewTMemoryBufferLen(len(arg459)) mbTrans461 := thrift.NewTMemoryBufferLen(len(arg460))
defer mbTrans460.Close() defer mbTrans461.Close()
_, err461 := mbTrans460.WriteString(arg459) _, err462 := mbTrans461.WriteString(arg460)
if err461 != nil { if err462 != nil {
Usage() Usage()
return return
} }
factory462 := thrift.NewTSimpleJSONProtocolFactory() factory463 := thrift.NewTSimpleJSONProtocolFactory()
jsProt463 := factory462.GetProtocol(mbTrans460) jsProt464 := factory463.GetProtocol(mbTrans461)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err464 := argvalue0.Read(jsProt463) err465 := argvalue0.Read(jsProt464)
if err464 != nil { if err465 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
arg465 := flag.Arg(2) arg466 := flag.Arg(2)
mbTrans466 := thrift.NewTMemoryBufferLen(len(arg465)) mbTrans467 := thrift.NewTMemoryBufferLen(len(arg466))
defer mbTrans466.Close() defer mbTrans467.Close()
_, err467 := mbTrans466.WriteString(arg465) _, err468 := mbTrans467.WriteString(arg466)
if err467 != nil { if err468 != nil {
Usage() Usage()
return return
} }
factory468 := thrift.NewTSimpleJSONProtocolFactory() factory469 := thrift.NewTSimpleJSONProtocolFactory()
jsProt469 := factory468.GetProtocol(mbTrans466) jsProt470 := factory469.GetProtocol(mbTrans467)
containerStruct1 := aurora.NewAuroraAdminKillTasksArgs() containerStruct1 := aurora.NewAuroraAdminKillTasksArgs()
err470 := containerStruct1.ReadField2(jsProt469) err471 := containerStruct1.ReadField2(jsProt470)
if err470 != nil { if err471 != nil {
Usage() Usage()
return return
} }
@ -702,25 +702,25 @@ func main() {
fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") fmt.Fprintln(os.Stderr, "AddInstances requires 2 args")
flag.Usage() flag.Usage()
} }
arg472 := flag.Arg(1) arg473 := flag.Arg(1)
mbTrans473 := thrift.NewTMemoryBufferLen(len(arg472)) mbTrans474 := thrift.NewTMemoryBufferLen(len(arg473))
defer mbTrans473.Close() defer mbTrans474.Close()
_, err474 := mbTrans473.WriteString(arg472) _, err475 := mbTrans474.WriteString(arg473)
if err474 != nil { if err475 != nil {
Usage() Usage()
return return
} }
factory475 := thrift.NewTSimpleJSONProtocolFactory() factory476 := thrift.NewTSimpleJSONProtocolFactory()
jsProt476 := factory475.GetProtocol(mbTrans473) jsProt477 := factory476.GetProtocol(mbTrans474)
argvalue0 := aurora.NewInstanceKey() argvalue0 := aurora.NewInstanceKey()
err477 := argvalue0.Read(jsProt476) err478 := argvalue0.Read(jsProt477)
if err477 != nil { if err478 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
tmp1, err478 := (strconv.Atoi(flag.Arg(2))) tmp1, err479 := (strconv.Atoi(flag.Arg(2)))
if err478 != nil { if err479 != nil {
Usage() Usage()
return return
} }
@ -734,19 +734,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args")
flag.Usage() flag.Usage()
} }
arg479 := flag.Arg(1) arg480 := flag.Arg(1)
mbTrans480 := thrift.NewTMemoryBufferLen(len(arg479)) mbTrans481 := thrift.NewTMemoryBufferLen(len(arg480))
defer mbTrans480.Close() defer mbTrans481.Close()
_, err481 := mbTrans480.WriteString(arg479) _, err482 := mbTrans481.WriteString(arg480)
if err481 != nil { if err482 != nil {
Usage() Usage()
return return
} }
factory482 := thrift.NewTSimpleJSONProtocolFactory() factory483 := thrift.NewTSimpleJSONProtocolFactory()
jsProt483 := factory482.GetProtocol(mbTrans480) jsProt484 := factory483.GetProtocol(mbTrans481)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err484 := argvalue0.Read(jsProt483) err485 := argvalue0.Read(jsProt484)
if err484 != nil { if err485 != nil {
Usage() Usage()
return return
} }
@ -759,19 +759,19 @@ func main() {
fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg485 := flag.Arg(1) arg486 := flag.Arg(1)
mbTrans486 := thrift.NewTMemoryBufferLen(len(arg485)) mbTrans487 := thrift.NewTMemoryBufferLen(len(arg486))
defer mbTrans486.Close() defer mbTrans487.Close()
_, err487 := mbTrans486.WriteString(arg485) _, err488 := mbTrans487.WriteString(arg486)
if err487 != nil { if err488 != nil {
Usage() Usage()
return return
} }
factory488 := thrift.NewTSimpleJSONProtocolFactory() factory489 := thrift.NewTSimpleJSONProtocolFactory()
jsProt489 := factory488.GetProtocol(mbTrans486) jsProt490 := factory489.GetProtocol(mbTrans487)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err490 := argvalue0.Read(jsProt489) err491 := argvalue0.Read(jsProt490)
if err490 != nil { if err491 != nil {
Usage() Usage()
return return
} }
@ -786,19 +786,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg492 := flag.Arg(1) arg493 := flag.Arg(1)
mbTrans493 := thrift.NewTMemoryBufferLen(len(arg492)) mbTrans494 := thrift.NewTMemoryBufferLen(len(arg493))
defer mbTrans493.Close() defer mbTrans494.Close()
_, err494 := mbTrans493.WriteString(arg492) _, err495 := mbTrans494.WriteString(arg493)
if err494 != nil { if err495 != nil {
Usage() Usage()
return return
} }
factory495 := thrift.NewTSimpleJSONProtocolFactory() factory496 := thrift.NewTSimpleJSONProtocolFactory()
jsProt496 := factory495.GetProtocol(mbTrans493) jsProt497 := factory496.GetProtocol(mbTrans494)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err497 := argvalue0.Read(jsProt496) err498 := argvalue0.Read(jsProt497)
if err497 != nil { if err498 != nil {
Usage() Usage()
return return
} }
@ -813,19 +813,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg499 := flag.Arg(1) arg500 := flag.Arg(1)
mbTrans500 := thrift.NewTMemoryBufferLen(len(arg499)) mbTrans501 := thrift.NewTMemoryBufferLen(len(arg500))
defer mbTrans500.Close() defer mbTrans501.Close()
_, err501 := mbTrans500.WriteString(arg499) _, err502 := mbTrans501.WriteString(arg500)
if err501 != nil { if err502 != nil {
Usage() Usage()
return return
} }
factory502 := thrift.NewTSimpleJSONProtocolFactory() factory503 := thrift.NewTSimpleJSONProtocolFactory()
jsProt503 := factory502.GetProtocol(mbTrans500) jsProt504 := factory503.GetProtocol(mbTrans501)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err504 := argvalue0.Read(jsProt503) err505 := argvalue0.Read(jsProt504)
if err504 != nil { if err505 != nil {
Usage() Usage()
return return
} }
@ -840,19 +840,19 @@ func main() {
fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg506 := flag.Arg(1) arg507 := flag.Arg(1)
mbTrans507 := thrift.NewTMemoryBufferLen(len(arg506)) mbTrans508 := thrift.NewTMemoryBufferLen(len(arg507))
defer mbTrans507.Close() defer mbTrans508.Close()
_, err508 := mbTrans507.WriteString(arg506) _, err509 := mbTrans508.WriteString(arg507)
if err508 != nil { if err509 != nil {
Usage() Usage()
return return
} }
factory509 := thrift.NewTSimpleJSONProtocolFactory() factory510 := thrift.NewTSimpleJSONProtocolFactory()
jsProt510 := factory509.GetProtocol(mbTrans507) jsProt511 := factory510.GetProtocol(mbTrans508)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err511 := argvalue0.Read(jsProt510) err512 := argvalue0.Read(jsProt511)
if err511 != nil { if err512 != nil {
Usage() Usage()
return return
} }
@ -867,19 +867,19 @@ func main() {
fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg513 := flag.Arg(1) arg514 := flag.Arg(1)
mbTrans514 := thrift.NewTMemoryBufferLen(len(arg513)) mbTrans515 := thrift.NewTMemoryBufferLen(len(arg514))
defer mbTrans514.Close() defer mbTrans515.Close()
_, err515 := mbTrans514.WriteString(arg513) _, err516 := mbTrans515.WriteString(arg514)
if err515 != nil { if err516 != nil {
Usage() Usage()
return return
} }
factory516 := thrift.NewTSimpleJSONProtocolFactory() factory517 := thrift.NewTSimpleJSONProtocolFactory()
jsProt517 := factory516.GetProtocol(mbTrans514) jsProt518 := factory517.GetProtocol(mbTrans515)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err518 := argvalue0.Read(jsProt517) err519 := argvalue0.Read(jsProt518)
if err518 != nil { if err519 != nil {
Usage() Usage()
return return
} }
@ -894,19 +894,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args")
flag.Usage() flag.Usage()
} }
arg520 := flag.Arg(1) arg521 := flag.Arg(1)
mbTrans521 := thrift.NewTMemoryBufferLen(len(arg520)) mbTrans522 := thrift.NewTMemoryBufferLen(len(arg521))
defer mbTrans521.Close() defer mbTrans522.Close()
_, err522 := mbTrans521.WriteString(arg520) _, err523 := mbTrans522.WriteString(arg521)
if err522 != nil { if err523 != nil {
Usage() Usage()
return return
} }
factory523 := thrift.NewTSimpleJSONProtocolFactory() factory524 := thrift.NewTSimpleJSONProtocolFactory()
jsProt524 := factory523.GetProtocol(mbTrans521) jsProt525 := factory524.GetProtocol(mbTrans522)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err525 := argvalue0.Read(jsProt524) err526 := argvalue0.Read(jsProt525)
if err525 != nil { if err526 != nil {
Usage() Usage()
return return
} }
@ -937,19 +937,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
flag.Usage() flag.Usage()
} }
arg527 := flag.Arg(1) arg528 := flag.Arg(1)
mbTrans528 := thrift.NewTMemoryBufferLen(len(arg527)) mbTrans529 := thrift.NewTMemoryBufferLen(len(arg528))
defer mbTrans528.Close() defer mbTrans529.Close()
_, err529 := mbTrans528.WriteString(arg527) _, err530 := mbTrans529.WriteString(arg528)
if err529 != nil { if err530 != nil {
Usage() Usage()
return return
} }
factory530 := thrift.NewTSimpleJSONProtocolFactory() factory531 := thrift.NewTSimpleJSONProtocolFactory()
jsProt531 := factory530.GetProtocol(mbTrans528) jsProt532 := factory531.GetProtocol(mbTrans529)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err532 := argvalue0.Read(jsProt531) err533 := argvalue0.Read(jsProt532)
if err532 != nil { if err533 != nil {
Usage() Usage()
return return
} }
@ -962,19 +962,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
flag.Usage() flag.Usage()
} }
arg533 := flag.Arg(1) arg534 := flag.Arg(1)
mbTrans534 := thrift.NewTMemoryBufferLen(len(arg533)) mbTrans535 := thrift.NewTMemoryBufferLen(len(arg534))
defer mbTrans534.Close() defer mbTrans535.Close()
_, err535 := mbTrans534.WriteString(arg533) _, err536 := mbTrans535.WriteString(arg534)
if err535 != nil { if err536 != nil {
Usage() Usage()
return return
} }
factory536 := thrift.NewTSimpleJSONProtocolFactory() factory537 := thrift.NewTSimpleJSONProtocolFactory()
jsProt537 := factory536.GetProtocol(mbTrans534) jsProt538 := factory537.GetProtocol(mbTrans535)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err538 := argvalue0.Read(jsProt537) err539 := argvalue0.Read(jsProt538)
if err538 != nil { if err539 != nil {
Usage() Usage()
return return
} }
@ -987,19 +987,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
flag.Usage() flag.Usage()
} }
arg539 := flag.Arg(1) arg540 := flag.Arg(1)
mbTrans540 := thrift.NewTMemoryBufferLen(len(arg539)) mbTrans541 := thrift.NewTMemoryBufferLen(len(arg540))
defer mbTrans540.Close() defer mbTrans541.Close()
_, err541 := mbTrans540.WriteString(arg539) _, err542 := mbTrans541.WriteString(arg540)
if err541 != nil { if err542 != nil {
Usage() Usage()
return return
} }
factory542 := thrift.NewTSimpleJSONProtocolFactory() factory543 := thrift.NewTSimpleJSONProtocolFactory()
jsProt543 := factory542.GetProtocol(mbTrans540) jsProt544 := factory543.GetProtocol(mbTrans541)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err544 := argvalue0.Read(jsProt543) err545 := argvalue0.Read(jsProt544)
if err544 != nil { if err545 != nil {
Usage() Usage()
return return
} }
@ -1012,19 +1012,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
flag.Usage() flag.Usage()
} }
arg545 := flag.Arg(1) arg546 := flag.Arg(1)
mbTrans546 := thrift.NewTMemoryBufferLen(len(arg545)) mbTrans547 := thrift.NewTMemoryBufferLen(len(arg546))
defer mbTrans546.Close() defer mbTrans547.Close()
_, err547 := mbTrans546.WriteString(arg545) _, err548 := mbTrans547.WriteString(arg546)
if err547 != nil { if err548 != nil {
Usage() Usage()
return return
} }
factory548 := thrift.NewTSimpleJSONProtocolFactory() factory549 := thrift.NewTSimpleJSONProtocolFactory()
jsProt549 := factory548.GetProtocol(mbTrans546) jsProt550 := factory549.GetProtocol(mbTrans547)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err550 := argvalue0.Read(jsProt549) err551 := argvalue0.Read(jsProt550)
if err550 != nil { if err551 != nil {
Usage() Usage()
return return
} }
@ -1057,19 +1057,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
flag.Usage() flag.Usage()
} }
arg553 := flag.Arg(1) arg554 := flag.Arg(1)
mbTrans554 := thrift.NewTMemoryBufferLen(len(arg553)) mbTrans555 := thrift.NewTMemoryBufferLen(len(arg554))
defer mbTrans554.Close() defer mbTrans555.Close()
_, err555 := mbTrans554.WriteString(arg553) _, err556 := mbTrans555.WriteString(arg554)
if err555 != nil { if err556 != nil {
Usage() Usage()
return return
} }
factory556 := thrift.NewTSimpleJSONProtocolFactory() factory557 := thrift.NewTSimpleJSONProtocolFactory()
jsProt557 := factory556.GetProtocol(mbTrans554) jsProt558 := factory557.GetProtocol(mbTrans555)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err558 := argvalue0.Read(jsProt557) err559 := argvalue0.Read(jsProt558)
if err558 != nil { if err559 != nil {
Usage() Usage()
return return
} }
@ -1082,19 +1082,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
flag.Usage() flag.Usage()
} }
arg559 := flag.Arg(1) arg560 := flag.Arg(1)
mbTrans560 := thrift.NewTMemoryBufferLen(len(arg559)) mbTrans561 := thrift.NewTMemoryBufferLen(len(arg560))
defer mbTrans560.Close() defer mbTrans561.Close()
_, err561 := mbTrans560.WriteString(arg559) _, err562 := mbTrans561.WriteString(arg560)
if err561 != nil { if err562 != nil {
Usage() Usage()
return return
} }
factory562 := thrift.NewTSimpleJSONProtocolFactory() factory563 := thrift.NewTSimpleJSONProtocolFactory()
jsProt563 := factory562.GetProtocol(mbTrans560) jsProt564 := factory563.GetProtocol(mbTrans561)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err564 := argvalue0.Read(jsProt563) err565 := argvalue0.Read(jsProt564)
if err564 != nil { if err565 != nil {
Usage() Usage()
return return
} }
@ -1107,19 +1107,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
flag.Usage() flag.Usage()
} }
arg565 := flag.Arg(1) arg566 := flag.Arg(1)
mbTrans566 := thrift.NewTMemoryBufferLen(len(arg565)) mbTrans567 := thrift.NewTMemoryBufferLen(len(arg566))
defer mbTrans566.Close() defer mbTrans567.Close()
_, err567 := mbTrans566.WriteString(arg565) _, err568 := mbTrans567.WriteString(arg566)
if err567 != nil { if err568 != nil {
Usage() Usage()
return return
} }
factory568 := thrift.NewTSimpleJSONProtocolFactory() factory569 := thrift.NewTSimpleJSONProtocolFactory()
jsProt569 := factory568.GetProtocol(mbTrans566) jsProt570 := factory569.GetProtocol(mbTrans567)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err570 := argvalue0.Read(jsProt569) err571 := argvalue0.Read(jsProt570)
if err570 != nil { if err571 != nil {
Usage() Usage()
return return
} }
@ -1132,19 +1132,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
flag.Usage() flag.Usage()
} }
arg571 := flag.Arg(1) arg572 := flag.Arg(1)
mbTrans572 := thrift.NewTMemoryBufferLen(len(arg571)) mbTrans573 := thrift.NewTMemoryBufferLen(len(arg572))
defer mbTrans572.Close() defer mbTrans573.Close()
_, err573 := mbTrans572.WriteString(arg571) _, err574 := mbTrans573.WriteString(arg572)
if err573 != nil { if err574 != nil {
Usage() Usage()
return return
} }
factory574 := thrift.NewTSimpleJSONProtocolFactory() factory575 := thrift.NewTSimpleJSONProtocolFactory()
jsProt575 := factory574.GetProtocol(mbTrans572) jsProt576 := factory575.GetProtocol(mbTrans573)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err576 := argvalue0.Read(jsProt575) err577 := argvalue0.Read(jsProt576)
if err576 != nil { if err577 != nil {
Usage() Usage()
return return
} }

436
gen-go/apache/aurora/aurora_scheduler_manager-remote/aurora_scheduler_manager-remote.go
View file

@ -146,19 +146,19 @@ func main() {
fmt.Fprintln(os.Stderr, "CreateJob requires 1 args") fmt.Fprintln(os.Stderr, "CreateJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg162 := flag.Arg(1) arg163 := flag.Arg(1)
mbTrans163 := thrift.NewTMemoryBufferLen(len(arg162)) mbTrans164 := thrift.NewTMemoryBufferLen(len(arg163))
defer mbTrans163.Close() defer mbTrans164.Close()
_, err164 := mbTrans163.WriteString(arg162) _, err165 := mbTrans164.WriteString(arg163)
if err164 != nil { if err165 != nil {
Usage() Usage()
return return
} }
factory165 := thrift.NewTSimpleJSONProtocolFactory() factory166 := thrift.NewTSimpleJSONProtocolFactory()
jsProt166 := factory165.GetProtocol(mbTrans163) jsProt167 := factory166.GetProtocol(mbTrans164)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err167 := argvalue0.Read(jsProt166) err168 := argvalue0.Read(jsProt167)
if err167 != nil { if err168 != nil {
Usage() Usage()
return return
} }
@ -171,19 +171,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg168 := flag.Arg(1) arg169 := flag.Arg(1)
mbTrans169 := thrift.NewTMemoryBufferLen(len(arg168)) mbTrans170 := thrift.NewTMemoryBufferLen(len(arg169))
defer mbTrans169.Close() defer mbTrans170.Close()
_, err170 := mbTrans169.WriteString(arg168) _, err171 := mbTrans170.WriteString(arg169)
if err170 != nil { if err171 != nil {
Usage() Usage()
return return
} }
factory171 := thrift.NewTSimpleJSONProtocolFactory() factory172 := thrift.NewTSimpleJSONProtocolFactory()
jsProt172 := factory171.GetProtocol(mbTrans169) jsProt173 := factory172.GetProtocol(mbTrans170)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err173 := argvalue0.Read(jsProt172) err174 := argvalue0.Read(jsProt173)
if err173 != nil { if err174 != nil {
Usage() Usage()
return return
} }
@ -196,19 +196,19 @@ func main() {
fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg174 := flag.Arg(1) arg175 := flag.Arg(1)
mbTrans175 := thrift.NewTMemoryBufferLen(len(arg174)) mbTrans176 := thrift.NewTMemoryBufferLen(len(arg175))
defer mbTrans175.Close() defer mbTrans176.Close()
_, err176 := mbTrans175.WriteString(arg174) _, err177 := mbTrans176.WriteString(arg175)
if err176 != nil { if err177 != nil {
Usage() Usage()
return return
} }
factory177 := thrift.NewTSimpleJSONProtocolFactory() factory178 := thrift.NewTSimpleJSONProtocolFactory()
jsProt178 := factory177.GetProtocol(mbTrans175) jsProt179 := factory178.GetProtocol(mbTrans176)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err179 := argvalue0.Read(jsProt178) err180 := argvalue0.Read(jsProt179)
if err179 != nil { if err180 != nil {
Usage() Usage()
return return
} }
@ -221,19 +221,19 @@ func main() {
fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args")
flag.Usage() flag.Usage()
} }
arg180 := flag.Arg(1) arg181 := flag.Arg(1)
mbTrans181 := thrift.NewTMemoryBufferLen(len(arg180)) mbTrans182 := thrift.NewTMemoryBufferLen(len(arg181))
defer mbTrans181.Close() defer mbTrans182.Close()
_, err182 := mbTrans181.WriteString(arg180) _, err183 := mbTrans182.WriteString(arg181)
if err182 != nil { if err183 != nil {
Usage() Usage()
return return
} }
factory183 := thrift.NewTSimpleJSONProtocolFactory() factory184 := thrift.NewTSimpleJSONProtocolFactory()
jsProt184 := factory183.GetProtocol(mbTrans181) jsProt185 := factory184.GetProtocol(mbTrans182)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err185 := argvalue0.Read(jsProt184) err186 := argvalue0.Read(jsProt185)
if err185 != nil { if err186 != nil {
Usage() Usage()
return return
} }
@ -246,36 +246,36 @@ func main() {
fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") fmt.Fprintln(os.Stderr, "RestartShards requires 2 args")
flag.Usage() flag.Usage()
} }
arg186 := flag.Arg(1) arg187 := flag.Arg(1)
mbTrans187 := thrift.NewTMemoryBufferLen(len(arg186)) mbTrans188 := thrift.NewTMemoryBufferLen(len(arg187))
defer mbTrans187.Close() defer mbTrans188.Close()
_, err188 := mbTrans187.WriteString(arg186) _, err189 := mbTrans188.WriteString(arg187)
if err188 != nil { if err189 != nil {
Usage() Usage()
return return
} }
factory189 := thrift.NewTSimpleJSONProtocolFactory() factory190 := thrift.NewTSimpleJSONProtocolFactory()
jsProt190 := factory189.GetProtocol(mbTrans187) jsProt191 := factory190.GetProtocol(mbTrans188)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err191 := argvalue0.Read(jsProt190) err192 := argvalue0.Read(jsProt191)
if err191 != nil { if err192 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
arg192 := flag.Arg(2) arg193 := flag.Arg(2)
mbTrans193 := thrift.NewTMemoryBufferLen(len(arg192)) mbTrans194 := thrift.NewTMemoryBufferLen(len(arg193))
defer mbTrans193.Close() defer mbTrans194.Close()
_, err194 := mbTrans193.WriteString(arg192) _, err195 := mbTrans194.WriteString(arg193)
if err194 != nil { if err195 != nil {
Usage() Usage()
return return
} }
factory195 := thrift.NewTSimpleJSONProtocolFactory() factory196 := thrift.NewTSimpleJSONProtocolFactory()
jsProt196 := factory195.GetProtocol(mbTrans193) jsProt197 := factory196.GetProtocol(mbTrans194)
containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs() containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs()
err197 := containerStruct1.ReadField2(jsProt196) err198 := containerStruct1.ReadField2(jsProt197)
if err197 != nil { if err198 != nil {
Usage() Usage()
return return
} }
@ -289,36 +289,36 @@ func main() {
fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") fmt.Fprintln(os.Stderr, "KillTasks requires 3 args")
flag.Usage() flag.Usage()
} }
arg198 := flag.Arg(1) arg199 := flag.Arg(1)
mbTrans199 := thrift.NewTMemoryBufferLen(len(arg198)) mbTrans200 := thrift.NewTMemoryBufferLen(len(arg199))
defer mbTrans199.Close() defer mbTrans200.Close()
_, err200 := mbTrans199.WriteString(arg198) _, err201 := mbTrans200.WriteString(arg199)
if err200 != nil { if err201 != nil {
Usage() Usage()
return return
} }
factory201 := thrift.NewTSimpleJSONProtocolFactory() factory202 := thrift.NewTSimpleJSONProtocolFactory()
jsProt202 := factory201.GetProtocol(mbTrans199) jsProt203 := factory202.GetProtocol(mbTrans200)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err203 := argvalue0.Read(jsProt202) err204 := argvalue0.Read(jsProt203)
if err203 != nil { if err204 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
arg204 := flag.Arg(2) arg205 := flag.Arg(2)
mbTrans205 := thrift.NewTMemoryBufferLen(len(arg204)) mbTrans206 := thrift.NewTMemoryBufferLen(len(arg205))
defer mbTrans205.Close() defer mbTrans206.Close()
_, err206 := mbTrans205.WriteString(arg204) _, err207 := mbTrans206.WriteString(arg205)
if err206 != nil { if err207 != nil {
Usage() Usage()
return return
} }
factory207 := thrift.NewTSimpleJSONProtocolFactory() factory208 := thrift.NewTSimpleJSONProtocolFactory()
jsProt208 := factory207.GetProtocol(mbTrans205) jsProt209 := factory208.GetProtocol(mbTrans206)
containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs() containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs()
err209 := containerStruct1.ReadField2(jsProt208) err210 := containerStruct1.ReadField2(jsProt209)
if err209 != nil { if err210 != nil {
Usage() Usage()
return return
} }
@ -334,25 +334,25 @@ func main() {
fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") fmt.Fprintln(os.Stderr, "AddInstances requires 2 args")
flag.Usage() flag.Usage()
} }
arg211 := flag.Arg(1) arg212 := flag.Arg(1)
mbTrans212 := thrift.NewTMemoryBufferLen(len(arg211)) mbTrans213 := thrift.NewTMemoryBufferLen(len(arg212))
defer mbTrans212.Close() defer mbTrans213.Close()
_, err213 := mbTrans212.WriteString(arg211) _, err214 := mbTrans213.WriteString(arg212)
if err213 != nil { if err214 != nil {
Usage() Usage()
return return
} }
factory214 := thrift.NewTSimpleJSONProtocolFactory() factory215 := thrift.NewTSimpleJSONProtocolFactory()
jsProt215 := factory214.GetProtocol(mbTrans212) jsProt216 := factory215.GetProtocol(mbTrans213)
argvalue0 := aurora.NewInstanceKey() argvalue0 := aurora.NewInstanceKey()
err216 := argvalue0.Read(jsProt215) err217 := argvalue0.Read(jsProt216)
if err216 != nil { if err217 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
tmp1, err217 := (strconv.Atoi(flag.Arg(2))) tmp1, err218 := (strconv.Atoi(flag.Arg(2)))
if err217 != nil { if err218 != nil {
Usage() Usage()
return return
} }
@ -366,19 +366,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args")
flag.Usage() flag.Usage()
} }
arg218 := flag.Arg(1) arg219 := flag.Arg(1)
mbTrans219 := thrift.NewTMemoryBufferLen(len(arg218)) mbTrans220 := thrift.NewTMemoryBufferLen(len(arg219))
defer mbTrans219.Close() defer mbTrans220.Close()
_, err220 := mbTrans219.WriteString(arg218) _, err221 := mbTrans220.WriteString(arg219)
if err220 != nil { if err221 != nil {
Usage() Usage()
return return
} }
factory221 := thrift.NewTSimpleJSONProtocolFactory() factory222 := thrift.NewTSimpleJSONProtocolFactory()
jsProt222 := factory221.GetProtocol(mbTrans219) jsProt223 := factory222.GetProtocol(mbTrans220)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err223 := argvalue0.Read(jsProt222) err224 := argvalue0.Read(jsProt223)
if err223 != nil { if err224 != nil {
Usage() Usage()
return return
} }
@ -391,19 +391,19 @@ func main() {
fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg224 := flag.Arg(1) arg225 := flag.Arg(1)
mbTrans225 := thrift.NewTMemoryBufferLen(len(arg224)) mbTrans226 := thrift.NewTMemoryBufferLen(len(arg225))
defer mbTrans225.Close() defer mbTrans226.Close()
_, err226 := mbTrans225.WriteString(arg224) _, err227 := mbTrans226.WriteString(arg225)
if err226 != nil { if err227 != nil {
Usage() Usage()
return return
} }
factory227 := thrift.NewTSimpleJSONProtocolFactory() factory228 := thrift.NewTSimpleJSONProtocolFactory()
jsProt228 := factory227.GetProtocol(mbTrans225) jsProt229 := factory228.GetProtocol(mbTrans226)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err229 := argvalue0.Read(jsProt228) err230 := argvalue0.Read(jsProt229)
if err229 != nil { if err230 != nil {
Usage() Usage()
return return
} }
@ -418,19 +418,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg231 := flag.Arg(1) arg232 := flag.Arg(1)
mbTrans232 := thrift.NewTMemoryBufferLen(len(arg231)) mbTrans233 := thrift.NewTMemoryBufferLen(len(arg232))
defer mbTrans232.Close() defer mbTrans233.Close()
_, err233 := mbTrans232.WriteString(arg231) _, err234 := mbTrans233.WriteString(arg232)
if err233 != nil { if err234 != nil {
Usage() Usage()
return return
} }
factory234 := thrift.NewTSimpleJSONProtocolFactory() factory235 := thrift.NewTSimpleJSONProtocolFactory()
jsProt235 := factory234.GetProtocol(mbTrans232) jsProt236 := factory235.GetProtocol(mbTrans233)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err236 := argvalue0.Read(jsProt235) err237 := argvalue0.Read(jsProt236)
if err236 != nil { if err237 != nil {
Usage() Usage()
return return
} }
@ -445,19 +445,19 @@ func main() {
fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg238 := flag.Arg(1) arg239 := flag.Arg(1)
mbTrans239 := thrift.NewTMemoryBufferLen(len(arg238)) mbTrans240 := thrift.NewTMemoryBufferLen(len(arg239))
defer mbTrans239.Close() defer mbTrans240.Close()
_, err240 := mbTrans239.WriteString(arg238) _, err241 := mbTrans240.WriteString(arg239)
if err240 != nil { if err241 != nil {
Usage() Usage()
return return
} }
factory241 := thrift.NewTSimpleJSONProtocolFactory() factory242 := thrift.NewTSimpleJSONProtocolFactory()
jsProt242 := factory241.GetProtocol(mbTrans239) jsProt243 := factory242.GetProtocol(mbTrans240)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err243 := argvalue0.Read(jsProt242) err244 := argvalue0.Read(jsProt243)
if err243 != nil { if err244 != nil {
Usage() Usage()
return return
} }
@ -472,19 +472,19 @@ func main() {
fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg245 := flag.Arg(1) arg246 := flag.Arg(1)
mbTrans246 := thrift.NewTMemoryBufferLen(len(arg245)) mbTrans247 := thrift.NewTMemoryBufferLen(len(arg246))
defer mbTrans246.Close() defer mbTrans247.Close()
_, err247 := mbTrans246.WriteString(arg245) _, err248 := mbTrans247.WriteString(arg246)
if err247 != nil { if err248 != nil {
Usage() Usage()
return return
} }
factory248 := thrift.NewTSimpleJSONProtocolFactory() factory249 := thrift.NewTSimpleJSONProtocolFactory()
jsProt249 := factory248.GetProtocol(mbTrans246) jsProt250 := factory249.GetProtocol(mbTrans247)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err250 := argvalue0.Read(jsProt249) err251 := argvalue0.Read(jsProt250)
if err250 != nil { if err251 != nil {
Usage() Usage()
return return
} }
@ -499,19 +499,19 @@ func main() {
fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args")
flag.Usage() flag.Usage()
} }
arg252 := flag.Arg(1) arg253 := flag.Arg(1)
mbTrans253 := thrift.NewTMemoryBufferLen(len(arg252)) mbTrans254 := thrift.NewTMemoryBufferLen(len(arg253))
defer mbTrans253.Close() defer mbTrans254.Close()
_, err254 := mbTrans253.WriteString(arg252) _, err255 := mbTrans254.WriteString(arg253)
if err254 != nil { if err255 != nil {
Usage() Usage()
return return
} }
factory255 := thrift.NewTSimpleJSONProtocolFactory() factory256 := thrift.NewTSimpleJSONProtocolFactory()
jsProt256 := factory255.GetProtocol(mbTrans253) jsProt257 := factory256.GetProtocol(mbTrans254)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err257 := argvalue0.Read(jsProt256) err258 := argvalue0.Read(jsProt257)
if err257 != nil { if err258 != nil {
Usage() Usage()
return return
} }
@ -526,19 +526,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args")
flag.Usage() flag.Usage()
} }
arg259 := flag.Arg(1) arg260 := flag.Arg(1)
mbTrans260 := thrift.NewTMemoryBufferLen(len(arg259)) mbTrans261 := thrift.NewTMemoryBufferLen(len(arg260))
defer mbTrans260.Close() defer mbTrans261.Close()
_, err261 := mbTrans260.WriteString(arg259) _, err262 := mbTrans261.WriteString(arg260)
if err261 != nil { if err262 != nil {
Usage() Usage()
return return
} }
factory262 := thrift.NewTSimpleJSONProtocolFactory() factory263 := thrift.NewTSimpleJSONProtocolFactory()
jsProt263 := factory262.GetProtocol(mbTrans260) jsProt264 := factory263.GetProtocol(mbTrans261)
argvalue0 := aurora.NewJobUpdateKey() argvalue0 := aurora.NewJobUpdateKey()
err264 := argvalue0.Read(jsProt263) err265 := argvalue0.Read(jsProt264)
if err264 != nil { if err265 != nil {
Usage() Usage()
return return
} }
@ -569,19 +569,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
flag.Usage() flag.Usage()
} }
arg266 := flag.Arg(1) arg267 := flag.Arg(1)
mbTrans267 := thrift.NewTMemoryBufferLen(len(arg266)) mbTrans268 := thrift.NewTMemoryBufferLen(len(arg267))
defer mbTrans267.Close() defer mbTrans268.Close()
_, err268 := mbTrans267.WriteString(arg266) _, err269 := mbTrans268.WriteString(arg267)
if err268 != nil { if err269 != nil {
Usage() Usage()
return return
} }
factory269 := thrift.NewTSimpleJSONProtocolFactory() factory270 := thrift.NewTSimpleJSONProtocolFactory()
jsProt270 := factory269.GetProtocol(mbTrans267) jsProt271 := factory270.GetProtocol(mbTrans268)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err271 := argvalue0.Read(jsProt270) err272 := argvalue0.Read(jsProt271)
if err271 != nil { if err272 != nil {
Usage() Usage()
return return
} }
@ -594,19 +594,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
flag.Usage() flag.Usage()
} }
arg272 := flag.Arg(1) arg273 := flag.Arg(1)
mbTrans273 := thrift.NewTMemoryBufferLen(len(arg272)) mbTrans274 := thrift.NewTMemoryBufferLen(len(arg273))
defer mbTrans273.Close() defer mbTrans274.Close()
_, err274 := mbTrans273.WriteString(arg272) _, err275 := mbTrans274.WriteString(arg273)
if err274 != nil { if err275 != nil {
Usage() Usage()
return return
} }
factory275 := thrift.NewTSimpleJSONProtocolFactory() factory276 := thrift.NewTSimpleJSONProtocolFactory()
jsProt276 := factory275.GetProtocol(mbTrans273) jsProt277 := factory276.GetProtocol(mbTrans274)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err277 := argvalue0.Read(jsProt276) err278 := argvalue0.Read(jsProt277)
if err277 != nil { if err278 != nil {
Usage() Usage()
return return
} }
@ -619,19 +619,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
flag.Usage() flag.Usage()
} }
arg278 := flag.Arg(1) arg279 := flag.Arg(1)
mbTrans279 := thrift.NewTMemoryBufferLen(len(arg278)) mbTrans280 := thrift.NewTMemoryBufferLen(len(arg279))
defer mbTrans279.Close() defer mbTrans280.Close()
_, err280 := mbTrans279.WriteString(arg278) _, err281 := mbTrans280.WriteString(arg279)
if err280 != nil { if err281 != nil {
Usage() Usage()
return return
} }
factory281 := thrift.NewTSimpleJSONProtocolFactory() factory282 := thrift.NewTSimpleJSONProtocolFactory()
jsProt282 := factory281.GetProtocol(mbTrans279) jsProt283 := factory282.GetProtocol(mbTrans280)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err283 := argvalue0.Read(jsProt282) err284 := argvalue0.Read(jsProt283)
if err283 != nil { if err284 != nil {
Usage() Usage()
return return
} }
@ -644,19 +644,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
flag.Usage() flag.Usage()
} }
arg284 := flag.Arg(1) arg285 := flag.Arg(1)
mbTrans285 := thrift.NewTMemoryBufferLen(len(arg284)) mbTrans286 := thrift.NewTMemoryBufferLen(len(arg285))
defer mbTrans285.Close() defer mbTrans286.Close()
_, err286 := mbTrans285.WriteString(arg284) _, err287 := mbTrans286.WriteString(arg285)
if err286 != nil { if err287 != nil {
Usage() Usage()
return return
} }
factory287 := thrift.NewTSimpleJSONProtocolFactory() factory288 := thrift.NewTSimpleJSONProtocolFactory()
jsProt288 := factory287.GetProtocol(mbTrans285) jsProt289 := factory288.GetProtocol(mbTrans286)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err289 := argvalue0.Read(jsProt288) err290 := argvalue0.Read(jsProt289)
if err289 != nil { if err290 != nil {
Usage() Usage()
return return
} }
@ -689,19 +689,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
flag.Usage() flag.Usage()
} }
arg292 := flag.Arg(1) arg293 := flag.Arg(1)
mbTrans293 := thrift.NewTMemoryBufferLen(len(arg292)) mbTrans294 := thrift.NewTMemoryBufferLen(len(arg293))
defer mbTrans293.Close() defer mbTrans294.Close()
_, err294 := mbTrans293.WriteString(arg292) _, err295 := mbTrans294.WriteString(arg293)
if err294 != nil { if err295 != nil {
Usage() Usage()
return return
} }
factory295 := thrift.NewTSimpleJSONProtocolFactory() factory296 := thrift.NewTSimpleJSONProtocolFactory()
jsProt296 := factory295.GetProtocol(mbTrans293) jsProt297 := factory296.GetProtocol(mbTrans294)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err297 := argvalue0.Read(jsProt296) err298 := argvalue0.Read(jsProt297)
if err297 != nil { if err298 != nil {
Usage() Usage()
return return
} }
@ -714,19 +714,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
flag.Usage() flag.Usage()
} }
arg298 := flag.Arg(1) arg299 := flag.Arg(1)
mbTrans299 := thrift.NewTMemoryBufferLen(len(arg298)) mbTrans300 := thrift.NewTMemoryBufferLen(len(arg299))
defer mbTrans299.Close() defer mbTrans300.Close()
_, err300 := mbTrans299.WriteString(arg298) _, err301 := mbTrans300.WriteString(arg299)
if err300 != nil { if err301 != nil {
Usage() Usage()
return return
} }
factory301 := thrift.NewTSimpleJSONProtocolFactory() factory302 := thrift.NewTSimpleJSONProtocolFactory()
jsProt302 := factory301.GetProtocol(mbTrans299) jsProt303 := factory302.GetProtocol(mbTrans300)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err303 := argvalue0.Read(jsProt302) err304 := argvalue0.Read(jsProt303)
if err303 != nil { if err304 != nil {
Usage() Usage()
return return
} }
@ -739,19 +739,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
flag.Usage() flag.Usage()
} }
arg304 := flag.Arg(1) arg305 := flag.Arg(1)
mbTrans305 := thrift.NewTMemoryBufferLen(len(arg304)) mbTrans306 := thrift.NewTMemoryBufferLen(len(arg305))
defer mbTrans305.Close() defer mbTrans306.Close()
_, err306 := mbTrans305.WriteString(arg304) _, err307 := mbTrans306.WriteString(arg305)
if err306 != nil { if err307 != nil {
Usage() Usage()
return return
} }
factory307 := thrift.NewTSimpleJSONProtocolFactory() factory308 := thrift.NewTSimpleJSONProtocolFactory()
jsProt308 := factory307.GetProtocol(mbTrans305) jsProt309 := factory308.GetProtocol(mbTrans306)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err309 := argvalue0.Read(jsProt308) err310 := argvalue0.Read(jsProt309)
if err309 != nil { if err310 != nil {
Usage() Usage()
return return
} }
@ -764,19 +764,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
flag.Usage() flag.Usage()
} }
arg310 := flag.Arg(1) arg311 := flag.Arg(1)
mbTrans311 := thrift.NewTMemoryBufferLen(len(arg310)) mbTrans312 := thrift.NewTMemoryBufferLen(len(arg311))
defer mbTrans311.Close() defer mbTrans312.Close()
_, err312 := mbTrans311.WriteString(arg310) _, err313 := mbTrans312.WriteString(arg311)
if err312 != nil { if err313 != nil {
Usage() Usage()
return return
} }
factory313 := thrift.NewTSimpleJSONProtocolFactory() factory314 := thrift.NewTSimpleJSONProtocolFactory()
jsProt314 := factory313.GetProtocol(mbTrans311) jsProt315 := factory314.GetProtocol(mbTrans312)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err315 := argvalue0.Read(jsProt314) err316 := argvalue0.Read(jsProt315)
if err315 != nil { if err316 != nil {
Usage() Usage()
return return
} }

184
gen-go/apache/aurora/auroraadmin.go
View file

@ -167,16 +167,16 @@ func (p *AuroraAdminClient) recvSetQuota() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error316 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error317 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error317 error var error318 error
error317, err = error316.Read(iprot) error318, err = error317.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error317 err = error318
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -250,16 +250,16 @@ func (p *AuroraAdminClient) recvForceTaskState() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error318 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error319 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error319 error var error320 error
error319, err = error318.Read(iprot) error320, err = error319.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error319 err = error320
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -324,16 +324,16 @@ func (p *AuroraAdminClient) recvPerformBackup() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error320 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error321 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error321 error var error322 error
error321, err = error320.Read(iprot) error322, err = error321.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error321 err = error322
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -398,16 +398,16 @@ func (p *AuroraAdminClient) recvListBackups() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error322 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error323 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error323 error var error324 error
error323, err = error322.Read(iprot) error324, err = error323.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error323 err = error324
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -477,16 +477,16 @@ func (p *AuroraAdminClient) recvStageRecovery() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error324 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error325 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error325 error var error326 error
error325, err = error324.Read(iprot) error326, err = error325.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error325 err = error326
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -556,16 +556,16 @@ func (p *AuroraAdminClient) recvQueryRecovery() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error326 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error327 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error327 error var error328 error
error327, err = error326.Read(iprot) error328, err = error327.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error327 err = error328
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -635,16 +635,16 @@ func (p *AuroraAdminClient) recvDeleteRecoveryTasks() (value *Response, err erro
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error328 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error329 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error329 error var error330 error
error329, err = error328.Read(iprot) error330, err = error329.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error329 err = error330
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -709,16 +709,16 @@ func (p *AuroraAdminClient) recvCommitRecovery() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error330 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error331 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error331 error var error332 error
error331, err = error330.Read(iprot) error332, err = error331.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error331 err = error332
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -783,16 +783,16 @@ func (p *AuroraAdminClient) recvUnloadRecovery() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error332 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error333 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error333 error var error334 error
error333, err = error332.Read(iprot) error334, err = error333.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error333 err = error334
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -862,16 +862,16 @@ func (p *AuroraAdminClient) recvStartMaintenance() (value *Response, err error)
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error334 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error335 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error335 error var error336 error
error335, err = error334.Read(iprot) error336, err = error335.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error335 err = error336
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -941,16 +941,16 @@ func (p *AuroraAdminClient) recvDrainHosts() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error336 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error337 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error337 error var error338 error
error337, err = error336.Read(iprot) error338, err = error337.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error337 err = error338
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1020,16 +1020,16 @@ func (p *AuroraAdminClient) recvMaintenanceStatus() (value *Response, err error)
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error338 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error339 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error339 error var error340 error
error339, err = error338.Read(iprot) error340, err = error339.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error339 err = error340
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1099,16 +1099,16 @@ func (p *AuroraAdminClient) recvEndMaintenance() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error340 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error341 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error341 error var error342 error
error341, err = error340.Read(iprot) error342, err = error341.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error341 err = error342
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1184,16 +1184,16 @@ func (p *AuroraAdminClient) recvSlaDrainHosts() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error342 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error343 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error343 error var error344 error
error343, err = error342.Read(iprot) error344, err = error343.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error343 err = error344
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1258,16 +1258,16 @@ func (p *AuroraAdminClient) recvSnapshot() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error344 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error345 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error345 error var error346 error
error345, err = error344.Read(iprot) error346, err = error345.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error345 err = error346
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1337,16 +1337,16 @@ func (p *AuroraAdminClient) recvTriggerExplicitTaskReconciliation() (value *Resp
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error346 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error347 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error347 error var error348 error
error347, err = error346.Read(iprot) error348, err = error347.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error347 err = error348
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1411,16 +1411,16 @@ func (p *AuroraAdminClient) recvTriggerImplicitTaskReconciliation() (value *Resp
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error348 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error349 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error349 error var error350 error
error349, err = error348.Read(iprot) error350, err = error349.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error349 err = error350
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1492,16 +1492,16 @@ func (p *AuroraAdminClient) recvPruneTasks() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error350 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error351 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error351 error var error352 error
error351, err = error350.Read(iprot) error352, err = error351.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error351 err = error352
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1524,26 +1524,26 @@ type AuroraAdminProcessor struct {
} }
func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor { func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor {
self352 := &AuroraAdminProcessor{NewAuroraSchedulerManagerProcessor(handler)} self353 := &AuroraAdminProcessor{NewAuroraSchedulerManagerProcessor(handler)}
self352.AddToProcessorMap("setQuota", &auroraAdminProcessorSetQuota{handler: handler}) self353.AddToProcessorMap("setQuota", &auroraAdminProcessorSetQuota{handler: handler})
self352.AddToProcessorMap("forceTaskState", &auroraAdminProcessorForceTaskState{handler: handler}) self353.AddToProcessorMap("forceTaskState", &auroraAdminProcessorForceTaskState{handler: handler})
self352.AddToProcessorMap("performBackup", &auroraAdminProcessorPerformBackup{handler: handler}) self353.AddToProcessorMap("performBackup", &auroraAdminProcessorPerformBackup{handler: handler})
self352.AddToProcessorMap("listBackups", &auroraAdminProcessorListBackups{handler: handler}) self353.AddToProcessorMap("listBackups", &auroraAdminProcessorListBackups{handler: handler})
self352.AddToProcessorMap("stageRecovery", &auroraAdminProcessorStageRecovery{handler: handler}) self353.AddToProcessorMap("stageRecovery", &auroraAdminProcessorStageRecovery{handler: handler})
self352.AddToProcessorMap("queryRecovery", &auroraAdminProcessorQueryRecovery{handler: handler}) self353.AddToProcessorMap("queryRecovery", &auroraAdminProcessorQueryRecovery{handler: handler})
self352.AddToProcessorMap("deleteRecoveryTasks", &auroraAdminProcessorDeleteRecoveryTasks{handler: handler}) self353.AddToProcessorMap("deleteRecoveryTasks", &auroraAdminProcessorDeleteRecoveryTasks{handler: handler})
self352.AddToProcessorMap("commitRecovery", &auroraAdminProcessorCommitRecovery{handler: handler}) self353.AddToProcessorMap("commitRecovery", &auroraAdminProcessorCommitRecovery{handler: handler})
self352.AddToProcessorMap("unloadRecovery", &auroraAdminProcessorUnloadRecovery{handler: handler}) self353.AddToProcessorMap("unloadRecovery", &auroraAdminProcessorUnloadRecovery{handler: handler})
self352.AddToProcessorMap("startMaintenance", &auroraAdminProcessorStartMaintenance{handler: handler}) self353.AddToProcessorMap("startMaintenance", &auroraAdminProcessorStartMaintenance{handler: handler})
self352.AddToProcessorMap("drainHosts", &auroraAdminProcessorDrainHosts{handler: handler}) self353.AddToProcessorMap("drainHosts", &auroraAdminProcessorDrainHosts{handler: handler})
self352.AddToProcessorMap("maintenanceStatus", &auroraAdminProcessorMaintenanceStatus{handler: handler}) self353.AddToProcessorMap("maintenanceStatus", &auroraAdminProcessorMaintenanceStatus{handler: handler})
self352.AddToProcessorMap("endMaintenance", &auroraAdminProcessorEndMaintenance{handler: handler}) self353.AddToProcessorMap("endMaintenance", &auroraAdminProcessorEndMaintenance{handler: handler})
self352.AddToProcessorMap("slaDrainHosts", &auroraAdminProcessorSlaDrainHosts{handler: handler}) self353.AddToProcessorMap("slaDrainHosts", &auroraAdminProcessorSlaDrainHosts{handler: handler})
self352.AddToProcessorMap("snapshot", &auroraAdminProcessorSnapshot{handler: handler}) self353.AddToProcessorMap("snapshot", &auroraAdminProcessorSnapshot{handler: handler})
self352.AddToProcessorMap("triggerExplicitTaskReconciliation", &auroraAdminProcessorTriggerExplicitTaskReconciliation{handler: handler}) self353.AddToProcessorMap("triggerExplicitTaskReconciliation", &auroraAdminProcessorTriggerExplicitTaskReconciliation{handler: handler})
self352.AddToProcessorMap("triggerImplicitTaskReconciliation", &auroraAdminProcessorTriggerImplicitTaskReconciliation{handler: handler}) self353.AddToProcessorMap("triggerImplicitTaskReconciliation", &auroraAdminProcessorTriggerImplicitTaskReconciliation{handler: handler})
self352.AddToProcessorMap("pruneTasks", &auroraAdminProcessorPruneTasks{handler: handler}) self353.AddToProcessorMap("pruneTasks", &auroraAdminProcessorPruneTasks{handler: handler})
return self352 return self353
} }
type auroraAdminProcessorSetQuota struct { type auroraAdminProcessorSetQuota struct {

156
gen-go/apache/aurora/auroraschedulermanager.go
View file

@ -171,16 +171,16 @@ func (p *AuroraSchedulerManagerClient) recvCreateJob() (value *Response, err err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error131 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error132 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error132 error var error133 error
error132, err = error131.Read(iprot) error133, err = error132.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error132 err = error133
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -252,16 +252,16 @@ func (p *AuroraSchedulerManagerClient) recvScheduleCronJob() (value *Response, e
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error133 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error134 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error134 error var error135 error
error134, err = error133.Read(iprot) error135, err = error134.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error134 err = error135
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -332,16 +332,16 @@ func (p *AuroraSchedulerManagerClient) recvDescheduleCronJob() (value *Response,
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error135 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error136 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error136 error var error137 error
error136, err = error135.Read(iprot) error137, err = error136.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error136 err = error137
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -412,16 +412,16 @@ func (p *AuroraSchedulerManagerClient) recvStartCronJob() (value *Response, err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error137 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error138 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error138 error var error139 error
error138, err = error137.Read(iprot) error139, err = error138.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error138 err = error139
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -493,16 +493,16 @@ func (p *AuroraSchedulerManagerClient) recvRestartShards() (value *Response, err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error139 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error140 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error140 error var error141 error
error140, err = error139.Read(iprot) error141, err = error140.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error140 err = error141
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -576,16 +576,16 @@ func (p *AuroraSchedulerManagerClient) recvKillTasks() (value *Response, err err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error141 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error142 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error142 error var error143 error
error142, err = error141.Read(iprot) error143, err = error142.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error142 err = error143
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -657,16 +657,16 @@ func (p *AuroraSchedulerManagerClient) recvAddInstances() (value *Response, err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error143 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error144 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error144 error var error145 error
error144, err = error143.Read(iprot) error145, err = error144.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error144 err = error145
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -737,16 +737,16 @@ func (p *AuroraSchedulerManagerClient) recvReplaceCronTemplate() (value *Respons
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error145 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error146 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error146 error var error147 error
error146, err = error145.Read(iprot) error147, err = error146.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error146 err = error147
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -818,16 +818,16 @@ func (p *AuroraSchedulerManagerClient) recvStartJobUpdate() (value *Response, er
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error147 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error148 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error148 error var error149 error
error148, err = error147.Read(iprot) error149, err = error148.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error148 err = error149
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -899,16 +899,16 @@ func (p *AuroraSchedulerManagerClient) recvPauseJobUpdate() (value *Response, er
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error149 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error150 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error150 error var error151 error
error150, err = error149.Read(iprot) error151, err = error150.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error150 err = error151
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -980,16 +980,16 @@ func (p *AuroraSchedulerManagerClient) recvResumeJobUpdate() (value *Response, e
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error151 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error152 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error152 error var error153 error
error152, err = error151.Read(iprot) error153, err = error152.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error152 err = error153
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1061,16 +1061,16 @@ func (p *AuroraSchedulerManagerClient) recvAbortJobUpdate() (value *Response, er
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error153 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error154 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error154 error var error155 error
error154, err = error153.Read(iprot) error155, err = error154.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error154 err = error155
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1142,16 +1142,16 @@ func (p *AuroraSchedulerManagerClient) recvRollbackJobUpdate() (value *Response,
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error155 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error156 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error156 error var error157 error
error156, err = error155.Read(iprot) error157, err = error156.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error156 err = error157
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1223,16 +1223,16 @@ func (p *AuroraSchedulerManagerClient) recvPulseJobUpdate() (value *Response, er
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error157 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error158 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error158 error var error159 error
error158, err = error157.Read(iprot) error159, err = error158.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error158 err = error159
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1255,22 +1255,22 @@ type AuroraSchedulerManagerProcessor struct {
} }
func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor { func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor {
self159 := &AuroraSchedulerManagerProcessor{NewReadOnlySchedulerProcessor(handler)} self160 := &AuroraSchedulerManagerProcessor{NewReadOnlySchedulerProcessor(handler)}
self159.AddToProcessorMap("createJob", &auroraSchedulerManagerProcessorCreateJob{handler: handler}) self160.AddToProcessorMap("createJob", &auroraSchedulerManagerProcessorCreateJob{handler: handler})
self159.AddToProcessorMap("scheduleCronJob", &auroraSchedulerManagerProcessorScheduleCronJob{handler: handler}) self160.AddToProcessorMap("scheduleCronJob", &auroraSchedulerManagerProcessorScheduleCronJob{handler: handler})
self159.AddToProcessorMap("descheduleCronJob", &auroraSchedulerManagerProcessorDescheduleCronJob{handler: handler}) self160.AddToProcessorMap("descheduleCronJob", &auroraSchedulerManagerProcessorDescheduleCronJob{handler: handler})
self159.AddToProcessorMap("startCronJob", &auroraSchedulerManagerProcessorStartCronJob{handler: handler}) self160.AddToProcessorMap("startCronJob", &auroraSchedulerManagerProcessorStartCronJob{handler: handler})
self159.AddToProcessorMap("restartShards", &auroraSchedulerManagerProcessorRestartShards{handler: handler}) self160.AddToProcessorMap("restartShards", &auroraSchedulerManagerProcessorRestartShards{handler: handler})
self159.AddToProcessorMap("killTasks", &auroraSchedulerManagerProcessorKillTasks{handler: handler}) self160.AddToProcessorMap("killTasks", &auroraSchedulerManagerProcessorKillTasks{handler: handler})
self159.AddToProcessorMap("addInstances", &auroraSchedulerManagerProcessorAddInstances{handler: handler}) self160.AddToProcessorMap("addInstances", &auroraSchedulerManagerProcessorAddInstances{handler: handler})
self159.AddToProcessorMap("replaceCronTemplate", &auroraSchedulerManagerProcessorReplaceCronTemplate{handler: handler}) self160.AddToProcessorMap("replaceCronTemplate", &auroraSchedulerManagerProcessorReplaceCronTemplate{handler: handler})
self159.AddToProcessorMap("startJobUpdate", &auroraSchedulerManagerProcessorStartJobUpdate{handler: handler}) self160.AddToProcessorMap("startJobUpdate", &auroraSchedulerManagerProcessorStartJobUpdate{handler: handler})
self159.AddToProcessorMap("pauseJobUpdate", &auroraSchedulerManagerProcessorPauseJobUpdate{handler: handler}) self160.AddToProcessorMap("pauseJobUpdate", &auroraSchedulerManagerProcessorPauseJobUpdate{handler: handler})
self159.AddToProcessorMap("resumeJobUpdate", &auroraSchedulerManagerProcessorResumeJobUpdate{handler: handler}) self160.AddToProcessorMap("resumeJobUpdate", &auroraSchedulerManagerProcessorResumeJobUpdate{handler: handler})
self159.AddToProcessorMap("abortJobUpdate", &auroraSchedulerManagerProcessorAbortJobUpdate{handler: handler}) self160.AddToProcessorMap("abortJobUpdate", &auroraSchedulerManagerProcessorAbortJobUpdate{handler: handler})
self159.AddToProcessorMap("rollbackJobUpdate", &auroraSchedulerManagerProcessorRollbackJobUpdate{handler: handler}) self160.AddToProcessorMap("rollbackJobUpdate", &auroraSchedulerManagerProcessorRollbackJobUpdate{handler: handler})
self159.AddToProcessorMap("pulseJobUpdate", &auroraSchedulerManagerProcessorPulseJobUpdate{handler: handler}) self160.AddToProcessorMap("pulseJobUpdate", &auroraSchedulerManagerProcessorPulseJobUpdate{handler: handler})
return self159 return self160
} }
type auroraSchedulerManagerProcessorCreateJob struct { type auroraSchedulerManagerProcessorCreateJob struct {
@ -2832,13 +2832,13 @@ func (p *AuroraSchedulerManagerRestartShardsArgs) readField3(iprot thrift.TProto
tSet := make(map[int32]bool, size) tSet := make(map[int32]bool, size)
p.ShardIds = tSet p.ShardIds = tSet
for i := 0; i < size; i++ { for i := 0; i < size; i++ {
var _elem160 int32 var _elem161 int32
if v, err := iprot.ReadI32(); err != nil { if v, err := iprot.ReadI32(); err != nil {
return thrift.PrependError("error reading field 0: ", err) return thrift.PrependError("error reading field 0: ", err)
} else { } else {
_elem160 = v _elem161 = v
} }
p.ShardIds[_elem160] = true p.ShardIds[_elem161] = true
} }
if err := iprot.ReadSetEnd(); err != nil { if err := iprot.ReadSetEnd(); err != nil {
return thrift.PrependError("error reading set end: ", err) return thrift.PrependError("error reading set end: ", err)
@ -3099,13 +3099,13 @@ func (p *AuroraSchedulerManagerKillTasksArgs) readField5(iprot thrift.TProtocol)
tSet := make(map[int32]bool, size) tSet := make(map[int32]bool, size)
p.Instances = tSet p.Instances = tSet
for i := 0; i < size; i++ { for i := 0; i < size; i++ {
var _elem161 int32 var _elem162 int32
if v, err := iprot.ReadI32(); err != nil { if v, err := iprot.ReadI32(); err != nil {
return thrift.PrependError("error reading field 0: ", err) return thrift.PrependError("error reading field 0: ", err)
} else { } else {
_elem161 = v _elem162 = v
} }
p.Instances[_elem161] = true p.Instances[_elem162] = true
} }
if err := iprot.ReadSetEnd(); err != nil { if err := iprot.ReadSetEnd(); err != nil {
return thrift.PrependError("error reading set end: ", err) return thrift.PrependError("error reading set end: ", err)

144
gen-go/apache/aurora/read_only_scheduler-remote/read_only_scheduler-remote.go
View file

@ -150,19 +150,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
flag.Usage() flag.Usage()
} }
arg81 := flag.Arg(1) arg82 := flag.Arg(1)
mbTrans82 := thrift.NewTMemoryBufferLen(len(arg81)) mbTrans83 := thrift.NewTMemoryBufferLen(len(arg82))
defer mbTrans82.Close() defer mbTrans83.Close()
_, err83 := mbTrans82.WriteString(arg81) _, err84 := mbTrans83.WriteString(arg82)
if err83 != nil { if err84 != nil {
Usage() Usage()
return return
} }
factory84 := thrift.NewTSimpleJSONProtocolFactory() factory85 := thrift.NewTSimpleJSONProtocolFactory()
jsProt85 := factory84.GetProtocol(mbTrans82) jsProt86 := factory85.GetProtocol(mbTrans83)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err86 := argvalue0.Read(jsProt85) err87 := argvalue0.Read(jsProt86)
if err86 != nil { if err87 != nil {
Usage() Usage()
return return
} }
@ -175,19 +175,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
flag.Usage() flag.Usage()
} }
arg87 := flag.Arg(1) arg88 := flag.Arg(1)
mbTrans88 := thrift.NewTMemoryBufferLen(len(arg87)) mbTrans89 := thrift.NewTMemoryBufferLen(len(arg88))
defer mbTrans88.Close() defer mbTrans89.Close()
_, err89 := mbTrans88.WriteString(arg87) _, err90 := mbTrans89.WriteString(arg88)
if err89 != nil { if err90 != nil {
Usage() Usage()
return return
} }
factory90 := thrift.NewTSimpleJSONProtocolFactory() factory91 := thrift.NewTSimpleJSONProtocolFactory()
jsProt91 := factory90.GetProtocol(mbTrans88) jsProt92 := factory91.GetProtocol(mbTrans89)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err92 := argvalue0.Read(jsProt91) err93 := argvalue0.Read(jsProt92)
if err92 != nil { if err93 != nil {
Usage() Usage()
return return
} }
@ -200,19 +200,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
flag.Usage() flag.Usage()
} }
arg93 := flag.Arg(1) arg94 := flag.Arg(1)
mbTrans94 := thrift.NewTMemoryBufferLen(len(arg93)) mbTrans95 := thrift.NewTMemoryBufferLen(len(arg94))
defer mbTrans94.Close() defer mbTrans95.Close()
_, err95 := mbTrans94.WriteString(arg93) _, err96 := mbTrans95.WriteString(arg94)
if err95 != nil { if err96 != nil {
Usage() Usage()
return return
} }
factory96 := thrift.NewTSimpleJSONProtocolFactory() factory97 := thrift.NewTSimpleJSONProtocolFactory()
jsProt97 := factory96.GetProtocol(mbTrans94) jsProt98 := factory97.GetProtocol(mbTrans95)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err98 := argvalue0.Read(jsProt97) err99 := argvalue0.Read(jsProt98)
if err98 != nil { if err99 != nil {
Usage() Usage()
return return
} }
@ -225,19 +225,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
flag.Usage() flag.Usage()
} }
arg99 := flag.Arg(1) arg100 := flag.Arg(1)
mbTrans100 := thrift.NewTMemoryBufferLen(len(arg99)) mbTrans101 := thrift.NewTMemoryBufferLen(len(arg100))
defer mbTrans100.Close() defer mbTrans101.Close()
_, err101 := mbTrans100.WriteString(arg99) _, err102 := mbTrans101.WriteString(arg100)
if err101 != nil { if err102 != nil {
Usage() Usage()
return return
} }
factory102 := thrift.NewTSimpleJSONProtocolFactory() factory103 := thrift.NewTSimpleJSONProtocolFactory()
jsProt103 := factory102.GetProtocol(mbTrans100) jsProt104 := factory103.GetProtocol(mbTrans101)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err104 := argvalue0.Read(jsProt103) err105 := argvalue0.Read(jsProt104)
if err104 != nil { if err105 != nil {
Usage() Usage()
return return
} }
@ -270,19 +270,19 @@ func main() {
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
flag.Usage() flag.Usage()
} }
arg107 := flag.Arg(1) arg108 := flag.Arg(1)
mbTrans108 := thrift.NewTMemoryBufferLen(len(arg107)) mbTrans109 := thrift.NewTMemoryBufferLen(len(arg108))
defer mbTrans108.Close() defer mbTrans109.Close()
_, err109 := mbTrans108.WriteString(arg107) _, err110 := mbTrans109.WriteString(arg108)
if err109 != nil { if err110 != nil {
Usage() Usage()
return return
} }
factory110 := thrift.NewTSimpleJSONProtocolFactory() factory111 := thrift.NewTSimpleJSONProtocolFactory()
jsProt111 := factory110.GetProtocol(mbTrans108) jsProt112 := factory111.GetProtocol(mbTrans109)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err112 := argvalue0.Read(jsProt111) err113 := argvalue0.Read(jsProt112)
if err112 != nil { if err113 != nil {
Usage() Usage()
return return
} }
@ -295,19 +295,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
flag.Usage() flag.Usage()
} }
arg113 := flag.Arg(1) arg114 := flag.Arg(1)
mbTrans114 := thrift.NewTMemoryBufferLen(len(arg113)) mbTrans115 := thrift.NewTMemoryBufferLen(len(arg114))
defer mbTrans114.Close() defer mbTrans115.Close()
_, err115 := mbTrans114.WriteString(arg113) _, err116 := mbTrans115.WriteString(arg114)
if err115 != nil { if err116 != nil {
Usage() Usage()
return return
} }
factory116 := thrift.NewTSimpleJSONProtocolFactory() factory117 := thrift.NewTSimpleJSONProtocolFactory()
jsProt117 := factory116.GetProtocol(mbTrans114) jsProt118 := factory117.GetProtocol(mbTrans115)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err118 := argvalue0.Read(jsProt117) err119 := argvalue0.Read(jsProt118)
if err118 != nil { if err119 != nil {
Usage() Usage()
return return
} }
@ -320,19 +320,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
flag.Usage() flag.Usage()
} }
arg119 := flag.Arg(1) arg120 := flag.Arg(1)
mbTrans120 := thrift.NewTMemoryBufferLen(len(arg119)) mbTrans121 := thrift.NewTMemoryBufferLen(len(arg120))
defer mbTrans120.Close() defer mbTrans121.Close()
_, err121 := mbTrans120.WriteString(arg119) _, err122 := mbTrans121.WriteString(arg120)
if err121 != nil { if err122 != nil {
Usage() Usage()
return return
} }
factory122 := thrift.NewTSimpleJSONProtocolFactory() factory123 := thrift.NewTSimpleJSONProtocolFactory()
jsProt123 := factory122.GetProtocol(mbTrans120) jsProt124 := factory123.GetProtocol(mbTrans121)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err124 := argvalue0.Read(jsProt123) err125 := argvalue0.Read(jsProt124)
if err124 != nil { if err125 != nil {
Usage() Usage()
return return
} }
@ -345,19 +345,19 @@ func main() {
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
flag.Usage() flag.Usage()
} }
arg125 := flag.Arg(1) arg126 := flag.Arg(1)
mbTrans126 := thrift.NewTMemoryBufferLen(len(arg125)) mbTrans127 := thrift.NewTMemoryBufferLen(len(arg126))
defer mbTrans126.Close() defer mbTrans127.Close()
_, err127 := mbTrans126.WriteString(arg125) _, err128 := mbTrans127.WriteString(arg126)
if err127 != nil { if err128 != nil {
Usage() Usage()
return return
} }
factory128 := thrift.NewTSimpleJSONProtocolFactory() factory129 := thrift.NewTSimpleJSONProtocolFactory()
jsProt129 := factory128.GetProtocol(mbTrans126) jsProt130 := factory129.GetProtocol(mbTrans127)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err130 := argvalue0.Read(jsProt129) err131 := argvalue0.Read(jsProt130)
if err130 != nil { if err131 != nil {
Usage() Usage()
return return
} }

140
gen-go/apache/aurora/readonlyscheduler.go
View file

@ -152,16 +152,16 @@ func (p *ReadOnlySchedulerClient) recvGetRoleSummary() (value *Response, err err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error52 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error53 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error53 error var error54 error
error53, err = error52.Read(iprot) error54, err = error53.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error53 err = error54
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -231,16 +231,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobSummary() (value *Response, err erro
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error54 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error55 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error55 error var error56 error
error55, err = error54.Read(iprot) error56, err = error55.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error55 err = error56
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -310,16 +310,16 @@ func (p *ReadOnlySchedulerClient) recvGetTasksStatus() (value *Response, err err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error56 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error57 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error57 error var error58 error
error57, err = error56.Read(iprot) error58, err = error57.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error57 err = error58
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -390,16 +390,16 @@ func (p *ReadOnlySchedulerClient) recvGetTasksWithoutConfigs() (value *Response,
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error58 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error59 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error59 error var error60 error
error59, err = error58.Read(iprot) error60, err = error59.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error59 err = error60
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -469,16 +469,16 @@ func (p *ReadOnlySchedulerClient) recvGetPendingReason() (value *Response, err e
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error60 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error61 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error61 error var error62 error
error61, err = error60.Read(iprot) error62, err = error61.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error61 err = error62
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -548,16 +548,16 @@ func (p *ReadOnlySchedulerClient) recvGetConfigSummary() (value *Response, err e
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error62 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error63 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error63 error var error64 error
error63, err = error62.Read(iprot) error64, err = error63.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error63 err = error64
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -628,16 +628,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobs() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error64 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error65 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error65 error var error66 error
error65, err = error64.Read(iprot) error66, err = error65.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error65 err = error66
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -707,16 +707,16 @@ func (p *ReadOnlySchedulerClient) recvGetQuota() (value *Response, err error) {
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error66 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error67 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error67 error var error68 error
error67, err = error66.Read(iprot) error68, err = error67.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error67 err = error68
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -787,16 +787,16 @@ func (p *ReadOnlySchedulerClient) recvPopulateJobConfig() (value *Response, err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error68 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error69 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error69 error var error70 error
error69, err = error68.Read(iprot) error70, err = error69.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error69 err = error70
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -866,16 +866,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateSummaries() (value *Response,
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error70 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error71 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error71 error var error72 error
error71, err = error70.Read(iprot) error72, err = error71.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error71 err = error72
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -945,16 +945,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateDetails() (value *Response, er
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error72 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error73 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error73 error var error74 error
error73, err = error72.Read(iprot) error74, err = error73.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error73 err = error74
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1024,16 +1024,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateDiff() (value *Response, err e
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error74 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error75 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error75 error var error76 error
error75, err = error74.Read(iprot) error76, err = error75.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error75 err = error76
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1098,16 +1098,16 @@ func (p *ReadOnlySchedulerClient) recvGetTierConfigs() (value *Response, err err
return return
} }
if mTypeId == thrift.EXCEPTION { if mTypeId == thrift.EXCEPTION {
error76 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") error77 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
var error77 error var error78 error
error77, err = error76.Read(iprot) error78, err = error77.Read(iprot)
if err != nil { if err != nil {
return return
} }
if err = iprot.ReadMessageEnd(); err != nil { if err = iprot.ReadMessageEnd(); err != nil {
return return
} }
err = error77 err = error78
return return
} }
if mTypeId != thrift.REPLY { if mTypeId != thrift.REPLY {
@ -1145,21 +1145,21 @@ func (p *ReadOnlySchedulerProcessor) ProcessorMap() map[string]thrift.TProcessor
func NewReadOnlySchedulerProcessor(handler ReadOnlyScheduler) *ReadOnlySchedulerProcessor { func NewReadOnlySchedulerProcessor(handler ReadOnlyScheduler) *ReadOnlySchedulerProcessor {
self78 := &ReadOnlySchedulerProcessor{handler: handler, processorMap: make(map[string]thrift.TProcessorFunction)} self79 := &ReadOnlySchedulerProcessor{handler: handler, processorMap: make(map[string]thrift.TProcessorFunction)}
self78.processorMap["getRoleSummary"] = &readOnlySchedulerProcessorGetRoleSummary{handler: handler} self79.processorMap["getRoleSummary"] = &readOnlySchedulerProcessorGetRoleSummary{handler: handler}
self78.processorMap["getJobSummary"] = &readOnlySchedulerProcessorGetJobSummary{handler: handler} self79.processorMap["getJobSummary"] = &readOnlySchedulerProcessorGetJobSummary{handler: handler}
self78.processorMap["getTasksStatus"] = &readOnlySchedulerProcessorGetTasksStatus{handler: handler} self79.processorMap["getTasksStatus"] = &readOnlySchedulerProcessorGetTasksStatus{handler: handler}
self78.processorMap["getTasksWithoutConfigs"] = &readOnlySchedulerProcessorGetTasksWithoutConfigs{handler: handler} self79.processorMap["getTasksWithoutConfigs"] = &readOnlySchedulerProcessorGetTasksWithoutConfigs{handler: handler}
self78.processorMap["getPendingReason"] = &readOnlySchedulerProcessorGetPendingReason{handler: handler} self79.processorMap["getPendingReason"] = &readOnlySchedulerProcessorGetPendingReason{handler: handler}
self78.processorMap["getConfigSummary"] = &readOnlySchedulerProcessorGetConfigSummary{handler: handler} self79.processorMap["getConfigSummary"] = &readOnlySchedulerProcessorGetConfigSummary{handler: handler}
self78.processorMap["getJobs"] = &readOnlySchedulerProcessorGetJobs{handler: handler} self79.processorMap["getJobs"] = &readOnlySchedulerProcessorGetJobs{handler: handler}
self78.processorMap["getQuota"] = &readOnlySchedulerProcessorGetQuota{handler: handler} self79.processorMap["getQuota"] = &readOnlySchedulerProcessorGetQuota{handler: handler}
self78.processorMap["populateJobConfig"] = &readOnlySchedulerProcessorPopulateJobConfig{handler: handler} self79.processorMap["populateJobConfig"] = &readOnlySchedulerProcessorPopulateJobConfig{handler: handler}
self78.processorMap["getJobUpdateSummaries"] = &readOnlySchedulerProcessorGetJobUpdateSummaries{handler: handler} self79.processorMap["getJobUpdateSummaries"] = &readOnlySchedulerProcessorGetJobUpdateSummaries{handler: handler}
self78.processorMap["getJobUpdateDetails"] = &readOnlySchedulerProcessorGetJobUpdateDetails{handler: handler} self79.processorMap["getJobUpdateDetails"] = &readOnlySchedulerProcessorGetJobUpdateDetails{handler: handler}
self78.processorMap["getJobUpdateDiff"] = &readOnlySchedulerProcessorGetJobUpdateDiff{handler: handler} self79.processorMap["getJobUpdateDiff"] = &readOnlySchedulerProcessorGetJobUpdateDiff{handler: handler}
self78.processorMap["getTierConfigs"] = &readOnlySchedulerProcessorGetTierConfigs{handler: handler} self79.processorMap["getTierConfigs"] = &readOnlySchedulerProcessorGetTierConfigs{handler: handler}
return self78 return self79
} }
func (p *ReadOnlySchedulerProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { func (p *ReadOnlySchedulerProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) {
@ -1172,12 +1172,12 @@ func (p *ReadOnlySchedulerProcessor) Process(iprot, oprot thrift.TProtocol) (suc
} }
iprot.Skip(thrift.STRUCT) iprot.Skip(thrift.STRUCT)
iprot.ReadMessageEnd() iprot.ReadMessageEnd()
x79 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function "+name) x80 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function "+name)
oprot.WriteMessageBegin(name, thrift.EXCEPTION, seqId) oprot.WriteMessageBegin(name, thrift.EXCEPTION, seqId)
x79.Write(oprot) x80.Write(oprot)
oprot.WriteMessageEnd() oprot.WriteMessageEnd()
oprot.Flush() oprot.Flush()
return false, x79 return false, x80
} }

774
gen-go/apache/aurora/ttypes.go
View file

File diff suppressed because it is too large Load diff