From 384e476f91fe8feba6f344f76e01faac10df572b Mon Sep 17 00:00:00 2001 From: Renan DelValle Date: Fri, 9 Nov 2018 15:44:09 -0800 Subject: [PATCH] Fixing Aurora thrift api definition to be compatible with go. --- auroraAPI.thrift | 3 +- .../aurora_admin-remote.go | 765 +++++++++--------- .../aurora_scheduler_manager-remote.go | 427 +++++----- gen-go/apache/aurora/auroraadmin.go | 184 ++--- .../apache/aurora/auroraschedulermanager.go | 156 ++-- .../read_only_scheduler-remote.go | 47 +- gen-go/apache/aurora/readonlyscheduler.go | 57 +- gen-go/apache/aurora/ttypes.go | 146 ++-- 8 files changed, 861 insertions(+), 924 deletions(-) diff --git a/auroraAPI.thrift b/auroraAPI.thrift index 221abd8..063774d 100644 --- a/auroraAPI.thrift +++ b/auroraAPI.thrift @@ -1091,8 +1091,7 @@ service ReadOnlyScheduler { Response getJobUpdateSummaries(1: JobUpdateQuery jobUpdateQuery) /** Gets job update details. */ - // TODO(zmanji): `key` is deprecated, remove this with AURORA-1765 - Response getJobUpdateDetails(1: JobUpdateKey key, 2: JobUpdateQuery query) + Response getJobUpdateDetails(2: JobUpdateQuery query) /** Gets the diff between client (desired) and server (current) job states. */ Response getJobUpdateDiff(1: JobUpdateRequest request) 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 d808e84..d6f7bfd 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 @@ -62,7 +62,7 @@ func Usage() { fmt.Fprintln(os.Stderr, " Response getQuota(string ownerRole)") fmt.Fprintln(os.Stderr, " Response populateJobConfig(JobConfiguration description)") fmt.Fprintln(os.Stderr, " Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery)") - fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query)") + fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateQuery query)") fmt.Fprintln(os.Stderr, " Response getJobUpdateDiff(JobUpdateRequest request)") fmt.Fprintln(os.Stderr, " Response getTierConfigs()") fmt.Fprintln(os.Stderr) @@ -166,19 +166,19 @@ func main() { } argvalue0 := flag.Arg(1) value0 := argvalue0 - arg366 := flag.Arg(2) - mbTrans367 := thrift.NewTMemoryBufferLen(len(arg366)) - defer mbTrans367.Close() - _, err368 := mbTrans367.WriteString(arg366) - if err368 != nil { + arg354 := flag.Arg(2) + mbTrans355 := thrift.NewTMemoryBufferLen(len(arg354)) + defer mbTrans355.Close() + _, err356 := mbTrans355.WriteString(arg354) + if err356 != nil { Usage() return } - factory369 := thrift.NewTSimpleJSONProtocolFactory() - jsProt370 := factory369.GetProtocol(mbTrans367) + factory357 := thrift.NewTSimpleJSONProtocolFactory() + jsProt358 := factory357.GetProtocol(mbTrans355) argvalue1 := aurora.NewResourceAggregate() - err371 := argvalue1.Read(jsProt370) - if err371 != nil { + err359 := argvalue1.Read(jsProt358) + if err359 != nil { Usage() return } @@ -234,19 +234,19 @@ func main() { fmt.Fprintln(os.Stderr, "QueryRecovery requires 1 args") flag.Usage() } - arg374 := flag.Arg(1) - mbTrans375 := thrift.NewTMemoryBufferLen(len(arg374)) - defer mbTrans375.Close() - _, err376 := mbTrans375.WriteString(arg374) - if err376 != nil { + arg362 := flag.Arg(1) + mbTrans363 := thrift.NewTMemoryBufferLen(len(arg362)) + defer mbTrans363.Close() + _, err364 := mbTrans363.WriteString(arg362) + if err364 != nil { Usage() return } - factory377 := thrift.NewTSimpleJSONProtocolFactory() - jsProt378 := factory377.GetProtocol(mbTrans375) + factory365 := thrift.NewTSimpleJSONProtocolFactory() + jsProt366 := factory365.GetProtocol(mbTrans363) argvalue0 := aurora.NewTaskQuery() - err379 := argvalue0.Read(jsProt378) - if err379 != nil { + err367 := argvalue0.Read(jsProt366) + if err367 != nil { Usage() return } @@ -259,19 +259,19 @@ func main() { fmt.Fprintln(os.Stderr, "DeleteRecoveryTasks requires 1 args") flag.Usage() } - arg380 := flag.Arg(1) - mbTrans381 := thrift.NewTMemoryBufferLen(len(arg380)) - defer mbTrans381.Close() - _, err382 := mbTrans381.WriteString(arg380) - if err382 != nil { + arg368 := flag.Arg(1) + mbTrans369 := thrift.NewTMemoryBufferLen(len(arg368)) + defer mbTrans369.Close() + _, err370 := mbTrans369.WriteString(arg368) + if err370 != nil { Usage() return } - factory383 := thrift.NewTSimpleJSONProtocolFactory() - jsProt384 := factory383.GetProtocol(mbTrans381) + factory371 := thrift.NewTSimpleJSONProtocolFactory() + jsProt372 := factory371.GetProtocol(mbTrans369) argvalue0 := aurora.NewTaskQuery() - err385 := argvalue0.Read(jsProt384) - if err385 != nil { + err373 := argvalue0.Read(jsProt372) + if err373 != nil { Usage() return } @@ -300,6 +300,56 @@ 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 { + Usage() + return + } + factory377 := thrift.NewTSimpleJSONProtocolFactory() + jsProt378 := factory377.GetProtocol(mbTrans375) + argvalue0 := aurora.NewHosts() + err379 := argvalue0.Read(jsProt378) + if err379 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.StartMaintenance(value0)) + fmt.Print("\n") + break + case "drainHosts": + if flag.NArg()-1 != 1 { + 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 { + Usage() + return + } + factory383 := thrift.NewTSimpleJSONProtocolFactory() + jsProt384 := factory383.GetProtocol(mbTrans381) + argvalue0 := aurora.NewHosts() + err385 := argvalue0.Read(jsProt384) + if err385 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.DrainHosts(value0)) + fmt.Print("\n") + break + case "maintenanceStatus": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args") + flag.Usage() + } arg386 := flag.Arg(1) mbTrans387 := thrift.NewTMemoryBufferLen(len(arg386)) defer mbTrans387.Close() @@ -317,12 +367,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.StartMaintenance(value0)) + fmt.Print(client.MaintenanceStatus(value0)) fmt.Print("\n") break - case "drainHosts": + case "endMaintenance": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "DrainHosts requires 1 args") + fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args") flag.Usage() } arg392 := flag.Arg(1) @@ -342,12 +392,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.DrainHosts(value0)) + fmt.Print(client.EndMaintenance(value0)) fmt.Print("\n") break - case "maintenanceStatus": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args") + case "slaDrainHosts": + if flag.NArg()-1 != 3 { + fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args") flag.Usage() } arg398 := flag.Arg(1) @@ -367,15 +417,7 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.MaintenanceStatus(value0)) - fmt.Print("\n") - break - case "endMaintenance": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args") - flag.Usage() - } - arg404 := flag.Arg(1) + arg404 := flag.Arg(2) mbTrans405 := thrift.NewTMemoryBufferLen(len(arg404)) defer mbTrans405.Close() _, err406 := mbTrans405.WriteString(arg404) @@ -385,57 +427,15 @@ func main() { } factory407 := thrift.NewTSimpleJSONProtocolFactory() jsProt408 := factory407.GetProtocol(mbTrans405) - argvalue0 := aurora.NewHosts() - err409 := argvalue0.Read(jsProt408) + argvalue1 := aurora.NewSlaPolicy() + err409 := argvalue1.Read(jsProt408) if err409 != nil { Usage() return } - value0 := argvalue0 - fmt.Print(client.EndMaintenance(value0)) - fmt.Print("\n") - break - case "slaDrainHosts": - if flag.NArg()-1 != 3 { - fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args") - flag.Usage() - } - arg410 := flag.Arg(1) - mbTrans411 := thrift.NewTMemoryBufferLen(len(arg410)) - defer mbTrans411.Close() - _, err412 := mbTrans411.WriteString(arg410) - if err412 != nil { - Usage() - return - } - factory413 := thrift.NewTSimpleJSONProtocolFactory() - jsProt414 := factory413.GetProtocol(mbTrans411) - argvalue0 := aurora.NewHosts() - err415 := argvalue0.Read(jsProt414) - if err415 != nil { - Usage() - return - } - value0 := argvalue0 - arg416 := flag.Arg(2) - mbTrans417 := thrift.NewTMemoryBufferLen(len(arg416)) - defer mbTrans417.Close() - _, err418 := mbTrans417.WriteString(arg416) - if err418 != nil { - Usage() - return - } - factory419 := thrift.NewTSimpleJSONProtocolFactory() - jsProt420 := factory419.GetProtocol(mbTrans417) - argvalue1 := aurora.NewSlaPolicy() - err421 := argvalue1.Read(jsProt420) - if err421 != nil { - Usage() - return - } value1 := argvalue1 - argvalue2, err422 := (strconv.ParseInt(flag.Arg(3), 10, 64)) - if err422 != nil { + argvalue2, err410 := (strconv.ParseInt(flag.Arg(3), 10, 64)) + if err410 != nil { Usage() return } @@ -456,19 +456,19 @@ func main() { fmt.Fprintln(os.Stderr, "TriggerExplicitTaskReconciliation requires 1 args") flag.Usage() } - arg423 := flag.Arg(1) - mbTrans424 := thrift.NewTMemoryBufferLen(len(arg423)) - defer mbTrans424.Close() - _, err425 := mbTrans424.WriteString(arg423) - if err425 != nil { + arg411 := flag.Arg(1) + mbTrans412 := thrift.NewTMemoryBufferLen(len(arg411)) + defer mbTrans412.Close() + _, err413 := mbTrans412.WriteString(arg411) + if err413 != nil { Usage() return } - factory426 := thrift.NewTSimpleJSONProtocolFactory() - jsProt427 := factory426.GetProtocol(mbTrans424) + factory414 := thrift.NewTSimpleJSONProtocolFactory() + jsProt415 := factory414.GetProtocol(mbTrans412) argvalue0 := aurora.NewExplicitReconciliationSettings() - err428 := argvalue0.Read(jsProt427) - if err428 != nil { + err416 := argvalue0.Read(jsProt415) + if err416 != nil { Usage() return } @@ -489,19 +489,19 @@ func main() { fmt.Fprintln(os.Stderr, "PruneTasks requires 1 args") flag.Usage() } - arg429 := flag.Arg(1) - mbTrans430 := thrift.NewTMemoryBufferLen(len(arg429)) - defer mbTrans430.Close() - _, err431 := mbTrans430.WriteString(arg429) - if err431 != nil { + arg417 := flag.Arg(1) + mbTrans418 := thrift.NewTMemoryBufferLen(len(arg417)) + defer mbTrans418.Close() + _, err419 := mbTrans418.WriteString(arg417) + if err419 != nil { Usage() return } - factory432 := thrift.NewTSimpleJSONProtocolFactory() - jsProt433 := factory432.GetProtocol(mbTrans430) + factory420 := thrift.NewTSimpleJSONProtocolFactory() + jsProt421 := factory420.GetProtocol(mbTrans418) argvalue0 := aurora.NewTaskQuery() - err434 := argvalue0.Read(jsProt433) - if err434 != nil { + err422 := argvalue0.Read(jsProt421) + if err422 != nil { Usage() return } @@ -514,19 +514,19 @@ func main() { fmt.Fprintln(os.Stderr, "CreateJob requires 1 args") flag.Usage() } - arg435 := flag.Arg(1) - mbTrans436 := thrift.NewTMemoryBufferLen(len(arg435)) - defer mbTrans436.Close() - _, err437 := mbTrans436.WriteString(arg435) - if err437 != nil { + arg423 := flag.Arg(1) + mbTrans424 := thrift.NewTMemoryBufferLen(len(arg423)) + defer mbTrans424.Close() + _, err425 := mbTrans424.WriteString(arg423) + if err425 != nil { Usage() return } - factory438 := thrift.NewTSimpleJSONProtocolFactory() - jsProt439 := factory438.GetProtocol(mbTrans436) + factory426 := thrift.NewTSimpleJSONProtocolFactory() + jsProt427 := factory426.GetProtocol(mbTrans424) argvalue0 := aurora.NewJobConfiguration() - err440 := argvalue0.Read(jsProt439) - if err440 != nil { + err428 := argvalue0.Read(jsProt427) + if err428 != nil { Usage() return } @@ -539,19 +539,19 @@ func main() { fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") flag.Usage() } - arg441 := flag.Arg(1) - mbTrans442 := thrift.NewTMemoryBufferLen(len(arg441)) - defer mbTrans442.Close() - _, err443 := mbTrans442.WriteString(arg441) - if err443 != nil { + arg429 := flag.Arg(1) + mbTrans430 := thrift.NewTMemoryBufferLen(len(arg429)) + defer mbTrans430.Close() + _, err431 := mbTrans430.WriteString(arg429) + if err431 != nil { Usage() return } - factory444 := thrift.NewTSimpleJSONProtocolFactory() - jsProt445 := factory444.GetProtocol(mbTrans442) + factory432 := thrift.NewTSimpleJSONProtocolFactory() + jsProt433 := factory432.GetProtocol(mbTrans430) argvalue0 := aurora.NewJobConfiguration() - err446 := argvalue0.Read(jsProt445) - if err446 != nil { + err434 := argvalue0.Read(jsProt433) + if err434 != nil { Usage() return } @@ -564,6 +564,56 @@ 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 { + Usage() + return + } + factory438 := thrift.NewTSimpleJSONProtocolFactory() + jsProt439 := factory438.GetProtocol(mbTrans436) + argvalue0 := aurora.NewJobKey() + err440 := argvalue0.Read(jsProt439) + if err440 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.DescheduleCronJob(value0)) + fmt.Print("\n") + break + case "startCronJob": + if flag.NArg()-1 != 1 { + 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 { + Usage() + return + } + factory444 := thrift.NewTSimpleJSONProtocolFactory() + jsProt445 := factory444.GetProtocol(mbTrans442) + argvalue0 := aurora.NewJobKey() + err446 := argvalue0.Read(jsProt445) + if err446 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.StartCronJob(value0)) + fmt.Print("\n") + break + case "restartShards": + if flag.NArg()-1 != 2 { + fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") + flag.Usage() + } arg447 := flag.Arg(1) mbTrans448 := thrift.NewTMemoryBufferLen(len(arg447)) defer mbTrans448.Close() @@ -581,15 +631,7 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.DescheduleCronJob(value0)) - fmt.Print("\n") - break - case "startCronJob": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") - flag.Usage() - } - arg453 := flag.Arg(1) + arg453 := flag.Arg(2) mbTrans454 := thrift.NewTMemoryBufferLen(len(arg453)) defer mbTrans454.Close() _, err455 := mbTrans454.WriteString(arg453) @@ -599,19 +641,20 @@ func main() { } factory456 := thrift.NewTSimpleJSONProtocolFactory() jsProt457 := factory456.GetProtocol(mbTrans454) - argvalue0 := aurora.NewJobKey() - err458 := argvalue0.Read(jsProt457) + containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs() + err458 := containerStruct1.ReadField2(jsProt457) if err458 != nil { Usage() return } - value0 := argvalue0 - fmt.Print(client.StartCronJob(value0)) + argvalue1 := containerStruct1.ShardIds + value1 := argvalue1 + fmt.Print(client.RestartShards(value0, value1)) fmt.Print("\n") break - case "restartShards": - if flag.NArg()-1 != 2 { - fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") + case "killTasks": + if flag.NArg()-1 != 3 { + fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") flag.Usage() } arg459 := flag.Arg(1) @@ -641,55 +684,12 @@ func main() { } factory468 := thrift.NewTSimpleJSONProtocolFactory() jsProt469 := factory468.GetProtocol(mbTrans466) - containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs() + containerStruct1 := aurora.NewAuroraAdminKillTasksArgs() err470 := containerStruct1.ReadField2(jsProt469) if err470 != nil { Usage() return } - argvalue1 := containerStruct1.ShardIds - value1 := argvalue1 - fmt.Print(client.RestartShards(value0, value1)) - fmt.Print("\n") - break - case "killTasks": - if flag.NArg()-1 != 3 { - fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") - flag.Usage() - } - arg471 := flag.Arg(1) - mbTrans472 := thrift.NewTMemoryBufferLen(len(arg471)) - defer mbTrans472.Close() - _, err473 := mbTrans472.WriteString(arg471) - if err473 != nil { - Usage() - return - } - factory474 := thrift.NewTSimpleJSONProtocolFactory() - jsProt475 := factory474.GetProtocol(mbTrans472) - argvalue0 := aurora.NewJobKey() - err476 := argvalue0.Read(jsProt475) - if err476 != nil { - Usage() - return - } - value0 := argvalue0 - arg477 := flag.Arg(2) - mbTrans478 := thrift.NewTMemoryBufferLen(len(arg477)) - defer mbTrans478.Close() - _, err479 := mbTrans478.WriteString(arg477) - if err479 != nil { - Usage() - return - } - factory480 := thrift.NewTSimpleJSONProtocolFactory() - jsProt481 := factory480.GetProtocol(mbTrans478) - containerStruct1 := aurora.NewAuroraAdminKillTasksArgs() - err482 := containerStruct1.ReadField2(jsProt481) - if err482 != nil { - Usage() - return - } argvalue1 := containerStruct1.Instances value1 := argvalue1 argvalue2 := flag.Arg(3) @@ -702,25 +702,25 @@ func main() { fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") flag.Usage() } - arg484 := flag.Arg(1) - mbTrans485 := thrift.NewTMemoryBufferLen(len(arg484)) - defer mbTrans485.Close() - _, err486 := mbTrans485.WriteString(arg484) - if err486 != nil { + arg472 := flag.Arg(1) + mbTrans473 := thrift.NewTMemoryBufferLen(len(arg472)) + defer mbTrans473.Close() + _, err474 := mbTrans473.WriteString(arg472) + if err474 != nil { Usage() return } - factory487 := thrift.NewTSimpleJSONProtocolFactory() - jsProt488 := factory487.GetProtocol(mbTrans485) + factory475 := thrift.NewTSimpleJSONProtocolFactory() + jsProt476 := factory475.GetProtocol(mbTrans473) argvalue0 := aurora.NewInstanceKey() - err489 := argvalue0.Read(jsProt488) - if err489 != nil { + err477 := argvalue0.Read(jsProt476) + if err477 != nil { Usage() return } value0 := argvalue0 - tmp1, err490 := (strconv.Atoi(flag.Arg(2))) - if err490 != nil { + tmp1, err478 := (strconv.Atoi(flag.Arg(2))) + if err478 != nil { Usage() return } @@ -734,19 +734,19 @@ func main() { fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") flag.Usage() } - arg491 := flag.Arg(1) - mbTrans492 := thrift.NewTMemoryBufferLen(len(arg491)) - defer mbTrans492.Close() - _, err493 := mbTrans492.WriteString(arg491) - if err493 != nil { + arg479 := flag.Arg(1) + mbTrans480 := thrift.NewTMemoryBufferLen(len(arg479)) + defer mbTrans480.Close() + _, err481 := mbTrans480.WriteString(arg479) + if err481 != nil { Usage() return } - factory494 := thrift.NewTSimpleJSONProtocolFactory() - jsProt495 := factory494.GetProtocol(mbTrans492) + factory482 := thrift.NewTSimpleJSONProtocolFactory() + jsProt483 := factory482.GetProtocol(mbTrans480) argvalue0 := aurora.NewJobConfiguration() - err496 := argvalue0.Read(jsProt495) - if err496 != nil { + err484 := argvalue0.Read(jsProt483) + if err484 != nil { Usage() return } @@ -759,19 +759,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") flag.Usage() } - arg497 := flag.Arg(1) - mbTrans498 := thrift.NewTMemoryBufferLen(len(arg497)) - defer mbTrans498.Close() - _, err499 := mbTrans498.WriteString(arg497) - if err499 != nil { + arg485 := flag.Arg(1) + mbTrans486 := thrift.NewTMemoryBufferLen(len(arg485)) + defer mbTrans486.Close() + _, err487 := mbTrans486.WriteString(arg485) + if err487 != nil { Usage() return } - factory500 := thrift.NewTSimpleJSONProtocolFactory() - jsProt501 := factory500.GetProtocol(mbTrans498) + factory488 := thrift.NewTSimpleJSONProtocolFactory() + jsProt489 := factory488.GetProtocol(mbTrans486) argvalue0 := aurora.NewJobUpdateRequest() - err502 := argvalue0.Read(jsProt501) - if err502 != nil { + err490 := argvalue0.Read(jsProt489) + if err490 != nil { Usage() return } @@ -786,19 +786,19 @@ func main() { fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") flag.Usage() } - arg504 := flag.Arg(1) - mbTrans505 := thrift.NewTMemoryBufferLen(len(arg504)) - defer mbTrans505.Close() - _, err506 := mbTrans505.WriteString(arg504) - if err506 != nil { + arg492 := flag.Arg(1) + mbTrans493 := thrift.NewTMemoryBufferLen(len(arg492)) + defer mbTrans493.Close() + _, err494 := mbTrans493.WriteString(arg492) + if err494 != nil { Usage() return } - factory507 := thrift.NewTSimpleJSONProtocolFactory() - jsProt508 := factory507.GetProtocol(mbTrans505) + factory495 := thrift.NewTSimpleJSONProtocolFactory() + jsProt496 := factory495.GetProtocol(mbTrans493) argvalue0 := aurora.NewJobUpdateKey() - err509 := argvalue0.Read(jsProt508) - if err509 != nil { + err497 := argvalue0.Read(jsProt496) + if err497 != nil { Usage() return } @@ -813,19 +813,19 @@ func main() { fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") flag.Usage() } - arg511 := flag.Arg(1) - mbTrans512 := thrift.NewTMemoryBufferLen(len(arg511)) - defer mbTrans512.Close() - _, err513 := mbTrans512.WriteString(arg511) - if err513 != nil { + arg499 := flag.Arg(1) + mbTrans500 := thrift.NewTMemoryBufferLen(len(arg499)) + defer mbTrans500.Close() + _, err501 := mbTrans500.WriteString(arg499) + if err501 != nil { Usage() return } - factory514 := thrift.NewTSimpleJSONProtocolFactory() - jsProt515 := factory514.GetProtocol(mbTrans512) + factory502 := thrift.NewTSimpleJSONProtocolFactory() + jsProt503 := factory502.GetProtocol(mbTrans500) argvalue0 := aurora.NewJobUpdateKey() - err516 := argvalue0.Read(jsProt515) - if err516 != nil { + err504 := argvalue0.Read(jsProt503) + if err504 != nil { Usage() return } @@ -840,19 +840,19 @@ func main() { fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") flag.Usage() } - arg518 := flag.Arg(1) - mbTrans519 := thrift.NewTMemoryBufferLen(len(arg518)) - defer mbTrans519.Close() - _, err520 := mbTrans519.WriteString(arg518) - if err520 != nil { + arg506 := flag.Arg(1) + mbTrans507 := thrift.NewTMemoryBufferLen(len(arg506)) + defer mbTrans507.Close() + _, err508 := mbTrans507.WriteString(arg506) + if err508 != nil { Usage() return } - factory521 := thrift.NewTSimpleJSONProtocolFactory() - jsProt522 := factory521.GetProtocol(mbTrans519) + factory509 := thrift.NewTSimpleJSONProtocolFactory() + jsProt510 := factory509.GetProtocol(mbTrans507) argvalue0 := aurora.NewJobUpdateKey() - err523 := argvalue0.Read(jsProt522) - if err523 != nil { + err511 := argvalue0.Read(jsProt510) + if err511 != nil { Usage() return } @@ -867,19 +867,19 @@ func main() { fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") flag.Usage() } - arg525 := flag.Arg(1) - mbTrans526 := thrift.NewTMemoryBufferLen(len(arg525)) - defer mbTrans526.Close() - _, err527 := mbTrans526.WriteString(arg525) - if err527 != nil { + arg513 := flag.Arg(1) + mbTrans514 := thrift.NewTMemoryBufferLen(len(arg513)) + defer mbTrans514.Close() + _, err515 := mbTrans514.WriteString(arg513) + if err515 != nil { Usage() return } - factory528 := thrift.NewTSimpleJSONProtocolFactory() - jsProt529 := factory528.GetProtocol(mbTrans526) + factory516 := thrift.NewTSimpleJSONProtocolFactory() + jsProt517 := factory516.GetProtocol(mbTrans514) argvalue0 := aurora.NewJobUpdateKey() - err530 := argvalue0.Read(jsProt529) - if err530 != nil { + err518 := argvalue0.Read(jsProt517) + if err518 != nil { Usage() return } @@ -894,19 +894,19 @@ func main() { fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") flag.Usage() } - arg532 := flag.Arg(1) - mbTrans533 := thrift.NewTMemoryBufferLen(len(arg532)) - defer mbTrans533.Close() - _, err534 := mbTrans533.WriteString(arg532) - if err534 != nil { + arg520 := flag.Arg(1) + mbTrans521 := thrift.NewTMemoryBufferLen(len(arg520)) + defer mbTrans521.Close() + _, err522 := mbTrans521.WriteString(arg520) + if err522 != nil { Usage() return } - factory535 := thrift.NewTSimpleJSONProtocolFactory() - jsProt536 := factory535.GetProtocol(mbTrans533) + factory523 := thrift.NewTSimpleJSONProtocolFactory() + jsProt524 := factory523.GetProtocol(mbTrans521) argvalue0 := aurora.NewJobUpdateKey() - err537 := argvalue0.Read(jsProt536) - if err537 != nil { + err525 := argvalue0.Read(jsProt524) + if err525 != nil { Usage() return } @@ -937,6 +937,56 @@ 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 { + Usage() + return + } + factory530 := thrift.NewTSimpleJSONProtocolFactory() + jsProt531 := factory530.GetProtocol(mbTrans528) + argvalue0 := aurora.NewTaskQuery() + err532 := argvalue0.Read(jsProt531) + if err532 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetTasksStatus(value0)) + fmt.Print("\n") + break + case "getTasksWithoutConfigs": + if flag.NArg()-1 != 1 { + 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 { + Usage() + return + } + factory536 := thrift.NewTSimpleJSONProtocolFactory() + jsProt537 := factory536.GetProtocol(mbTrans534) + argvalue0 := aurora.NewTaskQuery() + err538 := argvalue0.Read(jsProt537) + if err538 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetTasksWithoutConfigs(value0)) + fmt.Print("\n") + break + case "getPendingReason": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") + flag.Usage() + } arg539 := flag.Arg(1) mbTrans540 := thrift.NewTMemoryBufferLen(len(arg539)) defer mbTrans540.Close() @@ -954,12 +1004,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.GetTasksStatus(value0)) + fmt.Print(client.GetPendingReason(value0)) fmt.Print("\n") break - case "getTasksWithoutConfigs": + case "getConfigSummary": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") + fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") flag.Usage() } arg545 := flag.Arg(1) @@ -972,63 +1022,13 @@ func main() { } factory548 := thrift.NewTSimpleJSONProtocolFactory() jsProt549 := factory548.GetProtocol(mbTrans546) - argvalue0 := aurora.NewTaskQuery() + argvalue0 := aurora.NewJobKey() err550 := argvalue0.Read(jsProt549) if err550 != nil { Usage() return } value0 := argvalue0 - fmt.Print(client.GetTasksWithoutConfigs(value0)) - fmt.Print("\n") - break - case "getPendingReason": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") - flag.Usage() - } - arg551 := flag.Arg(1) - mbTrans552 := thrift.NewTMemoryBufferLen(len(arg551)) - defer mbTrans552.Close() - _, err553 := mbTrans552.WriteString(arg551) - if err553 != nil { - Usage() - return - } - factory554 := thrift.NewTSimpleJSONProtocolFactory() - jsProt555 := factory554.GetProtocol(mbTrans552) - argvalue0 := aurora.NewTaskQuery() - err556 := argvalue0.Read(jsProt555) - if err556 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetPendingReason(value0)) - fmt.Print("\n") - break - case "getConfigSummary": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") - flag.Usage() - } - arg557 := flag.Arg(1) - mbTrans558 := thrift.NewTMemoryBufferLen(len(arg557)) - defer mbTrans558.Close() - _, err559 := mbTrans558.WriteString(arg557) - if err559 != nil { - Usage() - return - } - factory560 := thrift.NewTSimpleJSONProtocolFactory() - jsProt561 := factory560.GetProtocol(mbTrans558) - argvalue0 := aurora.NewJobKey() - err562 := argvalue0.Read(jsProt561) - if err562 != nil { - Usage() - return - } - value0 := argvalue0 fmt.Print(client.GetConfigSummary(value0)) fmt.Print("\n") break @@ -1057,19 +1057,19 @@ func main() { fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") flag.Usage() } - arg565 := flag.Arg(1) - mbTrans566 := thrift.NewTMemoryBufferLen(len(arg565)) - defer mbTrans566.Close() - _, err567 := mbTrans566.WriteString(arg565) - if err567 != nil { + arg553 := flag.Arg(1) + mbTrans554 := thrift.NewTMemoryBufferLen(len(arg553)) + defer mbTrans554.Close() + _, err555 := mbTrans554.WriteString(arg553) + if err555 != nil { Usage() return } - factory568 := thrift.NewTSimpleJSONProtocolFactory() - jsProt569 := factory568.GetProtocol(mbTrans566) + factory556 := thrift.NewTSimpleJSONProtocolFactory() + jsProt557 := factory556.GetProtocol(mbTrans554) argvalue0 := aurora.NewJobConfiguration() - err570 := argvalue0.Read(jsProt569) - if err570 != nil { + err558 := argvalue0.Read(jsProt557) + if err558 != nil { Usage() return } @@ -1082,6 +1082,56 @@ 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 { + Usage() + return + } + factory562 := thrift.NewTSimpleJSONProtocolFactory() + jsProt563 := factory562.GetProtocol(mbTrans560) + argvalue0 := aurora.NewJobUpdateQuery() + err564 := argvalue0.Read(jsProt563) + if err564 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetJobUpdateSummaries(value0)) + fmt.Print("\n") + break + case "getJobUpdateDetails": + if flag.NArg()-1 != 1 { + 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 { + Usage() + return + } + factory568 := thrift.NewTSimpleJSONProtocolFactory() + jsProt569 := factory568.GetProtocol(mbTrans566) + argvalue0 := aurora.NewJobUpdateQuery() + err570 := argvalue0.Read(jsProt569) + if err570 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetJobUpdateDetails(value0)) + fmt.Print("\n") + break + case "getJobUpdateDiff": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") + flag.Usage() + } arg571 := flag.Arg(1) mbTrans572 := thrift.NewTMemoryBufferLen(len(arg571)) defer mbTrans572.Close() @@ -1092,80 +1142,13 @@ func main() { } factory574 := thrift.NewTSimpleJSONProtocolFactory() jsProt575 := factory574.GetProtocol(mbTrans572) - argvalue0 := aurora.NewJobUpdateQuery() + argvalue0 := aurora.NewJobUpdateRequest() err576 := argvalue0.Read(jsProt575) if err576 != nil { Usage() return } value0 := argvalue0 - fmt.Print(client.GetJobUpdateSummaries(value0)) - fmt.Print("\n") - break - case "getJobUpdateDetails": - if flag.NArg()-1 != 2 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 2 args") - flag.Usage() - } - arg577 := flag.Arg(1) - mbTrans578 := thrift.NewTMemoryBufferLen(len(arg577)) - defer mbTrans578.Close() - _, err579 := mbTrans578.WriteString(arg577) - if err579 != nil { - Usage() - return - } - factory580 := thrift.NewTSimpleJSONProtocolFactory() - jsProt581 := factory580.GetProtocol(mbTrans578) - argvalue0 := aurora.NewJobUpdateKey() - err582 := argvalue0.Read(jsProt581) - if err582 != nil { - Usage() - return - } - value0 := argvalue0 - arg583 := flag.Arg(2) - mbTrans584 := thrift.NewTMemoryBufferLen(len(arg583)) - defer mbTrans584.Close() - _, err585 := mbTrans584.WriteString(arg583) - if err585 != nil { - Usage() - return - } - factory586 := thrift.NewTSimpleJSONProtocolFactory() - jsProt587 := factory586.GetProtocol(mbTrans584) - argvalue1 := aurora.NewJobUpdateQuery() - err588 := argvalue1.Read(jsProt587) - if err588 != nil { - Usage() - return - } - value1 := argvalue1 - fmt.Print(client.GetJobUpdateDetails(value0, value1)) - fmt.Print("\n") - break - case "getJobUpdateDiff": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") - flag.Usage() - } - arg589 := flag.Arg(1) - mbTrans590 := thrift.NewTMemoryBufferLen(len(arg589)) - defer mbTrans590.Close() - _, err591 := mbTrans590.WriteString(arg589) - if err591 != nil { - Usage() - return - } - factory592 := thrift.NewTSimpleJSONProtocolFactory() - jsProt593 := factory592.GetProtocol(mbTrans590) - argvalue0 := aurora.NewJobUpdateRequest() - err594 := argvalue0.Read(jsProt593) - if err594 != nil { - Usage() - return - } - value0 := argvalue0 fmt.Print(client.GetJobUpdateDiff(value0)) fmt.Print("\n") break 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 6494573..3ca67ea 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 @@ -44,7 +44,7 @@ func Usage() { fmt.Fprintln(os.Stderr, " Response getQuota(string ownerRole)") fmt.Fprintln(os.Stderr, " Response populateJobConfig(JobConfiguration description)") fmt.Fprintln(os.Stderr, " Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery)") - fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query)") + fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateQuery query)") fmt.Fprintln(os.Stderr, " Response getJobUpdateDiff(JobUpdateRequest request)") fmt.Fprintln(os.Stderr, " Response getTierConfigs()") fmt.Fprintln(os.Stderr) @@ -146,6 +146,31 @@ 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 { + Usage() + return + } + factory165 := thrift.NewTSimpleJSONProtocolFactory() + jsProt166 := factory165.GetProtocol(mbTrans163) + argvalue0 := aurora.NewJobConfiguration() + err167 := argvalue0.Read(jsProt166) + if err167 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CreateJob(value0)) + fmt.Print("\n") + break + case "scheduleCronJob": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") + flag.Usage() + } arg168 := flag.Arg(1) mbTrans169 := thrift.NewTMemoryBufferLen(len(arg168)) defer mbTrans169.Close() @@ -163,12 +188,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.CreateJob(value0)) + fmt.Print(client.ScheduleCronJob(value0)) fmt.Print("\n") break - case "scheduleCronJob": + case "descheduleCronJob": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args") + fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") flag.Usage() } arg174 := flag.Arg(1) @@ -181,19 +206,19 @@ func main() { } factory177 := thrift.NewTSimpleJSONProtocolFactory() jsProt178 := factory177.GetProtocol(mbTrans175) - argvalue0 := aurora.NewJobConfiguration() + argvalue0 := aurora.NewJobKey() err179 := argvalue0.Read(jsProt178) if err179 != nil { Usage() return } value0 := argvalue0 - fmt.Print(client.ScheduleCronJob(value0)) + fmt.Print(client.DescheduleCronJob(value0)) fmt.Print("\n") break - case "descheduleCronJob": + case "startCronJob": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args") + fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") flag.Usage() } arg180 := flag.Arg(1) @@ -213,12 +238,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.DescheduleCronJob(value0)) + fmt.Print(client.StartCronJob(value0)) fmt.Print("\n") break - case "startCronJob": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args") + case "restartShards": + if flag.NArg()-1 != 2 { + fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") flag.Usage() } arg186 := flag.Arg(1) @@ -238,15 +263,7 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.StartCronJob(value0)) - fmt.Print("\n") - break - case "restartShards": - if flag.NArg()-1 != 2 { - fmt.Fprintln(os.Stderr, "RestartShards requires 2 args") - flag.Usage() - } - arg192 := flag.Arg(1) + arg192 := flag.Arg(2) mbTrans193 := thrift.NewTMemoryBufferLen(len(arg192)) defer mbTrans193.Close() _, err194 := mbTrans193.WriteString(arg192) @@ -256,26 +273,9 @@ func main() { } factory195 := thrift.NewTSimpleJSONProtocolFactory() jsProt196 := factory195.GetProtocol(mbTrans193) - argvalue0 := aurora.NewJobKey() - err197 := argvalue0.Read(jsProt196) - if err197 != nil { - Usage() - return - } - value0 := argvalue0 - arg198 := flag.Arg(2) - mbTrans199 := thrift.NewTMemoryBufferLen(len(arg198)) - defer mbTrans199.Close() - _, err200 := mbTrans199.WriteString(arg198) - if err200 != nil { - Usage() - return - } - factory201 := thrift.NewTSimpleJSONProtocolFactory() - jsProt202 := factory201.GetProtocol(mbTrans199) containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs() - err203 := containerStruct1.ReadField2(jsProt202) - if err203 != nil { + err197 := containerStruct1.ReadField2(jsProt196) + if err197 != nil { Usage() return } @@ -289,7 +289,24 @@ func main() { fmt.Fprintln(os.Stderr, "KillTasks requires 3 args") flag.Usage() } - arg204 := flag.Arg(1) + arg198 := flag.Arg(1) + mbTrans199 := thrift.NewTMemoryBufferLen(len(arg198)) + defer mbTrans199.Close() + _, err200 := mbTrans199.WriteString(arg198) + if err200 != nil { + Usage() + return + } + factory201 := thrift.NewTSimpleJSONProtocolFactory() + jsProt202 := factory201.GetProtocol(mbTrans199) + argvalue0 := aurora.NewJobKey() + err203 := argvalue0.Read(jsProt202) + if err203 != nil { + Usage() + return + } + value0 := argvalue0 + arg204 := flag.Arg(2) mbTrans205 := thrift.NewTMemoryBufferLen(len(arg204)) defer mbTrans205.Close() _, err206 := mbTrans205.WriteString(arg204) @@ -299,26 +316,9 @@ func main() { } factory207 := thrift.NewTSimpleJSONProtocolFactory() jsProt208 := factory207.GetProtocol(mbTrans205) - argvalue0 := aurora.NewJobKey() - err209 := argvalue0.Read(jsProt208) - if err209 != nil { - Usage() - return - } - value0 := argvalue0 - arg210 := flag.Arg(2) - mbTrans211 := thrift.NewTMemoryBufferLen(len(arg210)) - defer mbTrans211.Close() - _, err212 := mbTrans211.WriteString(arg210) - if err212 != nil { - Usage() - return - } - factory213 := thrift.NewTSimpleJSONProtocolFactory() - jsProt214 := factory213.GetProtocol(mbTrans211) containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs() - err215 := containerStruct1.ReadField2(jsProt214) - if err215 != nil { + err209 := containerStruct1.ReadField2(jsProt208) + if err209 != nil { Usage() return } @@ -334,25 +334,25 @@ func main() { fmt.Fprintln(os.Stderr, "AddInstances requires 2 args") flag.Usage() } - arg217 := flag.Arg(1) - mbTrans218 := thrift.NewTMemoryBufferLen(len(arg217)) - defer mbTrans218.Close() - _, err219 := mbTrans218.WriteString(arg217) - if err219 != nil { + arg211 := flag.Arg(1) + mbTrans212 := thrift.NewTMemoryBufferLen(len(arg211)) + defer mbTrans212.Close() + _, err213 := mbTrans212.WriteString(arg211) + if err213 != nil { Usage() return } - factory220 := thrift.NewTSimpleJSONProtocolFactory() - jsProt221 := factory220.GetProtocol(mbTrans218) + factory214 := thrift.NewTSimpleJSONProtocolFactory() + jsProt215 := factory214.GetProtocol(mbTrans212) argvalue0 := aurora.NewInstanceKey() - err222 := argvalue0.Read(jsProt221) - if err222 != nil { + err216 := argvalue0.Read(jsProt215) + if err216 != nil { Usage() return } value0 := argvalue0 - tmp1, err223 := (strconv.Atoi(flag.Arg(2))) - if err223 != nil { + tmp1, err217 := (strconv.Atoi(flag.Arg(2))) + if err217 != nil { Usage() return } @@ -366,19 +366,19 @@ func main() { fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args") flag.Usage() } - arg224 := flag.Arg(1) - mbTrans225 := thrift.NewTMemoryBufferLen(len(arg224)) - defer mbTrans225.Close() - _, err226 := mbTrans225.WriteString(arg224) - if err226 != nil { + arg218 := flag.Arg(1) + mbTrans219 := thrift.NewTMemoryBufferLen(len(arg218)) + defer mbTrans219.Close() + _, err220 := mbTrans219.WriteString(arg218) + if err220 != nil { Usage() return } - factory227 := thrift.NewTSimpleJSONProtocolFactory() - jsProt228 := factory227.GetProtocol(mbTrans225) + factory221 := thrift.NewTSimpleJSONProtocolFactory() + jsProt222 := factory221.GetProtocol(mbTrans219) argvalue0 := aurora.NewJobConfiguration() - err229 := argvalue0.Read(jsProt228) - if err229 != nil { + err223 := argvalue0.Read(jsProt222) + if err223 != nil { Usage() return } @@ -391,19 +391,19 @@ func main() { fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args") flag.Usage() } - arg230 := flag.Arg(1) - mbTrans231 := thrift.NewTMemoryBufferLen(len(arg230)) - defer mbTrans231.Close() - _, err232 := mbTrans231.WriteString(arg230) - if err232 != nil { + arg224 := flag.Arg(1) + mbTrans225 := thrift.NewTMemoryBufferLen(len(arg224)) + defer mbTrans225.Close() + _, err226 := mbTrans225.WriteString(arg224) + if err226 != nil { Usage() return } - factory233 := thrift.NewTSimpleJSONProtocolFactory() - jsProt234 := factory233.GetProtocol(mbTrans231) + factory227 := thrift.NewTSimpleJSONProtocolFactory() + jsProt228 := factory227.GetProtocol(mbTrans225) argvalue0 := aurora.NewJobUpdateRequest() - err235 := argvalue0.Read(jsProt234) - if err235 != nil { + err229 := argvalue0.Read(jsProt228) + if err229 != nil { Usage() return } @@ -418,19 +418,19 @@ func main() { fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args") flag.Usage() } - arg237 := flag.Arg(1) - mbTrans238 := thrift.NewTMemoryBufferLen(len(arg237)) - defer mbTrans238.Close() - _, err239 := mbTrans238.WriteString(arg237) - if err239 != nil { + arg231 := flag.Arg(1) + mbTrans232 := thrift.NewTMemoryBufferLen(len(arg231)) + defer mbTrans232.Close() + _, err233 := mbTrans232.WriteString(arg231) + if err233 != nil { Usage() return } - factory240 := thrift.NewTSimpleJSONProtocolFactory() - jsProt241 := factory240.GetProtocol(mbTrans238) + factory234 := thrift.NewTSimpleJSONProtocolFactory() + jsProt235 := factory234.GetProtocol(mbTrans232) argvalue0 := aurora.NewJobUpdateKey() - err242 := argvalue0.Read(jsProt241) - if err242 != nil { + err236 := argvalue0.Read(jsProt235) + if err236 != nil { Usage() return } @@ -445,19 +445,19 @@ func main() { fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args") flag.Usage() } - arg244 := flag.Arg(1) - mbTrans245 := thrift.NewTMemoryBufferLen(len(arg244)) - defer mbTrans245.Close() - _, err246 := mbTrans245.WriteString(arg244) - if err246 != nil { + arg238 := flag.Arg(1) + mbTrans239 := thrift.NewTMemoryBufferLen(len(arg238)) + defer mbTrans239.Close() + _, err240 := mbTrans239.WriteString(arg238) + if err240 != nil { Usage() return } - factory247 := thrift.NewTSimpleJSONProtocolFactory() - jsProt248 := factory247.GetProtocol(mbTrans245) + factory241 := thrift.NewTSimpleJSONProtocolFactory() + jsProt242 := factory241.GetProtocol(mbTrans239) argvalue0 := aurora.NewJobUpdateKey() - err249 := argvalue0.Read(jsProt248) - if err249 != nil { + err243 := argvalue0.Read(jsProt242) + if err243 != nil { Usage() return } @@ -472,19 +472,19 @@ func main() { fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args") flag.Usage() } - arg251 := flag.Arg(1) - mbTrans252 := thrift.NewTMemoryBufferLen(len(arg251)) - defer mbTrans252.Close() - _, err253 := mbTrans252.WriteString(arg251) - if err253 != nil { + arg245 := flag.Arg(1) + mbTrans246 := thrift.NewTMemoryBufferLen(len(arg245)) + defer mbTrans246.Close() + _, err247 := mbTrans246.WriteString(arg245) + if err247 != nil { Usage() return } - factory254 := thrift.NewTSimpleJSONProtocolFactory() - jsProt255 := factory254.GetProtocol(mbTrans252) + factory248 := thrift.NewTSimpleJSONProtocolFactory() + jsProt249 := factory248.GetProtocol(mbTrans246) argvalue0 := aurora.NewJobUpdateKey() - err256 := argvalue0.Read(jsProt255) - if err256 != nil { + err250 := argvalue0.Read(jsProt249) + if err250 != nil { Usage() return } @@ -499,19 +499,19 @@ func main() { fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args") flag.Usage() } - arg258 := flag.Arg(1) - mbTrans259 := thrift.NewTMemoryBufferLen(len(arg258)) - defer mbTrans259.Close() - _, err260 := mbTrans259.WriteString(arg258) - if err260 != nil { + arg252 := flag.Arg(1) + mbTrans253 := thrift.NewTMemoryBufferLen(len(arg252)) + defer mbTrans253.Close() + _, err254 := mbTrans253.WriteString(arg252) + if err254 != nil { Usage() return } - factory261 := thrift.NewTSimpleJSONProtocolFactory() - jsProt262 := factory261.GetProtocol(mbTrans259) + factory255 := thrift.NewTSimpleJSONProtocolFactory() + jsProt256 := factory255.GetProtocol(mbTrans253) argvalue0 := aurora.NewJobUpdateKey() - err263 := argvalue0.Read(jsProt262) - if err263 != nil { + err257 := argvalue0.Read(jsProt256) + if err257 != nil { Usage() return } @@ -526,19 +526,19 @@ func main() { fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args") flag.Usage() } - arg265 := flag.Arg(1) - mbTrans266 := thrift.NewTMemoryBufferLen(len(arg265)) - defer mbTrans266.Close() - _, err267 := mbTrans266.WriteString(arg265) - if err267 != nil { + arg259 := flag.Arg(1) + mbTrans260 := thrift.NewTMemoryBufferLen(len(arg259)) + defer mbTrans260.Close() + _, err261 := mbTrans260.WriteString(arg259) + if err261 != nil { Usage() return } - factory268 := thrift.NewTSimpleJSONProtocolFactory() - jsProt269 := factory268.GetProtocol(mbTrans266) + factory262 := thrift.NewTSimpleJSONProtocolFactory() + jsProt263 := factory262.GetProtocol(mbTrans260) argvalue0 := aurora.NewJobUpdateKey() - err270 := argvalue0.Read(jsProt269) - if err270 != nil { + err264 := argvalue0.Read(jsProt263) + if err264 != nil { Usage() return } @@ -569,6 +569,31 @@ 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 { + Usage() + return + } + factory269 := thrift.NewTSimpleJSONProtocolFactory() + jsProt270 := factory269.GetProtocol(mbTrans267) + argvalue0 := aurora.NewTaskQuery() + err271 := argvalue0.Read(jsProt270) + if err271 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetTasksStatus(value0)) + fmt.Print("\n") + break + case "getTasksWithoutConfigs": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") + flag.Usage() + } arg272 := flag.Arg(1) mbTrans273 := thrift.NewTMemoryBufferLen(len(arg272)) defer mbTrans273.Close() @@ -586,12 +611,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.GetTasksStatus(value0)) + fmt.Print(client.GetTasksWithoutConfigs(value0)) fmt.Print("\n") break - case "getTasksWithoutConfigs": + case "getPendingReason": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") + fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") flag.Usage() } arg278 := flag.Arg(1) @@ -611,12 +636,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.GetTasksWithoutConfigs(value0)) + fmt.Print(client.GetPendingReason(value0)) fmt.Print("\n") break - case "getPendingReason": + case "getConfigSummary": if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") + fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") flag.Usage() } arg284 := flag.Arg(1) @@ -629,38 +654,13 @@ func main() { } factory287 := thrift.NewTSimpleJSONProtocolFactory() jsProt288 := factory287.GetProtocol(mbTrans285) - argvalue0 := aurora.NewTaskQuery() + argvalue0 := aurora.NewJobKey() err289 := argvalue0.Read(jsProt288) if err289 != nil { Usage() return } value0 := argvalue0 - fmt.Print(client.GetPendingReason(value0)) - fmt.Print("\n") - break - case "getConfigSummary": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") - flag.Usage() - } - arg290 := flag.Arg(1) - mbTrans291 := thrift.NewTMemoryBufferLen(len(arg290)) - defer mbTrans291.Close() - _, err292 := mbTrans291.WriteString(arg290) - if err292 != nil { - Usage() - return - } - factory293 := thrift.NewTSimpleJSONProtocolFactory() - jsProt294 := factory293.GetProtocol(mbTrans291) - argvalue0 := aurora.NewJobKey() - err295 := argvalue0.Read(jsProt294) - if err295 != nil { - Usage() - return - } - value0 := argvalue0 fmt.Print(client.GetConfigSummary(value0)) fmt.Print("\n") break @@ -689,19 +689,19 @@ func main() { fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") flag.Usage() } - arg298 := flag.Arg(1) - mbTrans299 := thrift.NewTMemoryBufferLen(len(arg298)) - defer mbTrans299.Close() - _, err300 := mbTrans299.WriteString(arg298) - if err300 != nil { + arg292 := flag.Arg(1) + mbTrans293 := thrift.NewTMemoryBufferLen(len(arg292)) + defer mbTrans293.Close() + _, err294 := mbTrans293.WriteString(arg292) + if err294 != nil { Usage() return } - factory301 := thrift.NewTSimpleJSONProtocolFactory() - jsProt302 := factory301.GetProtocol(mbTrans299) + factory295 := thrift.NewTSimpleJSONProtocolFactory() + jsProt296 := factory295.GetProtocol(mbTrans293) argvalue0 := aurora.NewJobConfiguration() - err303 := argvalue0.Read(jsProt302) - if err303 != nil { + err297 := argvalue0.Read(jsProt296) + if err297 != nil { Usage() return } @@ -714,6 +714,31 @@ 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 { + Usage() + return + } + factory301 := thrift.NewTSimpleJSONProtocolFactory() + jsProt302 := factory301.GetProtocol(mbTrans299) + argvalue0 := aurora.NewJobUpdateQuery() + err303 := argvalue0.Read(jsProt302) + if err303 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetJobUpdateSummaries(value0)) + fmt.Print("\n") + break + case "getJobUpdateDetails": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") + flag.Usage() + } arg304 := flag.Arg(1) mbTrans305 := thrift.NewTMemoryBufferLen(len(arg304)) defer mbTrans305.Close() @@ -731,12 +756,12 @@ func main() { return } value0 := argvalue0 - fmt.Print(client.GetJobUpdateSummaries(value0)) + fmt.Print(client.GetJobUpdateDetails(value0)) fmt.Print("\n") break - case "getJobUpdateDetails": - if flag.NArg()-1 != 2 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 2 args") + case "getJobUpdateDiff": + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") flag.Usage() } arg310 := flag.Arg(1) @@ -749,55 +774,13 @@ func main() { } factory313 := thrift.NewTSimpleJSONProtocolFactory() jsProt314 := factory313.GetProtocol(mbTrans311) - argvalue0 := aurora.NewJobUpdateKey() + argvalue0 := aurora.NewJobUpdateRequest() err315 := argvalue0.Read(jsProt314) if err315 != nil { Usage() return } value0 := argvalue0 - arg316 := flag.Arg(2) - mbTrans317 := thrift.NewTMemoryBufferLen(len(arg316)) - defer mbTrans317.Close() - _, err318 := mbTrans317.WriteString(arg316) - if err318 != nil { - Usage() - return - } - factory319 := thrift.NewTSimpleJSONProtocolFactory() - jsProt320 := factory319.GetProtocol(mbTrans317) - argvalue1 := aurora.NewJobUpdateQuery() - err321 := argvalue1.Read(jsProt320) - if err321 != nil { - Usage() - return - } - value1 := argvalue1 - fmt.Print(client.GetJobUpdateDetails(value0, value1)) - fmt.Print("\n") - break - case "getJobUpdateDiff": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") - flag.Usage() - } - arg322 := flag.Arg(1) - mbTrans323 := thrift.NewTMemoryBufferLen(len(arg322)) - defer mbTrans323.Close() - _, err324 := mbTrans323.WriteString(arg322) - if err324 != nil { - Usage() - return - } - factory325 := thrift.NewTSimpleJSONProtocolFactory() - jsProt326 := factory325.GetProtocol(mbTrans323) - argvalue0 := aurora.NewJobUpdateRequest() - err327 := argvalue0.Read(jsProt326) - if err327 != nil { - Usage() - return - } - value0 := argvalue0 fmt.Print(client.GetJobUpdateDiff(value0)) fmt.Print("\n") break diff --git a/gen-go/apache/aurora/auroraadmin.go b/gen-go/apache/aurora/auroraadmin.go index b9495db..b00e9cf 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 { - error328 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error329 error - error329, err = error328.Read(iprot) + error316 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error317 error + error317, err = error316.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error329 + err = error317 return } if mTypeId != thrift.REPLY { @@ -250,16 +250,16 @@ func (p *AuroraAdminClient) recvForceTaskState() (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) + error318 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error319 error + error319, err = error318.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error331 + err = error319 return } if mTypeId != thrift.REPLY { @@ -324,16 +324,16 @@ func (p *AuroraAdminClient) recvPerformBackup() (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) + error320 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error321 error + error321, err = error320.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error333 + err = error321 return } if mTypeId != thrift.REPLY { @@ -398,16 +398,16 @@ func (p *AuroraAdminClient) recvListBackups() (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) + error322 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error323 error + error323, err = error322.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error335 + err = error323 return } if mTypeId != thrift.REPLY { @@ -477,16 +477,16 @@ func (p *AuroraAdminClient) recvStageRecovery() (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) + error324 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error325 error + error325, err = error324.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error337 + err = error325 return } if mTypeId != thrift.REPLY { @@ -556,16 +556,16 @@ func (p *AuroraAdminClient) recvQueryRecovery() (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) + error326 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error327 error + error327, err = error326.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error339 + err = error327 return } if mTypeId != thrift.REPLY { @@ -635,16 +635,16 @@ func (p *AuroraAdminClient) recvDeleteRecoveryTasks() (value *Response, err erro return } if mTypeId == thrift.EXCEPTION { - error340 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error341 error - error341, err = error340.Read(iprot) + error328 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error329 error + error329, err = error328.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error341 + err = error329 return } if mTypeId != thrift.REPLY { @@ -709,16 +709,16 @@ func (p *AuroraAdminClient) recvCommitRecovery() (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) + error330 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error331 error + error331, err = error330.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error343 + err = error331 return } if mTypeId != thrift.REPLY { @@ -783,16 +783,16 @@ func (p *AuroraAdminClient) recvUnloadRecovery() (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) + error332 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error333 error + error333, err = error332.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error345 + err = error333 return } if mTypeId != thrift.REPLY { @@ -862,16 +862,16 @@ func (p *AuroraAdminClient) recvStartMaintenance() (value *Response, err error) return } if mTypeId == thrift.EXCEPTION { - error346 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error347 error - error347, err = error346.Read(iprot) + error334 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error335 error + error335, err = error334.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error347 + err = error335 return } if mTypeId != thrift.REPLY { @@ -941,16 +941,16 @@ func (p *AuroraAdminClient) recvDrainHosts() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error348 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error349 error - error349, err = error348.Read(iprot) + error336 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error337 error + error337, err = error336.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error349 + err = error337 return } if mTypeId != thrift.REPLY { @@ -1020,16 +1020,16 @@ func (p *AuroraAdminClient) recvMaintenanceStatus() (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) + error338 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error339 error + error339, err = error338.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error351 + err = error339 return } if mTypeId != thrift.REPLY { @@ -1099,16 +1099,16 @@ func (p *AuroraAdminClient) recvEndMaintenance() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error352 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error353 error - error353, err = error352.Read(iprot) + error340 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error341 error + error341, err = error340.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error353 + err = error341 return } if mTypeId != thrift.REPLY { @@ -1184,16 +1184,16 @@ func (p *AuroraAdminClient) recvSlaDrainHosts() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error354 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error355 error - error355, err = error354.Read(iprot) + error342 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error343 error + error343, err = error342.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error355 + err = error343 return } if mTypeId != thrift.REPLY { @@ -1258,16 +1258,16 @@ func (p *AuroraAdminClient) recvSnapshot() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error356 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error357 error - error357, err = error356.Read(iprot) + error344 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error345 error + error345, err = error344.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error357 + err = error345 return } if mTypeId != thrift.REPLY { @@ -1337,16 +1337,16 @@ func (p *AuroraAdminClient) recvTriggerExplicitTaskReconciliation() (value *Resp return } if mTypeId == thrift.EXCEPTION { - error358 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error359 error - error359, err = error358.Read(iprot) + error346 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error347 error + error347, err = error346.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error359 + err = error347 return } if mTypeId != thrift.REPLY { @@ -1411,16 +1411,16 @@ func (p *AuroraAdminClient) recvTriggerImplicitTaskReconciliation() (value *Resp return } if mTypeId == thrift.EXCEPTION { - error360 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error361 error - error361, err = error360.Read(iprot) + error348 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error349 error + error349, err = error348.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error361 + err = error349 return } if mTypeId != thrift.REPLY { @@ -1492,16 +1492,16 @@ func (p *AuroraAdminClient) recvPruneTasks() (value *Response, err error) { return } if mTypeId == thrift.EXCEPTION { - error362 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error363 error - error363, err = error362.Read(iprot) + error350 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error351 error + error351, err = error350.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error363 + err = error351 return } if mTypeId != thrift.REPLY { @@ -1524,26 +1524,26 @@ type AuroraAdminProcessor struct { } func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor { - self364 := &AuroraAdminProcessor{NewAuroraSchedulerManagerProcessor(handler)} - self364.AddToProcessorMap("setQuota", &auroraAdminProcessorSetQuota{handler: handler}) - self364.AddToProcessorMap("forceTaskState", &auroraAdminProcessorForceTaskState{handler: handler}) - self364.AddToProcessorMap("performBackup", &auroraAdminProcessorPerformBackup{handler: handler}) - self364.AddToProcessorMap("listBackups", &auroraAdminProcessorListBackups{handler: handler}) - self364.AddToProcessorMap("stageRecovery", &auroraAdminProcessorStageRecovery{handler: handler}) - self364.AddToProcessorMap("queryRecovery", &auroraAdminProcessorQueryRecovery{handler: handler}) - self364.AddToProcessorMap("deleteRecoveryTasks", &auroraAdminProcessorDeleteRecoveryTasks{handler: handler}) - self364.AddToProcessorMap("commitRecovery", &auroraAdminProcessorCommitRecovery{handler: handler}) - self364.AddToProcessorMap("unloadRecovery", &auroraAdminProcessorUnloadRecovery{handler: handler}) - self364.AddToProcessorMap("startMaintenance", &auroraAdminProcessorStartMaintenance{handler: handler}) - self364.AddToProcessorMap("drainHosts", &auroraAdminProcessorDrainHosts{handler: handler}) - self364.AddToProcessorMap("maintenanceStatus", &auroraAdminProcessorMaintenanceStatus{handler: handler}) - self364.AddToProcessorMap("endMaintenance", &auroraAdminProcessorEndMaintenance{handler: handler}) - self364.AddToProcessorMap("slaDrainHosts", &auroraAdminProcessorSlaDrainHosts{handler: handler}) - self364.AddToProcessorMap("snapshot", &auroraAdminProcessorSnapshot{handler: handler}) - self364.AddToProcessorMap("triggerExplicitTaskReconciliation", &auroraAdminProcessorTriggerExplicitTaskReconciliation{handler: handler}) - self364.AddToProcessorMap("triggerImplicitTaskReconciliation", &auroraAdminProcessorTriggerImplicitTaskReconciliation{handler: handler}) - self364.AddToProcessorMap("pruneTasks", &auroraAdminProcessorPruneTasks{handler: handler}) - return self364 + 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 } type auroraAdminProcessorSetQuota struct { diff --git a/gen-go/apache/aurora/auroraschedulermanager.go b/gen-go/apache/aurora/auroraschedulermanager.go index 24aeb65..a448b72 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 { - error137 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error138 error - error138, err = error137.Read(iprot) + error131 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error132 error + error132, err = error131.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error138 + err = error132 return } if mTypeId != thrift.REPLY { @@ -252,16 +252,16 @@ func (p *AuroraSchedulerManagerClient) recvScheduleCronJob() (value *Response, e return } if mTypeId == thrift.EXCEPTION { - error139 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error140 error - error140, err = error139.Read(iprot) + error133 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error134 error + error134, err = error133.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error140 + err = error134 return } if mTypeId != thrift.REPLY { @@ -332,16 +332,16 @@ func (p *AuroraSchedulerManagerClient) recvDescheduleCronJob() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error141 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error142 error - error142, err = error141.Read(iprot) + error135 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error136 error + error136, err = error135.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error142 + err = error136 return } if mTypeId != thrift.REPLY { @@ -412,16 +412,16 @@ func (p *AuroraSchedulerManagerClient) recvStartCronJob() (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) + error137 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error138 error + error138, err = error137.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error144 + err = error138 return } if mTypeId != thrift.REPLY { @@ -493,16 +493,16 @@ func (p *AuroraSchedulerManagerClient) recvRestartShards() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error145 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error146 error - error146, err = error145.Read(iprot) + error139 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error140 error + error140, err = error139.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error146 + err = error140 return } if mTypeId != thrift.REPLY { @@ -576,16 +576,16 @@ func (p *AuroraSchedulerManagerClient) recvKillTasks() (value *Response, err err return } if mTypeId == thrift.EXCEPTION { - error147 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error148 error - error148, err = error147.Read(iprot) + error141 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error142 error + error142, err = error141.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error148 + err = error142 return } if mTypeId != thrift.REPLY { @@ -657,16 +657,16 @@ func (p *AuroraSchedulerManagerClient) recvAddInstances() (value *Response, err return } if mTypeId == thrift.EXCEPTION { - error149 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error150 error - error150, err = error149.Read(iprot) + error143 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error144 error + error144, err = error143.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error150 + err = error144 return } if mTypeId != thrift.REPLY { @@ -737,16 +737,16 @@ func (p *AuroraSchedulerManagerClient) recvReplaceCronTemplate() (value *Respons return } if mTypeId == thrift.EXCEPTION { - error151 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error152 error - error152, err = error151.Read(iprot) + error145 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error146 error + error146, err = error145.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error152 + err = error146 return } if mTypeId != thrift.REPLY { @@ -818,16 +818,16 @@ func (p *AuroraSchedulerManagerClient) recvStartJobUpdate() (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) + error147 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error148 error + error148, err = error147.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error154 + err = error148 return } if mTypeId != thrift.REPLY { @@ -899,16 +899,16 @@ func (p *AuroraSchedulerManagerClient) recvPauseJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error155 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error156 error - error156, err = error155.Read(iprot) + error149 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error150 error + error150, err = error149.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error156 + err = error150 return } if mTypeId != thrift.REPLY { @@ -980,16 +980,16 @@ func (p *AuroraSchedulerManagerClient) recvResumeJobUpdate() (value *Response, e return } if mTypeId == thrift.EXCEPTION { - error157 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error158 error - error158, err = error157.Read(iprot) + error151 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error152 error + error152, err = error151.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error158 + err = error152 return } if mTypeId != thrift.REPLY { @@ -1061,16 +1061,16 @@ func (p *AuroraSchedulerManagerClient) recvAbortJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error159 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error160 error - error160, err = error159.Read(iprot) + error153 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error154 error + error154, err = error153.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error160 + err = error154 return } if mTypeId != thrift.REPLY { @@ -1142,16 +1142,16 @@ func (p *AuroraSchedulerManagerClient) recvRollbackJobUpdate() (value *Response, return } if mTypeId == thrift.EXCEPTION { - error161 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error162 error - error162, err = error161.Read(iprot) + error155 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error156 error + error156, err = error155.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error162 + err = error156 return } if mTypeId != thrift.REPLY { @@ -1223,16 +1223,16 @@ func (p *AuroraSchedulerManagerClient) recvPulseJobUpdate() (value *Response, er return } if mTypeId == thrift.EXCEPTION { - error163 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") - var error164 error - error164, err = error163.Read(iprot) + error157 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception") + var error158 error + error158, err = error157.Read(iprot) if err != nil { return } if err = iprot.ReadMessageEnd(); err != nil { return } - err = error164 + err = error158 return } if mTypeId != thrift.REPLY { @@ -1255,22 +1255,22 @@ type AuroraSchedulerManagerProcessor struct { } func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor { - self165 := &AuroraSchedulerManagerProcessor{NewReadOnlySchedulerProcessor(handler)} - self165.AddToProcessorMap("createJob", &auroraSchedulerManagerProcessorCreateJob{handler: handler}) - self165.AddToProcessorMap("scheduleCronJob", &auroraSchedulerManagerProcessorScheduleCronJob{handler: handler}) - self165.AddToProcessorMap("descheduleCronJob", &auroraSchedulerManagerProcessorDescheduleCronJob{handler: handler}) - self165.AddToProcessorMap("startCronJob", &auroraSchedulerManagerProcessorStartCronJob{handler: handler}) - self165.AddToProcessorMap("restartShards", &auroraSchedulerManagerProcessorRestartShards{handler: handler}) - self165.AddToProcessorMap("killTasks", &auroraSchedulerManagerProcessorKillTasks{handler: handler}) - self165.AddToProcessorMap("addInstances", &auroraSchedulerManagerProcessorAddInstances{handler: handler}) - self165.AddToProcessorMap("replaceCronTemplate", &auroraSchedulerManagerProcessorReplaceCronTemplate{handler: handler}) - self165.AddToProcessorMap("startJobUpdate", &auroraSchedulerManagerProcessorStartJobUpdate{handler: handler}) - self165.AddToProcessorMap("pauseJobUpdate", &auroraSchedulerManagerProcessorPauseJobUpdate{handler: handler}) - self165.AddToProcessorMap("resumeJobUpdate", &auroraSchedulerManagerProcessorResumeJobUpdate{handler: handler}) - self165.AddToProcessorMap("abortJobUpdate", &auroraSchedulerManagerProcessorAbortJobUpdate{handler: handler}) - self165.AddToProcessorMap("rollbackJobUpdate", &auroraSchedulerManagerProcessorRollbackJobUpdate{handler: handler}) - self165.AddToProcessorMap("pulseJobUpdate", &auroraSchedulerManagerProcessorPulseJobUpdate{handler: handler}) - return self165 + 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 } 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 _elem166 int32 + var _elem160 int32 if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem166 = v + _elem160 = v } - p.ShardIds[_elem166] = true + p.ShardIds[_elem160] = 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 _elem167 int32 + var _elem161 int32 if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem167 = v + _elem161 = v } - p.Instances[_elem167] = true + p.Instances[_elem161] = 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 023b2f9..2c2687f 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 @@ -30,7 +30,7 @@ func Usage() { fmt.Fprintln(os.Stderr, " Response getQuota(string ownerRole)") fmt.Fprintln(os.Stderr, " Response populateJobConfig(JobConfiguration description)") fmt.Fprintln(os.Stderr, " Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery)") - fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query)") + fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateQuery query)") fmt.Fprintln(os.Stderr, " Response getJobUpdateDiff(JobUpdateRequest request)") fmt.Fprintln(os.Stderr, " Response getTierConfigs()") fmt.Fprintln(os.Stderr) @@ -316,8 +316,8 @@ func main() { fmt.Print("\n") break case "getJobUpdateDetails": - if flag.NArg()-1 != 2 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 2 args") + if flag.NArg()-1 != 1 { + fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") flag.Usage() } arg119 := flag.Arg(1) @@ -330,14 +330,22 @@ func main() { } factory122 := thrift.NewTSimpleJSONProtocolFactory() jsProt123 := factory122.GetProtocol(mbTrans120) - argvalue0 := aurora.NewJobUpdateKey() + argvalue0 := aurora.NewJobUpdateQuery() err124 := argvalue0.Read(jsProt123) if err124 != nil { Usage() return } value0 := argvalue0 - arg125 := flag.Arg(2) + fmt.Print(client.GetJobUpdateDetails(value0)) + fmt.Print("\n") + break + case "getJobUpdateDiff": + if flag.NArg()-1 != 1 { + 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) @@ -347,34 +355,9 @@ func main() { } factory128 := thrift.NewTSimpleJSONProtocolFactory() jsProt129 := factory128.GetProtocol(mbTrans126) - argvalue1 := aurora.NewJobUpdateQuery() - err130 := argvalue1.Read(jsProt129) - if err130 != nil { - Usage() - return - } - value1 := argvalue1 - fmt.Print(client.GetJobUpdateDetails(value0, value1)) - fmt.Print("\n") - break - case "getJobUpdateDiff": - if flag.NArg()-1 != 1 { - fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") - flag.Usage() - } - arg131 := flag.Arg(1) - mbTrans132 := thrift.NewTMemoryBufferLen(len(arg131)) - defer mbTrans132.Close() - _, err133 := mbTrans132.WriteString(arg131) - if err133 != nil { - Usage() - return - } - factory134 := thrift.NewTSimpleJSONProtocolFactory() - jsProt135 := factory134.GetProtocol(mbTrans132) argvalue0 := aurora.NewJobUpdateRequest() - err136 := argvalue0.Read(jsProt135) - if err136 != nil { + err130 := argvalue0.Read(jsProt129) + if err130 != nil { Usage() return } diff --git a/gen-go/apache/aurora/readonlyscheduler.go b/gen-go/apache/aurora/readonlyscheduler.go index e7eaa4d..dba7255 100644 --- a/gen-go/apache/aurora/readonlyscheduler.go +++ b/gen-go/apache/aurora/readonlyscheduler.go @@ -68,9 +68,8 @@ type ReadOnlyScheduler interface { // Gets job update details. // // Parameters: - // - Key // - Query - GetJobUpdateDetails(key *JobUpdateKey, query *JobUpdateQuery) (r *Response, err error) + GetJobUpdateDetails(query *JobUpdateQuery) (r *Response, err error) // Gets the diff between client (desired) and server (current) job states. // // Parameters: @@ -897,16 +896,15 @@ func (p *ReadOnlySchedulerClient) recvGetJobUpdateSummaries() (value *Response, // Gets job update details. // // Parameters: -// - Key // - Query -func (p *ReadOnlySchedulerClient) GetJobUpdateDetails(key *JobUpdateKey, query *JobUpdateQuery) (r *Response, err error) { - if err = p.sendGetJobUpdateDetails(key, query); err != nil { +func (p *ReadOnlySchedulerClient) GetJobUpdateDetails(query *JobUpdateQuery) (r *Response, err error) { + if err = p.sendGetJobUpdateDetails(query); err != nil { return } return p.recvGetJobUpdateDetails() } -func (p *ReadOnlySchedulerClient) sendGetJobUpdateDetails(key *JobUpdateKey, query *JobUpdateQuery) (err error) { +func (p *ReadOnlySchedulerClient) sendGetJobUpdateDetails(query *JobUpdateQuery) (err error) { oprot := p.OutputProtocol if oprot == nil { oprot = p.ProtocolFactory.GetProtocol(p.Transport) @@ -917,7 +915,6 @@ func (p *ReadOnlySchedulerClient) sendGetJobUpdateDetails(key *JobUpdateKey, que return } args := ReadOnlySchedulerGetJobUpdateDetailsArgs{ - Key: key, Query: query, } if err = args.Write(oprot); err != nil { @@ -1684,7 +1681,7 @@ func (p *readOnlySchedulerProcessorGetJobUpdateDetails) Process(seqId int32, ipr result := ReadOnlySchedulerGetJobUpdateDetailsResult{} var retval *Response var err2 error - if retval, err2 = p.handler.GetJobUpdateDetails(args.Key, args.Query); err2 != nil { + if retval, err2 = p.handler.GetJobUpdateDetails(args.Query); err2 != nil { x := thrift.NewTApplicationException(thrift.INTERNAL_ERROR, "Internal error processing getJobUpdateDetails: "+err2.Error()) oprot.WriteMessageBegin("getJobUpdateDetails", thrift.EXCEPTION, seqId) x.Write(oprot) @@ -3741,10 +3738,9 @@ func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) String() string { } // Attributes: -// - Key // - Query type ReadOnlySchedulerGetJobUpdateDetailsArgs struct { - Key *JobUpdateKey `thrift:"key,1" json:"key"` + // unused field # 1 Query *JobUpdateQuery `thrift:"query,2" json:"query"` } @@ -3752,15 +3748,6 @@ func NewReadOnlySchedulerGetJobUpdateDetailsArgs() *ReadOnlySchedulerGetJobUpdat return &ReadOnlySchedulerGetJobUpdateDetailsArgs{} } -var ReadOnlySchedulerGetJobUpdateDetailsArgs_Key_DEFAULT *JobUpdateKey - -func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) GetKey() *JobUpdateKey { - if !p.IsSetKey() { - return ReadOnlySchedulerGetJobUpdateDetailsArgs_Key_DEFAULT - } - return p.Key -} - var ReadOnlySchedulerGetJobUpdateDetailsArgs_Query_DEFAULT *JobUpdateQuery func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery() *JobUpdateQuery { @@ -3769,10 +3756,6 @@ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery() *JobUpdateQuery { } return p.Query } -func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetKey() bool { - return p.Key != nil -} - func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetQuery() bool { return p.Query != nil } @@ -3791,10 +3774,6 @@ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) Read(iprot thrift.TProtocol) 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 @@ -3814,14 +3793,6 @@ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) Read(iprot thrift.TProtocol) return nil } -func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) readField1(iprot thrift.TProtocol) error { - p.Key = &JobUpdateKey{} - if err := p.Key.Read(iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Key), err) - } - return nil -} - func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) readField2(iprot thrift.TProtocol) error { p.Query = &JobUpdateQuery{} if err := p.Query.Read(iprot); err != nil { @@ -3834,9 +3805,6 @@ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) Write(oprot thrift.TProtocol) if err := oprot.WriteStructBegin("getJobUpdateDetails_args"); 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 } @@ -3849,19 +3817,6 @@ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) Write(oprot thrift.TProtocol) return nil } -func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) writeField1(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("key", thrift.STRUCT, 1); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:key: ", p), err) - } - if err := p.Key.Write(oprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Key), err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 1:key: ", p), err) - } - return err -} - func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("query", thrift.STRUCT, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:query: ", p), err) diff --git a/gen-go/apache/aurora/ttypes.go b/gen-go/apache/aurora/ttypes.go index 285b9c1..1f1d45c 100644 --- a/gen-go/apache/aurora/ttypes.go +++ b/gen-go/apache/aurora/ttypes.go @@ -12093,21 +12093,26 @@ func (p *JobUpdateRequest) String() string { // - Limit: Number or records to serve. Used by pagination. type JobUpdateQuery struct { // unused field # 1 - Role string `thrift:"role,2" json:"role"` - JobKey *JobKey `thrift:"jobKey,3" json:"jobKey"` - User string `thrift:"user,4" json:"user"` - UpdateStatuses map[JobUpdateStatus]bool `thrift:"updateStatuses,5" json:"updateStatuses"` + Role *string `thrift:"role,2" json:"role,omitempty"` + JobKey *JobKey `thrift:"jobKey,3" json:"jobKey,omitempty"` + User *string `thrift:"user,4" json:"user,omitempty"` + UpdateStatuses map[JobUpdateStatus]bool `thrift:"updateStatuses,5" json:"updateStatuses,omitempty"` Offset int32 `thrift:"offset,6" json:"offset"` Limit int32 `thrift:"limit,7" json:"limit"` - Key *JobUpdateKey `thrift:"key,8" json:"key"` + Key *JobUpdateKey `thrift:"key,8" json:"key,omitempty"` } func NewJobUpdateQuery() *JobUpdateQuery { return &JobUpdateQuery{} } +var JobUpdateQuery_Role_DEFAULT string + func (p *JobUpdateQuery) GetRole() string { - return p.Role + if !p.IsSetRole() { + return JobUpdateQuery_Role_DEFAULT + } + return *p.Role } var JobUpdateQuery_Key_DEFAULT *JobUpdateKey @@ -12128,10 +12133,17 @@ func (p *JobUpdateQuery) GetJobKey() *JobKey { return p.JobKey } +var JobUpdateQuery_User_DEFAULT string + func (p *JobUpdateQuery) GetUser() string { - return p.User + if !p.IsSetUser() { + return JobUpdateQuery_User_DEFAULT + } + return *p.User } +var JobUpdateQuery_UpdateStatuses_DEFAULT map[JobUpdateStatus]bool + func (p *JobUpdateQuery) GetUpdateStatuses() map[JobUpdateStatus]bool { return p.UpdateStatuses } @@ -12143,6 +12155,10 @@ func (p *JobUpdateQuery) GetOffset() int32 { func (p *JobUpdateQuery) GetLimit() int32 { return p.Limit } +func (p *JobUpdateQuery) IsSetRole() bool { + return p.Role != nil +} + func (p *JobUpdateQuery) IsSetKey() bool { return p.Key != nil } @@ -12151,6 +12167,14 @@ func (p *JobUpdateQuery) IsSetJobKey() bool { return p.JobKey != nil } +func (p *JobUpdateQuery) IsSetUser() bool { + return p.User != nil +} + +func (p *JobUpdateQuery) IsSetUpdateStatuses() bool { + return p.UpdateStatuses != nil +} + func (p *JobUpdateQuery) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) @@ -12212,7 +12236,7 @@ func (p *JobUpdateQuery) readField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { - p.Role = v + p.Role = &v } return nil } @@ -12237,7 +12261,7 @@ func (p *JobUpdateQuery) readField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { - p.User = v + p.User = &v } return nil } @@ -12318,61 +12342,69 @@ func (p *JobUpdateQuery) Write(oprot thrift.TProtocol) error { } func (p *JobUpdateQuery) writeField2(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("role", thrift.STRING, 2); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:role: ", p), err) - } - if err := oprot.WriteString(string(p.Role)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T.role (2) field write error: ", p), err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 2:role: ", p), err) + if p.IsSetRole() { + if err := oprot.WriteFieldBegin("role", thrift.STRING, 2); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:role: ", p), err) + } + if err := oprot.WriteString(string(*p.Role)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.role (2) field write error: ", p), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 2:role: ", p), err) + } } return err } func (p *JobUpdateQuery) writeField3(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("jobKey", thrift.STRUCT, 3); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:jobKey: ", p), err) - } - if err := p.JobKey.Write(oprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.JobKey), err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 3:jobKey: ", p), err) + if p.IsSetJobKey() { + if err := oprot.WriteFieldBegin("jobKey", thrift.STRUCT, 3); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:jobKey: ", p), err) + } + if err := p.JobKey.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.JobKey), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 3:jobKey: ", p), err) + } } return err } func (p *JobUpdateQuery) writeField4(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("user", thrift.STRING, 4); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:user: ", p), err) - } - if err := oprot.WriteString(string(p.User)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T.user (4) field write error: ", p), err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 4:user: ", p), err) + if p.IsSetUser() { + if err := oprot.WriteFieldBegin("user", thrift.STRING, 4); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:user: ", p), err) + } + if err := oprot.WriteString(string(*p.User)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.user (4) field write error: ", p), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 4:user: ", p), err) + } } return err } func (p *JobUpdateQuery) writeField5(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("updateStatuses", thrift.SET, 5); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:updateStatuses: ", p), err) - } - if err := oprot.WriteSetBegin(thrift.I32, len(p.UpdateStatuses)); err != nil { - return thrift.PrependError("error writing set begin: ", err) - } - for v, _ := range p.UpdateStatuses { - if err := oprot.WriteI32(int32(v)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) + if p.IsSetUpdateStatuses() { + if err := oprot.WriteFieldBegin("updateStatuses", thrift.SET, 5); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:updateStatuses: ", p), err) + } + if err := oprot.WriteSetBegin(thrift.I32, len(p.UpdateStatuses)); err != nil { + return thrift.PrependError("error writing set begin: ", err) + } + for v, _ := range p.UpdateStatuses { + if err := oprot.WriteI32(int32(v)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) + } + } + if err := oprot.WriteSetEnd(); err != nil { + return thrift.PrependError("error writing set end: ", err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 5:updateStatuses: ", p), err) } - } - if err := oprot.WriteSetEnd(); err != nil { - return thrift.PrependError("error writing set end: ", err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 5:updateStatuses: ", p), err) } return err } @@ -12404,14 +12436,16 @@ func (p *JobUpdateQuery) writeField7(oprot thrift.TProtocol) (err error) { } func (p *JobUpdateQuery) writeField8(oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin("key", thrift.STRUCT, 8); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:key: ", p), err) - } - if err := p.Key.Write(oprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Key), err) - } - if err := oprot.WriteFieldEnd(); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 8:key: ", p), err) + if p.IsSetKey() { + if err := oprot.WriteFieldBegin("key", thrift.STRUCT, 8); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:key: ", p), err) + } + if err := p.Key.Write(oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Key), err) + } + if err := oprot.WriteFieldEnd(); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 8:key: ", p), err) + } } return err }