diff --git a/auroraAPI.thrift b/auroraAPI.thrift index 063774d..3872dbc 100644 --- a/auroraAPI.thrift +++ b/auroraAPI.thrift @@ -716,6 +716,31 @@ struct JobUpdateKey { 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 groupSizes +} + +union JobUpdateStrategy { + 1: QueueJobUpdateStrategy queueStrategy + 2: BatchJobUpdateStrategy batchStrategy + 3: VariableBatchJobUpdateStrategy varBatchStrategy +} + /** Job update thresholds and limits. */ struct JobUpdateSettings { /** 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. */ 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. */ diff --git a/gen-go/apache/aurora/aurora_admin-remote/aurora_admin-remote.go b/gen-go/apache/aurora/aurora_admin-remote/aurora_admin-remote.go index d6f7bfd..b5982cb 100755 --- a/gen-go/apache/aurora/aurora_admin-remote/aurora_admin-remote.go +++ b/gen-go/apache/aurora/aurora_admin-remote/aurora_admin-remote.go @@ -166,19 +166,19 @@ func main() { } argvalue0 := flag.Arg(1) value0 := argvalue0 - arg354 := flag.Arg(2) - mbTrans355 := thrift.NewTMemoryBufferLen(len(arg354)) - defer mbTrans355.Close() - _, err356 := mbTrans355.WriteString(arg354) - if err356 != nil { + arg355 := flag.Arg(2) + mbTrans356 := thrift.NewTMemoryBufferLen(len(arg355)) + defer mbTrans356.Close() + _, err357 := mbTrans356.WriteString(arg355) + if err357 != nil { Usage() return } - factory357 := thrift.NewTSimpleJSONProtocolFactory() - jsProt358 := factory357.GetProtocol(mbTrans355) + factory358 := thrift.NewTSimpleJSONProtocolFactory() + jsProt359 := factory358.GetProtocol(mbTrans356) argvalue1 := aurora.NewResourceAggregate() - err359 := argvalue1.Read(jsProt358) - if err359 != nil { + err360 := argvalue1.Read(jsProt359) + if err360 != nil { Usage() return } @@ -234,19 +234,19 @@ func main() { fmt.Fprintln(os.Stderr, "QueryRecovery requires 1 args") flag.Usage() } - arg362 := flag.Arg(1) - mbTrans363 := thrift.NewTMemoryBufferLen(len(arg362)) - defer mbTrans363.Close() - _, err364 := mbTrans363.WriteString(arg362) - if err364 != nil { + arg363 := flag.Arg(1) + mbTrans364 := thrift.NewTMemoryBufferLen(len(arg363)) + defer mbTrans364.Close() + _, err365 := mbTrans364.WriteString(arg363) + if err365 != nil { Usage() return } - factory365 := thrift.NewTSimpleJSONProtocolFactory() - jsProt366 := factory365.GetProtocol(mbTrans363) + factory366 := thrift.NewTSimpleJSONProtocolFactory() + jsProt367 := factory366.GetProtocol(mbTrans364) argvalue0 := aurora.NewTaskQuery() - err367 := argvalue0.Read(jsProt366) - if err367 != nil { + err368 := argvalue0.Read(jsProt367) + if err368 != nil { Usage() return } @@ -259,19 +259,19 @@ func main() { fmt.Fprintln(os.Stderr, "DeleteRecoveryTasks requires 1 args") flag.Usage() } - arg368 := flag.Arg(1) - mbTrans369 := thrift.NewTMemoryBufferLen(len(arg368)) - defer mbTrans369.Close() - _, err370 := mbTrans369.WriteString(arg368) - if err370 != nil { + arg369 := flag.Arg(1) + mbTrans370 := thrift.NewTMemoryBufferLen(len(arg369)) + defer mbTrans370.Close() + _, err371 := mbTrans370.WriteString(arg369) + if err371 != nil { Usage() return } - factory371 := thrift.NewTSimpleJSONProtocolFactory() - jsProt372 := factory371.GetProtocol(mbTrans369) + factory372 := thrift.NewTSimpleJSONProtocolFactory() + jsProt373 := factory372.GetProtocol(mbTrans370) argvalue0 := aurora.NewTaskQuery() - err373 := argvalue0.Read(jsProt372) - if err373 != nil { + err374 := argvalue0.Read(jsProt373) + if err374 != nil { Usage() return } @@ -300,19 +300,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartMaintenance requires 1 args") flag.Usage() } - arg374 := flag.Arg(1) - mbTrans375 := thrift.NewTMemoryBufferLen(len(arg374)) - defer mbTrans375.Close() - _, err376 := mbTrans375.WriteString(arg374) - if err376 != nil { + arg375 := flag.Arg(1) + mbTrans376 := thrift.NewTMemoryBufferLen(len(arg375)) + defer mbTrans376.Close() + _, err377 := mbTrans376.WriteString(arg375) + if err377 != nil { Usage() return } - factory377 := thrift.NewTSimpleJSONProtocolFactory() - jsProt378 := factory377.GetProtocol(mbTrans375) + factory378 := thrift.NewTSimpleJSONProtocolFactory() + jsProt379 := factory378.GetProtocol(mbTrans376) argvalue0 := aurora.NewHosts() - err379 := argvalue0.Read(jsProt378) - if err379 != nil { + err380 := argvalue0.Read(jsProt379) + if err380 != nil { Usage() return } @@ -325,19 +325,19 @@ func main() { fmt.Fprintln(os.Stderr, "DrainHosts requires 1 args") flag.Usage() } - arg380 := flag.Arg(1) - mbTrans381 := thrift.NewTMemoryBufferLen(len(arg380)) - defer mbTrans381.Close() - _, err382 := mbTrans381.WriteString(arg380) - if err382 != nil { + arg381 := flag.Arg(1) + mbTrans382 := thrift.NewTMemoryBufferLen(len(arg381)) + defer mbTrans382.Close() + _, err383 := mbTrans382.WriteString(arg381) + if err383 != nil { Usage() return } - factory383 := thrift.NewTSimpleJSONProtocolFactory() - jsProt384 := factory383.GetProtocol(mbTrans381) + factory384 := thrift.NewTSimpleJSONProtocolFactory() + jsProt385 := factory384.GetProtocol(mbTrans382) argvalue0 := aurora.NewHosts() - err385 := argvalue0.Read(jsProt384) - if err385 != nil { + err386 := argvalue0.Read(jsProt385) + if err386 != nil { Usage() return } @@ -350,19 +350,19 @@ func main() { fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args") flag.Usage() } - arg386 := flag.Arg(1) - mbTrans387 := thrift.NewTMemoryBufferLen(len(arg386)) - defer mbTrans387.Close() - _, err388 := mbTrans387.WriteString(arg386) - if err388 != nil { + arg387 := flag.Arg(1) + mbTrans388 := thrift.NewTMemoryBufferLen(len(arg387)) + defer mbTrans388.Close() + _, err389 := mbTrans388.WriteString(arg387) + if err389 != nil { Usage() return } - factory389 := thrift.NewTSimpleJSONProtocolFactory() - jsProt390 := factory389.GetProtocol(mbTrans387) + factory390 := thrift.NewTSimpleJSONProtocolFactory() + jsProt391 := factory390.GetProtocol(mbTrans388) argvalue0 := aurora.NewHosts() - err391 := argvalue0.Read(jsProt390) - if err391 != nil { + err392 := argvalue0.Read(jsProt391) + if err392 != nil { Usage() return } @@ -375,19 +375,19 @@ func main() { fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args") flag.Usage() } - arg392 := flag.Arg(1) - mbTrans393 := thrift.NewTMemoryBufferLen(len(arg392)) - defer mbTrans393.Close() - _, err394 := mbTrans393.WriteString(arg392) - if err394 != nil { + arg393 := flag.Arg(1) + mbTrans394 := thrift.NewTMemoryBufferLen(len(arg393)) + defer mbTrans394.Close() + _, err395 := mbTrans394.WriteString(arg393) + if err395 != nil { Usage() return } - factory395 := thrift.NewTSimpleJSONProtocolFactory() - jsProt396 := factory395.GetProtocol(mbTrans393) + factory396 := thrift.NewTSimpleJSONProtocolFactory() + jsProt397 := factory396.GetProtocol(mbTrans394) argvalue0 := aurora.NewHosts() - err397 := argvalue0.Read(jsProt396) - if err397 != nil { + err398 := argvalue0.Read(jsProt397) + if err398 != nil { Usage() return } @@ -400,42 +400,42 @@ func main() { fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args") flag.Usage() } - arg398 := flag.Arg(1) - mbTrans399 := thrift.NewTMemoryBufferLen(len(arg398)) - defer mbTrans399.Close() - _, err400 := mbTrans399.WriteString(arg398) - if err400 != nil { + arg399 := flag.Arg(1) + mbTrans400 := thrift.NewTMemoryBufferLen(len(arg399)) + defer mbTrans400.Close() + _, err401 := mbTrans400.WriteString(arg399) + if err401 != nil { Usage() return } - factory401 := thrift.NewTSimpleJSONProtocolFactory() - jsProt402 := factory401.GetProtocol(mbTrans399) + factory402 := thrift.NewTSimpleJSONProtocolFactory() + jsProt403 := factory402.GetProtocol(mbTrans400) argvalue0 := aurora.NewHosts() - err403 := argvalue0.Read(jsProt402) - if err403 != nil { + err404 := argvalue0.Read(jsProt403) + if err404 != nil { Usage() return } value0 := argvalue0 - arg404 := flag.Arg(2) - mbTrans405 := thrift.NewTMemoryBufferLen(len(arg404)) - defer mbTrans405.Close() - _, err406 := mbTrans405.WriteString(arg404) - if err406 != nil { + arg405 := flag.Arg(2) + mbTrans406 := thrift.NewTMemoryBufferLen(len(arg405)) + defer mbTrans406.Close() + _, err407 := mbTrans406.WriteString(arg405) + if err407 != nil { Usage() return } - factory407 := thrift.NewTSimpleJSONProtocolFactory() - jsProt408 := factory407.GetProtocol(mbTrans405) + factory408 := thrift.NewTSimpleJSONProtocolFactory() + jsProt409 := factory408.GetProtocol(mbTrans406) argvalue1 := aurora.NewSlaPolicy() - err409 := argvalue1.Read(jsProt408) - if err409 != nil { + err410 := argvalue1.Read(jsProt409) + if err410 != nil { Usage() return } value1 := argvalue1 - argvalue2, err410 := (strconv.ParseInt(flag.Arg(3), 10, 64)) - if err410 != nil { + argvalue2, err411 := (strconv.ParseInt(flag.Arg(3), 10, 64)) + if err411 != nil { Usage() return } @@ -456,19 +456,19 @@ func main() { fmt.Fprintln(os.Stderr, "TriggerExplicitTaskReconciliation requires 1 args") flag.Usage() } - arg411 := flag.Arg(1) - mbTrans412 := thrift.NewTMemoryBufferLen(len(arg411)) - defer mbTrans412.Close() - _, err413 := mbTrans412.WriteString(arg411) - if err413 != nil { + arg412 := flag.Arg(1) + mbTrans413 := thrift.NewTMemoryBufferLen(len(arg412)) + defer mbTrans413.Close() + _, err414 := mbTrans413.WriteString(arg412) + if err414 != nil { Usage() return } - factory414 := thrift.NewTSimpleJSONProtocolFactory() - jsProt415 := factory414.GetProtocol(mbTrans412) + factory415 := thrift.NewTSimpleJSONProtocolFactory() + jsProt416 := factory415.GetProtocol(mbTrans413) argvalue0 := aurora.NewExplicitReconciliationSettings() - err416 := argvalue0.Read(jsProt415) - if err416 != nil { + err417 := argvalue0.Read(jsProt416) + if err417 != nil { Usage() return } @@ -489,19 +489,19 @@ func main() { fmt.Fprintln(os.Stderr, "PruneTasks requires 1 args") flag.Usage() } - arg417 := flag.Arg(1) - mbTrans418 := thrift.NewTMemoryBufferLen(len(arg417)) - defer mbTrans418.Close() - _, err419 := mbTrans418.WriteString(arg417) - if err419 != nil { + arg418 := flag.Arg(1) + mbTrans419 := thrift.NewTMemoryBufferLen(len(arg418)) + defer mbTrans419.Close() + _, err420 := mbTrans419.WriteString(arg418) + if err420 != nil { Usage() return } - factory420 := thrift.NewTSimpleJSONProtocolFactory() - jsProt421 := factory420.GetProtocol(mbTrans418) + factory421 := thrift.NewTSimpleJSONProtocolFactory() + jsProt422 := factory421.GetProtocol(mbTrans419) argvalue0 := aurora.NewTaskQuery() - err422 := argvalue0.Read(jsProt421) - if err422 != nil { + err423 := argvalue0.Read(jsProt422) + if err423 != nil { Usage() return } @@ -514,19 +514,19 @@ func main() { fmt.Fprintln(os.Stderr, "CreateJob requires 1 args") flag.Usage() } - arg423 := flag.Arg(1) - mbTrans424 := thrift.NewTMemoryBufferLen(len(arg423)) - defer mbTrans424.Close() - _, err425 := mbTrans424.WriteString(arg423) - if err425 != nil { + arg424 := flag.Arg(1) + mbTrans425 := thrift.NewTMemoryBufferLen(len(arg424)) + defer mbTrans425.Close() + _, err426 := mbTrans425.WriteString(arg424) + if err426 != nil { Usage() return } - factory426 := thrift.NewTSimpleJSONProtocolFactory() - jsProt427 := factory426.GetProtocol(mbTrans424) + factory427 := thrift.NewTSimpleJSONProtocolFactory() + jsProt428 := factory427.GetProtocol(mbTrans425) argvalue0 := aurora.NewJobConfiguration() - err428 := argvalue0.Read(jsProt427) - if err428 != nil { + err429 := argvalue0.Read(jsProt428) + if err429 != nil { Usage() return } @@ -539,19 +539,19 @@ func main() { fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") flag.Usage() } - arg429 := flag.Arg(1) - mbTrans430 := thrift.NewTMemoryBufferLen(len(arg429)) - defer mbTrans430.Close() - _, err431 := mbTrans430.WriteString(arg429) - if err431 != nil { + arg430 := flag.Arg(1) + mbTrans431 := thrift.NewTMemoryBufferLen(len(arg430)) + defer mbTrans431.Close() + _, err432 := mbTrans431.WriteString(arg430) + if err432 != nil { Usage() return } - factory432 := thrift.NewTSimpleJSONProtocolFactory() - jsProt433 := factory432.GetProtocol(mbTrans430) + factory433 := thrift.NewTSimpleJSONProtocolFactory() + jsProt434 := factory433.GetProtocol(mbTrans431) argvalue0 := aurora.NewJobConfiguration() - err434 := argvalue0.Read(jsProt433) - if err434 != nil { + err435 := argvalue0.Read(jsProt434) + if err435 != nil { Usage() return } @@ -564,19 +564,19 @@ func main() { fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") flag.Usage() } - arg435 := flag.Arg(1) - mbTrans436 := thrift.NewTMemoryBufferLen(len(arg435)) - defer mbTrans436.Close() - _, err437 := mbTrans436.WriteString(arg435) - if err437 != nil { + arg436 := flag.Arg(1) + mbTrans437 := thrift.NewTMemoryBufferLen(len(arg436)) + defer mbTrans437.Close() + _, err438 := mbTrans437.WriteString(arg436) + if err438 != nil { Usage() return } - factory438 := thrift.NewTSimpleJSONProtocolFactory() - jsProt439 := factory438.GetProtocol(mbTrans436) + factory439 := thrift.NewTSimpleJSONProtocolFactory() + jsProt440 := factory439.GetProtocol(mbTrans437) argvalue0 := aurora.NewJobKey() - err440 := argvalue0.Read(jsProt439) - if err440 != nil { + err441 := argvalue0.Read(jsProt440) + if err441 != nil { Usage() return } @@ -589,19 +589,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") flag.Usage() } - arg441 := flag.Arg(1) - mbTrans442 := thrift.NewTMemoryBufferLen(len(arg441)) - defer mbTrans442.Close() - _, err443 := mbTrans442.WriteString(arg441) - if err443 != nil { + arg442 := flag.Arg(1) + mbTrans443 := thrift.NewTMemoryBufferLen(len(arg442)) + defer mbTrans443.Close() + _, err444 := mbTrans443.WriteString(arg442) + if err444 != nil { Usage() return } - factory444 := thrift.NewTSimpleJSONProtocolFactory() - jsProt445 := factory444.GetProtocol(mbTrans442) + factory445 := thrift.NewTSimpleJSONProtocolFactory() + jsProt446 := factory445.GetProtocol(mbTrans443) argvalue0 := aurora.NewJobKey() - err446 := argvalue0.Read(jsProt445) - if err446 != nil { + err447 := argvalue0.Read(jsProt446) + if err447 != nil { Usage() return } @@ -614,36 +614,36 @@ func main() { fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") flag.Usage() } - arg447 := flag.Arg(1) - mbTrans448 := thrift.NewTMemoryBufferLen(len(arg447)) - defer mbTrans448.Close() - _, err449 := mbTrans448.WriteString(arg447) - if err449 != nil { + arg448 := flag.Arg(1) + mbTrans449 := thrift.NewTMemoryBufferLen(len(arg448)) + defer mbTrans449.Close() + _, err450 := mbTrans449.WriteString(arg448) + if err450 != nil { Usage() return } - factory450 := thrift.NewTSimpleJSONProtocolFactory() - jsProt451 := factory450.GetProtocol(mbTrans448) + factory451 := thrift.NewTSimpleJSONProtocolFactory() + jsProt452 := factory451.GetProtocol(mbTrans449) argvalue0 := aurora.NewJobKey() - err452 := argvalue0.Read(jsProt451) - if err452 != nil { + err453 := argvalue0.Read(jsProt452) + if err453 != nil { Usage() return } value0 := argvalue0 - arg453 := flag.Arg(2) - mbTrans454 := thrift.NewTMemoryBufferLen(len(arg453)) - defer mbTrans454.Close() - _, err455 := mbTrans454.WriteString(arg453) - if err455 != nil { + arg454 := flag.Arg(2) + mbTrans455 := thrift.NewTMemoryBufferLen(len(arg454)) + defer mbTrans455.Close() + _, err456 := mbTrans455.WriteString(arg454) + if err456 != nil { Usage() return } - factory456 := thrift.NewTSimpleJSONProtocolFactory() - jsProt457 := factory456.GetProtocol(mbTrans454) + factory457 := thrift.NewTSimpleJSONProtocolFactory() + jsProt458 := factory457.GetProtocol(mbTrans455) containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs() - err458 := containerStruct1.ReadField2(jsProt457) - if err458 != nil { + err459 := containerStruct1.ReadField2(jsProt458) + if err459 != nil { Usage() return } @@ -657,36 +657,36 @@ func main() { fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") flag.Usage() } - arg459 := flag.Arg(1) - mbTrans460 := thrift.NewTMemoryBufferLen(len(arg459)) - defer mbTrans460.Close() - _, err461 := mbTrans460.WriteString(arg459) - if err461 != nil { + arg460 := flag.Arg(1) + mbTrans461 := thrift.NewTMemoryBufferLen(len(arg460)) + defer mbTrans461.Close() + _, err462 := mbTrans461.WriteString(arg460) + if err462 != nil { Usage() return } - factory462 := thrift.NewTSimpleJSONProtocolFactory() - jsProt463 := factory462.GetProtocol(mbTrans460) + factory463 := thrift.NewTSimpleJSONProtocolFactory() + jsProt464 := factory463.GetProtocol(mbTrans461) argvalue0 := aurora.NewJobKey() - err464 := argvalue0.Read(jsProt463) - if err464 != nil { + err465 := argvalue0.Read(jsProt464) + if err465 != nil { Usage() return } value0 := argvalue0 - arg465 := flag.Arg(2) - mbTrans466 := thrift.NewTMemoryBufferLen(len(arg465)) - defer mbTrans466.Close() - _, err467 := mbTrans466.WriteString(arg465) - if err467 != nil { + arg466 := flag.Arg(2) + mbTrans467 := thrift.NewTMemoryBufferLen(len(arg466)) + defer mbTrans467.Close() + _, err468 := mbTrans467.WriteString(arg466) + if err468 != nil { Usage() return } - factory468 := thrift.NewTSimpleJSONProtocolFactory() - jsProt469 := factory468.GetProtocol(mbTrans466) + factory469 := thrift.NewTSimpleJSONProtocolFactory() + jsProt470 := factory469.GetProtocol(mbTrans467) containerStruct1 := aurora.NewAuroraAdminKillTasksArgs() - err470 := containerStruct1.ReadField2(jsProt469) - if err470 != nil { + err471 := containerStruct1.ReadField2(jsProt470) + if err471 != nil { Usage() return } @@ -702,25 +702,25 @@ func main() { fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") flag.Usage() } - arg472 := flag.Arg(1) - mbTrans473 := thrift.NewTMemoryBufferLen(len(arg472)) - defer mbTrans473.Close() - _, err474 := mbTrans473.WriteString(arg472) - if err474 != nil { + arg473 := flag.Arg(1) + mbTrans474 := thrift.NewTMemoryBufferLen(len(arg473)) + defer mbTrans474.Close() + _, err475 := mbTrans474.WriteString(arg473) + if err475 != nil { Usage() return } - factory475 := thrift.NewTSimpleJSONProtocolFactory() - jsProt476 := factory475.GetProtocol(mbTrans473) + factory476 := thrift.NewTSimpleJSONProtocolFactory() + jsProt477 := factory476.GetProtocol(mbTrans474) argvalue0 := aurora.NewInstanceKey() - err477 := argvalue0.Read(jsProt476) - if err477 != nil { + err478 := argvalue0.Read(jsProt477) + if err478 != nil { Usage() return } value0 := argvalue0 - tmp1, err478 := (strconv.Atoi(flag.Arg(2))) - if err478 != nil { + tmp1, err479 := (strconv.Atoi(flag.Arg(2))) + if err479 != nil { Usage() return } @@ -734,19 +734,19 @@ func main() { fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") flag.Usage() } - arg479 := flag.Arg(1) - mbTrans480 := thrift.NewTMemoryBufferLen(len(arg479)) - defer mbTrans480.Close() - _, err481 := mbTrans480.WriteString(arg479) - if err481 != nil { + arg480 := flag.Arg(1) + mbTrans481 := thrift.NewTMemoryBufferLen(len(arg480)) + defer mbTrans481.Close() + _, err482 := mbTrans481.WriteString(arg480) + if err482 != nil { Usage() return } - factory482 := thrift.NewTSimpleJSONProtocolFactory() - jsProt483 := factory482.GetProtocol(mbTrans480) + factory483 := thrift.NewTSimpleJSONProtocolFactory() + jsProt484 := factory483.GetProtocol(mbTrans481) argvalue0 := aurora.NewJobConfiguration() - err484 := argvalue0.Read(jsProt483) - if err484 != nil { + err485 := argvalue0.Read(jsProt484) + if err485 != nil { Usage() return } @@ -759,19 +759,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") flag.Usage() } - arg485 := flag.Arg(1) - mbTrans486 := thrift.NewTMemoryBufferLen(len(arg485)) - defer mbTrans486.Close() - _, err487 := mbTrans486.WriteString(arg485) - if err487 != nil { + arg486 := flag.Arg(1) + mbTrans487 := thrift.NewTMemoryBufferLen(len(arg486)) + defer mbTrans487.Close() + _, err488 := mbTrans487.WriteString(arg486) + if err488 != nil { Usage() return } - factory488 := thrift.NewTSimpleJSONProtocolFactory() - jsProt489 := factory488.GetProtocol(mbTrans486) + factory489 := thrift.NewTSimpleJSONProtocolFactory() + jsProt490 := factory489.GetProtocol(mbTrans487) argvalue0 := aurora.NewJobUpdateRequest() - err490 := argvalue0.Read(jsProt489) - if err490 != nil { + err491 := argvalue0.Read(jsProt490) + if err491 != nil { Usage() return } @@ -786,19 +786,19 @@ func main() { fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") flag.Usage() } - arg492 := flag.Arg(1) - mbTrans493 := thrift.NewTMemoryBufferLen(len(arg492)) - defer mbTrans493.Close() - _, err494 := mbTrans493.WriteString(arg492) - if err494 != nil { + arg493 := flag.Arg(1) + mbTrans494 := thrift.NewTMemoryBufferLen(len(arg493)) + defer mbTrans494.Close() + _, err495 := mbTrans494.WriteString(arg493) + if err495 != nil { Usage() return } - factory495 := thrift.NewTSimpleJSONProtocolFactory() - jsProt496 := factory495.GetProtocol(mbTrans493) + factory496 := thrift.NewTSimpleJSONProtocolFactory() + jsProt497 := factory496.GetProtocol(mbTrans494) argvalue0 := aurora.NewJobUpdateKey() - err497 := argvalue0.Read(jsProt496) - if err497 != nil { + err498 := argvalue0.Read(jsProt497) + if err498 != nil { Usage() return } @@ -813,19 +813,19 @@ func main() { fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") flag.Usage() } - arg499 := flag.Arg(1) - mbTrans500 := thrift.NewTMemoryBufferLen(len(arg499)) - defer mbTrans500.Close() - _, err501 := mbTrans500.WriteString(arg499) - if err501 != nil { + arg500 := flag.Arg(1) + mbTrans501 := thrift.NewTMemoryBufferLen(len(arg500)) + defer mbTrans501.Close() + _, err502 := mbTrans501.WriteString(arg500) + if err502 != nil { Usage() return } - factory502 := thrift.NewTSimpleJSONProtocolFactory() - jsProt503 := factory502.GetProtocol(mbTrans500) + factory503 := thrift.NewTSimpleJSONProtocolFactory() + jsProt504 := factory503.GetProtocol(mbTrans501) argvalue0 := aurora.NewJobUpdateKey() - err504 := argvalue0.Read(jsProt503) - if err504 != nil { + err505 := argvalue0.Read(jsProt504) + if err505 != nil { Usage() return } @@ -840,19 +840,19 @@ func main() { fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") flag.Usage() } - arg506 := flag.Arg(1) - mbTrans507 := thrift.NewTMemoryBufferLen(len(arg506)) - defer mbTrans507.Close() - _, err508 := mbTrans507.WriteString(arg506) - if err508 != nil { + arg507 := flag.Arg(1) + mbTrans508 := thrift.NewTMemoryBufferLen(len(arg507)) + defer mbTrans508.Close() + _, err509 := mbTrans508.WriteString(arg507) + if err509 != nil { Usage() return } - factory509 := thrift.NewTSimpleJSONProtocolFactory() - jsProt510 := factory509.GetProtocol(mbTrans507) + factory510 := thrift.NewTSimpleJSONProtocolFactory() + jsProt511 := factory510.GetProtocol(mbTrans508) argvalue0 := aurora.NewJobUpdateKey() - err511 := argvalue0.Read(jsProt510) - if err511 != nil { + err512 := argvalue0.Read(jsProt511) + if err512 != nil { Usage() return } @@ -867,19 +867,19 @@ func main() { fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") flag.Usage() } - arg513 := flag.Arg(1) - mbTrans514 := thrift.NewTMemoryBufferLen(len(arg513)) - defer mbTrans514.Close() - _, err515 := mbTrans514.WriteString(arg513) - if err515 != nil { + arg514 := flag.Arg(1) + mbTrans515 := thrift.NewTMemoryBufferLen(len(arg514)) + defer mbTrans515.Close() + _, err516 := mbTrans515.WriteString(arg514) + if err516 != nil { Usage() return } - factory516 := thrift.NewTSimpleJSONProtocolFactory() - jsProt517 := factory516.GetProtocol(mbTrans514) + factory517 := thrift.NewTSimpleJSONProtocolFactory() + jsProt518 := factory517.GetProtocol(mbTrans515) argvalue0 := aurora.NewJobUpdateKey() - err518 := argvalue0.Read(jsProt517) - if err518 != nil { + err519 := argvalue0.Read(jsProt518) + if err519 != nil { Usage() return } @@ -894,19 +894,19 @@ func main() { fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") flag.Usage() } - arg520 := flag.Arg(1) - mbTrans521 := thrift.NewTMemoryBufferLen(len(arg520)) - defer mbTrans521.Close() - _, err522 := mbTrans521.WriteString(arg520) - if err522 != nil { + arg521 := flag.Arg(1) + mbTrans522 := thrift.NewTMemoryBufferLen(len(arg521)) + defer mbTrans522.Close() + _, err523 := mbTrans522.WriteString(arg521) + if err523 != nil { Usage() return } - factory523 := thrift.NewTSimpleJSONProtocolFactory() - jsProt524 := factory523.GetProtocol(mbTrans521) + factory524 := thrift.NewTSimpleJSONProtocolFactory() + jsProt525 := factory524.GetProtocol(mbTrans522) argvalue0 := aurora.NewJobUpdateKey() - err525 := argvalue0.Read(jsProt524) - if err525 != nil { + err526 := argvalue0.Read(jsProt525) + if err526 != nil { Usage() return } @@ -937,19 +937,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") flag.Usage() } - arg527 := flag.Arg(1) - mbTrans528 := thrift.NewTMemoryBufferLen(len(arg527)) - defer mbTrans528.Close() - _, err529 := mbTrans528.WriteString(arg527) - if err529 != nil { + arg528 := flag.Arg(1) + mbTrans529 := thrift.NewTMemoryBufferLen(len(arg528)) + defer mbTrans529.Close() + _, err530 := mbTrans529.WriteString(arg528) + if err530 != nil { Usage() return } - factory530 := thrift.NewTSimpleJSONProtocolFactory() - jsProt531 := factory530.GetProtocol(mbTrans528) + factory531 := thrift.NewTSimpleJSONProtocolFactory() + jsProt532 := factory531.GetProtocol(mbTrans529) argvalue0 := aurora.NewTaskQuery() - err532 := argvalue0.Read(jsProt531) - if err532 != nil { + err533 := argvalue0.Read(jsProt532) + if err533 != nil { Usage() return } @@ -962,19 +962,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") flag.Usage() } - arg533 := flag.Arg(1) - mbTrans534 := thrift.NewTMemoryBufferLen(len(arg533)) - defer mbTrans534.Close() - _, err535 := mbTrans534.WriteString(arg533) - if err535 != nil { + arg534 := flag.Arg(1) + mbTrans535 := thrift.NewTMemoryBufferLen(len(arg534)) + defer mbTrans535.Close() + _, err536 := mbTrans535.WriteString(arg534) + if err536 != nil { Usage() return } - factory536 := thrift.NewTSimpleJSONProtocolFactory() - jsProt537 := factory536.GetProtocol(mbTrans534) + factory537 := thrift.NewTSimpleJSONProtocolFactory() + jsProt538 := factory537.GetProtocol(mbTrans535) argvalue0 := aurora.NewTaskQuery() - err538 := argvalue0.Read(jsProt537) - if err538 != nil { + err539 := argvalue0.Read(jsProt538) + if err539 != nil { Usage() return } @@ -987,19 +987,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") flag.Usage() } - arg539 := flag.Arg(1) - mbTrans540 := thrift.NewTMemoryBufferLen(len(arg539)) - defer mbTrans540.Close() - _, err541 := mbTrans540.WriteString(arg539) - if err541 != nil { + arg540 := flag.Arg(1) + mbTrans541 := thrift.NewTMemoryBufferLen(len(arg540)) + defer mbTrans541.Close() + _, err542 := mbTrans541.WriteString(arg540) + if err542 != nil { Usage() return } - factory542 := thrift.NewTSimpleJSONProtocolFactory() - jsProt543 := factory542.GetProtocol(mbTrans540) + factory543 := thrift.NewTSimpleJSONProtocolFactory() + jsProt544 := factory543.GetProtocol(mbTrans541) argvalue0 := aurora.NewTaskQuery() - err544 := argvalue0.Read(jsProt543) - if err544 != nil { + err545 := argvalue0.Read(jsProt544) + if err545 != nil { Usage() return } @@ -1012,19 +1012,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") flag.Usage() } - arg545 := flag.Arg(1) - mbTrans546 := thrift.NewTMemoryBufferLen(len(arg545)) - defer mbTrans546.Close() - _, err547 := mbTrans546.WriteString(arg545) - if err547 != nil { + arg546 := flag.Arg(1) + mbTrans547 := thrift.NewTMemoryBufferLen(len(arg546)) + defer mbTrans547.Close() + _, err548 := mbTrans547.WriteString(arg546) + if err548 != nil { Usage() return } - factory548 := thrift.NewTSimpleJSONProtocolFactory() - jsProt549 := factory548.GetProtocol(mbTrans546) + factory549 := thrift.NewTSimpleJSONProtocolFactory() + jsProt550 := factory549.GetProtocol(mbTrans547) argvalue0 := aurora.NewJobKey() - err550 := argvalue0.Read(jsProt549) - if err550 != nil { + err551 := argvalue0.Read(jsProt550) + if err551 != nil { Usage() return } @@ -1057,19 +1057,19 @@ func main() { fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") flag.Usage() } - arg553 := flag.Arg(1) - mbTrans554 := thrift.NewTMemoryBufferLen(len(arg553)) - defer mbTrans554.Close() - _, err555 := mbTrans554.WriteString(arg553) - if err555 != nil { + arg554 := flag.Arg(1) + mbTrans555 := thrift.NewTMemoryBufferLen(len(arg554)) + defer mbTrans555.Close() + _, err556 := mbTrans555.WriteString(arg554) + if err556 != nil { Usage() return } - factory556 := thrift.NewTSimpleJSONProtocolFactory() - jsProt557 := factory556.GetProtocol(mbTrans554) + factory557 := thrift.NewTSimpleJSONProtocolFactory() + jsProt558 := factory557.GetProtocol(mbTrans555) argvalue0 := aurora.NewJobConfiguration() - err558 := argvalue0.Read(jsProt557) - if err558 != nil { + err559 := argvalue0.Read(jsProt558) + if err559 != nil { Usage() return } @@ -1082,19 +1082,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") flag.Usage() } - arg559 := flag.Arg(1) - mbTrans560 := thrift.NewTMemoryBufferLen(len(arg559)) - defer mbTrans560.Close() - _, err561 := mbTrans560.WriteString(arg559) - if err561 != nil { + arg560 := flag.Arg(1) + mbTrans561 := thrift.NewTMemoryBufferLen(len(arg560)) + defer mbTrans561.Close() + _, err562 := mbTrans561.WriteString(arg560) + if err562 != nil { Usage() return } - factory562 := thrift.NewTSimpleJSONProtocolFactory() - jsProt563 := factory562.GetProtocol(mbTrans560) + factory563 := thrift.NewTSimpleJSONProtocolFactory() + jsProt564 := factory563.GetProtocol(mbTrans561) argvalue0 := aurora.NewJobUpdateQuery() - err564 := argvalue0.Read(jsProt563) - if err564 != nil { + err565 := argvalue0.Read(jsProt564) + if err565 != nil { Usage() return } @@ -1107,19 +1107,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") flag.Usage() } - arg565 := flag.Arg(1) - mbTrans566 := thrift.NewTMemoryBufferLen(len(arg565)) - defer mbTrans566.Close() - _, err567 := mbTrans566.WriteString(arg565) - if err567 != nil { + arg566 := flag.Arg(1) + mbTrans567 := thrift.NewTMemoryBufferLen(len(arg566)) + defer mbTrans567.Close() + _, err568 := mbTrans567.WriteString(arg566) + if err568 != nil { Usage() return } - factory568 := thrift.NewTSimpleJSONProtocolFactory() - jsProt569 := factory568.GetProtocol(mbTrans566) + factory569 := thrift.NewTSimpleJSONProtocolFactory() + jsProt570 := factory569.GetProtocol(mbTrans567) argvalue0 := aurora.NewJobUpdateQuery() - err570 := argvalue0.Read(jsProt569) - if err570 != nil { + err571 := argvalue0.Read(jsProt570) + if err571 != nil { Usage() return } @@ -1132,19 +1132,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") flag.Usage() } - arg571 := flag.Arg(1) - mbTrans572 := thrift.NewTMemoryBufferLen(len(arg571)) - defer mbTrans572.Close() - _, err573 := mbTrans572.WriteString(arg571) - if err573 != nil { + arg572 := flag.Arg(1) + mbTrans573 := thrift.NewTMemoryBufferLen(len(arg572)) + defer mbTrans573.Close() + _, err574 := mbTrans573.WriteString(arg572) + if err574 != nil { Usage() return } - factory574 := thrift.NewTSimpleJSONProtocolFactory() - jsProt575 := factory574.GetProtocol(mbTrans572) + factory575 := thrift.NewTSimpleJSONProtocolFactory() + jsProt576 := factory575.GetProtocol(mbTrans573) argvalue0 := aurora.NewJobUpdateRequest() - err576 := argvalue0.Read(jsProt575) - if err576 != nil { + err577 := argvalue0.Read(jsProt576) + if err577 != nil { Usage() return } diff --git a/gen-go/apache/aurora/aurora_scheduler_manager-remote/aurora_scheduler_manager-remote.go b/gen-go/apache/aurora/aurora_scheduler_manager-remote/aurora_scheduler_manager-remote.go index 3ca67ea..463e867 100755 --- a/gen-go/apache/aurora/aurora_scheduler_manager-remote/aurora_scheduler_manager-remote.go +++ b/gen-go/apache/aurora/aurora_scheduler_manager-remote/aurora_scheduler_manager-remote.go @@ -146,19 +146,19 @@ func main() { fmt.Fprintln(os.Stderr, "CreateJob requires 1 args") flag.Usage() } - arg162 := flag.Arg(1) - mbTrans163 := thrift.NewTMemoryBufferLen(len(arg162)) - defer mbTrans163.Close() - _, err164 := mbTrans163.WriteString(arg162) - if err164 != nil { + arg163 := flag.Arg(1) + mbTrans164 := thrift.NewTMemoryBufferLen(len(arg163)) + defer mbTrans164.Close() + _, err165 := mbTrans164.WriteString(arg163) + if err165 != nil { Usage() return } - factory165 := thrift.NewTSimpleJSONProtocolFactory() - jsProt166 := factory165.GetProtocol(mbTrans163) + factory166 := thrift.NewTSimpleJSONProtocolFactory() + jsProt167 := factory166.GetProtocol(mbTrans164) argvalue0 := aurora.NewJobConfiguration() - err167 := argvalue0.Read(jsProt166) - if err167 != nil { + err168 := argvalue0.Read(jsProt167) + if err168 != nil { Usage() return } @@ -171,19 +171,19 @@ func main() { fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") flag.Usage() } - arg168 := flag.Arg(1) - mbTrans169 := thrift.NewTMemoryBufferLen(len(arg168)) - defer mbTrans169.Close() - _, err170 := mbTrans169.WriteString(arg168) - if err170 != nil { + arg169 := flag.Arg(1) + mbTrans170 := thrift.NewTMemoryBufferLen(len(arg169)) + defer mbTrans170.Close() + _, err171 := mbTrans170.WriteString(arg169) + if err171 != nil { Usage() return } - factory171 := thrift.NewTSimpleJSONProtocolFactory() - jsProt172 := factory171.GetProtocol(mbTrans169) + factory172 := thrift.NewTSimpleJSONProtocolFactory() + jsProt173 := factory172.GetProtocol(mbTrans170) argvalue0 := aurora.NewJobConfiguration() - err173 := argvalue0.Read(jsProt172) - if err173 != nil { + err174 := argvalue0.Read(jsProt173) + if err174 != nil { Usage() return } @@ -196,19 +196,19 @@ func main() { fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") flag.Usage() } - arg174 := flag.Arg(1) - mbTrans175 := thrift.NewTMemoryBufferLen(len(arg174)) - defer mbTrans175.Close() - _, err176 := mbTrans175.WriteString(arg174) - if err176 != nil { + arg175 := flag.Arg(1) + mbTrans176 := thrift.NewTMemoryBufferLen(len(arg175)) + defer mbTrans176.Close() + _, err177 := mbTrans176.WriteString(arg175) + if err177 != nil { Usage() return } - factory177 := thrift.NewTSimpleJSONProtocolFactory() - jsProt178 := factory177.GetProtocol(mbTrans175) + factory178 := thrift.NewTSimpleJSONProtocolFactory() + jsProt179 := factory178.GetProtocol(mbTrans176) argvalue0 := aurora.NewJobKey() - err179 := argvalue0.Read(jsProt178) - if err179 != nil { + err180 := argvalue0.Read(jsProt179) + if err180 != nil { Usage() return } @@ -221,19 +221,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") flag.Usage() } - arg180 := flag.Arg(1) - mbTrans181 := thrift.NewTMemoryBufferLen(len(arg180)) - defer mbTrans181.Close() - _, err182 := mbTrans181.WriteString(arg180) - if err182 != nil { + arg181 := flag.Arg(1) + mbTrans182 := thrift.NewTMemoryBufferLen(len(arg181)) + defer mbTrans182.Close() + _, err183 := mbTrans182.WriteString(arg181) + if err183 != nil { Usage() return } - factory183 := thrift.NewTSimpleJSONProtocolFactory() - jsProt184 := factory183.GetProtocol(mbTrans181) + factory184 := thrift.NewTSimpleJSONProtocolFactory() + jsProt185 := factory184.GetProtocol(mbTrans182) argvalue0 := aurora.NewJobKey() - err185 := argvalue0.Read(jsProt184) - if err185 != nil { + err186 := argvalue0.Read(jsProt185) + if err186 != nil { Usage() return } @@ -246,36 +246,36 @@ func main() { fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") flag.Usage() } - arg186 := flag.Arg(1) - mbTrans187 := thrift.NewTMemoryBufferLen(len(arg186)) - defer mbTrans187.Close() - _, err188 := mbTrans187.WriteString(arg186) - if err188 != nil { + arg187 := flag.Arg(1) + mbTrans188 := thrift.NewTMemoryBufferLen(len(arg187)) + defer mbTrans188.Close() + _, err189 := mbTrans188.WriteString(arg187) + if err189 != nil { Usage() return } - factory189 := thrift.NewTSimpleJSONProtocolFactory() - jsProt190 := factory189.GetProtocol(mbTrans187) + factory190 := thrift.NewTSimpleJSONProtocolFactory() + jsProt191 := factory190.GetProtocol(mbTrans188) argvalue0 := aurora.NewJobKey() - err191 := argvalue0.Read(jsProt190) - if err191 != nil { + err192 := argvalue0.Read(jsProt191) + if err192 != nil { Usage() return } value0 := argvalue0 - arg192 := flag.Arg(2) - mbTrans193 := thrift.NewTMemoryBufferLen(len(arg192)) - defer mbTrans193.Close() - _, err194 := mbTrans193.WriteString(arg192) - if err194 != nil { + arg193 := flag.Arg(2) + mbTrans194 := thrift.NewTMemoryBufferLen(len(arg193)) + defer mbTrans194.Close() + _, err195 := mbTrans194.WriteString(arg193) + if err195 != nil { Usage() return } - factory195 := thrift.NewTSimpleJSONProtocolFactory() - jsProt196 := factory195.GetProtocol(mbTrans193) + factory196 := thrift.NewTSimpleJSONProtocolFactory() + jsProt197 := factory196.GetProtocol(mbTrans194) containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs() - err197 := containerStruct1.ReadField2(jsProt196) - if err197 != nil { + err198 := containerStruct1.ReadField2(jsProt197) + if err198 != nil { Usage() return } @@ -289,36 +289,36 @@ func main() { fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") flag.Usage() } - arg198 := flag.Arg(1) - mbTrans199 := thrift.NewTMemoryBufferLen(len(arg198)) - defer mbTrans199.Close() - _, err200 := mbTrans199.WriteString(arg198) - if err200 != nil { + arg199 := flag.Arg(1) + mbTrans200 := thrift.NewTMemoryBufferLen(len(arg199)) + defer mbTrans200.Close() + _, err201 := mbTrans200.WriteString(arg199) + if err201 != nil { Usage() return } - factory201 := thrift.NewTSimpleJSONProtocolFactory() - jsProt202 := factory201.GetProtocol(mbTrans199) + factory202 := thrift.NewTSimpleJSONProtocolFactory() + jsProt203 := factory202.GetProtocol(mbTrans200) argvalue0 := aurora.NewJobKey() - err203 := argvalue0.Read(jsProt202) - if err203 != nil { + err204 := argvalue0.Read(jsProt203) + if err204 != nil { Usage() return } value0 := argvalue0 - arg204 := flag.Arg(2) - mbTrans205 := thrift.NewTMemoryBufferLen(len(arg204)) - defer mbTrans205.Close() - _, err206 := mbTrans205.WriteString(arg204) - if err206 != nil { + arg205 := flag.Arg(2) + mbTrans206 := thrift.NewTMemoryBufferLen(len(arg205)) + defer mbTrans206.Close() + _, err207 := mbTrans206.WriteString(arg205) + if err207 != nil { Usage() return } - factory207 := thrift.NewTSimpleJSONProtocolFactory() - jsProt208 := factory207.GetProtocol(mbTrans205) + factory208 := thrift.NewTSimpleJSONProtocolFactory() + jsProt209 := factory208.GetProtocol(mbTrans206) containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs() - err209 := containerStruct1.ReadField2(jsProt208) - if err209 != nil { + err210 := containerStruct1.ReadField2(jsProt209) + if err210 != nil { Usage() return } @@ -334,25 +334,25 @@ func main() { fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") flag.Usage() } - arg211 := flag.Arg(1) - mbTrans212 := thrift.NewTMemoryBufferLen(len(arg211)) - defer mbTrans212.Close() - _, err213 := mbTrans212.WriteString(arg211) - if err213 != nil { + arg212 := flag.Arg(1) + mbTrans213 := thrift.NewTMemoryBufferLen(len(arg212)) + defer mbTrans213.Close() + _, err214 := mbTrans213.WriteString(arg212) + if err214 != nil { Usage() return } - factory214 := thrift.NewTSimpleJSONProtocolFactory() - jsProt215 := factory214.GetProtocol(mbTrans212) + factory215 := thrift.NewTSimpleJSONProtocolFactory() + jsProt216 := factory215.GetProtocol(mbTrans213) argvalue0 := aurora.NewInstanceKey() - err216 := argvalue0.Read(jsProt215) - if err216 != nil { + err217 := argvalue0.Read(jsProt216) + if err217 != nil { Usage() return } value0 := argvalue0 - tmp1, err217 := (strconv.Atoi(flag.Arg(2))) - if err217 != nil { + tmp1, err218 := (strconv.Atoi(flag.Arg(2))) + if err218 != nil { Usage() return } @@ -366,19 +366,19 @@ func main() { fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") flag.Usage() } - arg218 := flag.Arg(1) - mbTrans219 := thrift.NewTMemoryBufferLen(len(arg218)) - defer mbTrans219.Close() - _, err220 := mbTrans219.WriteString(arg218) - if err220 != nil { + arg219 := flag.Arg(1) + mbTrans220 := thrift.NewTMemoryBufferLen(len(arg219)) + defer mbTrans220.Close() + _, err221 := mbTrans220.WriteString(arg219) + if err221 != nil { Usage() return } - factory221 := thrift.NewTSimpleJSONProtocolFactory() - jsProt222 := factory221.GetProtocol(mbTrans219) + factory222 := thrift.NewTSimpleJSONProtocolFactory() + jsProt223 := factory222.GetProtocol(mbTrans220) argvalue0 := aurora.NewJobConfiguration() - err223 := argvalue0.Read(jsProt222) - if err223 != nil { + err224 := argvalue0.Read(jsProt223) + if err224 != nil { Usage() return } @@ -391,19 +391,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") flag.Usage() } - arg224 := flag.Arg(1) - mbTrans225 := thrift.NewTMemoryBufferLen(len(arg224)) - defer mbTrans225.Close() - _, err226 := mbTrans225.WriteString(arg224) - if err226 != nil { + arg225 := flag.Arg(1) + mbTrans226 := thrift.NewTMemoryBufferLen(len(arg225)) + defer mbTrans226.Close() + _, err227 := mbTrans226.WriteString(arg225) + if err227 != nil { Usage() return } - factory227 := thrift.NewTSimpleJSONProtocolFactory() - jsProt228 := factory227.GetProtocol(mbTrans225) + factory228 := thrift.NewTSimpleJSONProtocolFactory() + jsProt229 := factory228.GetProtocol(mbTrans226) argvalue0 := aurora.NewJobUpdateRequest() - err229 := argvalue0.Read(jsProt228) - if err229 != nil { + err230 := argvalue0.Read(jsProt229) + if err230 != nil { Usage() return } @@ -418,19 +418,19 @@ func main() { fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") flag.Usage() } - arg231 := flag.Arg(1) - mbTrans232 := thrift.NewTMemoryBufferLen(len(arg231)) - defer mbTrans232.Close() - _, err233 := mbTrans232.WriteString(arg231) - if err233 != nil { + arg232 := flag.Arg(1) + mbTrans233 := thrift.NewTMemoryBufferLen(len(arg232)) + defer mbTrans233.Close() + _, err234 := mbTrans233.WriteString(arg232) + if err234 != nil { Usage() return } - factory234 := thrift.NewTSimpleJSONProtocolFactory() - jsProt235 := factory234.GetProtocol(mbTrans232) + factory235 := thrift.NewTSimpleJSONProtocolFactory() + jsProt236 := factory235.GetProtocol(mbTrans233) argvalue0 := aurora.NewJobUpdateKey() - err236 := argvalue0.Read(jsProt235) - if err236 != nil { + err237 := argvalue0.Read(jsProt236) + if err237 != nil { Usage() return } @@ -445,19 +445,19 @@ func main() { fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") flag.Usage() } - arg238 := flag.Arg(1) - mbTrans239 := thrift.NewTMemoryBufferLen(len(arg238)) - defer mbTrans239.Close() - _, err240 := mbTrans239.WriteString(arg238) - if err240 != nil { + arg239 := flag.Arg(1) + mbTrans240 := thrift.NewTMemoryBufferLen(len(arg239)) + defer mbTrans240.Close() + _, err241 := mbTrans240.WriteString(arg239) + if err241 != nil { Usage() return } - factory241 := thrift.NewTSimpleJSONProtocolFactory() - jsProt242 := factory241.GetProtocol(mbTrans239) + factory242 := thrift.NewTSimpleJSONProtocolFactory() + jsProt243 := factory242.GetProtocol(mbTrans240) argvalue0 := aurora.NewJobUpdateKey() - err243 := argvalue0.Read(jsProt242) - if err243 != nil { + err244 := argvalue0.Read(jsProt243) + if err244 != nil { Usage() return } @@ -472,19 +472,19 @@ func main() { fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") flag.Usage() } - arg245 := flag.Arg(1) - mbTrans246 := thrift.NewTMemoryBufferLen(len(arg245)) - defer mbTrans246.Close() - _, err247 := mbTrans246.WriteString(arg245) - if err247 != nil { + arg246 := flag.Arg(1) + mbTrans247 := thrift.NewTMemoryBufferLen(len(arg246)) + defer mbTrans247.Close() + _, err248 := mbTrans247.WriteString(arg246) + if err248 != nil { Usage() return } - factory248 := thrift.NewTSimpleJSONProtocolFactory() - jsProt249 := factory248.GetProtocol(mbTrans246) + factory249 := thrift.NewTSimpleJSONProtocolFactory() + jsProt250 := factory249.GetProtocol(mbTrans247) argvalue0 := aurora.NewJobUpdateKey() - err250 := argvalue0.Read(jsProt249) - if err250 != nil { + err251 := argvalue0.Read(jsProt250) + if err251 != nil { Usage() return } @@ -499,19 +499,19 @@ func main() { fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") flag.Usage() } - arg252 := flag.Arg(1) - mbTrans253 := thrift.NewTMemoryBufferLen(len(arg252)) - defer mbTrans253.Close() - _, err254 := mbTrans253.WriteString(arg252) - if err254 != nil { + arg253 := flag.Arg(1) + mbTrans254 := thrift.NewTMemoryBufferLen(len(arg253)) + defer mbTrans254.Close() + _, err255 := mbTrans254.WriteString(arg253) + if err255 != nil { Usage() return } - factory255 := thrift.NewTSimpleJSONProtocolFactory() - jsProt256 := factory255.GetProtocol(mbTrans253) + factory256 := thrift.NewTSimpleJSONProtocolFactory() + jsProt257 := factory256.GetProtocol(mbTrans254) argvalue0 := aurora.NewJobUpdateKey() - err257 := argvalue0.Read(jsProt256) - if err257 != nil { + err258 := argvalue0.Read(jsProt257) + if err258 != nil { Usage() return } @@ -526,19 +526,19 @@ func main() { fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") flag.Usage() } - arg259 := flag.Arg(1) - mbTrans260 := thrift.NewTMemoryBufferLen(len(arg259)) - defer mbTrans260.Close() - _, err261 := mbTrans260.WriteString(arg259) - if err261 != nil { + arg260 := flag.Arg(1) + mbTrans261 := thrift.NewTMemoryBufferLen(len(arg260)) + defer mbTrans261.Close() + _, err262 := mbTrans261.WriteString(arg260) + if err262 != nil { Usage() return } - factory262 := thrift.NewTSimpleJSONProtocolFactory() - jsProt263 := factory262.GetProtocol(mbTrans260) + factory263 := thrift.NewTSimpleJSONProtocolFactory() + jsProt264 := factory263.GetProtocol(mbTrans261) argvalue0 := aurora.NewJobUpdateKey() - err264 := argvalue0.Read(jsProt263) - if err264 != nil { + err265 := argvalue0.Read(jsProt264) + if err265 != nil { Usage() return } @@ -569,19 +569,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") flag.Usage() } - arg266 := flag.Arg(1) - mbTrans267 := thrift.NewTMemoryBufferLen(len(arg266)) - defer mbTrans267.Close() - _, err268 := mbTrans267.WriteString(arg266) - if err268 != nil { + arg267 := flag.Arg(1) + mbTrans268 := thrift.NewTMemoryBufferLen(len(arg267)) + defer mbTrans268.Close() + _, err269 := mbTrans268.WriteString(arg267) + if err269 != nil { Usage() return } - factory269 := thrift.NewTSimpleJSONProtocolFactory() - jsProt270 := factory269.GetProtocol(mbTrans267) + factory270 := thrift.NewTSimpleJSONProtocolFactory() + jsProt271 := factory270.GetProtocol(mbTrans268) argvalue0 := aurora.NewTaskQuery() - err271 := argvalue0.Read(jsProt270) - if err271 != nil { + err272 := argvalue0.Read(jsProt271) + if err272 != nil { Usage() return } @@ -594,19 +594,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") flag.Usage() } - arg272 := flag.Arg(1) - mbTrans273 := thrift.NewTMemoryBufferLen(len(arg272)) - defer mbTrans273.Close() - _, err274 := mbTrans273.WriteString(arg272) - if err274 != nil { + arg273 := flag.Arg(1) + mbTrans274 := thrift.NewTMemoryBufferLen(len(arg273)) + defer mbTrans274.Close() + _, err275 := mbTrans274.WriteString(arg273) + if err275 != nil { Usage() return } - factory275 := thrift.NewTSimpleJSONProtocolFactory() - jsProt276 := factory275.GetProtocol(mbTrans273) + factory276 := thrift.NewTSimpleJSONProtocolFactory() + jsProt277 := factory276.GetProtocol(mbTrans274) argvalue0 := aurora.NewTaskQuery() - err277 := argvalue0.Read(jsProt276) - if err277 != nil { + err278 := argvalue0.Read(jsProt277) + if err278 != nil { Usage() return } @@ -619,19 +619,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") flag.Usage() } - arg278 := flag.Arg(1) - mbTrans279 := thrift.NewTMemoryBufferLen(len(arg278)) - defer mbTrans279.Close() - _, err280 := mbTrans279.WriteString(arg278) - if err280 != nil { + arg279 := flag.Arg(1) + mbTrans280 := thrift.NewTMemoryBufferLen(len(arg279)) + defer mbTrans280.Close() + _, err281 := mbTrans280.WriteString(arg279) + if err281 != nil { Usage() return } - factory281 := thrift.NewTSimpleJSONProtocolFactory() - jsProt282 := factory281.GetProtocol(mbTrans279) + factory282 := thrift.NewTSimpleJSONProtocolFactory() + jsProt283 := factory282.GetProtocol(mbTrans280) argvalue0 := aurora.NewTaskQuery() - err283 := argvalue0.Read(jsProt282) - if err283 != nil { + err284 := argvalue0.Read(jsProt283) + if err284 != nil { Usage() return } @@ -644,19 +644,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") flag.Usage() } - arg284 := flag.Arg(1) - mbTrans285 := thrift.NewTMemoryBufferLen(len(arg284)) - defer mbTrans285.Close() - _, err286 := mbTrans285.WriteString(arg284) - if err286 != nil { + arg285 := flag.Arg(1) + mbTrans286 := thrift.NewTMemoryBufferLen(len(arg285)) + defer mbTrans286.Close() + _, err287 := mbTrans286.WriteString(arg285) + if err287 != nil { Usage() return } - factory287 := thrift.NewTSimpleJSONProtocolFactory() - jsProt288 := factory287.GetProtocol(mbTrans285) + factory288 := thrift.NewTSimpleJSONProtocolFactory() + jsProt289 := factory288.GetProtocol(mbTrans286) argvalue0 := aurora.NewJobKey() - err289 := argvalue0.Read(jsProt288) - if err289 != nil { + err290 := argvalue0.Read(jsProt289) + if err290 != nil { Usage() return } @@ -689,19 +689,19 @@ func main() { fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") flag.Usage() } - arg292 := flag.Arg(1) - mbTrans293 := thrift.NewTMemoryBufferLen(len(arg292)) - defer mbTrans293.Close() - _, err294 := mbTrans293.WriteString(arg292) - if err294 != nil { + arg293 := flag.Arg(1) + mbTrans294 := thrift.NewTMemoryBufferLen(len(arg293)) + defer mbTrans294.Close() + _, err295 := mbTrans294.WriteString(arg293) + if err295 != nil { Usage() return } - factory295 := thrift.NewTSimpleJSONProtocolFactory() - jsProt296 := factory295.GetProtocol(mbTrans293) + factory296 := thrift.NewTSimpleJSONProtocolFactory() + jsProt297 := factory296.GetProtocol(mbTrans294) argvalue0 := aurora.NewJobConfiguration() - err297 := argvalue0.Read(jsProt296) - if err297 != nil { + err298 := argvalue0.Read(jsProt297) + if err298 != nil { Usage() return } @@ -714,19 +714,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") flag.Usage() } - arg298 := flag.Arg(1) - mbTrans299 := thrift.NewTMemoryBufferLen(len(arg298)) - defer mbTrans299.Close() - _, err300 := mbTrans299.WriteString(arg298) - if err300 != nil { + arg299 := flag.Arg(1) + mbTrans300 := thrift.NewTMemoryBufferLen(len(arg299)) + defer mbTrans300.Close() + _, err301 := mbTrans300.WriteString(arg299) + if err301 != nil { Usage() return } - factory301 := thrift.NewTSimpleJSONProtocolFactory() - jsProt302 := factory301.GetProtocol(mbTrans299) + factory302 := thrift.NewTSimpleJSONProtocolFactory() + jsProt303 := factory302.GetProtocol(mbTrans300) argvalue0 := aurora.NewJobUpdateQuery() - err303 := argvalue0.Read(jsProt302) - if err303 != nil { + err304 := argvalue0.Read(jsProt303) + if err304 != nil { Usage() return } @@ -739,19 +739,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") flag.Usage() } - arg304 := flag.Arg(1) - mbTrans305 := thrift.NewTMemoryBufferLen(len(arg304)) - defer mbTrans305.Close() - _, err306 := mbTrans305.WriteString(arg304) - if err306 != nil { + arg305 := flag.Arg(1) + mbTrans306 := thrift.NewTMemoryBufferLen(len(arg305)) + defer mbTrans306.Close() + _, err307 := mbTrans306.WriteString(arg305) + if err307 != nil { Usage() return } - factory307 := thrift.NewTSimpleJSONProtocolFactory() - jsProt308 := factory307.GetProtocol(mbTrans305) + factory308 := thrift.NewTSimpleJSONProtocolFactory() + jsProt309 := factory308.GetProtocol(mbTrans306) argvalue0 := aurora.NewJobUpdateQuery() - err309 := argvalue0.Read(jsProt308) - if err309 != nil { + err310 := argvalue0.Read(jsProt309) + if err310 != nil { Usage() return } @@ -764,19 +764,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") flag.Usage() } - arg310 := flag.Arg(1) - mbTrans311 := thrift.NewTMemoryBufferLen(len(arg310)) - defer mbTrans311.Close() - _, err312 := mbTrans311.WriteString(arg310) - if err312 != nil { + arg311 := flag.Arg(1) + mbTrans312 := thrift.NewTMemoryBufferLen(len(arg311)) + defer mbTrans312.Close() + _, err313 := mbTrans312.WriteString(arg311) + if err313 != nil { Usage() return } - factory313 := thrift.NewTSimpleJSONProtocolFactory() - jsProt314 := factory313.GetProtocol(mbTrans311) + factory314 := thrift.NewTSimpleJSONProtocolFactory() + jsProt315 := factory314.GetProtocol(mbTrans312) argvalue0 := aurora.NewJobUpdateRequest() - err315 := argvalue0.Read(jsProt314) - if err315 != nil { + err316 := argvalue0.Read(jsProt315) + if err316 != nil { Usage() return } diff --git a/gen-go/apache/aurora/auroraadmin.go b/gen-go/apache/aurora/auroraadmin.go index b00e9cf..18a8162 100644 --- a/gen-go/apache/aurora/auroraadmin.go +++ b/gen-go/apache/aurora/auroraadmin.go @@ -167,16 +167,16 @@ func (p *AuroraAdminClient) recvSetQuota() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error316 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error317 error - error317, err = error316.Read(iprot) + error317 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error318 error + error318, err = error317.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error317 + err = error318 return } if mTypeId != thrift.REPLY { @@ -250,16 +250,16 @@ func (p *AuroraAdminClient) recvForceTaskState() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error318 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error319 error - error319, err = error318.Read(iprot) + error319 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error320 error + error320, err = error319.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error319 + err = error320 return } if mTypeId != thrift.REPLY { @@ -324,16 +324,16 @@ func (p *AuroraAdminClient) recvPerformBackup() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error320 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error321 error - error321, err = error320.Read(iprot) + error321 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error322 error + error322, err = error321.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error321 + err = error322 return } if mTypeId != thrift.REPLY { @@ -398,16 +398,16 @@ func (p *AuroraAdminClient) recvListBackups() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error322 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error323 error - error323, err = error322.Read(iprot) + error323 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error324 error + error324, err = error323.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error323 + err = error324 return } if mTypeId != thrift.REPLY { @@ -477,16 +477,16 @@ func (p *AuroraAdminClient) recvStageRecovery() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error324 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error325 error - error325, err = error324.Read(iprot) + error325 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error326 error + error326, err = error325.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error325 + err = error326 return } if mTypeId != thrift.REPLY { @@ -556,16 +556,16 @@ func (p *AuroraAdminClient) recvQueryRecovery() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error326 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error327 error - error327, err = error326.Read(iprot) + error327 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error328 error + error328, err = error327.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error327 + err = error328 return } if mTypeId != thrift.REPLY { @@ -635,16 +635,16 @@ func (p *AuroraAdminClient) recvDeleteRecoveryTasks() (value *Response, err erro return } if mTypeId == thrift.EXCEPTION { - error328 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error329 error - error329, err = error328.Read(iprot) + error329 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error330 error + error330, err = error329.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error329 + err = error330 return } if mTypeId != thrift.REPLY { @@ -709,16 +709,16 @@ func (p *AuroraAdminClient) recvCommitRecovery() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error330 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error331 error - error331, err = error330.Read(iprot) + error331 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error332 error + error332, err = error331.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error331 + err = error332 return } if mTypeId != thrift.REPLY { @@ -783,16 +783,16 @@ func (p *AuroraAdminClient) recvUnloadRecovery() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error332 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error333 error - error333, err = error332.Read(iprot) + error333 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error334 error + error334, err = error333.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error333 + err = error334 return } if mTypeId != thrift.REPLY { @@ -862,16 +862,16 @@ func (p *AuroraAdminClient) recvStartMaintenance() (value *Response, err error) return } if mTypeId == thrift.EXCEPTION { - error334 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error335 error - error335, err = error334.Read(iprot) + error335 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error336 error + error336, err = error335.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error335 + err = error336 return } if mTypeId != thrift.REPLY { @@ -941,16 +941,16 @@ func (p *AuroraAdminClient) recvDrainHosts() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error336 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error337 error - error337, err = error336.Read(iprot) + error337 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error338 error + error338, err = error337.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error337 + err = error338 return } if mTypeId != thrift.REPLY { @@ -1020,16 +1020,16 @@ func (p *AuroraAdminClient) recvMaintenanceStatus() (value *Response, err error) return } if mTypeId == thrift.EXCEPTION { - error338 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error339 error - error339, err = error338.Read(iprot) + error339 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error340 error + error340, err = error339.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error339 + err = error340 return } if mTypeId != thrift.REPLY { @@ -1099,16 +1099,16 @@ func (p *AuroraAdminClient) recvEndMaintenance() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error340 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error341 error - error341, err = error340.Read(iprot) + error341 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error342 error + error342, err = error341.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error341 + err = error342 return } if mTypeId != thrift.REPLY { @@ -1184,16 +1184,16 @@ func (p *AuroraAdminClient) recvSlaDrainHosts() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error342 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error343 error - error343, err = error342.Read(iprot) + error343 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error344 error + error344, err = error343.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error343 + err = error344 return } if mTypeId != thrift.REPLY { @@ -1258,16 +1258,16 @@ func (p *AuroraAdminClient) recvSnapshot() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error344 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error345 error - error345, err = error344.Read(iprot) + error345 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error346 error + error346, err = error345.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error345 + err = error346 return } if mTypeId != thrift.REPLY { @@ -1337,16 +1337,16 @@ func (p *AuroraAdminClient) recvTriggerExplicitTaskReconciliation() (value *Resp return } if mTypeId == thrift.EXCEPTION { - error346 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error347 error - error347, err = error346.Read(iprot) + error347 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error348 error + error348, err = error347.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error347 + err = error348 return } if mTypeId != thrift.REPLY { @@ -1411,16 +1411,16 @@ func (p *AuroraAdminClient) recvTriggerImplicitTaskReconciliation() (value *Resp return } if mTypeId == thrift.EXCEPTION { - error348 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error349 error - error349, err = error348.Read(iprot) + error349 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error350 error + error350, err = error349.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error349 + err = error350 return } if mTypeId != thrift.REPLY { @@ -1492,16 +1492,16 @@ func (p *AuroraAdminClient) recvPruneTasks() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error350 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error351 error - error351, err = error350.Read(iprot) + error351 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error352 error + error352, err = error351.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error351 + err = error352 return } if mTypeId != thrift.REPLY { @@ -1524,26 +1524,26 @@ type AuroraAdminProcessor struct { } func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor { - self352 := &AuroraAdminProcessor{NewAuroraSchedulerManagerProcessor(handler)} - self352.AddToProcessorMap("setQuota", &auroraAdminProcessorSetQuota{handler: handler}) - self352.AddToProcessorMap("forceTaskState", &auroraAdminProcessorForceTaskState{handler: handler}) - self352.AddToProcessorMap("performBackup", &auroraAdminProcessorPerformBackup{handler: handler}) - self352.AddToProcessorMap("listBackups", &auroraAdminProcessorListBackups{handler: handler}) - self352.AddToProcessorMap("stageRecovery", &auroraAdminProcessorStageRecovery{handler: handler}) - self352.AddToProcessorMap("queryRecovery", &auroraAdminProcessorQueryRecovery{handler: handler}) - self352.AddToProcessorMap("deleteRecoveryTasks", &auroraAdminProcessorDeleteRecoveryTasks{handler: handler}) - self352.AddToProcessorMap("commitRecovery", &auroraAdminProcessorCommitRecovery{handler: handler}) - self352.AddToProcessorMap("unloadRecovery", &auroraAdminProcessorUnloadRecovery{handler: handler}) - self352.AddToProcessorMap("startMaintenance", &auroraAdminProcessorStartMaintenance{handler: handler}) - self352.AddToProcessorMap("drainHosts", &auroraAdminProcessorDrainHosts{handler: handler}) - self352.AddToProcessorMap("maintenanceStatus", &auroraAdminProcessorMaintenanceStatus{handler: handler}) - self352.AddToProcessorMap("endMaintenance", &auroraAdminProcessorEndMaintenance{handler: handler}) - self352.AddToProcessorMap("slaDrainHosts", &auroraAdminProcessorSlaDrainHosts{handler: handler}) - self352.AddToProcessorMap("snapshot", &auroraAdminProcessorSnapshot{handler: handler}) - self352.AddToProcessorMap("triggerExplicitTaskReconciliation", &auroraAdminProcessorTriggerExplicitTaskReconciliation{handler: handler}) - self352.AddToProcessorMap("triggerImplicitTaskReconciliation", &auroraAdminProcessorTriggerImplicitTaskReconciliation{handler: handler}) - self352.AddToProcessorMap("pruneTasks", &auroraAdminProcessorPruneTasks{handler: handler}) - return self352 + self353 := &AuroraAdminProcessor{NewAuroraSchedulerManagerProcessor(handler)} + self353.AddToProcessorMap("setQuota", &auroraAdminProcessorSetQuota{handler: handler}) + self353.AddToProcessorMap("forceTaskState", &auroraAdminProcessorForceTaskState{handler: handler}) + self353.AddToProcessorMap("performBackup", &auroraAdminProcessorPerformBackup{handler: handler}) + self353.AddToProcessorMap("listBackups", &auroraAdminProcessorListBackups{handler: handler}) + self353.AddToProcessorMap("stageRecovery", &auroraAdminProcessorStageRecovery{handler: handler}) + self353.AddToProcessorMap("queryRecovery", &auroraAdminProcessorQueryRecovery{handler: handler}) + self353.AddToProcessorMap("deleteRecoveryTasks", &auroraAdminProcessorDeleteRecoveryTasks{handler: handler}) + self353.AddToProcessorMap("commitRecovery", &auroraAdminProcessorCommitRecovery{handler: handler}) + self353.AddToProcessorMap("unloadRecovery", &auroraAdminProcessorUnloadRecovery{handler: handler}) + self353.AddToProcessorMap("startMaintenance", &auroraAdminProcessorStartMaintenance{handler: handler}) + self353.AddToProcessorMap("drainHosts", &auroraAdminProcessorDrainHosts{handler: handler}) + self353.AddToProcessorMap("maintenanceStatus", &auroraAdminProcessorMaintenanceStatus{handler: handler}) + self353.AddToProcessorMap("endMaintenance", &auroraAdminProcessorEndMaintenance{handler: handler}) + self353.AddToProcessorMap("slaDrainHosts", &auroraAdminProcessorSlaDrainHosts{handler: handler}) + self353.AddToProcessorMap("snapshot", &auroraAdminProcessorSnapshot{handler: handler}) + self353.AddToProcessorMap("triggerExplicitTaskReconciliation", &auroraAdminProcessorTriggerExplicitTaskReconciliation{handler: handler}) + self353.AddToProcessorMap("triggerImplicitTaskReconciliation", &auroraAdminProcessorTriggerImplicitTaskReconciliation{handler: handler}) + self353.AddToProcessorMap("pruneTasks", &auroraAdminProcessorPruneTasks{handler: handler}) + return self353 } type auroraAdminProcessorSetQuota struct { diff --git a/gen-go/apache/aurora/auroraschedulermanager.go b/gen-go/apache/aurora/auroraschedulermanager.go index a448b72..33757e8 100644 --- a/gen-go/apache/aurora/auroraschedulermanager.go +++ b/gen-go/apache/aurora/auroraschedulermanager.go @@ -171,16 +171,16 @@ func (p *AuroraSchedulerManagerClient) recvCreateJob() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error131 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error132 error - error132, err = error131.Read(iprot) + error132 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error133 error + error133, err = error132.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error132 + err = error133 return } if mTypeId != thrift.REPLY { @@ -252,16 +252,16 @@ func (p *AuroraSchedulerManagerClient) recvScheduleCronJob() (value *Response, e return } if mTypeId == thrift.EXCEPTION { - error133 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error134 error - error134, err = error133.Read(iprot) + error134 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error135 error + error135, err = error134.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error134 + err = error135 return } if mTypeId != thrift.REPLY { @@ -332,16 +332,16 @@ func (p *AuroraSchedulerManagerClient) recvDescheduleCronJob() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error135 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error136 error - error136, err = error135.Read(iprot) + error136 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error137 error + error137, err = error136.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error136 + err = error137 return } if mTypeId != thrift.REPLY { @@ -412,16 +412,16 @@ func (p *AuroraSchedulerManagerClient) recvStartCronJob() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error137 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error138 error - error138, err = error137.Read(iprot) + error138 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error139 error + error139, err = error138.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error138 + err = error139 return } if mTypeId != thrift.REPLY { @@ -493,16 +493,16 @@ func (p *AuroraSchedulerManagerClient) recvRestartShards() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error139 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error140 error - error140, err = error139.Read(iprot) + error140 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error141 error + error141, err = error140.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error140 + err = error141 return } if mTypeId != thrift.REPLY { @@ -576,16 +576,16 @@ func (p *AuroraSchedulerManagerClient) recvKillTasks() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error141 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error142 error - error142, err = error141.Read(iprot) + error142 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error143 error + error143, err = error142.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error142 + err = error143 return } if mTypeId != thrift.REPLY { @@ -657,16 +657,16 @@ func (p *AuroraSchedulerManagerClient) recvAddInstances() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error143 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error144 error - error144, err = error143.Read(iprot) + error144 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error145 error + error145, err = error144.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error144 + err = error145 return } if mTypeId != thrift.REPLY { @@ -737,16 +737,16 @@ func (p *AuroraSchedulerManagerClient) recvReplaceCronTemplate() (value *Respons return } if mTypeId == thrift.EXCEPTION { - error145 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error146 error - error146, err = error145.Read(iprot) + error146 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error147 error + error147, err = error146.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error146 + err = error147 return } if mTypeId != thrift.REPLY { @@ -818,16 +818,16 @@ func (p *AuroraSchedulerManagerClient) recvStartJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error147 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error148 error - error148, err = error147.Read(iprot) + error148 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error149 error + error149, err = error148.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error148 + err = error149 return } if mTypeId != thrift.REPLY { @@ -899,16 +899,16 @@ func (p *AuroraSchedulerManagerClient) recvPauseJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error149 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error150 error - error150, err = error149.Read(iprot) + error150 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error151 error + error151, err = error150.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error150 + err = error151 return } if mTypeId != thrift.REPLY { @@ -980,16 +980,16 @@ func (p *AuroraSchedulerManagerClient) recvResumeJobUpdate() (value *Response, e return } if mTypeId == thrift.EXCEPTION { - error151 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error152 error - error152, err = error151.Read(iprot) + error152 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error153 error + error153, err = error152.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error152 + err = error153 return } if mTypeId != thrift.REPLY { @@ -1061,16 +1061,16 @@ func (p *AuroraSchedulerManagerClient) recvAbortJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error153 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error154 error - error154, err = error153.Read(iprot) + error154 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error155 error + error155, err = error154.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error154 + err = error155 return } if mTypeId != thrift.REPLY { @@ -1142,16 +1142,16 @@ func (p *AuroraSchedulerManagerClient) recvRollbackJobUpdate() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error155 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error156 error - error156, err = error155.Read(iprot) + error156 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error157 error + error157, err = error156.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error156 + err = error157 return } if mTypeId != thrift.REPLY { @@ -1223,16 +1223,16 @@ func (p *AuroraSchedulerManagerClient) recvPulseJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error157 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error158 error - error158, err = error157.Read(iprot) + error158 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error159 error + error159, err = error158.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error158 + err = error159 return } if mTypeId != thrift.REPLY { @@ -1255,22 +1255,22 @@ type AuroraSchedulerManagerProcessor struct { } func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor { - self159 := &AuroraSchedulerManagerProcessor{NewReadOnlySchedulerProcessor(handler)} - self159.AddToProcessorMap("createJob", &auroraSchedulerManagerProcessorCreateJob{handler: handler}) - self159.AddToProcessorMap("scheduleCronJob", &auroraSchedulerManagerProcessorScheduleCronJob{handler: handler}) - self159.AddToProcessorMap("descheduleCronJob", &auroraSchedulerManagerProcessorDescheduleCronJob{handler: handler}) - self159.AddToProcessorMap("startCronJob", &auroraSchedulerManagerProcessorStartCronJob{handler: handler}) - self159.AddToProcessorMap("restartShards", &auroraSchedulerManagerProcessorRestartShards{handler: handler}) - self159.AddToProcessorMap("killTasks", &auroraSchedulerManagerProcessorKillTasks{handler: handler}) - self159.AddToProcessorMap("addInstances", &auroraSchedulerManagerProcessorAddInstances{handler: handler}) - self159.AddToProcessorMap("replaceCronTemplate", &auroraSchedulerManagerProcessorReplaceCronTemplate{handler: handler}) - self159.AddToProcessorMap("startJobUpdate", &auroraSchedulerManagerProcessorStartJobUpdate{handler: handler}) - self159.AddToProcessorMap("pauseJobUpdate", &auroraSchedulerManagerProcessorPauseJobUpdate{handler: handler}) - self159.AddToProcessorMap("resumeJobUpdate", &auroraSchedulerManagerProcessorResumeJobUpdate{handler: handler}) - self159.AddToProcessorMap("abortJobUpdate", &auroraSchedulerManagerProcessorAbortJobUpdate{handler: handler}) - self159.AddToProcessorMap("rollbackJobUpdate", &auroraSchedulerManagerProcessorRollbackJobUpdate{handler: handler}) - self159.AddToProcessorMap("pulseJobUpdate", &auroraSchedulerManagerProcessorPulseJobUpdate{handler: handler}) - return self159 + self160 := &AuroraSchedulerManagerProcessor{NewReadOnlySchedulerProcessor(handler)} + self160.AddToProcessorMap("createJob", &auroraSchedulerManagerProcessorCreateJob{handler: handler}) + self160.AddToProcessorMap("scheduleCronJob", &auroraSchedulerManagerProcessorScheduleCronJob{handler: handler}) + self160.AddToProcessorMap("descheduleCronJob", &auroraSchedulerManagerProcessorDescheduleCronJob{handler: handler}) + self160.AddToProcessorMap("startCronJob", &auroraSchedulerManagerProcessorStartCronJob{handler: handler}) + self160.AddToProcessorMap("restartShards", &auroraSchedulerManagerProcessorRestartShards{handler: handler}) + self160.AddToProcessorMap("killTasks", &auroraSchedulerManagerProcessorKillTasks{handler: handler}) + self160.AddToProcessorMap("addInstances", &auroraSchedulerManagerProcessorAddInstances{handler: handler}) + self160.AddToProcessorMap("replaceCronTemplate", &auroraSchedulerManagerProcessorReplaceCronTemplate{handler: handler}) + self160.AddToProcessorMap("startJobUpdate", &auroraSchedulerManagerProcessorStartJobUpdate{handler: handler}) + self160.AddToProcessorMap("pauseJobUpdate", &auroraSchedulerManagerProcessorPauseJobUpdate{handler: handler}) + self160.AddToProcessorMap("resumeJobUpdate", &auroraSchedulerManagerProcessorResumeJobUpdate{handler: handler}) + self160.AddToProcessorMap("abortJobUpdate", &auroraSchedulerManagerProcessorAbortJobUpdate{handler: handler}) + self160.AddToProcessorMap("rollbackJobUpdate", &auroraSchedulerManagerProcessorRollbackJobUpdate{handler: handler}) + self160.AddToProcessorMap("pulseJobUpdate", &auroraSchedulerManagerProcessorPulseJobUpdate{handler: handler}) + return self160 } type auroraSchedulerManagerProcessorCreateJob struct { @@ -2832,13 +2832,13 @@ func (p *AuroraSchedulerManagerRestartShardsArgs) readField3(iprot thrift.TProto tSet := make(map[int32]bool, size) p.ShardIds = tSet for i := 0; i < size; i++ { - var _elem160 int32 + var _elem161 int32 if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem160 = v + _elem161 = v } - p.ShardIds[_elem160] = true + p.ShardIds[_elem161] = true } if err := iprot.ReadSetEnd(); err != nil { 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) p.Instances = tSet for i := 0; i < size; i++ { - var _elem161 int32 + var _elem162 int32 if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem161 = v + _elem162 = v } - p.Instances[_elem161] = true + p.Instances[_elem162] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) diff --git a/gen-go/apache/aurora/read_only_scheduler-remote/read_only_scheduler-remote.go b/gen-go/apache/aurora/read_only_scheduler-remote/read_only_scheduler-remote.go index 2c2687f..b9c3d90 100755 --- a/gen-go/apache/aurora/read_only_scheduler-remote/read_only_scheduler-remote.go +++ b/gen-go/apache/aurora/read_only_scheduler-remote/read_only_scheduler-remote.go @@ -150,19 +150,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") flag.Usage() } - arg81 := flag.Arg(1) - mbTrans82 := thrift.NewTMemoryBufferLen(len(arg81)) - defer mbTrans82.Close() - _, err83 := mbTrans82.WriteString(arg81) - if err83 != nil { + arg82 := flag.Arg(1) + mbTrans83 := thrift.NewTMemoryBufferLen(len(arg82)) + defer mbTrans83.Close() + _, err84 := mbTrans83.WriteString(arg82) + if err84 != nil { Usage() return } - factory84 := thrift.NewTSimpleJSONProtocolFactory() - jsProt85 := factory84.GetProtocol(mbTrans82) + factory85 := thrift.NewTSimpleJSONProtocolFactory() + jsProt86 := factory85.GetProtocol(mbTrans83) argvalue0 := aurora.NewTaskQuery() - err86 := argvalue0.Read(jsProt85) - if err86 != nil { + err87 := argvalue0.Read(jsProt86) + if err87 != nil { Usage() return } @@ -175,19 +175,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") flag.Usage() } - arg87 := flag.Arg(1) - mbTrans88 := thrift.NewTMemoryBufferLen(len(arg87)) - defer mbTrans88.Close() - _, err89 := mbTrans88.WriteString(arg87) - if err89 != nil { + arg88 := flag.Arg(1) + mbTrans89 := thrift.NewTMemoryBufferLen(len(arg88)) + defer mbTrans89.Close() + _, err90 := mbTrans89.WriteString(arg88) + if err90 != nil { Usage() return } - factory90 := thrift.NewTSimpleJSONProtocolFactory() - jsProt91 := factory90.GetProtocol(mbTrans88) + factory91 := thrift.NewTSimpleJSONProtocolFactory() + jsProt92 := factory91.GetProtocol(mbTrans89) argvalue0 := aurora.NewTaskQuery() - err92 := argvalue0.Read(jsProt91) - if err92 != nil { + err93 := argvalue0.Read(jsProt92) + if err93 != nil { Usage() return } @@ -200,19 +200,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") flag.Usage() } - arg93 := flag.Arg(1) - mbTrans94 := thrift.NewTMemoryBufferLen(len(arg93)) - defer mbTrans94.Close() - _, err95 := mbTrans94.WriteString(arg93) - if err95 != nil { + arg94 := flag.Arg(1) + mbTrans95 := thrift.NewTMemoryBufferLen(len(arg94)) + defer mbTrans95.Close() + _, err96 := mbTrans95.WriteString(arg94) + if err96 != nil { Usage() return } - factory96 := thrift.NewTSimpleJSONProtocolFactory() - jsProt97 := factory96.GetProtocol(mbTrans94) + factory97 := thrift.NewTSimpleJSONProtocolFactory() + jsProt98 := factory97.GetProtocol(mbTrans95) argvalue0 := aurora.NewTaskQuery() - err98 := argvalue0.Read(jsProt97) - if err98 != nil { + err99 := argvalue0.Read(jsProt98) + if err99 != nil { Usage() return } @@ -225,19 +225,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") flag.Usage() } - arg99 := flag.Arg(1) - mbTrans100 := thrift.NewTMemoryBufferLen(len(arg99)) - defer mbTrans100.Close() - _, err101 := mbTrans100.WriteString(arg99) - if err101 != nil { + arg100 := flag.Arg(1) + mbTrans101 := thrift.NewTMemoryBufferLen(len(arg100)) + defer mbTrans101.Close() + _, err102 := mbTrans101.WriteString(arg100) + if err102 != nil { Usage() return } - factory102 := thrift.NewTSimpleJSONProtocolFactory() - jsProt103 := factory102.GetProtocol(mbTrans100) + factory103 := thrift.NewTSimpleJSONProtocolFactory() + jsProt104 := factory103.GetProtocol(mbTrans101) argvalue0 := aurora.NewJobKey() - err104 := argvalue0.Read(jsProt103) - if err104 != nil { + err105 := argvalue0.Read(jsProt104) + if err105 != nil { Usage() return } @@ -270,19 +270,19 @@ func main() { fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") flag.Usage() } - arg107 := flag.Arg(1) - mbTrans108 := thrift.NewTMemoryBufferLen(len(arg107)) - defer mbTrans108.Close() - _, err109 := mbTrans108.WriteString(arg107) - if err109 != nil { + arg108 := flag.Arg(1) + mbTrans109 := thrift.NewTMemoryBufferLen(len(arg108)) + defer mbTrans109.Close() + _, err110 := mbTrans109.WriteString(arg108) + if err110 != nil { Usage() return } - factory110 := thrift.NewTSimpleJSONProtocolFactory() - jsProt111 := factory110.GetProtocol(mbTrans108) + factory111 := thrift.NewTSimpleJSONProtocolFactory() + jsProt112 := factory111.GetProtocol(mbTrans109) argvalue0 := aurora.NewJobConfiguration() - err112 := argvalue0.Read(jsProt111) - if err112 != nil { + err113 := argvalue0.Read(jsProt112) + if err113 != nil { Usage() return } @@ -295,19 +295,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") flag.Usage() } - arg113 := flag.Arg(1) - mbTrans114 := thrift.NewTMemoryBufferLen(len(arg113)) - defer mbTrans114.Close() - _, err115 := mbTrans114.WriteString(arg113) - if err115 != nil { + arg114 := flag.Arg(1) + mbTrans115 := thrift.NewTMemoryBufferLen(len(arg114)) + defer mbTrans115.Close() + _, err116 := mbTrans115.WriteString(arg114) + if err116 != nil { Usage() return } - factory116 := thrift.NewTSimpleJSONProtocolFactory() - jsProt117 := factory116.GetProtocol(mbTrans114) + factory117 := thrift.NewTSimpleJSONProtocolFactory() + jsProt118 := factory117.GetProtocol(mbTrans115) argvalue0 := aurora.NewJobUpdateQuery() - err118 := argvalue0.Read(jsProt117) - if err118 != nil { + err119 := argvalue0.Read(jsProt118) + if err119 != nil { Usage() return } @@ -320,19 +320,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") flag.Usage() } - arg119 := flag.Arg(1) - mbTrans120 := thrift.NewTMemoryBufferLen(len(arg119)) - defer mbTrans120.Close() - _, err121 := mbTrans120.WriteString(arg119) - if err121 != nil { + arg120 := flag.Arg(1) + mbTrans121 := thrift.NewTMemoryBufferLen(len(arg120)) + defer mbTrans121.Close() + _, err122 := mbTrans121.WriteString(arg120) + if err122 != nil { Usage() return } - factory122 := thrift.NewTSimpleJSONProtocolFactory() - jsProt123 := factory122.GetProtocol(mbTrans120) + factory123 := thrift.NewTSimpleJSONProtocolFactory() + jsProt124 := factory123.GetProtocol(mbTrans121) argvalue0 := aurora.NewJobUpdateQuery() - err124 := argvalue0.Read(jsProt123) - if err124 != nil { + err125 := argvalue0.Read(jsProt124) + if err125 != nil { Usage() return } @@ -345,19 +345,19 @@ func main() { fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") flag.Usage() } - arg125 := flag.Arg(1) - mbTrans126 := thrift.NewTMemoryBufferLen(len(arg125)) - defer mbTrans126.Close() - _, err127 := mbTrans126.WriteString(arg125) - if err127 != nil { + arg126 := flag.Arg(1) + mbTrans127 := thrift.NewTMemoryBufferLen(len(arg126)) + defer mbTrans127.Close() + _, err128 := mbTrans127.WriteString(arg126) + if err128 != nil { Usage() return } - factory128 := thrift.NewTSimpleJSONProtocolFactory() - jsProt129 := factory128.GetProtocol(mbTrans126) + factory129 := thrift.NewTSimpleJSONProtocolFactory() + jsProt130 := factory129.GetProtocol(mbTrans127) argvalue0 := aurora.NewJobUpdateRequest() - err130 := argvalue0.Read(jsProt129) - if err130 != nil { + err131 := argvalue0.Read(jsProt130) + if err131 != nil { Usage() return } diff --git a/gen-go/apache/aurora/readonlyscheduler.go b/gen-go/apache/aurora/readonlyscheduler.go index dba7255..e87a66d 100644 --- a/gen-go/apache/aurora/readonlyscheduler.go +++ b/gen-go/apache/aurora/readonlyscheduler.go @@ -152,16 +152,16 @@ func (p *ReadOnlySchedulerClient) recvGetRoleSummary() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error52 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error53 error - error53, err = error52.Read(iprot) + error53 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error54 error + error54, err = error53.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error53 + err = error54 return } if mTypeId != thrift.REPLY { @@ -231,16 +231,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobSummary() (value *Response, err erro return } if mTypeId == thrift.EXCEPTION { - error54 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error55 error - error55, err = error54.Read(iprot) + error55 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error56 error + error56, err = error55.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error55 + err = error56 return } if mTypeId != thrift.REPLY { @@ -310,16 +310,16 @@ func (p *ReadOnlySchedulerClient) recvGetTasksStatus() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error56 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error57 error - error57, err = error56.Read(iprot) + error57 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error58 error + error58, err = error57.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error57 + err = error58 return } if mTypeId != thrift.REPLY { @@ -390,16 +390,16 @@ func (p *ReadOnlySchedulerClient) recvGetTasksWithoutConfigs() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error58 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error59 error - error59, err = error58.Read(iprot) + error59 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error60 error + error60, err = error59.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error59 + err = error60 return } if mTypeId != thrift.REPLY { @@ -469,16 +469,16 @@ func (p *ReadOnlySchedulerClient) recvGetPendingReason() (value *Response, err e return } if mTypeId == thrift.EXCEPTION { - error60 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error61 error - error61, err = error60.Read(iprot) + error61 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error62 error + error62, err = error61.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error61 + err = error62 return } if mTypeId != thrift.REPLY { @@ -548,16 +548,16 @@ func (p *ReadOnlySchedulerClient) recvGetConfigSummary() (value *Response, err e return } if mTypeId == thrift.EXCEPTION { - error62 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error63 error - error63, err = error62.Read(iprot) + error63 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error64 error + error64, err = error63.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error63 + err = error64 return } if mTypeId != thrift.REPLY { @@ -628,16 +628,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobs() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error64 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error65 error - error65, err = error64.Read(iprot) + error65 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error66 error + error66, err = error65.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error65 + err = error66 return } if mTypeId != thrift.REPLY { @@ -707,16 +707,16 @@ func (p *ReadOnlySchedulerClient) recvGetQuota() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error66 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error67 error - error67, err = error66.Read(iprot) + error67 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error68 error + error68, err = error67.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error67 + err = error68 return } if mTypeId != thrift.REPLY { @@ -787,16 +787,16 @@ func (p *ReadOnlySchedulerClient) recvPopulateJobConfig() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error68 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error69 error - error69, err = error68.Read(iprot) + error69 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error70 error + error70, err = error69.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error69 + err = error70 return } if mTypeId != thrift.REPLY { @@ -866,16 +866,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateSummaries() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error70 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error71 error - error71, err = error70.Read(iprot) + error71 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error72 error + error72, err = error71.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error71 + err = error72 return } if mTypeId != thrift.REPLY { @@ -945,16 +945,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateDetails() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error72 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error73 error - error73, err = error72.Read(iprot) + error73 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error74 error + error74, err = error73.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error73 + err = error74 return } if mTypeId != thrift.REPLY { @@ -1024,16 +1024,16 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateDiff() (value *Response, err e return } if mTypeId == thrift.EXCEPTION { - error74 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error75 error - error75, err = error74.Read(iprot) + error75 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error76 error + error76, err = error75.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error75 + err = error76 return } if mTypeId != thrift.REPLY { @@ -1098,16 +1098,16 @@ func (p *ReadOnlySchedulerClient) recvGetTierConfigs() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error76 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error77 error - error77, err = error76.Read(iprot) + error77 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error78 error + error78, err = error77.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error77 + err = error78 return } if mTypeId != thrift.REPLY { @@ -1145,21 +1145,21 @@ func (p *ReadOnlySchedulerProcessor) ProcessorMap() map[string]thrift.TProcessor func NewReadOnlySchedulerProcessor(handler ReadOnlyScheduler) *ReadOnlySchedulerProcessor { - self78 := &ReadOnlySchedulerProcessor{handler: handler, processorMap: make(map[string]thrift.TProcessorFunction)} - self78.processorMap["getRoleSummary"] = &readOnlySchedulerProcessorGetRoleSummary{handler: handler} - self78.processorMap["getJobSummary"] = &readOnlySchedulerProcessorGetJobSummary{handler: handler} - self78.processorMap["getTasksStatus"] = &readOnlySchedulerProcessorGetTasksStatus{handler: handler} - self78.processorMap["getTasksWithoutConfigs"] = &readOnlySchedulerProcessorGetTasksWithoutConfigs{handler: handler} - self78.processorMap["getPendingReason"] = &readOnlySchedulerProcessorGetPendingReason{handler: handler} - self78.processorMap["getConfigSummary"] = &readOnlySchedulerProcessorGetConfigSummary{handler: handler} - self78.processorMap["getJobs"] = &readOnlySchedulerProcessorGetJobs{handler: handler} - self78.processorMap["getQuota"] = &readOnlySchedulerProcessorGetQuota{handler: handler} - self78.processorMap["populateJobConfig"] = &readOnlySchedulerProcessorPopulateJobConfig{handler: handler} - self78.processorMap["getJobUpdateSummaries"] = &readOnlySchedulerProcessorGetJobUpdateSummaries{handler: handler} - self78.processorMap["getJobUpdateDetails"] = &readOnlySchedulerProcessorGetJobUpdateDetails{handler: handler} - self78.processorMap["getJobUpdateDiff"] = &readOnlySchedulerProcessorGetJobUpdateDiff{handler: handler} - self78.processorMap["getTierConfigs"] = &readOnlySchedulerProcessorGetTierConfigs{handler: handler} - return self78 + self79 := &ReadOnlySchedulerProcessor{handler: handler, processorMap: make(map[string]thrift.TProcessorFunction)} + self79.processorMap["getRoleSummary"] = &readOnlySchedulerProcessorGetRoleSummary{handler: handler} + self79.processorMap["getJobSummary"] = &readOnlySchedulerProcessorGetJobSummary{handler: handler} + self79.processorMap["getTasksStatus"] = &readOnlySchedulerProcessorGetTasksStatus{handler: handler} + self79.processorMap["getTasksWithoutConfigs"] = &readOnlySchedulerProcessorGetTasksWithoutConfigs{handler: handler} + self79.processorMap["getPendingReason"] = &readOnlySchedulerProcessorGetPendingReason{handler: handler} + self79.processorMap["getConfigSummary"] = &readOnlySchedulerProcessorGetConfigSummary{handler: handler} + self79.processorMap["getJobs"] = &readOnlySchedulerProcessorGetJobs{handler: handler} + self79.processorMap["getQuota"] = &readOnlySchedulerProcessorGetQuota{handler: handler} + self79.processorMap["populateJobConfig"] = &readOnlySchedulerProcessorPopulateJobConfig{handler: handler} + self79.processorMap["getJobUpdateSummaries"] = &readOnlySchedulerProcessorGetJobUpdateSummaries{handler: handler} + self79.processorMap["getJobUpdateDetails"] = &readOnlySchedulerProcessorGetJobUpdateDetails{handler: handler} + self79.processorMap["getJobUpdateDiff"] = &readOnlySchedulerProcessorGetJobUpdateDiff{handler: handler} + self79.processorMap["getTierConfigs"] = &readOnlySchedulerProcessorGetTierConfigs{handler: handler} + return self79 } 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.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) - x79.Write(oprot) + x80.Write(oprot) oprot.WriteMessageEnd() oprot.Flush() - return false, x79 + return false, x80 } diff --git a/gen-go/apache/aurora/ttypes.go b/gen-go/apache/aurora/ttypes.go index 1f1d45c..44c0569 100644 --- a/gen-go/apache/aurora/ttypes.go +++ b/gen-go/apache/aurora/ttypes.go @@ -9877,6 +9877,517 @@ func (p *JobUpdateKey) String() string { return fmt.Sprintf("JobUpdateKey(%+v)", *p) } +// Limits the amount of active changes being made to instances to groupSize. +// +// Attributes: +// - GroupSize +type QueueJobUpdateStrategy struct { + GroupSize int32 `thrift:"groupSize,1" json:"groupSize"` +} + +func NewQueueJobUpdateStrategy() *QueueJobUpdateStrategy { + return &QueueJobUpdateStrategy{} +} + +func (p *QueueJobUpdateStrategy) GetGroupSize() int32 { + return p.GroupSize +} +func (p *QueueJobUpdateStrategy) Read(iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { + break + } + switch fieldId { + case 1: + if err := p.readField1(iprot); err != nil { + return err + } + default: + if err := iprot.Skip(fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *QueueJobUpdateStrategy) readField1(iprot thrift.TProtocol) error { + if v, err := iprot.ReadI32(); err != nil { + return thrift.PrependError("error reading field 1: ", err) + } else { + p.GroupSize = v + } + return nil +} + +func (p *QueueJobUpdateStrategy) Write(oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin("QueueJobUpdateStrategy"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) + } + if err := p.writeField1(oprot); err != nil { + return err + } + if err := oprot.WriteFieldStop(); err != nil { + return thrift.PrependError("write field stop error: ", err) + } + if err := oprot.WriteStructEnd(); err != nil { + return thrift.PrependError("write struct stop error: ", err) + } + return nil +} + +func (p *QueueJobUpdateStrategy) writeField1(oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin("groupSize", thrift.I32, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:groupSize: ", p), err) + } + if err := oprot.WriteI32(int32(p.GroupSize)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.groupSize (1) field write error: ", p), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:groupSize: ", p), err) + } + return err +} + +func (p *QueueJobUpdateStrategy) String() string { + if p == nil { + return "" + } + return fmt.Sprintf("QueueJobUpdateStrategy(%+v)", *p) +} + +// Similar to Queue strategy but will not start a new group until all instances in an active +// group have finished updating. +// +// Attributes: +// - GroupSize +type BatchJobUpdateStrategy struct { + GroupSize int32 `thrift:"groupSize,1" json:"groupSize"` +} + +func NewBatchJobUpdateStrategy() *BatchJobUpdateStrategy { + return &BatchJobUpdateStrategy{} +} + +func (p *BatchJobUpdateStrategy) GetGroupSize() int32 { + return p.GroupSize +} +func (p *BatchJobUpdateStrategy) Read(iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { + break + } + switch fieldId { + case 1: + if err := p.readField1(iprot); err != nil { + return err + } + default: + if err := iprot.Skip(fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *BatchJobUpdateStrategy) readField1(iprot thrift.TProtocol) error { + if v, err := iprot.ReadI32(); err != nil { + return thrift.PrependError("error reading field 1: ", err) + } else { + p.GroupSize = v + } + return nil +} + +func (p *BatchJobUpdateStrategy) Write(oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin("BatchJobUpdateStrategy"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) + } + if err := p.writeField1(oprot); err != nil { + return err + } + if err := oprot.WriteFieldStop(); err != nil { + return thrift.PrependError("write field stop error: ", err) + } + if err := oprot.WriteStructEnd(); err != nil { + return thrift.PrependError("write struct stop error: ", err) + } + return nil +} + +func (p *BatchJobUpdateStrategy) writeField1(oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin("groupSize", thrift.I32, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:groupSize: ", p), err) + } + if err := oprot.WriteI32(int32(p.GroupSize)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.groupSize (1) field write error: ", p), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:groupSize: ", p), err) + } + return err +} + +func (p *BatchJobUpdateStrategy) String() string { + if p == nil { + return "" + } + return fmt.Sprintf("BatchJobUpdateStrategy(%+v)", *p) +} + +// Same as Batch strategy but each time an active group completes, the size of the next active +// group may change. +// +// Attributes: +// - GroupSizes +type VariableBatchJobUpdateStrategy struct { + GroupSizes []int32 `thrift:"groupSizes,1" json:"groupSizes"` +} + +func NewVariableBatchJobUpdateStrategy() *VariableBatchJobUpdateStrategy { + return &VariableBatchJobUpdateStrategy{} +} + +func (p *VariableBatchJobUpdateStrategy) GetGroupSizes() []int32 { + return p.GroupSizes +} +func (p *VariableBatchJobUpdateStrategy) Read(iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { + break + } + switch fieldId { + case 1: + if err := p.readField1(iprot); err != nil { + return err + } + default: + if err := iprot.Skip(fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *VariableBatchJobUpdateStrategy) readField1(iprot thrift.TProtocol) error { + _, size, err := iprot.ReadListBegin() + if err != nil { + return thrift.PrependError("error reading list begin: ", err) + } + tSlice := make([]int32, 0, size) + p.GroupSizes = tSlice + for i := 0; i < size; i++ { + var _elem25 int32 + if v, err := iprot.ReadI32(); err != nil { + return thrift.PrependError("error reading field 0: ", err) + } else { + _elem25 = v + } + p.GroupSizes = append(p.GroupSizes, _elem25) + } + if err := iprot.ReadListEnd(); err != nil { + return thrift.PrependError("error reading list end: ", err) + } + return nil +} + +func (p *VariableBatchJobUpdateStrategy) Write(oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin("VariableBatchJobUpdateStrategy"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) + } + if err := p.writeField1(oprot); err != nil { + return err + } + if err := oprot.WriteFieldStop(); err != nil { + return thrift.PrependError("write field stop error: ", err) + } + if err := oprot.WriteStructEnd(); err != nil { + return thrift.PrependError("write struct stop error: ", err) + } + return nil +} + +func (p *VariableBatchJobUpdateStrategy) writeField1(oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin("groupSizes", thrift.LIST, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:groupSizes: ", p), err) + } + if err := oprot.WriteListBegin(thrift.I32, len(p.GroupSizes)); err != nil { + return thrift.PrependError("error writing list begin: ", err) + } + for _, v := range p.GroupSizes { + if err := oprot.WriteI32(int32(v)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) + } + } + if err := oprot.WriteListEnd(); err != nil { + return thrift.PrependError("error writing list end: ", err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:groupSizes: ", p), err) + } + return err +} + +func (p *VariableBatchJobUpdateStrategy) String() string { + if p == nil { + return "" + } + return fmt.Sprintf("VariableBatchJobUpdateStrategy(%+v)", *p) +} + +// Attributes: +// - QueueStrategy +// - BatchStrategy +// - VarBatchStrategy +type JobUpdateStrategy struct { + QueueStrategy *QueueJobUpdateStrategy `thrift:"queueStrategy,1" json:"queueStrategy,omitempty"` + BatchStrategy *BatchJobUpdateStrategy `thrift:"batchStrategy,2" json:"batchStrategy,omitempty"` + VarBatchStrategy *VariableBatchJobUpdateStrategy `thrift:"varBatchStrategy,3" json:"varBatchStrategy,omitempty"` +} + +func NewJobUpdateStrategy() *JobUpdateStrategy { + return &JobUpdateStrategy{} +} + +var JobUpdateStrategy_QueueStrategy_DEFAULT *QueueJobUpdateStrategy + +func (p *JobUpdateStrategy) GetQueueStrategy() *QueueJobUpdateStrategy { + if !p.IsSetQueueStrategy() { + return JobUpdateStrategy_QueueStrategy_DEFAULT + } + return p.QueueStrategy +} + +var JobUpdateStrategy_BatchStrategy_DEFAULT *BatchJobUpdateStrategy + +func (p *JobUpdateStrategy) GetBatchStrategy() *BatchJobUpdateStrategy { + if !p.IsSetBatchStrategy() { + return JobUpdateStrategy_BatchStrategy_DEFAULT + } + return p.BatchStrategy +} + +var JobUpdateStrategy_VarBatchStrategy_DEFAULT *VariableBatchJobUpdateStrategy + +func (p *JobUpdateStrategy) GetVarBatchStrategy() *VariableBatchJobUpdateStrategy { + if !p.IsSetVarBatchStrategy() { + return JobUpdateStrategy_VarBatchStrategy_DEFAULT + } + return p.VarBatchStrategy +} +func (p *JobUpdateStrategy) CountSetFieldsJobUpdateStrategy() int { + count := 0 + if p.IsSetQueueStrategy() { + count++ + } + if p.IsSetBatchStrategy() { + count++ + } + if p.IsSetVarBatchStrategy() { + count++ + } + return count + +} + +func (p *JobUpdateStrategy) IsSetQueueStrategy() bool { + return p.QueueStrategy != nil +} + +func (p *JobUpdateStrategy) IsSetBatchStrategy() bool { + return p.BatchStrategy != nil +} + +func (p *JobUpdateStrategy) IsSetVarBatchStrategy() bool { + return p.VarBatchStrategy != nil +} + +func (p *JobUpdateStrategy) Read(iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { + break + } + switch fieldId { + case 1: + if err := p.readField1(iprot); err != nil { + return err + } + case 2: + if err := p.readField2(iprot); err != nil { + return err + } + case 3: + if err := p.readField3(iprot); err != nil { + return err + } + default: + if err := iprot.Skip(fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *JobUpdateStrategy) readField1(iprot thrift.TProtocol) error { + p.QueueStrategy = &QueueJobUpdateStrategy{} + if err := p.QueueStrategy.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.QueueStrategy), err) + } + return nil +} + +func (p *JobUpdateStrategy) readField2(iprot thrift.TProtocol) error { + p.BatchStrategy = &BatchJobUpdateStrategy{} + if err := p.BatchStrategy.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.BatchStrategy), err) + } + return nil +} + +func (p *JobUpdateStrategy) readField3(iprot thrift.TProtocol) error { + p.VarBatchStrategy = &VariableBatchJobUpdateStrategy{} + if err := p.VarBatchStrategy.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.VarBatchStrategy), err) + } + return nil +} + +func (p *JobUpdateStrategy) Write(oprot thrift.TProtocol) error { + if c := p.CountSetFieldsJobUpdateStrategy(); c != 1 { + return fmt.Errorf("%T write union: exactly one field must be set (%d set).", p, c) + } + if err := oprot.WriteStructBegin("JobUpdateStrategy"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) + } + if err := p.writeField1(oprot); err != nil { + return err + } + if err := p.writeField2(oprot); err != nil { + return err + } + if err := p.writeField3(oprot); err != nil { + return err + } + if err := oprot.WriteFieldStop(); err != nil { + return thrift.PrependError("write field stop error: ", err) + } + if err := oprot.WriteStructEnd(); err != nil { + return thrift.PrependError("write struct stop error: ", err) + } + return nil +} + +func (p *JobUpdateStrategy) writeField1(oprot thrift.TProtocol) (err error) { + if p.IsSetQueueStrategy() { + if err := oprot.WriteFieldBegin("queueStrategy", thrift.STRUCT, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:queueStrategy: ", p), err) + } + if err := p.QueueStrategy.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.QueueStrategy), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:queueStrategy: ", p), err) + } + } + return err +} + +func (p *JobUpdateStrategy) writeField2(oprot thrift.TProtocol) (err error) { + if p.IsSetBatchStrategy() { + if err := oprot.WriteFieldBegin("batchStrategy", thrift.STRUCT, 2); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:batchStrategy: ", p), err) + } + if err := p.BatchStrategy.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.BatchStrategy), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 2:batchStrategy: ", p), err) + } + } + return err +} + +func (p *JobUpdateStrategy) writeField3(oprot thrift.TProtocol) (err error) { + if p.IsSetVarBatchStrategy() { + if err := oprot.WriteFieldBegin("varBatchStrategy", thrift.STRUCT, 3); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:varBatchStrategy: ", p), err) + } + if err := p.VarBatchStrategy.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.VarBatchStrategy), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 3:varBatchStrategy: ", p), err) + } + } + return err +} + +func (p *JobUpdateStrategy) String() string { + if p == nil { + return "" + } + return fmt.Sprintf("JobUpdateStrategy(%+v)", *p) +} + // Job update thresholds and limits. // // Attributes: @@ -9894,17 +10405,19 @@ func (p *JobUpdateKey) String() string { // unblocked by a fresh pulseJobUpdate call. // - SlaAware: If true, updates will obey the SLA requirements of the tasks being updated. If the SLA policy // differs between the old and new task configurations, updates will use the newest configuration. +// - UpdateStrategy: Update strategy to be used for the update. See JobUpdateStrategy for choices. type JobUpdateSettings struct { UpdateGroupSize int32 `thrift:"updateGroupSize,1" json:"updateGroupSize"` MaxPerInstanceFailures int32 `thrift:"maxPerInstanceFailures,2" json:"maxPerInstanceFailures"` MaxFailedInstances int32 `thrift:"maxFailedInstances,3" json:"maxFailedInstances"` // unused field # 4 - MinWaitInInstanceRunningMs int32 `thrift:"minWaitInInstanceRunningMs,5" json:"minWaitInInstanceRunningMs"` - RollbackOnFailure bool `thrift:"rollbackOnFailure,6" json:"rollbackOnFailure"` - UpdateOnlyTheseInstances map[*Range]bool `thrift:"updateOnlyTheseInstances,7" json:"updateOnlyTheseInstances"` - WaitForBatchCompletion bool `thrift:"waitForBatchCompletion,8" json:"waitForBatchCompletion"` - BlockIfNoPulsesAfterMs *int32 `thrift:"blockIfNoPulsesAfterMs,9" json:"blockIfNoPulsesAfterMs,omitempty"` - SlaAware *bool `thrift:"slaAware,10" json:"slaAware,omitempty"` + MinWaitInInstanceRunningMs int32 `thrift:"minWaitInInstanceRunningMs,5" json:"minWaitInInstanceRunningMs"` + RollbackOnFailure bool `thrift:"rollbackOnFailure,6" json:"rollbackOnFailure"` + UpdateOnlyTheseInstances map[*Range]bool `thrift:"updateOnlyTheseInstances,7" json:"updateOnlyTheseInstances"` + WaitForBatchCompletion bool `thrift:"waitForBatchCompletion,8" json:"waitForBatchCompletion"` + BlockIfNoPulsesAfterMs *int32 `thrift:"blockIfNoPulsesAfterMs,9" json:"blockIfNoPulsesAfterMs,omitempty"` + SlaAware *bool `thrift:"slaAware,10" json:"slaAware,omitempty"` + UpdateStrategy *JobUpdateStrategy `thrift:"updateStrategy,11" json:"updateStrategy,omitempty"` } func NewJobUpdateSettings() *JobUpdateSettings { @@ -9956,6 +10469,15 @@ func (p *JobUpdateSettings) GetSlaAware() bool { } return *p.SlaAware } + +var JobUpdateSettings_UpdateStrategy_DEFAULT *JobUpdateStrategy + +func (p *JobUpdateSettings) GetUpdateStrategy() *JobUpdateStrategy { + if !p.IsSetUpdateStrategy() { + return JobUpdateSettings_UpdateStrategy_DEFAULT + } + return p.UpdateStrategy +} func (p *JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs() bool { return p.BlockIfNoPulsesAfterMs != nil } @@ -9964,6 +10486,10 @@ func (p *JobUpdateSettings) IsSetSlaAware() bool { return p.SlaAware != nil } +func (p *JobUpdateSettings) IsSetUpdateStrategy() bool { + return p.UpdateStrategy != nil +} + func (p *JobUpdateSettings) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) @@ -10014,6 +10540,10 @@ func (p *JobUpdateSettings) Read(iprot thrift.TProtocol) error { if err := p.readField10(iprot); err != nil { return err } + case 11: + if err := p.readField11(iprot); err != nil { + return err + } default: if err := iprot.Skip(fieldTypeId); err != nil { return err @@ -10082,11 +10612,11 @@ func (p *JobUpdateSettings) readField7(iprot thrift.TProtocol) error { tSet := make(map[*Range]bool, size) p.UpdateOnlyTheseInstances = tSet for i := 0; i < size; i++ { - _elem25 := &Range{} - if err := _elem25.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem25), err) + _elem26 := &Range{} + if err := _elem26.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem26), err) } - p.UpdateOnlyTheseInstances[_elem25] = true + p.UpdateOnlyTheseInstances[_elem26] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -10121,6 +10651,14 @@ func (p *JobUpdateSettings) readField10(iprot thrift.TProtocol) error { return nil } +func (p *JobUpdateSettings) readField11(iprot thrift.TProtocol) error { + p.UpdateStrategy = &JobUpdateStrategy{} + if err := p.UpdateStrategy.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.UpdateStrategy), err) + } + return nil +} + func (p *JobUpdateSettings) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("JobUpdateSettings"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) @@ -10152,6 +10690,9 @@ func (p *JobUpdateSettings) Write(oprot thrift.TProtocol) error { if err := p.writeField10(oprot); err != nil { return err } + if err := p.writeField11(oprot); err != nil { + return err + } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } @@ -10290,6 +10831,21 @@ func (p *JobUpdateSettings) writeField10(oprot thrift.TProtocol) (err error) { return err } +func (p *JobUpdateSettings) writeField11(oprot thrift.TProtocol) (err error) { + if p.IsSetUpdateStrategy() { + if err := oprot.WriteFieldBegin("updateStrategy", thrift.STRUCT, 11); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 11:updateStrategy: ", p), err) + } + if err := p.UpdateStrategy.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.UpdateStrategy), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 11:updateStrategy: ", p), err) + } + } + return err +} + func (p *JobUpdateSettings) String() string { if p == nil { return "" @@ -10812,11 +11368,11 @@ func (p *InstanceTaskConfig) readField2(iprot thrift.TProtocol) error { tSet := make(map[*Range]bool, size) p.Instances = tSet for i := 0; i < size; i++ { - _elem26 := &Range{} - if err := _elem26.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem26), err) + _elem27 := &Range{} + if err := _elem27.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem27), err) } - p.Instances[_elem26] = true + p.Instances[_elem27] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -11184,11 +11740,11 @@ func (p *JobUpdateSummary) readField6(iprot thrift.TProtocol) error { tSet := make(map[*Metadata]bool, size) p.Metadata = tSet for i := 0; i < size; i++ { - _elem27 := &Metadata{} - if err := _elem27.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem27), err) + _elem28 := &Metadata{} + if err := _elem28.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem28), err) } - p.Metadata[_elem27] = true + p.Metadata[_elem28] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -11384,11 +11940,11 @@ func (p *JobUpdateInstructions) readField1(iprot thrift.TProtocol) error { tSet := make(map[*InstanceTaskConfig]bool, size) p.InitialState = tSet for i := 0; i < size; i++ { - _elem28 := &InstanceTaskConfig{} - if err := _elem28.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem28), err) + _elem29 := &InstanceTaskConfig{} + if err := _elem29.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem29), err) } - p.InitialState[_elem28] = true + p.InitialState[_elem29] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -11723,11 +12279,11 @@ func (p *JobUpdateDetails) readField2(iprot thrift.TProtocol) error { tSlice := make([]*JobUpdateEvent, 0, size) p.UpdateEvents = tSlice for i := 0; i < size; i++ { - _elem29 := &JobUpdateEvent{} - if err := _elem29.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem29), err) + _elem30 := &JobUpdateEvent{} + if err := _elem30.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem30), err) } - p.UpdateEvents = append(p.UpdateEvents, _elem29) + p.UpdateEvents = append(p.UpdateEvents, _elem30) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -11743,11 +12299,11 @@ func (p *JobUpdateDetails) readField3(iprot thrift.TProtocol) error { tSlice := make([]*JobInstanceUpdateEvent, 0, size) p.InstanceEvents = tSlice for i := 0; i < size; i++ { - _elem30 := &JobInstanceUpdateEvent{} - if err := _elem30.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem30), err) + _elem31 := &JobInstanceUpdateEvent{} + if err := _elem31.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem31), err) } - p.InstanceEvents = append(p.InstanceEvents, _elem30) + p.InstanceEvents = append(p.InstanceEvents, _elem31) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -11974,11 +12530,11 @@ func (p *JobUpdateRequest) readField4(iprot thrift.TProtocol) error { tSet := make(map[*Metadata]bool, size) p.Metadata = tSet for i := 0; i < size; i++ { - _elem31 := &Metadata{} - if err := _elem31.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem31), err) + _elem32 := &Metadata{} + if err := _elem32.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem32), err) } - p.Metadata[_elem31] = true + p.Metadata[_elem32] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -12274,14 +12830,14 @@ func (p *JobUpdateQuery) readField5(iprot thrift.TProtocol) error { tSet := make(map[JobUpdateStatus]bool, size) p.UpdateStatuses = tSet for i := 0; i < size; i++ { - var _elem32 JobUpdateStatus + var _elem33 JobUpdateStatus if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { temp := JobUpdateStatus(v) - _elem32 = temp + _elem33 = temp } - p.UpdateStatuses[_elem32] = true + p.UpdateStatuses[_elem33] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -12715,13 +13271,13 @@ func (p *ListBackupsResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[string]bool, size) p.Backups = tSet for i := 0; i < size; i++ { - var _elem33 string + var _elem34 string if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem33 = v + _elem34 = v } - p.Backups[_elem33] = true + p.Backups[_elem34] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -12827,11 +13383,11 @@ func (p *StartMaintenanceResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*HostStatus]bool, size) p.Statuses = tSet for i := 0; i < size; i++ { - _elem34 := &HostStatus{} - if err := _elem34.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem34), err) + _elem35 := &HostStatus{} + if err := _elem35.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem35), err) } - p.Statuses[_elem34] = true + p.Statuses[_elem35] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -12937,11 +13493,11 @@ func (p *DrainHostsResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*HostStatus]bool, size) p.Statuses = tSet for i := 0; i < size; i++ { - _elem35 := &HostStatus{} - if err := _elem35.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem35), err) + _elem36 := &HostStatus{} + if err := _elem36.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem36), err) } - p.Statuses[_elem35] = true + p.Statuses[_elem36] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13047,11 +13603,11 @@ func (p *QueryRecoveryResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*ScheduledTask]bool, size) p.Tasks = tSet for i := 0; i < size; i++ { - _elem36 := &ScheduledTask{} - if err := _elem36.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem36), err) + _elem37 := &ScheduledTask{} + if err := _elem37.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem37), err) } - p.Tasks[_elem36] = true + p.Tasks[_elem37] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13157,11 +13713,11 @@ func (p *MaintenanceStatusResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*HostStatus]bool, size) p.Statuses = tSet for i := 0; i < size; i++ { - _elem37 := &HostStatus{} - if err := _elem37.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem37), err) + _elem38 := &HostStatus{} + if err := _elem38.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem38), err) } - p.Statuses[_elem37] = true + p.Statuses[_elem38] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13267,11 +13823,11 @@ func (p *EndMaintenanceResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*HostStatus]bool, size) p.Statuses = tSet for i := 0; i < size; i++ { - _elem38 := &HostStatus{} - if err := _elem38.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem38), err) + _elem39 := &HostStatus{} + if err := _elem39.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem39), err) } - p.Statuses[_elem38] = true + p.Statuses[_elem39] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13377,11 +13933,11 @@ func (p *RoleSummaryResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*RoleSummary]bool, size) p.Summaries = tSet for i := 0; i < size; i++ { - _elem39 := &RoleSummary{} - if err := _elem39.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem39), err) + _elem40 := &RoleSummary{} + if err := _elem40.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem40), err) } - p.Summaries[_elem39] = true + p.Summaries[_elem40] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13487,11 +14043,11 @@ func (p *JobSummaryResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*JobSummary]bool, size) p.Summaries = tSet for i := 0; i < size; i++ { - _elem40 := &JobSummary{} - if err := _elem40.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem40), err) + _elem41 := &JobSummary{} + if err := _elem41.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem41), err) } - p.Summaries[_elem40] = true + p.Summaries[_elem41] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13696,11 +14252,11 @@ func (p *GetPendingReasonResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*PendingReason]bool, size) p.Reasons = tSet for i := 0; i < size; i++ { - _elem41 := &PendingReason{} - if err := _elem41.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem41), err) + _elem42 := &PendingReason{} + if err := _elem42.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem42), err) } - p.Reasons[_elem41] = true + p.Reasons[_elem42] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -13954,11 +14510,11 @@ func (p *GetJobUpdateSummariesResult_) readField1(iprot thrift.TProtocol) error tSlice := make([]*JobUpdateSummary, 0, size) p.UpdateSummaries = tSlice for i := 0; i < size; i++ { - _elem42 := &JobUpdateSummary{} - if err := _elem42.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem42), err) + _elem43 := &JobUpdateSummary{} + if err := _elem43.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem43), err) } - p.UpdateSummaries = append(p.UpdateSummaries, _elem42) + p.UpdateSummaries = append(p.UpdateSummaries, _elem43) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14093,11 +14649,11 @@ func (p *GetJobUpdateDetailsResult_) readField2(iprot thrift.TProtocol) error { tSlice := make([]*JobUpdateDetails, 0, size) p.DetailsList = tSlice for i := 0; i < size; i++ { - _elem43 := &JobUpdateDetails{} - if err := _elem43.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem43), err) + _elem44 := &JobUpdateDetails{} + if err := _elem44.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem44), err) } - p.DetailsList = append(p.DetailsList, _elem43) + p.DetailsList = append(p.DetailsList, _elem44) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14343,11 +14899,11 @@ func (p *GetJobUpdateDiffResult_) readField1(iprot thrift.TProtocol) error { tSet := make(map[*ConfigGroup]bool, size) p.Add = tSet for i := 0; i < size; i++ { - _elem44 := &ConfigGroup{} - if err := _elem44.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem44), err) + _elem45 := &ConfigGroup{} + if err := _elem45.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem45), err) } - p.Add[_elem44] = true + p.Add[_elem45] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -14363,11 +14919,11 @@ func (p *GetJobUpdateDiffResult_) readField2(iprot thrift.TProtocol) error { tSet := make(map[*ConfigGroup]bool, size) p.Remove = tSet for i := 0; i < size; i++ { - _elem45 := &ConfigGroup{} - if err := _elem45.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem45), err) + _elem46 := &ConfigGroup{} + if err := _elem46.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem46), err) } - p.Remove[_elem45] = true + p.Remove[_elem46] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -14383,11 +14939,11 @@ func (p *GetJobUpdateDiffResult_) readField3(iprot thrift.TProtocol) error { tSet := make(map[*ConfigGroup]bool, size) p.Update = tSet for i := 0; i < size; i++ { - _elem46 := &ConfigGroup{} - if err := _elem46.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem46), err) + _elem47 := &ConfigGroup{} + if err := _elem47.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem47), err) } - p.Update[_elem46] = true + p.Update[_elem47] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -14403,11 +14959,11 @@ func (p *GetJobUpdateDiffResult_) readField4(iprot thrift.TProtocol) error { tSet := make(map[*ConfigGroup]bool, size) p.Unchanged = tSet for i := 0; i < size; i++ { - _elem47 := &ConfigGroup{} - if err := _elem47.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem47), err) + _elem48 := &ConfigGroup{} + if err := _elem48.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem48), err) } - p.Unchanged[_elem47] = true + p.Unchanged[_elem48] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -14606,19 +15162,19 @@ func (p *TierConfig) readField2(iprot thrift.TProtocol) error { tMap := make(map[string]string, size) p.Settings = tMap for i := 0; i < size; i++ { - var _key48 string + var _key49 string if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key48 = v + _key49 = v } - var _val49 string + var _val50 string if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val49 = v + _val50 = v } - p.Settings[_key48] = _val49 + p.Settings[_key49] = _val50 } if err := iprot.ReadMapEnd(); err != nil { return thrift.PrependError("error reading map end: ", err) @@ -14764,11 +15320,11 @@ func (p *GetTierConfigResult_) readField2(iprot thrift.TProtocol) error { tSet := make(map[*TierConfig]bool, size) p.Tiers = tSet for i := 0; i < size; i++ { - _elem50 := &TierConfig{} - if err := _elem50.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem50), err) + _elem51 := &TierConfig{} + if err := _elem51.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem51), err) } - p.Tiers[_elem50] = true + p.Tiers[_elem51] = true } if err := iprot.ReadSetEnd(); err != nil { return thrift.PrependError("error reading set end: ", err) @@ -16215,11 +16771,11 @@ func (p *Response) readField6(iprot thrift.TProtocol) error { tSlice := make([]*ResponseDetail, 0, size) p.Details = tSlice for i := 0; i < size; i++ { - _elem51 := &ResponseDetail{} - if err := _elem51.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem51), err) + _elem52 := &ResponseDetail{} + if err := _elem52.Read(iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem52), err) } - p.Details = append(p.Details, _elem51) + p.Details = append(p.Details, _elem52) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err)