Upgrading to Thrift 0.14.0 (#126)
Upgrading thrift to 0.14.0 in order to pick up bug fixes, including the fix for trying to write to closed connections.
This commit is contained in:
Renán I. Del Valle
GitHub
parent
8be66da88a
commit
511e76a0ac
10 changed files with 10403 additions and 7332 deletions
18
CHANGELOG.md
18
CHANGELOG.md
|
|
@ -1,4 +1,20 @@
|
|||
1.22.1 (unreleased)
|
||||
1.22.5 (unreleased)
|
||||
|
||||
* Upgrading to thrift 0.14.0
|
||||
|
||||
1.22.4
|
||||
|
||||
* Updates which result in a no-op now return a response value so that the caller may analyze it to determine what happened
|
||||
|
||||
1.22.3
|
||||
|
||||
* Contains a monitor timeout fix. Previously an error was being left unchecked which made a specific monitor timining out not be handled properly.
|
||||
|
||||
1.22.2
|
||||
|
||||
* Bug fix: Change in retry mechanism created a deadlock. This release reverts that particular change.
|
||||
|
||||
1.22.1
|
||||
|
||||
* Adding safeguards against setting multiple constraints with the same name for a single task.
|
||||
|
||||
|
|
|
|||
|
|
@ -1,5 +1,4 @@
|
|||
// Autogenerated by Thrift Compiler (0.13.0)
|
||||
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
// Code generated by Thrift Compiler (0.14.0). DO NOT EDIT.
|
||||
|
||||
package aurora
|
||||
|
||||
|
|
|
|||
|
|
@ -1,13 +1,12 @@
|
|||
// Autogenerated by Thrift Compiler (0.13.0)
|
||||
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
// Code generated by Thrift Compiler (0.14.0). DO NOT EDIT.
|
||||
|
||||
package aurora
|
||||
|
||||
import(
|
||||
"bytes"
|
||||
"context"
|
||||
"reflect"
|
||||
"fmt"
|
||||
"time"
|
||||
"github.com/apache/thrift/lib/go/thrift"
|
||||
)
|
||||
|
||||
|
|
@ -15,7 +14,7 @@ import(
|
|||
var _ = thrift.ZERO
|
||||
var _ = fmt.Printf
|
||||
var _ = context.Background
|
||||
var _ = reflect.DeepEqual
|
||||
var _ = time.Now
|
||||
var _ = bytes.Equal
|
||||
|
||||
const AURORA_EXECUTOR_NAME = "AuroraExecutor"
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load diff
|
|
@ -1,5 +1,4 @@
|
|||
// Autogenerated by Thrift Compiler (0.13.0)
|
||||
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
// Code generated by Thrift Compiler (0.14.0). DO NOT EDIT.
|
||||
|
||||
package main
|
||||
|
||||
|
|
@ -196,19 +195,19 @@ func main() {
|
|||
}
|
||||
argvalue0 := flag.Arg(1)
|
||||
value0 := argvalue0
|
||||
arg355 := flag.Arg(2)
|
||||
mbTrans356 := thrift.NewTMemoryBufferLen(len(arg355))
|
||||
defer mbTrans356.Close()
|
||||
_, err357 := mbTrans356.WriteString(arg355)
|
||||
if err357 != nil {
|
||||
arg405 := flag.Arg(2)
|
||||
mbTrans406 := thrift.NewTMemoryBufferLen(len(arg405))
|
||||
defer mbTrans406.Close()
|
||||
_, err407 := mbTrans406.WriteString(arg405)
|
||||
if err407 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory358 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt359 := factory358.GetProtocol(mbTrans356)
|
||||
factory408 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt409 := factory408.GetProtocol(mbTrans406)
|
||||
argvalue1 := aurora.NewResourceAggregate()
|
||||
err360 := argvalue1.Read(jsProt359)
|
||||
if err360 != nil {
|
||||
err410 := argvalue1.Read(context.Background(), jsProt409)
|
||||
if err410 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -264,19 +263,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "QueryRecovery requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg363 := flag.Arg(1)
|
||||
mbTrans364 := thrift.NewTMemoryBufferLen(len(arg363))
|
||||
defer mbTrans364.Close()
|
||||
_, err365 := mbTrans364.WriteString(arg363)
|
||||
if err365 != nil {
|
||||
arg413 := flag.Arg(1)
|
||||
mbTrans414 := thrift.NewTMemoryBufferLen(len(arg413))
|
||||
defer mbTrans414.Close()
|
||||
_, err415 := mbTrans414.WriteString(arg413)
|
||||
if err415 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory366 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt367 := factory366.GetProtocol(mbTrans364)
|
||||
factory416 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt417 := factory416.GetProtocol(mbTrans414)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err368 := argvalue0.Read(jsProt367)
|
||||
if err368 != nil {
|
||||
err418 := argvalue0.Read(context.Background(), jsProt417)
|
||||
if err418 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -289,19 +288,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "DeleteRecoveryTasks requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg369 := flag.Arg(1)
|
||||
mbTrans370 := thrift.NewTMemoryBufferLen(len(arg369))
|
||||
defer mbTrans370.Close()
|
||||
_, err371 := mbTrans370.WriteString(arg369)
|
||||
if err371 != nil {
|
||||
arg419 := flag.Arg(1)
|
||||
mbTrans420 := thrift.NewTMemoryBufferLen(len(arg419))
|
||||
defer mbTrans420.Close()
|
||||
_, err421 := mbTrans420.WriteString(arg419)
|
||||
if err421 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory372 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt373 := factory372.GetProtocol(mbTrans370)
|
||||
factory422 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt423 := factory422.GetProtocol(mbTrans420)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err374 := argvalue0.Read(jsProt373)
|
||||
if err374 != nil {
|
||||
err424 := argvalue0.Read(context.Background(), jsProt423)
|
||||
if err424 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -330,19 +329,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "StartMaintenance requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg375 := flag.Arg(1)
|
||||
mbTrans376 := thrift.NewTMemoryBufferLen(len(arg375))
|
||||
defer mbTrans376.Close()
|
||||
_, err377 := mbTrans376.WriteString(arg375)
|
||||
if err377 != nil {
|
||||
arg425 := flag.Arg(1)
|
||||
mbTrans426 := thrift.NewTMemoryBufferLen(len(arg425))
|
||||
defer mbTrans426.Close()
|
||||
_, err427 := mbTrans426.WriteString(arg425)
|
||||
if err427 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory378 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt379 := factory378.GetProtocol(mbTrans376)
|
||||
factory428 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt429 := factory428.GetProtocol(mbTrans426)
|
||||
argvalue0 := aurora.NewHosts()
|
||||
err380 := argvalue0.Read(jsProt379)
|
||||
if err380 != nil {
|
||||
err430 := argvalue0.Read(context.Background(), jsProt429)
|
||||
if err430 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -355,19 +354,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "DrainHosts requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg381 := flag.Arg(1)
|
||||
mbTrans382 := thrift.NewTMemoryBufferLen(len(arg381))
|
||||
defer mbTrans382.Close()
|
||||
_, err383 := mbTrans382.WriteString(arg381)
|
||||
if err383 != nil {
|
||||
arg431 := flag.Arg(1)
|
||||
mbTrans432 := thrift.NewTMemoryBufferLen(len(arg431))
|
||||
defer mbTrans432.Close()
|
||||
_, err433 := mbTrans432.WriteString(arg431)
|
||||
if err433 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory384 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt385 := factory384.GetProtocol(mbTrans382)
|
||||
factory434 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt435 := factory434.GetProtocol(mbTrans432)
|
||||
argvalue0 := aurora.NewHosts()
|
||||
err386 := argvalue0.Read(jsProt385)
|
||||
if err386 != nil {
|
||||
err436 := argvalue0.Read(context.Background(), jsProt435)
|
||||
if err436 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -380,19 +379,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "MaintenanceStatus requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg387 := flag.Arg(1)
|
||||
mbTrans388 := thrift.NewTMemoryBufferLen(len(arg387))
|
||||
defer mbTrans388.Close()
|
||||
_, err389 := mbTrans388.WriteString(arg387)
|
||||
if err389 != nil {
|
||||
arg437 := flag.Arg(1)
|
||||
mbTrans438 := thrift.NewTMemoryBufferLen(len(arg437))
|
||||
defer mbTrans438.Close()
|
||||
_, err439 := mbTrans438.WriteString(arg437)
|
||||
if err439 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory390 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt391 := factory390.GetProtocol(mbTrans388)
|
||||
factory440 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt441 := factory440.GetProtocol(mbTrans438)
|
||||
argvalue0 := aurora.NewHosts()
|
||||
err392 := argvalue0.Read(jsProt391)
|
||||
if err392 != nil {
|
||||
err442 := argvalue0.Read(context.Background(), jsProt441)
|
||||
if err442 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -405,19 +404,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "EndMaintenance requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg393 := flag.Arg(1)
|
||||
mbTrans394 := thrift.NewTMemoryBufferLen(len(arg393))
|
||||
defer mbTrans394.Close()
|
||||
_, err395 := mbTrans394.WriteString(arg393)
|
||||
if err395 != nil {
|
||||
arg443 := flag.Arg(1)
|
||||
mbTrans444 := thrift.NewTMemoryBufferLen(len(arg443))
|
||||
defer mbTrans444.Close()
|
||||
_, err445 := mbTrans444.WriteString(arg443)
|
||||
if err445 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory396 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt397 := factory396.GetProtocol(mbTrans394)
|
||||
factory446 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt447 := factory446.GetProtocol(mbTrans444)
|
||||
argvalue0 := aurora.NewHosts()
|
||||
err398 := argvalue0.Read(jsProt397)
|
||||
if err398 != nil {
|
||||
err448 := argvalue0.Read(context.Background(), jsProt447)
|
||||
if err448 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -430,42 +429,42 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "SlaDrainHosts requires 3 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg399 := flag.Arg(1)
|
||||
mbTrans400 := thrift.NewTMemoryBufferLen(len(arg399))
|
||||
defer mbTrans400.Close()
|
||||
_, err401 := mbTrans400.WriteString(arg399)
|
||||
if err401 != nil {
|
||||
arg449 := flag.Arg(1)
|
||||
mbTrans450 := thrift.NewTMemoryBufferLen(len(arg449))
|
||||
defer mbTrans450.Close()
|
||||
_, err451 := mbTrans450.WriteString(arg449)
|
||||
if err451 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory402 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt403 := factory402.GetProtocol(mbTrans400)
|
||||
factory452 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt453 := factory452.GetProtocol(mbTrans450)
|
||||
argvalue0 := aurora.NewHosts()
|
||||
err404 := argvalue0.Read(jsProt403)
|
||||
if err404 != nil {
|
||||
err454 := argvalue0.Read(context.Background(), jsProt453)
|
||||
if err454 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
arg405 := flag.Arg(2)
|
||||
mbTrans406 := thrift.NewTMemoryBufferLen(len(arg405))
|
||||
defer mbTrans406.Close()
|
||||
_, err407 := mbTrans406.WriteString(arg405)
|
||||
if err407 != nil {
|
||||
arg455 := flag.Arg(2)
|
||||
mbTrans456 := thrift.NewTMemoryBufferLen(len(arg455))
|
||||
defer mbTrans456.Close()
|
||||
_, err457 := mbTrans456.WriteString(arg455)
|
||||
if err457 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory408 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt409 := factory408.GetProtocol(mbTrans406)
|
||||
factory458 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt459 := factory458.GetProtocol(mbTrans456)
|
||||
argvalue1 := aurora.NewSlaPolicy()
|
||||
err410 := argvalue1.Read(jsProt409)
|
||||
if err410 != nil {
|
||||
err460 := argvalue1.Read(context.Background(), jsProt459)
|
||||
if err460 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value1 := argvalue1
|
||||
argvalue2, err411 := (strconv.ParseInt(flag.Arg(3), 10, 64))
|
||||
if err411 != nil {
|
||||
argvalue2, err461 := (strconv.ParseInt(flag.Arg(3), 10, 64))
|
||||
if err461 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -486,19 +485,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "TriggerExplicitTaskReconciliation requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg412 := flag.Arg(1)
|
||||
mbTrans413 := thrift.NewTMemoryBufferLen(len(arg412))
|
||||
defer mbTrans413.Close()
|
||||
_, err414 := mbTrans413.WriteString(arg412)
|
||||
if err414 != nil {
|
||||
arg462 := flag.Arg(1)
|
||||
mbTrans463 := thrift.NewTMemoryBufferLen(len(arg462))
|
||||
defer mbTrans463.Close()
|
||||
_, err464 := mbTrans463.WriteString(arg462)
|
||||
if err464 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory415 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt416 := factory415.GetProtocol(mbTrans413)
|
||||
factory465 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt466 := factory465.GetProtocol(mbTrans463)
|
||||
argvalue0 := aurora.NewExplicitReconciliationSettings()
|
||||
err417 := argvalue0.Read(jsProt416)
|
||||
if err417 != nil {
|
||||
err467 := argvalue0.Read(context.Background(), jsProt466)
|
||||
if err467 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -519,19 +518,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PruneTasks requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg418 := flag.Arg(1)
|
||||
mbTrans419 := thrift.NewTMemoryBufferLen(len(arg418))
|
||||
defer mbTrans419.Close()
|
||||
_, err420 := mbTrans419.WriteString(arg418)
|
||||
if err420 != nil {
|
||||
arg468 := flag.Arg(1)
|
||||
mbTrans469 := thrift.NewTMemoryBufferLen(len(arg468))
|
||||
defer mbTrans469.Close()
|
||||
_, err470 := mbTrans469.WriteString(arg468)
|
||||
if err470 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory421 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt422 := factory421.GetProtocol(mbTrans419)
|
||||
factory471 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt472 := factory471.GetProtocol(mbTrans469)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err423 := argvalue0.Read(jsProt422)
|
||||
if err423 != nil {
|
||||
err473 := argvalue0.Read(context.Background(), jsProt472)
|
||||
if err473 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -544,19 +543,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "CreateJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg424 := flag.Arg(1)
|
||||
mbTrans425 := thrift.NewTMemoryBufferLen(len(arg424))
|
||||
defer mbTrans425.Close()
|
||||
_, err426 := mbTrans425.WriteString(arg424)
|
||||
if err426 != nil {
|
||||
arg474 := flag.Arg(1)
|
||||
mbTrans475 := thrift.NewTMemoryBufferLen(len(arg474))
|
||||
defer mbTrans475.Close()
|
||||
_, err476 := mbTrans475.WriteString(arg474)
|
||||
if err476 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory427 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt428 := factory427.GetProtocol(mbTrans425)
|
||||
factory477 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt478 := factory477.GetProtocol(mbTrans475)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err429 := argvalue0.Read(jsProt428)
|
||||
if err429 != nil {
|
||||
err479 := argvalue0.Read(context.Background(), jsProt478)
|
||||
if err479 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -569,19 +568,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg430 := flag.Arg(1)
|
||||
mbTrans431 := thrift.NewTMemoryBufferLen(len(arg430))
|
||||
defer mbTrans431.Close()
|
||||
_, err432 := mbTrans431.WriteString(arg430)
|
||||
if err432 != nil {
|
||||
arg480 := flag.Arg(1)
|
||||
mbTrans481 := thrift.NewTMemoryBufferLen(len(arg480))
|
||||
defer mbTrans481.Close()
|
||||
_, err482 := mbTrans481.WriteString(arg480)
|
||||
if err482 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory433 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt434 := factory433.GetProtocol(mbTrans431)
|
||||
factory483 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt484 := factory483.GetProtocol(mbTrans481)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err435 := argvalue0.Read(jsProt434)
|
||||
if err435 != nil {
|
||||
err485 := argvalue0.Read(context.Background(), jsProt484)
|
||||
if err485 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -594,19 +593,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg436 := flag.Arg(1)
|
||||
mbTrans437 := thrift.NewTMemoryBufferLen(len(arg436))
|
||||
defer mbTrans437.Close()
|
||||
_, err438 := mbTrans437.WriteString(arg436)
|
||||
if err438 != nil {
|
||||
arg486 := flag.Arg(1)
|
||||
mbTrans487 := thrift.NewTMemoryBufferLen(len(arg486))
|
||||
defer mbTrans487.Close()
|
||||
_, err488 := mbTrans487.WriteString(arg486)
|
||||
if err488 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory439 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt440 := factory439.GetProtocol(mbTrans437)
|
||||
factory489 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt490 := factory489.GetProtocol(mbTrans487)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err441 := argvalue0.Read(jsProt440)
|
||||
if err441 != nil {
|
||||
err491 := argvalue0.Read(context.Background(), jsProt490)
|
||||
if err491 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -619,19 +618,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg442 := flag.Arg(1)
|
||||
mbTrans443 := thrift.NewTMemoryBufferLen(len(arg442))
|
||||
defer mbTrans443.Close()
|
||||
_, err444 := mbTrans443.WriteString(arg442)
|
||||
if err444 != nil {
|
||||
arg492 := flag.Arg(1)
|
||||
mbTrans493 := thrift.NewTMemoryBufferLen(len(arg492))
|
||||
defer mbTrans493.Close()
|
||||
_, err494 := mbTrans493.WriteString(arg492)
|
||||
if err494 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory445 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt446 := factory445.GetProtocol(mbTrans443)
|
||||
factory495 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt496 := factory495.GetProtocol(mbTrans493)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err447 := argvalue0.Read(jsProt446)
|
||||
if err447 != nil {
|
||||
err497 := argvalue0.Read(context.Background(), jsProt496)
|
||||
if err497 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -644,36 +643,36 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "RestartShards requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg448 := flag.Arg(1)
|
||||
mbTrans449 := thrift.NewTMemoryBufferLen(len(arg448))
|
||||
defer mbTrans449.Close()
|
||||
_, err450 := mbTrans449.WriteString(arg448)
|
||||
if err450 != nil {
|
||||
arg498 := flag.Arg(1)
|
||||
mbTrans499 := thrift.NewTMemoryBufferLen(len(arg498))
|
||||
defer mbTrans499.Close()
|
||||
_, err500 := mbTrans499.WriteString(arg498)
|
||||
if err500 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory451 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt452 := factory451.GetProtocol(mbTrans449)
|
||||
factory501 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt502 := factory501.GetProtocol(mbTrans499)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err453 := argvalue0.Read(jsProt452)
|
||||
if err453 != nil {
|
||||
err503 := argvalue0.Read(context.Background(), jsProt502)
|
||||
if err503 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
arg454 := flag.Arg(2)
|
||||
mbTrans455 := thrift.NewTMemoryBufferLen(len(arg454))
|
||||
defer mbTrans455.Close()
|
||||
_, err456 := mbTrans455.WriteString(arg454)
|
||||
if err456 != nil {
|
||||
arg504 := flag.Arg(2)
|
||||
mbTrans505 := thrift.NewTMemoryBufferLen(len(arg504))
|
||||
defer mbTrans505.Close()
|
||||
_, err506 := mbTrans505.WriteString(arg504)
|
||||
if err506 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory457 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt458 := factory457.GetProtocol(mbTrans455)
|
||||
containerStruct1 := aurora.NewAuroraAdminRestartShardsArgs()
|
||||
err459 := containerStruct1.ReadField2(jsProt458)
|
||||
if err459 != nil {
|
||||
factory507 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt508 := factory507.GetProtocol(mbTrans505)
|
||||
containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs()
|
||||
err509 := containerStruct1.ReadField2(context.Background(), jsProt508)
|
||||
if err509 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -687,36 +686,36 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "KillTasks requires 3 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg460 := flag.Arg(1)
|
||||
mbTrans461 := thrift.NewTMemoryBufferLen(len(arg460))
|
||||
defer mbTrans461.Close()
|
||||
_, err462 := mbTrans461.WriteString(arg460)
|
||||
if err462 != nil {
|
||||
arg510 := flag.Arg(1)
|
||||
mbTrans511 := thrift.NewTMemoryBufferLen(len(arg510))
|
||||
defer mbTrans511.Close()
|
||||
_, err512 := mbTrans511.WriteString(arg510)
|
||||
if err512 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory463 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt464 := factory463.GetProtocol(mbTrans461)
|
||||
factory513 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt514 := factory513.GetProtocol(mbTrans511)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err465 := argvalue0.Read(jsProt464)
|
||||
if err465 != nil {
|
||||
err515 := argvalue0.Read(context.Background(), jsProt514)
|
||||
if err515 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
arg466 := flag.Arg(2)
|
||||
mbTrans467 := thrift.NewTMemoryBufferLen(len(arg466))
|
||||
defer mbTrans467.Close()
|
||||
_, err468 := mbTrans467.WriteString(arg466)
|
||||
if err468 != nil {
|
||||
arg516 := flag.Arg(2)
|
||||
mbTrans517 := thrift.NewTMemoryBufferLen(len(arg516))
|
||||
defer mbTrans517.Close()
|
||||
_, err518 := mbTrans517.WriteString(arg516)
|
||||
if err518 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory469 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt470 := factory469.GetProtocol(mbTrans467)
|
||||
containerStruct1 := aurora.NewAuroraAdminKillTasksArgs()
|
||||
err471 := containerStruct1.ReadField2(jsProt470)
|
||||
if err471 != nil {
|
||||
factory519 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt520 := factory519.GetProtocol(mbTrans517)
|
||||
containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs()
|
||||
err521 := containerStruct1.ReadField2(context.Background(), jsProt520)
|
||||
if err521 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -732,25 +731,25 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "AddInstances requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg473 := flag.Arg(1)
|
||||
mbTrans474 := thrift.NewTMemoryBufferLen(len(arg473))
|
||||
defer mbTrans474.Close()
|
||||
_, err475 := mbTrans474.WriteString(arg473)
|
||||
if err475 != nil {
|
||||
arg523 := flag.Arg(1)
|
||||
mbTrans524 := thrift.NewTMemoryBufferLen(len(arg523))
|
||||
defer mbTrans524.Close()
|
||||
_, err525 := mbTrans524.WriteString(arg523)
|
||||
if err525 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory476 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt477 := factory476.GetProtocol(mbTrans474)
|
||||
factory526 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt527 := factory526.GetProtocol(mbTrans524)
|
||||
argvalue0 := aurora.NewInstanceKey()
|
||||
err478 := argvalue0.Read(jsProt477)
|
||||
if err478 != nil {
|
||||
err528 := argvalue0.Read(context.Background(), jsProt527)
|
||||
if err528 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
tmp1, err479 := (strconv.Atoi(flag.Arg(2)))
|
||||
if err479 != nil {
|
||||
tmp1, err529 := (strconv.Atoi(flag.Arg(2)))
|
||||
if err529 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -764,19 +763,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg480 := flag.Arg(1)
|
||||
mbTrans481 := thrift.NewTMemoryBufferLen(len(arg480))
|
||||
defer mbTrans481.Close()
|
||||
_, err482 := mbTrans481.WriteString(arg480)
|
||||
if err482 != nil {
|
||||
arg530 := flag.Arg(1)
|
||||
mbTrans531 := thrift.NewTMemoryBufferLen(len(arg530))
|
||||
defer mbTrans531.Close()
|
||||
_, err532 := mbTrans531.WriteString(arg530)
|
||||
if err532 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory483 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt484 := factory483.GetProtocol(mbTrans481)
|
||||
factory533 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt534 := factory533.GetProtocol(mbTrans531)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err485 := argvalue0.Read(jsProt484)
|
||||
if err485 != nil {
|
||||
err535 := argvalue0.Read(context.Background(), jsProt534)
|
||||
if err535 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -789,19 +788,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg486 := flag.Arg(1)
|
||||
mbTrans487 := thrift.NewTMemoryBufferLen(len(arg486))
|
||||
defer mbTrans487.Close()
|
||||
_, err488 := mbTrans487.WriteString(arg486)
|
||||
if err488 != nil {
|
||||
arg536 := flag.Arg(1)
|
||||
mbTrans537 := thrift.NewTMemoryBufferLen(len(arg536))
|
||||
defer mbTrans537.Close()
|
||||
_, err538 := mbTrans537.WriteString(arg536)
|
||||
if err538 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory489 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt490 := factory489.GetProtocol(mbTrans487)
|
||||
factory539 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt540 := factory539.GetProtocol(mbTrans537)
|
||||
argvalue0 := aurora.NewJobUpdateRequest()
|
||||
err491 := argvalue0.Read(jsProt490)
|
||||
if err491 != nil {
|
||||
err541 := argvalue0.Read(context.Background(), jsProt540)
|
||||
if err541 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -816,19 +815,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg493 := flag.Arg(1)
|
||||
mbTrans494 := thrift.NewTMemoryBufferLen(len(arg493))
|
||||
defer mbTrans494.Close()
|
||||
_, err495 := mbTrans494.WriteString(arg493)
|
||||
if err495 != nil {
|
||||
arg543 := flag.Arg(1)
|
||||
mbTrans544 := thrift.NewTMemoryBufferLen(len(arg543))
|
||||
defer mbTrans544.Close()
|
||||
_, err545 := mbTrans544.WriteString(arg543)
|
||||
if err545 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory496 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt497 := factory496.GetProtocol(mbTrans494)
|
||||
factory546 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt547 := factory546.GetProtocol(mbTrans544)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err498 := argvalue0.Read(jsProt497)
|
||||
if err498 != nil {
|
||||
err548 := argvalue0.Read(context.Background(), jsProt547)
|
||||
if err548 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -843,19 +842,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg500 := flag.Arg(1)
|
||||
mbTrans501 := thrift.NewTMemoryBufferLen(len(arg500))
|
||||
defer mbTrans501.Close()
|
||||
_, err502 := mbTrans501.WriteString(arg500)
|
||||
if err502 != nil {
|
||||
arg550 := flag.Arg(1)
|
||||
mbTrans551 := thrift.NewTMemoryBufferLen(len(arg550))
|
||||
defer mbTrans551.Close()
|
||||
_, err552 := mbTrans551.WriteString(arg550)
|
||||
if err552 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory503 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt504 := factory503.GetProtocol(mbTrans501)
|
||||
factory553 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt554 := factory553.GetProtocol(mbTrans551)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err505 := argvalue0.Read(jsProt504)
|
||||
if err505 != nil {
|
||||
err555 := argvalue0.Read(context.Background(), jsProt554)
|
||||
if err555 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -870,19 +869,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg507 := flag.Arg(1)
|
||||
mbTrans508 := thrift.NewTMemoryBufferLen(len(arg507))
|
||||
defer mbTrans508.Close()
|
||||
_, err509 := mbTrans508.WriteString(arg507)
|
||||
if err509 != nil {
|
||||
arg557 := flag.Arg(1)
|
||||
mbTrans558 := thrift.NewTMemoryBufferLen(len(arg557))
|
||||
defer mbTrans558.Close()
|
||||
_, err559 := mbTrans558.WriteString(arg557)
|
||||
if err559 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory510 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt511 := factory510.GetProtocol(mbTrans508)
|
||||
factory560 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt561 := factory560.GetProtocol(mbTrans558)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err512 := argvalue0.Read(jsProt511)
|
||||
if err512 != nil {
|
||||
err562 := argvalue0.Read(context.Background(), jsProt561)
|
||||
if err562 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -897,19 +896,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg514 := flag.Arg(1)
|
||||
mbTrans515 := thrift.NewTMemoryBufferLen(len(arg514))
|
||||
defer mbTrans515.Close()
|
||||
_, err516 := mbTrans515.WriteString(arg514)
|
||||
if err516 != nil {
|
||||
arg564 := flag.Arg(1)
|
||||
mbTrans565 := thrift.NewTMemoryBufferLen(len(arg564))
|
||||
defer mbTrans565.Close()
|
||||
_, err566 := mbTrans565.WriteString(arg564)
|
||||
if err566 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory517 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt518 := factory517.GetProtocol(mbTrans515)
|
||||
factory567 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt568 := factory567.GetProtocol(mbTrans565)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err519 := argvalue0.Read(jsProt518)
|
||||
if err519 != nil {
|
||||
err569 := argvalue0.Read(context.Background(), jsProt568)
|
||||
if err569 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -924,19 +923,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg521 := flag.Arg(1)
|
||||
mbTrans522 := thrift.NewTMemoryBufferLen(len(arg521))
|
||||
defer mbTrans522.Close()
|
||||
_, err523 := mbTrans522.WriteString(arg521)
|
||||
if err523 != nil {
|
||||
arg571 := flag.Arg(1)
|
||||
mbTrans572 := thrift.NewTMemoryBufferLen(len(arg571))
|
||||
defer mbTrans572.Close()
|
||||
_, err573 := mbTrans572.WriteString(arg571)
|
||||
if err573 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory524 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt525 := factory524.GetProtocol(mbTrans522)
|
||||
factory574 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt575 := factory574.GetProtocol(mbTrans572)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err526 := argvalue0.Read(jsProt525)
|
||||
if err526 != nil {
|
||||
err576 := argvalue0.Read(context.Background(), jsProt575)
|
||||
if err576 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -967,19 +966,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg528 := flag.Arg(1)
|
||||
mbTrans529 := thrift.NewTMemoryBufferLen(len(arg528))
|
||||
defer mbTrans529.Close()
|
||||
_, err530 := mbTrans529.WriteString(arg528)
|
||||
if err530 != nil {
|
||||
arg578 := flag.Arg(1)
|
||||
mbTrans579 := thrift.NewTMemoryBufferLen(len(arg578))
|
||||
defer mbTrans579.Close()
|
||||
_, err580 := mbTrans579.WriteString(arg578)
|
||||
if err580 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory531 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt532 := factory531.GetProtocol(mbTrans529)
|
||||
factory581 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt582 := factory581.GetProtocol(mbTrans579)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err533 := argvalue0.Read(jsProt532)
|
||||
if err533 != nil {
|
||||
err583 := argvalue0.Read(context.Background(), jsProt582)
|
||||
if err583 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -992,19 +991,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg534 := flag.Arg(1)
|
||||
mbTrans535 := thrift.NewTMemoryBufferLen(len(arg534))
|
||||
defer mbTrans535.Close()
|
||||
_, err536 := mbTrans535.WriteString(arg534)
|
||||
if err536 != nil {
|
||||
arg584 := flag.Arg(1)
|
||||
mbTrans585 := thrift.NewTMemoryBufferLen(len(arg584))
|
||||
defer mbTrans585.Close()
|
||||
_, err586 := mbTrans585.WriteString(arg584)
|
||||
if err586 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory537 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt538 := factory537.GetProtocol(mbTrans535)
|
||||
factory587 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt588 := factory587.GetProtocol(mbTrans585)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err539 := argvalue0.Read(jsProt538)
|
||||
if err539 != nil {
|
||||
err589 := argvalue0.Read(context.Background(), jsProt588)
|
||||
if err589 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1017,19 +1016,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg540 := flag.Arg(1)
|
||||
mbTrans541 := thrift.NewTMemoryBufferLen(len(arg540))
|
||||
defer mbTrans541.Close()
|
||||
_, err542 := mbTrans541.WriteString(arg540)
|
||||
if err542 != nil {
|
||||
arg590 := flag.Arg(1)
|
||||
mbTrans591 := thrift.NewTMemoryBufferLen(len(arg590))
|
||||
defer mbTrans591.Close()
|
||||
_, err592 := mbTrans591.WriteString(arg590)
|
||||
if err592 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory543 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt544 := factory543.GetProtocol(mbTrans541)
|
||||
factory593 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt594 := factory593.GetProtocol(mbTrans591)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err545 := argvalue0.Read(jsProt544)
|
||||
if err545 != nil {
|
||||
err595 := argvalue0.Read(context.Background(), jsProt594)
|
||||
if err595 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1042,19 +1041,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg546 := flag.Arg(1)
|
||||
mbTrans547 := thrift.NewTMemoryBufferLen(len(arg546))
|
||||
defer mbTrans547.Close()
|
||||
_, err548 := mbTrans547.WriteString(arg546)
|
||||
if err548 != nil {
|
||||
arg596 := flag.Arg(1)
|
||||
mbTrans597 := thrift.NewTMemoryBufferLen(len(arg596))
|
||||
defer mbTrans597.Close()
|
||||
_, err598 := mbTrans597.WriteString(arg596)
|
||||
if err598 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory549 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt550 := factory549.GetProtocol(mbTrans547)
|
||||
factory599 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt600 := factory599.GetProtocol(mbTrans597)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err551 := argvalue0.Read(jsProt550)
|
||||
if err551 != nil {
|
||||
err601 := argvalue0.Read(context.Background(), jsProt600)
|
||||
if err601 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1087,19 +1086,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg554 := flag.Arg(1)
|
||||
mbTrans555 := thrift.NewTMemoryBufferLen(len(arg554))
|
||||
defer mbTrans555.Close()
|
||||
_, err556 := mbTrans555.WriteString(arg554)
|
||||
if err556 != nil {
|
||||
arg604 := flag.Arg(1)
|
||||
mbTrans605 := thrift.NewTMemoryBufferLen(len(arg604))
|
||||
defer mbTrans605.Close()
|
||||
_, err606 := mbTrans605.WriteString(arg604)
|
||||
if err606 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory557 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt558 := factory557.GetProtocol(mbTrans555)
|
||||
factory607 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt608 := factory607.GetProtocol(mbTrans605)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err559 := argvalue0.Read(jsProt558)
|
||||
if err559 != nil {
|
||||
err609 := argvalue0.Read(context.Background(), jsProt608)
|
||||
if err609 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1112,19 +1111,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg560 := flag.Arg(1)
|
||||
mbTrans561 := thrift.NewTMemoryBufferLen(len(arg560))
|
||||
defer mbTrans561.Close()
|
||||
_, err562 := mbTrans561.WriteString(arg560)
|
||||
if err562 != nil {
|
||||
arg610 := flag.Arg(1)
|
||||
mbTrans611 := thrift.NewTMemoryBufferLen(len(arg610))
|
||||
defer mbTrans611.Close()
|
||||
_, err612 := mbTrans611.WriteString(arg610)
|
||||
if err612 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory563 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt564 := factory563.GetProtocol(mbTrans561)
|
||||
factory613 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt614 := factory613.GetProtocol(mbTrans611)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err565 := argvalue0.Read(jsProt564)
|
||||
if err565 != nil {
|
||||
err615 := argvalue0.Read(context.Background(), jsProt614)
|
||||
if err615 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1137,19 +1136,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg566 := flag.Arg(1)
|
||||
mbTrans567 := thrift.NewTMemoryBufferLen(len(arg566))
|
||||
defer mbTrans567.Close()
|
||||
_, err568 := mbTrans567.WriteString(arg566)
|
||||
if err568 != nil {
|
||||
arg616 := flag.Arg(1)
|
||||
mbTrans617 := thrift.NewTMemoryBufferLen(len(arg616))
|
||||
defer mbTrans617.Close()
|
||||
_, err618 := mbTrans617.WriteString(arg616)
|
||||
if err618 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory569 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt570 := factory569.GetProtocol(mbTrans567)
|
||||
factory619 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt620 := factory619.GetProtocol(mbTrans617)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err571 := argvalue0.Read(jsProt570)
|
||||
if err571 != nil {
|
||||
err621 := argvalue0.Read(context.Background(), jsProt620)
|
||||
if err621 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -1162,19 +1161,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg572 := flag.Arg(1)
|
||||
mbTrans573 := thrift.NewTMemoryBufferLen(len(arg572))
|
||||
defer mbTrans573.Close()
|
||||
_, err574 := mbTrans573.WriteString(arg572)
|
||||
if err574 != nil {
|
||||
arg622 := flag.Arg(1)
|
||||
mbTrans623 := thrift.NewTMemoryBufferLen(len(arg622))
|
||||
defer mbTrans623.Close()
|
||||
_, err624 := mbTrans623.WriteString(arg622)
|
||||
if err624 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory575 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt576 := factory575.GetProtocol(mbTrans573)
|
||||
factory625 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt626 := factory625.GetProtocol(mbTrans623)
|
||||
argvalue0 := aurora.NewJobUpdateRequest()
|
||||
err577 := argvalue0.Read(jsProt576)
|
||||
if err577 != nil {
|
||||
err627 := argvalue0.Read(context.Background(), jsProt626)
|
||||
if err627 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,5 +1,4 @@
|
|||
// Autogenerated by Thrift Compiler (0.13.0)
|
||||
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
// Code generated by Thrift Compiler (0.14.0). DO NOT EDIT.
|
||||
|
||||
package main
|
||||
|
||||
|
|
@ -176,19 +175,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "CreateJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg163 := flag.Arg(1)
|
||||
mbTrans164 := thrift.NewTMemoryBufferLen(len(arg163))
|
||||
defer mbTrans164.Close()
|
||||
_, err165 := mbTrans164.WriteString(arg163)
|
||||
if err165 != nil {
|
||||
arg213 := flag.Arg(1)
|
||||
mbTrans214 := thrift.NewTMemoryBufferLen(len(arg213))
|
||||
defer mbTrans214.Close()
|
||||
_, err215 := mbTrans214.WriteString(arg213)
|
||||
if err215 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory166 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt167 := factory166.GetProtocol(mbTrans164)
|
||||
factory216 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt217 := factory216.GetProtocol(mbTrans214)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err168 := argvalue0.Read(jsProt167)
|
||||
if err168 != nil {
|
||||
err218 := argvalue0.Read(context.Background(), jsProt217)
|
||||
if err218 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -201,19 +200,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ScheduleCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg169 := flag.Arg(1)
|
||||
mbTrans170 := thrift.NewTMemoryBufferLen(len(arg169))
|
||||
defer mbTrans170.Close()
|
||||
_, err171 := mbTrans170.WriteString(arg169)
|
||||
if err171 != nil {
|
||||
arg219 := flag.Arg(1)
|
||||
mbTrans220 := thrift.NewTMemoryBufferLen(len(arg219))
|
||||
defer mbTrans220.Close()
|
||||
_, err221 := mbTrans220.WriteString(arg219)
|
||||
if err221 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory172 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt173 := factory172.GetProtocol(mbTrans170)
|
||||
factory222 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt223 := factory222.GetProtocol(mbTrans220)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err174 := argvalue0.Read(jsProt173)
|
||||
if err174 != nil {
|
||||
err224 := argvalue0.Read(context.Background(), jsProt223)
|
||||
if err224 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -226,19 +225,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "DescheduleCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg175 := flag.Arg(1)
|
||||
mbTrans176 := thrift.NewTMemoryBufferLen(len(arg175))
|
||||
defer mbTrans176.Close()
|
||||
_, err177 := mbTrans176.WriteString(arg175)
|
||||
if err177 != nil {
|
||||
arg225 := flag.Arg(1)
|
||||
mbTrans226 := thrift.NewTMemoryBufferLen(len(arg225))
|
||||
defer mbTrans226.Close()
|
||||
_, err227 := mbTrans226.WriteString(arg225)
|
||||
if err227 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory178 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt179 := factory178.GetProtocol(mbTrans176)
|
||||
factory228 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt229 := factory228.GetProtocol(mbTrans226)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err180 := argvalue0.Read(jsProt179)
|
||||
if err180 != nil {
|
||||
err230 := argvalue0.Read(context.Background(), jsProt229)
|
||||
if err230 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -251,19 +250,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "StartCronJob requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg181 := flag.Arg(1)
|
||||
mbTrans182 := thrift.NewTMemoryBufferLen(len(arg181))
|
||||
defer mbTrans182.Close()
|
||||
_, err183 := mbTrans182.WriteString(arg181)
|
||||
if err183 != nil {
|
||||
arg231 := flag.Arg(1)
|
||||
mbTrans232 := thrift.NewTMemoryBufferLen(len(arg231))
|
||||
defer mbTrans232.Close()
|
||||
_, err233 := mbTrans232.WriteString(arg231)
|
||||
if err233 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory184 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt185 := factory184.GetProtocol(mbTrans182)
|
||||
factory234 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt235 := factory234.GetProtocol(mbTrans232)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err186 := argvalue0.Read(jsProt185)
|
||||
if err186 != nil {
|
||||
err236 := argvalue0.Read(context.Background(), jsProt235)
|
||||
if err236 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -276,36 +275,36 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "RestartShards requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg187 := flag.Arg(1)
|
||||
mbTrans188 := thrift.NewTMemoryBufferLen(len(arg187))
|
||||
defer mbTrans188.Close()
|
||||
_, err189 := mbTrans188.WriteString(arg187)
|
||||
if err189 != nil {
|
||||
arg237 := flag.Arg(1)
|
||||
mbTrans238 := thrift.NewTMemoryBufferLen(len(arg237))
|
||||
defer mbTrans238.Close()
|
||||
_, err239 := mbTrans238.WriteString(arg237)
|
||||
if err239 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory190 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt191 := factory190.GetProtocol(mbTrans188)
|
||||
factory240 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt241 := factory240.GetProtocol(mbTrans238)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err192 := argvalue0.Read(jsProt191)
|
||||
if err192 != nil {
|
||||
err242 := argvalue0.Read(context.Background(), jsProt241)
|
||||
if err242 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
arg193 := flag.Arg(2)
|
||||
mbTrans194 := thrift.NewTMemoryBufferLen(len(arg193))
|
||||
defer mbTrans194.Close()
|
||||
_, err195 := mbTrans194.WriteString(arg193)
|
||||
if err195 != nil {
|
||||
arg243 := flag.Arg(2)
|
||||
mbTrans244 := thrift.NewTMemoryBufferLen(len(arg243))
|
||||
defer mbTrans244.Close()
|
||||
_, err245 := mbTrans244.WriteString(arg243)
|
||||
if err245 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory196 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt197 := factory196.GetProtocol(mbTrans194)
|
||||
factory246 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt247 := factory246.GetProtocol(mbTrans244)
|
||||
containerStruct1 := aurora.NewAuroraSchedulerManagerRestartShardsArgs()
|
||||
err198 := containerStruct1.ReadField2(jsProt197)
|
||||
if err198 != nil {
|
||||
err248 := containerStruct1.ReadField2(context.Background(), jsProt247)
|
||||
if err248 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -319,36 +318,36 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "KillTasks requires 3 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg199 := flag.Arg(1)
|
||||
mbTrans200 := thrift.NewTMemoryBufferLen(len(arg199))
|
||||
defer mbTrans200.Close()
|
||||
_, err201 := mbTrans200.WriteString(arg199)
|
||||
if err201 != nil {
|
||||
arg249 := flag.Arg(1)
|
||||
mbTrans250 := thrift.NewTMemoryBufferLen(len(arg249))
|
||||
defer mbTrans250.Close()
|
||||
_, err251 := mbTrans250.WriteString(arg249)
|
||||
if err251 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory202 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt203 := factory202.GetProtocol(mbTrans200)
|
||||
factory252 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt253 := factory252.GetProtocol(mbTrans250)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err204 := argvalue0.Read(jsProt203)
|
||||
if err204 != nil {
|
||||
err254 := argvalue0.Read(context.Background(), jsProt253)
|
||||
if err254 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
arg205 := flag.Arg(2)
|
||||
mbTrans206 := thrift.NewTMemoryBufferLen(len(arg205))
|
||||
defer mbTrans206.Close()
|
||||
_, err207 := mbTrans206.WriteString(arg205)
|
||||
if err207 != nil {
|
||||
arg255 := flag.Arg(2)
|
||||
mbTrans256 := thrift.NewTMemoryBufferLen(len(arg255))
|
||||
defer mbTrans256.Close()
|
||||
_, err257 := mbTrans256.WriteString(arg255)
|
||||
if err257 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory208 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt209 := factory208.GetProtocol(mbTrans206)
|
||||
factory258 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt259 := factory258.GetProtocol(mbTrans256)
|
||||
containerStruct1 := aurora.NewAuroraSchedulerManagerKillTasksArgs()
|
||||
err210 := containerStruct1.ReadField2(jsProt209)
|
||||
if err210 != nil {
|
||||
err260 := containerStruct1.ReadField2(context.Background(), jsProt259)
|
||||
if err260 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -364,25 +363,25 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "AddInstances requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg212 := flag.Arg(1)
|
||||
mbTrans213 := thrift.NewTMemoryBufferLen(len(arg212))
|
||||
defer mbTrans213.Close()
|
||||
_, err214 := mbTrans213.WriteString(arg212)
|
||||
if err214 != nil {
|
||||
arg262 := flag.Arg(1)
|
||||
mbTrans263 := thrift.NewTMemoryBufferLen(len(arg262))
|
||||
defer mbTrans263.Close()
|
||||
_, err264 := mbTrans263.WriteString(arg262)
|
||||
if err264 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory215 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt216 := factory215.GetProtocol(mbTrans213)
|
||||
factory265 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt266 := factory265.GetProtocol(mbTrans263)
|
||||
argvalue0 := aurora.NewInstanceKey()
|
||||
err217 := argvalue0.Read(jsProt216)
|
||||
if err217 != nil {
|
||||
err267 := argvalue0.Read(context.Background(), jsProt266)
|
||||
if err267 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
value0 := argvalue0
|
||||
tmp1, err218 := (strconv.Atoi(flag.Arg(2)))
|
||||
if err218 != nil {
|
||||
tmp1, err268 := (strconv.Atoi(flag.Arg(2)))
|
||||
if err268 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -396,19 +395,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ReplaceCronTemplate requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg219 := flag.Arg(1)
|
||||
mbTrans220 := thrift.NewTMemoryBufferLen(len(arg219))
|
||||
defer mbTrans220.Close()
|
||||
_, err221 := mbTrans220.WriteString(arg219)
|
||||
if err221 != nil {
|
||||
arg269 := flag.Arg(1)
|
||||
mbTrans270 := thrift.NewTMemoryBufferLen(len(arg269))
|
||||
defer mbTrans270.Close()
|
||||
_, err271 := mbTrans270.WriteString(arg269)
|
||||
if err271 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory222 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt223 := factory222.GetProtocol(mbTrans220)
|
||||
factory272 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt273 := factory272.GetProtocol(mbTrans270)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err224 := argvalue0.Read(jsProt223)
|
||||
if err224 != nil {
|
||||
err274 := argvalue0.Read(context.Background(), jsProt273)
|
||||
if err274 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -421,19 +420,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "StartJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg225 := flag.Arg(1)
|
||||
mbTrans226 := thrift.NewTMemoryBufferLen(len(arg225))
|
||||
defer mbTrans226.Close()
|
||||
_, err227 := mbTrans226.WriteString(arg225)
|
||||
if err227 != nil {
|
||||
arg275 := flag.Arg(1)
|
||||
mbTrans276 := thrift.NewTMemoryBufferLen(len(arg275))
|
||||
defer mbTrans276.Close()
|
||||
_, err277 := mbTrans276.WriteString(arg275)
|
||||
if err277 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory228 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt229 := factory228.GetProtocol(mbTrans226)
|
||||
factory278 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt279 := factory278.GetProtocol(mbTrans276)
|
||||
argvalue0 := aurora.NewJobUpdateRequest()
|
||||
err230 := argvalue0.Read(jsProt229)
|
||||
if err230 != nil {
|
||||
err280 := argvalue0.Read(context.Background(), jsProt279)
|
||||
if err280 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -448,19 +447,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PauseJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg232 := flag.Arg(1)
|
||||
mbTrans233 := thrift.NewTMemoryBufferLen(len(arg232))
|
||||
defer mbTrans233.Close()
|
||||
_, err234 := mbTrans233.WriteString(arg232)
|
||||
if err234 != nil {
|
||||
arg282 := flag.Arg(1)
|
||||
mbTrans283 := thrift.NewTMemoryBufferLen(len(arg282))
|
||||
defer mbTrans283.Close()
|
||||
_, err284 := mbTrans283.WriteString(arg282)
|
||||
if err284 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory235 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt236 := factory235.GetProtocol(mbTrans233)
|
||||
factory285 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt286 := factory285.GetProtocol(mbTrans283)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err237 := argvalue0.Read(jsProt236)
|
||||
if err237 != nil {
|
||||
err287 := argvalue0.Read(context.Background(), jsProt286)
|
||||
if err287 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -475,19 +474,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "ResumeJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg239 := flag.Arg(1)
|
||||
mbTrans240 := thrift.NewTMemoryBufferLen(len(arg239))
|
||||
defer mbTrans240.Close()
|
||||
_, err241 := mbTrans240.WriteString(arg239)
|
||||
if err241 != nil {
|
||||
arg289 := flag.Arg(1)
|
||||
mbTrans290 := thrift.NewTMemoryBufferLen(len(arg289))
|
||||
defer mbTrans290.Close()
|
||||
_, err291 := mbTrans290.WriteString(arg289)
|
||||
if err291 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory242 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt243 := factory242.GetProtocol(mbTrans240)
|
||||
factory292 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt293 := factory292.GetProtocol(mbTrans290)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err244 := argvalue0.Read(jsProt243)
|
||||
if err244 != nil {
|
||||
err294 := argvalue0.Read(context.Background(), jsProt293)
|
||||
if err294 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -502,19 +501,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "AbortJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg246 := flag.Arg(1)
|
||||
mbTrans247 := thrift.NewTMemoryBufferLen(len(arg246))
|
||||
defer mbTrans247.Close()
|
||||
_, err248 := mbTrans247.WriteString(arg246)
|
||||
if err248 != nil {
|
||||
arg296 := flag.Arg(1)
|
||||
mbTrans297 := thrift.NewTMemoryBufferLen(len(arg296))
|
||||
defer mbTrans297.Close()
|
||||
_, err298 := mbTrans297.WriteString(arg296)
|
||||
if err298 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory249 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt250 := factory249.GetProtocol(mbTrans247)
|
||||
factory299 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt300 := factory299.GetProtocol(mbTrans297)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err251 := argvalue0.Read(jsProt250)
|
||||
if err251 != nil {
|
||||
err301 := argvalue0.Read(context.Background(), jsProt300)
|
||||
if err301 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -529,19 +528,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "RollbackJobUpdate requires 2 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg253 := flag.Arg(1)
|
||||
mbTrans254 := thrift.NewTMemoryBufferLen(len(arg253))
|
||||
defer mbTrans254.Close()
|
||||
_, err255 := mbTrans254.WriteString(arg253)
|
||||
if err255 != nil {
|
||||
arg303 := flag.Arg(1)
|
||||
mbTrans304 := thrift.NewTMemoryBufferLen(len(arg303))
|
||||
defer mbTrans304.Close()
|
||||
_, err305 := mbTrans304.WriteString(arg303)
|
||||
if err305 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory256 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt257 := factory256.GetProtocol(mbTrans254)
|
||||
factory306 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt307 := factory306.GetProtocol(mbTrans304)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err258 := argvalue0.Read(jsProt257)
|
||||
if err258 != nil {
|
||||
err308 := argvalue0.Read(context.Background(), jsProt307)
|
||||
if err308 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -556,19 +555,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PulseJobUpdate requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg260 := flag.Arg(1)
|
||||
mbTrans261 := thrift.NewTMemoryBufferLen(len(arg260))
|
||||
defer mbTrans261.Close()
|
||||
_, err262 := mbTrans261.WriteString(arg260)
|
||||
if err262 != nil {
|
||||
arg310 := flag.Arg(1)
|
||||
mbTrans311 := thrift.NewTMemoryBufferLen(len(arg310))
|
||||
defer mbTrans311.Close()
|
||||
_, err312 := mbTrans311.WriteString(arg310)
|
||||
if err312 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory263 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt264 := factory263.GetProtocol(mbTrans261)
|
||||
factory313 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt314 := factory313.GetProtocol(mbTrans311)
|
||||
argvalue0 := aurora.NewJobUpdateKey()
|
||||
err265 := argvalue0.Read(jsProt264)
|
||||
if err265 != nil {
|
||||
err315 := argvalue0.Read(context.Background(), jsProt314)
|
||||
if err315 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -599,19 +598,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg267 := flag.Arg(1)
|
||||
mbTrans268 := thrift.NewTMemoryBufferLen(len(arg267))
|
||||
defer mbTrans268.Close()
|
||||
_, err269 := mbTrans268.WriteString(arg267)
|
||||
if err269 != nil {
|
||||
arg317 := flag.Arg(1)
|
||||
mbTrans318 := thrift.NewTMemoryBufferLen(len(arg317))
|
||||
defer mbTrans318.Close()
|
||||
_, err319 := mbTrans318.WriteString(arg317)
|
||||
if err319 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory270 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt271 := factory270.GetProtocol(mbTrans268)
|
||||
factory320 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt321 := factory320.GetProtocol(mbTrans318)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err272 := argvalue0.Read(jsProt271)
|
||||
if err272 != nil {
|
||||
err322 := argvalue0.Read(context.Background(), jsProt321)
|
||||
if err322 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -624,19 +623,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg273 := flag.Arg(1)
|
||||
mbTrans274 := thrift.NewTMemoryBufferLen(len(arg273))
|
||||
defer mbTrans274.Close()
|
||||
_, err275 := mbTrans274.WriteString(arg273)
|
||||
if err275 != nil {
|
||||
arg323 := flag.Arg(1)
|
||||
mbTrans324 := thrift.NewTMemoryBufferLen(len(arg323))
|
||||
defer mbTrans324.Close()
|
||||
_, err325 := mbTrans324.WriteString(arg323)
|
||||
if err325 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory276 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt277 := factory276.GetProtocol(mbTrans274)
|
||||
factory326 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt327 := factory326.GetProtocol(mbTrans324)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err278 := argvalue0.Read(jsProt277)
|
||||
if err278 != nil {
|
||||
err328 := argvalue0.Read(context.Background(), jsProt327)
|
||||
if err328 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -649,19 +648,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg279 := flag.Arg(1)
|
||||
mbTrans280 := thrift.NewTMemoryBufferLen(len(arg279))
|
||||
defer mbTrans280.Close()
|
||||
_, err281 := mbTrans280.WriteString(arg279)
|
||||
if err281 != nil {
|
||||
arg329 := flag.Arg(1)
|
||||
mbTrans330 := thrift.NewTMemoryBufferLen(len(arg329))
|
||||
defer mbTrans330.Close()
|
||||
_, err331 := mbTrans330.WriteString(arg329)
|
||||
if err331 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory282 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt283 := factory282.GetProtocol(mbTrans280)
|
||||
factory332 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt333 := factory332.GetProtocol(mbTrans330)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err284 := argvalue0.Read(jsProt283)
|
||||
if err284 != nil {
|
||||
err334 := argvalue0.Read(context.Background(), jsProt333)
|
||||
if err334 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -674,19 +673,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg285 := flag.Arg(1)
|
||||
mbTrans286 := thrift.NewTMemoryBufferLen(len(arg285))
|
||||
defer mbTrans286.Close()
|
||||
_, err287 := mbTrans286.WriteString(arg285)
|
||||
if err287 != nil {
|
||||
arg335 := flag.Arg(1)
|
||||
mbTrans336 := thrift.NewTMemoryBufferLen(len(arg335))
|
||||
defer mbTrans336.Close()
|
||||
_, err337 := mbTrans336.WriteString(arg335)
|
||||
if err337 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory288 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt289 := factory288.GetProtocol(mbTrans286)
|
||||
factory338 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt339 := factory338.GetProtocol(mbTrans336)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err290 := argvalue0.Read(jsProt289)
|
||||
if err290 != nil {
|
||||
err340 := argvalue0.Read(context.Background(), jsProt339)
|
||||
if err340 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -719,19 +718,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg293 := flag.Arg(1)
|
||||
mbTrans294 := thrift.NewTMemoryBufferLen(len(arg293))
|
||||
defer mbTrans294.Close()
|
||||
_, err295 := mbTrans294.WriteString(arg293)
|
||||
if err295 != nil {
|
||||
arg343 := flag.Arg(1)
|
||||
mbTrans344 := thrift.NewTMemoryBufferLen(len(arg343))
|
||||
defer mbTrans344.Close()
|
||||
_, err345 := mbTrans344.WriteString(arg343)
|
||||
if err345 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory296 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt297 := factory296.GetProtocol(mbTrans294)
|
||||
factory346 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt347 := factory346.GetProtocol(mbTrans344)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err298 := argvalue0.Read(jsProt297)
|
||||
if err298 != nil {
|
||||
err348 := argvalue0.Read(context.Background(), jsProt347)
|
||||
if err348 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -744,19 +743,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg299 := flag.Arg(1)
|
||||
mbTrans300 := thrift.NewTMemoryBufferLen(len(arg299))
|
||||
defer mbTrans300.Close()
|
||||
_, err301 := mbTrans300.WriteString(arg299)
|
||||
if err301 != nil {
|
||||
arg349 := flag.Arg(1)
|
||||
mbTrans350 := thrift.NewTMemoryBufferLen(len(arg349))
|
||||
defer mbTrans350.Close()
|
||||
_, err351 := mbTrans350.WriteString(arg349)
|
||||
if err351 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory302 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt303 := factory302.GetProtocol(mbTrans300)
|
||||
factory352 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt353 := factory352.GetProtocol(mbTrans350)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err304 := argvalue0.Read(jsProt303)
|
||||
if err304 != nil {
|
||||
err354 := argvalue0.Read(context.Background(), jsProt353)
|
||||
if err354 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -769,19 +768,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg305 := flag.Arg(1)
|
||||
mbTrans306 := thrift.NewTMemoryBufferLen(len(arg305))
|
||||
defer mbTrans306.Close()
|
||||
_, err307 := mbTrans306.WriteString(arg305)
|
||||
if err307 != nil {
|
||||
arg355 := flag.Arg(1)
|
||||
mbTrans356 := thrift.NewTMemoryBufferLen(len(arg355))
|
||||
defer mbTrans356.Close()
|
||||
_, err357 := mbTrans356.WriteString(arg355)
|
||||
if err357 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory308 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt309 := factory308.GetProtocol(mbTrans306)
|
||||
factory358 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt359 := factory358.GetProtocol(mbTrans356)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err310 := argvalue0.Read(jsProt309)
|
||||
if err310 != nil {
|
||||
err360 := argvalue0.Read(context.Background(), jsProt359)
|
||||
if err360 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -794,19 +793,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg311 := flag.Arg(1)
|
||||
mbTrans312 := thrift.NewTMemoryBufferLen(len(arg311))
|
||||
defer mbTrans312.Close()
|
||||
_, err313 := mbTrans312.WriteString(arg311)
|
||||
if err313 != nil {
|
||||
arg361 := flag.Arg(1)
|
||||
mbTrans362 := thrift.NewTMemoryBufferLen(len(arg361))
|
||||
defer mbTrans362.Close()
|
||||
_, err363 := mbTrans362.WriteString(arg361)
|
||||
if err363 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory314 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt315 := factory314.GetProtocol(mbTrans312)
|
||||
factory364 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt365 := factory364.GetProtocol(mbTrans362)
|
||||
argvalue0 := aurora.NewJobUpdateRequest()
|
||||
err316 := argvalue0.Read(jsProt315)
|
||||
if err316 != nil {
|
||||
err366 := argvalue0.Read(context.Background(), jsProt365)
|
||||
if err366 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,5 +1,4 @@
|
|||
// Autogenerated by Thrift Compiler (0.13.0)
|
||||
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
||||
// Code generated by Thrift Compiler (0.14.0). DO NOT EDIT.
|
||||
|
||||
package main
|
||||
|
||||
|
|
@ -180,19 +179,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg82 := flag.Arg(1)
|
||||
mbTrans83 := thrift.NewTMemoryBufferLen(len(arg82))
|
||||
defer mbTrans83.Close()
|
||||
_, err84 := mbTrans83.WriteString(arg82)
|
||||
if err84 != nil {
|
||||
arg132 := flag.Arg(1)
|
||||
mbTrans133 := thrift.NewTMemoryBufferLen(len(arg132))
|
||||
defer mbTrans133.Close()
|
||||
_, err134 := mbTrans133.WriteString(arg132)
|
||||
if err134 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory85 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt86 := factory85.GetProtocol(mbTrans83)
|
||||
factory135 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt136 := factory135.GetProtocol(mbTrans133)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err87 := argvalue0.Read(jsProt86)
|
||||
if err87 != nil {
|
||||
err137 := argvalue0.Read(context.Background(), jsProt136)
|
||||
if err137 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -205,19 +204,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg88 := flag.Arg(1)
|
||||
mbTrans89 := thrift.NewTMemoryBufferLen(len(arg88))
|
||||
defer mbTrans89.Close()
|
||||
_, err90 := mbTrans89.WriteString(arg88)
|
||||
if err90 != nil {
|
||||
arg138 := flag.Arg(1)
|
||||
mbTrans139 := thrift.NewTMemoryBufferLen(len(arg138))
|
||||
defer mbTrans139.Close()
|
||||
_, err140 := mbTrans139.WriteString(arg138)
|
||||
if err140 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory91 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt92 := factory91.GetProtocol(mbTrans89)
|
||||
factory141 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt142 := factory141.GetProtocol(mbTrans139)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err93 := argvalue0.Read(jsProt92)
|
||||
if err93 != nil {
|
||||
err143 := argvalue0.Read(context.Background(), jsProt142)
|
||||
if err143 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -230,19 +229,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg94 := flag.Arg(1)
|
||||
mbTrans95 := thrift.NewTMemoryBufferLen(len(arg94))
|
||||
defer mbTrans95.Close()
|
||||
_, err96 := mbTrans95.WriteString(arg94)
|
||||
if err96 != nil {
|
||||
arg144 := flag.Arg(1)
|
||||
mbTrans145 := thrift.NewTMemoryBufferLen(len(arg144))
|
||||
defer mbTrans145.Close()
|
||||
_, err146 := mbTrans145.WriteString(arg144)
|
||||
if err146 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory97 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt98 := factory97.GetProtocol(mbTrans95)
|
||||
factory147 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt148 := factory147.GetProtocol(mbTrans145)
|
||||
argvalue0 := aurora.NewTaskQuery()
|
||||
err99 := argvalue0.Read(jsProt98)
|
||||
if err99 != nil {
|
||||
err149 := argvalue0.Read(context.Background(), jsProt148)
|
||||
if err149 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -255,19 +254,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg100 := flag.Arg(1)
|
||||
mbTrans101 := thrift.NewTMemoryBufferLen(len(arg100))
|
||||
defer mbTrans101.Close()
|
||||
_, err102 := mbTrans101.WriteString(arg100)
|
||||
if err102 != nil {
|
||||
arg150 := flag.Arg(1)
|
||||
mbTrans151 := thrift.NewTMemoryBufferLen(len(arg150))
|
||||
defer mbTrans151.Close()
|
||||
_, err152 := mbTrans151.WriteString(arg150)
|
||||
if err152 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory103 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt104 := factory103.GetProtocol(mbTrans101)
|
||||
factory153 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt154 := factory153.GetProtocol(mbTrans151)
|
||||
argvalue0 := aurora.NewJobKey()
|
||||
err105 := argvalue0.Read(jsProt104)
|
||||
if err105 != nil {
|
||||
err155 := argvalue0.Read(context.Background(), jsProt154)
|
||||
if err155 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -300,19 +299,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg108 := flag.Arg(1)
|
||||
mbTrans109 := thrift.NewTMemoryBufferLen(len(arg108))
|
||||
defer mbTrans109.Close()
|
||||
_, err110 := mbTrans109.WriteString(arg108)
|
||||
if err110 != nil {
|
||||
arg158 := flag.Arg(1)
|
||||
mbTrans159 := thrift.NewTMemoryBufferLen(len(arg158))
|
||||
defer mbTrans159.Close()
|
||||
_, err160 := mbTrans159.WriteString(arg158)
|
||||
if err160 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory111 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt112 := factory111.GetProtocol(mbTrans109)
|
||||
factory161 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt162 := factory161.GetProtocol(mbTrans159)
|
||||
argvalue0 := aurora.NewJobConfiguration()
|
||||
err113 := argvalue0.Read(jsProt112)
|
||||
if err113 != nil {
|
||||
err163 := argvalue0.Read(context.Background(), jsProt162)
|
||||
if err163 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -325,19 +324,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg114 := flag.Arg(1)
|
||||
mbTrans115 := thrift.NewTMemoryBufferLen(len(arg114))
|
||||
defer mbTrans115.Close()
|
||||
_, err116 := mbTrans115.WriteString(arg114)
|
||||
if err116 != nil {
|
||||
arg164 := flag.Arg(1)
|
||||
mbTrans165 := thrift.NewTMemoryBufferLen(len(arg164))
|
||||
defer mbTrans165.Close()
|
||||
_, err166 := mbTrans165.WriteString(arg164)
|
||||
if err166 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory117 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt118 := factory117.GetProtocol(mbTrans115)
|
||||
factory167 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt168 := factory167.GetProtocol(mbTrans165)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err119 := argvalue0.Read(jsProt118)
|
||||
if err119 != nil {
|
||||
err169 := argvalue0.Read(context.Background(), jsProt168)
|
||||
if err169 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -350,19 +349,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg120 := flag.Arg(1)
|
||||
mbTrans121 := thrift.NewTMemoryBufferLen(len(arg120))
|
||||
defer mbTrans121.Close()
|
||||
_, err122 := mbTrans121.WriteString(arg120)
|
||||
if err122 != nil {
|
||||
arg170 := flag.Arg(1)
|
||||
mbTrans171 := thrift.NewTMemoryBufferLen(len(arg170))
|
||||
defer mbTrans171.Close()
|
||||
_, err172 := mbTrans171.WriteString(arg170)
|
||||
if err172 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory123 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt124 := factory123.GetProtocol(mbTrans121)
|
||||
factory173 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt174 := factory173.GetProtocol(mbTrans171)
|
||||
argvalue0 := aurora.NewJobUpdateQuery()
|
||||
err125 := argvalue0.Read(jsProt124)
|
||||
if err125 != nil {
|
||||
err175 := argvalue0.Read(context.Background(), jsProt174)
|
||||
if err175 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
@ -375,19 +374,19 @@ func main() {
|
|||
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
|
||||
flag.Usage()
|
||||
}
|
||||
arg126 := flag.Arg(1)
|
||||
mbTrans127 := thrift.NewTMemoryBufferLen(len(arg126))
|
||||
defer mbTrans127.Close()
|
||||
_, err128 := mbTrans127.WriteString(arg126)
|
||||
if err128 != nil {
|
||||
arg176 := flag.Arg(1)
|
||||
mbTrans177 := thrift.NewTMemoryBufferLen(len(arg176))
|
||||
defer mbTrans177.Close()
|
||||
_, err178 := mbTrans177.WriteString(arg176)
|
||||
if err178 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
factory129 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt130 := factory129.GetProtocol(mbTrans127)
|
||||
factory179 := thrift.NewTJSONProtocolFactory()
|
||||
jsProt180 := factory179.GetProtocol(mbTrans177)
|
||||
argvalue0 := aurora.NewJobUpdateRequest()
|
||||
err131 := argvalue0.Read(jsProt130)
|
||||
if err131 != nil {
|
||||
err181 := argvalue0.Read(context.Background(), jsProt180)
|
||||
if err181 != nil {
|
||||
Usage()
|
||||
return
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
#! /bin/bash
|
||||
|
||||
THRIFT_VER=0.13.0
|
||||
THRIFT_VER=0.14.0
|
||||
|
||||
if [[ $(thrift -version | grep -e $THRIFT_VER -c) -ne 1 ]]; then
|
||||
echo "Warning: This wrapper has only been tested with version" $THRIFT_VER;
|
||||
|
|
|
|||
8
go.mod
8
go.mod
|
|
@ -3,12 +3,10 @@ module github.com/paypal/gorealis
|
|||
go 1.13
|
||||
|
||||
require (
|
||||
github.com/apache/thrift v0.13.0
|
||||
github.com/davecgh/go-spew v1.1.0
|
||||
github.com/apache/thrift v0.14.0
|
||||
github.com/davecgh/go-spew v1.1.0 // indirect
|
||||
github.com/pkg/errors v0.9.1
|
||||
github.com/pmezard/go-difflib v1.0.0
|
||||
github.com/pmezard/go-difflib v1.0.0 // indirect
|
||||
github.com/samuel/go-zookeeper v0.0.0-20171117190445-471cd4e61d7a
|
||||
github.com/stretchr/testify v1.2.0
|
||||
)
|
||||
|
||||
replace github.com/apache/thrift v0.13.0 => github.com/ridv/thrift v0.13.2
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
#!/bin/bash
|
||||
|
||||
# Since we run our docker compose setup in bridge mode to be able to run on MacOS, we have to launch a Docker container within the bridge network in order to avoid any routing issues.
|
||||
docker run --rm -t -v $(pwd):/go/src/github.com/paypal/gorealis --network gorealis_aurora_cluster golang:1.10-stretch go test -v github.com/paypal/gorealis $@
|
||||
docker run --rm -t -w /gorealis -v $GOPATH/pkg:/go/pkg -v $(pwd):/gorealis --network gorealis_aurora_cluster golang:1.16-buster go test -v github.com/paypal/gorealis $@
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue