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

Updating thrift generated code to be 0.12.0 final generated code.

Browse source
This commit is contained in:
Renan DelValle 2019-02-19 11:30:10 -08:00
parent 15e05653e6
commit 904fdbd1a1
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
6 changed files with 23833 additions and 26393 deletions
Download patch file Download diff file Expand all files Collapse all files

4
gen-go/apache/aurora/GoUnusedProtection__.go
View file

@ -1,7 +1,7 @@
// Autogenerated by Thrift Compiler (1.0.0-dev)
// Autogenerated by Thrift Compiler (0.12.0) // Autogenerated by Thrift Compiler (0.12.0)
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING // DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
package aurora package aurora
var GoUnusedProtection__ int var GoUnusedProtection__ int;

34
gen-go/apache/aurora/auroraAPI-consts.go
View file

@ -6,10 +6,9 @@ package aurora
import ( import (
"bytes" "bytes"
"context" "context"
"fmt"
"reflect" "reflect"
"fmt"
"git.apache.org/thrift.git/lib/go/thrift" "github.com/apache/thrift/lib/go/thrift"
) )
// (needed to ensure safety because of naive import list construction.) // (needed to ensure safety because of naive import list construction.)
@ -20,39 +19,36 @@ var _ = reflect.DeepEqual
var _ = bytes.Equal var _ = bytes.Equal
const AURORA_EXECUTOR_NAME = "AuroraExecutor" const AURORA_EXECUTOR_NAME = "AuroraExecutor"
var ACTIVE_STATES []ScheduleStatus var ACTIVE_STATES []ScheduleStatus
var SLAVE_ASSIGNED_STATES []ScheduleStatus var SLAVE_ASSIGNED_STATES []ScheduleStatus
var LIVE_STATES []ScheduleStatus var LIVE_STATES []ScheduleStatus
var TERMINAL_STATES []ScheduleStatus var TERMINAL_STATES []ScheduleStatus
const GOOD_IDENTIFIER_PATTERN = "^[\\w\\-\\.]+$" const GOOD_IDENTIFIER_PATTERN = "^[\\w\\-\\.]+$"
const GOOD_IDENTIFIER_PATTERN_JVM = "^[\\w\\-\\.]+$" const GOOD_IDENTIFIER_PATTERN_JVM = "^[\\w\\-\\.]+$"
const GOOD_IDENTIFIER_PATTERN_PYTHON = "^[\\w\\-\\.]+$" const GOOD_IDENTIFIER_PATTERN_PYTHON = "^[\\w\\-\\.]+$"
var ACTIVE_JOB_UPDATE_STATES []JobUpdateStatus var ACTIVE_JOB_UPDATE_STATES []JobUpdateStatus
var AWAITNG_PULSE_JOB_UPDATE_STATES []JobUpdateStatus var AWAITNG_PULSE_JOB_UPDATE_STATES []JobUpdateStatus
const BYPASS_LEADER_REDIRECT_HEADER_NAME = "Bypass-Leader-Redirect" const BYPASS_LEADER_REDIRECT_HEADER_NAME = "Bypass-Leader-Redirect"
const TASK_FILESYSTEM_MOUNT_POINT = "taskfs" const TASK_FILESYSTEM_MOUNT_POINT = "taskfs"
func init() { func init() {
ACTIVE_STATES = []ScheduleStatus{ ACTIVE_STATES = []ScheduleStatus{
9, 17, 6, 0, 13, 12, 2, 1, 18, 16} 9, 17, 6, 0, 13, 12, 2, 1, 18, 16, }
SLAVE_ASSIGNED_STATES = []ScheduleStatus{ SLAVE_ASSIGNED_STATES = []ScheduleStatus{
9, 17, 6, 13, 12, 2, 18, 1} 9, 17, 6, 13, 12, 2, 18, 1, }
LIVE_STATES = []ScheduleStatus{ LIVE_STATES = []ScheduleStatus{
6, 13, 12, 17, 18, 2} 6, 13, 12, 17, 18, 2, }
TERMINAL_STATES = []ScheduleStatus{ TERMINAL_STATES = []ScheduleStatus{
4, 3, 5, 7} 4, 3, 5, 7, }
ACTIVE_JOB_UPDATE_STATES = []JobUpdateStatus{ ACTIVE_JOB_UPDATE_STATES = []JobUpdateStatus{
0, 1, 2, 3, 9, 10} 0, 1, 2, 3, 9, 10, }
AWAITNG_PULSE_JOB_UPDATE_STATES = []JobUpdateStatus{ AWAITNG_PULSE_JOB_UPDATE_STATES = []JobUpdateStatus{
9, 10} 9, 10, }
} }

45436
gen-go/apache/aurora/auroraAPI.go
View file

File diff suppressed because it is too large Load diff

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

File diff suppressed because it is too large Load diff

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

File diff suppressed because it is too large Load diff

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

@ -4,408 +4,408 @@
package main package main
import ( import (
"apache/aurora" "context"
"context" "flag"
"flag" "fmt"
"fmt" "math"
"math" "net"
"net" "net/url"
"net/url" "os"
"os" "strconv"
"strconv" "strings"
"strings" "github.com/apache/thrift/lib/go/thrift"
"apache/aurora"
"git.apache.org/thrift.git/lib/go/thrift"
) )
func Usage() { func Usage() {
fmt.Fprintln(os.Stderr, "Usage of ", os.Args[0], " [-h host:port] [-u url] [-f[ramed]] function [arg1 [arg2...]]:") fmt.Fprintln(os.Stderr, "Usage of ", os.Args[0], " [-h host:port] [-u url] [-f[ramed]] function [arg1 [arg2...]]:")
flag.PrintDefaults() flag.PrintDefaults()
fmt.Fprintln(os.Stderr, "\nFunctions:") fmt.Fprintln(os.Stderr, "\nFunctions:")
fmt.Fprintln(os.Stderr, " Response getRoleSummary()") fmt.Fprintln(os.Stderr, " Response getRoleSummary()")
fmt.Fprintln(os.Stderr, " Response getJobSummary(string role)") fmt.Fprintln(os.Stderr, " Response getJobSummary(string role)")
fmt.Fprintln(os.Stderr, " Response getTasksStatus(TaskQuery query)") fmt.Fprintln(os.Stderr, " Response getTasksStatus(TaskQuery query)")
fmt.Fprintln(os.Stderr, " Response getTasksWithoutConfigs(TaskQuery query)") fmt.Fprintln(os.Stderr, " Response getTasksWithoutConfigs(TaskQuery query)")
fmt.Fprintln(os.Stderr, " Response getPendingReason(TaskQuery query)") fmt.Fprintln(os.Stderr, " Response getPendingReason(TaskQuery query)")
fmt.Fprintln(os.Stderr, " Response getConfigSummary(JobKey job)") fmt.Fprintln(os.Stderr, " Response getConfigSummary(JobKey job)")
fmt.Fprintln(os.Stderr, " Response getJobs(string ownerRole)") fmt.Fprintln(os.Stderr, " Response getJobs(string ownerRole)")
fmt.Fprintln(os.Stderr, " Response getQuota(string ownerRole)") fmt.Fprintln(os.Stderr, " Response getQuota(string ownerRole)")
fmt.Fprintln(os.Stderr, " Response populateJobConfig(JobConfiguration description)") fmt.Fprintln(os.Stderr, " Response populateJobConfig(JobConfiguration description)")
fmt.Fprintln(os.Stderr, " Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery)") fmt.Fprintln(os.Stderr, " Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery)")
fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateQuery query)") fmt.Fprintln(os.Stderr, " Response getJobUpdateDetails(JobUpdateQuery query)")
fmt.Fprintln(os.Stderr, " Response getJobUpdateDiff(JobUpdateRequest request)") fmt.Fprintln(os.Stderr, " Response getJobUpdateDiff(JobUpdateRequest request)")
fmt.Fprintln(os.Stderr, " Response getTierConfigs()") fmt.Fprintln(os.Stderr, " Response getTierConfigs()")
fmt.Fprintln(os.Stderr) fmt.Fprintln(os.Stderr)
os.Exit(0) os.Exit(0)
} }
type httpHeaders map[string]string type httpHeaders map[string]string
func (h httpHeaders) String() string { func (h httpHeaders) String() string {
var m map[string]string = h var m map[string]string = h
return fmt.Sprintf("%s", m) return fmt.Sprintf("%s", m)
} }
func (h httpHeaders) Set(value string) error { func (h httpHeaders) Set(value string) error {
parts := strings.Split(value, ": ") parts := strings.Split(value, ": ")
if len(parts) != 2 { if len(parts) != 2 {
return fmt.Errorf("header should be of format 'Key: Value'") return fmt.Errorf("header should be of format 'Key: Value'")
} }
h[parts[0]] = parts[1] h[parts[0]] = parts[1]
return nil return nil
} }
func main() { func main() {
flag.Usage = Usage flag.Usage = Usage
var host string var host string
var port int var port int
var protocol string var protocol string
var urlString string var urlString string
var framed bool var framed bool
var useHttp bool var useHttp bool
headers := make(httpHeaders) headers := make(httpHeaders)
var parsedUrl *url.URL var parsedUrl *url.URL
var trans thrift.TTransport var trans thrift.TTransport
_ = strconv.Atoi _ = strconv.Atoi
_ = math.Abs _ = math.Abs
flag.Usage = Usage flag.Usage = Usage
flag.StringVar(&host, "h", "localhost", "Specify host and port") flag.StringVar(&host, "h", "localhost", "Specify host and port")
flag.IntVar(&port, "p", 9090, "Specify port") flag.IntVar(&port, "p", 9090, "Specify port")
flag.StringVar(&protocol, "P", "binary", "Specify the protocol (binary, compact, simplejson, json)") flag.StringVar(&protocol, "P", "binary", "Specify the protocol (binary, compact, simplejson, json)")
flag.StringVar(&urlString, "u", "", "Specify the url") flag.StringVar(&urlString, "u", "", "Specify the url")
flag.BoolVar(&framed, "framed", false, "Use framed transport") flag.BoolVar(&framed, "framed", false, "Use framed transport")
flag.BoolVar(&useHttp, "http", false, "Use http") flag.BoolVar(&useHttp, "http", false, "Use http")
flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")")
flag.Parse() flag.Parse()
if len(urlString) > 0 { if len(urlString) > 0 {
var err error var err error
parsedUrl, err = url.Parse(urlString) parsedUrl, err = url.Parse(urlString)
if err != nil { if err != nil {
fmt.Fprintln(os.Stderr, "Error parsing URL: ", err) fmt.Fprintln(os.Stderr, "Error parsing URL: ", err)
flag.Usage() flag.Usage()
} }
host = parsedUrl.Host host = parsedUrl.Host
useHttp = len(parsedUrl.Scheme) <= 0 || parsedUrl.Scheme == "http" || parsedUrl.Scheme == "https" useHttp = len(parsedUrl.Scheme) <= 0 || parsedUrl.Scheme == "http" || parsedUrl.Scheme == "https"
} else if useHttp { } else if useHttp {
_, err := url.Parse(fmt.Sprint("http://", host, ":", port)) _, err := url.Parse(fmt.Sprint("http://", host, ":", port))
if err != nil { if err != nil {
fmt.Fprintln(os.Stderr, "Error parsing URL: ", err) fmt.Fprintln(os.Stderr, "Error parsing URL: ", err)
flag.Usage() flag.Usage()
} }
} }
cmd := flag.Arg(0) cmd := flag.Arg(0)
var err error var err error
if useHttp { if useHttp {
trans, err = thrift.NewTHttpClient(parsedUrl.String()) trans, err = thrift.NewTHttpClient(parsedUrl.String())
if len(headers) > 0 { if len(headers) > 0 {
httptrans := trans.(*thrift.THttpClient) httptrans := trans.(*thrift.THttpClient)
for key, value := range headers { for key, value := range headers {
httptrans.SetHeader(key, value) httptrans.SetHeader(key, value)
} }
} }
} else { } else {
portStr := fmt.Sprint(port) portStr := fmt.Sprint(port)
if strings.Contains(host, ":") { if strings.Contains(host, ":") {
host, portStr, err = net.SplitHostPort(host) host, portStr, err = net.SplitHostPort(host)
if err != nil { if err != nil {
fmt.Fprintln(os.Stderr, "error with host:", err) fmt.Fprintln(os.Stderr, "error with host:", err)
os.Exit(1) os.Exit(1)
} }
} }
trans, err = thrift.NewTSocket(net.JoinHostPort(host, portStr)) trans, err = thrift.NewTSocket(net.JoinHostPort(host, portStr))
if err != nil { if err != nil {
fmt.Fprintln(os.Stderr, "error resolving address:", err) fmt.Fprintln(os.Stderr, "error resolving address:", err)
os.Exit(1) os.Exit(1)
} }
if framed { if framed {
trans = thrift.NewTFramedTransport(trans) trans = thrift.NewTFramedTransport(trans)
} }
} }
if err != nil { if err != nil {
fmt.Fprintln(os.Stderr, "Error creating transport", err) fmt.Fprintln(os.Stderr, "Error creating transport", err)
os.Exit(1) os.Exit(1)
} }
defer trans.Close() defer trans.Close()
var protocolFactory thrift.TProtocolFactory var protocolFactory thrift.TProtocolFactory
switch protocol { switch protocol {
case "compact": case "compact":
protocolFactory = thrift.NewTCompactProtocolFactory() protocolFactory = thrift.NewTCompactProtocolFactory()
break break
case "simplejson": case "simplejson":
protocolFactory = thrift.NewTSimpleJSONProtocolFactory() protocolFactory = thrift.NewTSimpleJSONProtocolFactory()
break break
case "json": case "json":
protocolFactory = thrift.NewTJSONProtocolFactory() protocolFactory = thrift.NewTJSONProtocolFactory()
break break
case "binary", "": case "binary", "":
protocolFactory = thrift.NewTBinaryProtocolFactoryDefault() protocolFactory = thrift.NewTBinaryProtocolFactoryDefault()
break break
default: default:
fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol)
Usage() Usage()
os.Exit(1) os.Exit(1)
} }
iprot := protocolFactory.GetProtocol(trans) iprot := protocolFactory.GetProtocol(trans)
oprot := protocolFactory.GetProtocol(trans) oprot := protocolFactory.GetProtocol(trans)
client := aurora.NewReadOnlySchedulerClient(thrift.NewTStandardClient(iprot, oprot)) client := aurora.NewReadOnlySchedulerClient(thrift.NewTStandardClient(iprot, oprot))
if err := trans.Open(); err != nil { if err := trans.Open(); err != nil {
fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err)
os.Exit(1) os.Exit(1)
} }
switch cmd { switch cmd {
case "getRoleSummary": case "getRoleSummary":
if flag.NArg()-1 != 0 { if flag.NArg() - 1 != 0 {
fmt.Fprintln(os.Stderr, "GetRoleSummary requires 0 args") fmt.Fprintln(os.Stderr, "GetRoleSummary requires 0 args")
flag.Usage() flag.Usage()
} }
fmt.Print(client.GetRoleSummary(context.Background())) fmt.Print(client.GetRoleSummary(context.Background()))
fmt.Print("\n") fmt.Print("\n")
break break
case "getJobSummary": case "getJobSummary":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetJobSummary requires 1 args") fmt.Fprintln(os.Stderr, "GetJobSummary requires 1 args")
flag.Usage() flag.Usage()
} }
argvalue0 := flag.Arg(1) argvalue0 := flag.Arg(1)
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetJobSummary(context.Background(), value0)) fmt.Print(client.GetJobSummary(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getTasksStatus": case "getTasksStatus":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksStatus requires 1 args")
flag.Usage() flag.Usage()
} }
arg81 := flag.Arg(1) arg81 := flag.Arg(1)
mbTrans82 := thrift.NewTMemoryBufferLen(len(arg81)) mbTrans82 := thrift.NewTMemoryBufferLen(len(arg81))
defer mbTrans82.Close() defer mbTrans82.Close()
_, err83 := mbTrans82.WriteString(arg81) _, err83 := mbTrans82.WriteString(arg81)
if err83 != nil { if err83 != nil {
Usage() Usage()
return return
} }
factory84 := thrift.NewTJSONProtocolFactory() factory84 := thrift.NewTJSONProtocolFactory()
jsProt85 := factory84.GetProtocol(mbTrans82) jsProt85 := factory84.GetProtocol(mbTrans82)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err86 := argvalue0.Read(jsProt85) err86 := argvalue0.Read(jsProt85)
if err86 != nil { if err86 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetTasksStatus(context.Background(), value0)) fmt.Print(client.GetTasksStatus(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getTasksWithoutConfigs": case "getTasksWithoutConfigs":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args") fmt.Fprintln(os.Stderr, "GetTasksWithoutConfigs requires 1 args")
flag.Usage() flag.Usage()
} }
arg87 := flag.Arg(1) arg87 := flag.Arg(1)
mbTrans88 := thrift.NewTMemoryBufferLen(len(arg87)) mbTrans88 := thrift.NewTMemoryBufferLen(len(arg87))
defer mbTrans88.Close() defer mbTrans88.Close()
_, err89 := mbTrans88.WriteString(arg87) _, err89 := mbTrans88.WriteString(arg87)
if err89 != nil { if err89 != nil {
Usage() Usage()
return return
} }
factory90 := thrift.NewTJSONProtocolFactory() factory90 := thrift.NewTJSONProtocolFactory()
jsProt91 := factory90.GetProtocol(mbTrans88) jsProt91 := factory90.GetProtocol(mbTrans88)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err92 := argvalue0.Read(jsProt91) err92 := argvalue0.Read(jsProt91)
if err92 != nil { if err92 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetTasksWithoutConfigs(context.Background(), value0)) fmt.Print(client.GetTasksWithoutConfigs(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getPendingReason": case "getPendingReason":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args") fmt.Fprintln(os.Stderr, "GetPendingReason requires 1 args")
flag.Usage() flag.Usage()
} }
arg93 := flag.Arg(1) arg93 := flag.Arg(1)
mbTrans94 := thrift.NewTMemoryBufferLen(len(arg93)) mbTrans94 := thrift.NewTMemoryBufferLen(len(arg93))
defer mbTrans94.Close() defer mbTrans94.Close()
_, err95 := mbTrans94.WriteString(arg93) _, err95 := mbTrans94.WriteString(arg93)
if err95 != nil { if err95 != nil {
Usage() Usage()
return return
} }
factory96 := thrift.NewTJSONProtocolFactory() factory96 := thrift.NewTJSONProtocolFactory()
jsProt97 := factory96.GetProtocol(mbTrans94) jsProt97 := factory96.GetProtocol(mbTrans94)
argvalue0 := aurora.NewTaskQuery() argvalue0 := aurora.NewTaskQuery()
err98 := argvalue0.Read(jsProt97) err98 := argvalue0.Read(jsProt97)
if err98 != nil { if err98 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetPendingReason(context.Background(), value0)) fmt.Print(client.GetPendingReason(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getConfigSummary": case "getConfigSummary":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args") fmt.Fprintln(os.Stderr, "GetConfigSummary requires 1 args")
flag.Usage() flag.Usage()
} }
arg99 := flag.Arg(1) arg99 := flag.Arg(1)
mbTrans100 := thrift.NewTMemoryBufferLen(len(arg99)) mbTrans100 := thrift.NewTMemoryBufferLen(len(arg99))
defer mbTrans100.Close() defer mbTrans100.Close()
_, err101 := mbTrans100.WriteString(arg99) _, err101 := mbTrans100.WriteString(arg99)
if err101 != nil { if err101 != nil {
Usage() Usage()
return return
} }
factory102 := thrift.NewTJSONProtocolFactory() factory102 := thrift.NewTJSONProtocolFactory()
jsProt103 := factory102.GetProtocol(mbTrans100) jsProt103 := factory102.GetProtocol(mbTrans100)
argvalue0 := aurora.NewJobKey() argvalue0 := aurora.NewJobKey()
err104 := argvalue0.Read(jsProt103) err104 := argvalue0.Read(jsProt103)
if err104 != nil { if err104 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetConfigSummary(context.Background(), value0)) fmt.Print(client.GetConfigSummary(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getJobs": case "getJobs":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetJobs requires 1 args") fmt.Fprintln(os.Stderr, "GetJobs requires 1 args")
flag.Usage() flag.Usage()
} }
argvalue0 := flag.Arg(1) argvalue0 := flag.Arg(1)
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetJobs(context.Background(), value0)) fmt.Print(client.GetJobs(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getQuota": case "getQuota":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetQuota requires 1 args") fmt.Fprintln(os.Stderr, "GetQuota requires 1 args")
flag.Usage() flag.Usage()
} }
argvalue0 := flag.Arg(1) argvalue0 := flag.Arg(1)
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetQuota(context.Background(), value0)) fmt.Print(client.GetQuota(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "populateJobConfig": case "populateJobConfig":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args") fmt.Fprintln(os.Stderr, "PopulateJobConfig requires 1 args")
flag.Usage() flag.Usage()
} }
arg107 := flag.Arg(1) arg107 := flag.Arg(1)
mbTrans108 := thrift.NewTMemoryBufferLen(len(arg107)) mbTrans108 := thrift.NewTMemoryBufferLen(len(arg107))
defer mbTrans108.Close() defer mbTrans108.Close()
_, err109 := mbTrans108.WriteString(arg107) _, err109 := mbTrans108.WriteString(arg107)
if err109 != nil { if err109 != nil {
Usage() Usage()
return return
} }
factory110 := thrift.NewTJSONProtocolFactory() factory110 := thrift.NewTJSONProtocolFactory()
jsProt111 := factory110.GetProtocol(mbTrans108) jsProt111 := factory110.GetProtocol(mbTrans108)
argvalue0 := aurora.NewJobConfiguration() argvalue0 := aurora.NewJobConfiguration()
err112 := argvalue0.Read(jsProt111) err112 := argvalue0.Read(jsProt111)
if err112 != nil { if err112 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.PopulateJobConfig(context.Background(), value0)) fmt.Print(client.PopulateJobConfig(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getJobUpdateSummaries": case "getJobUpdateSummaries":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateSummaries requires 1 args")
flag.Usage() flag.Usage()
} }
arg113 := flag.Arg(1) arg113 := flag.Arg(1)
mbTrans114 := thrift.NewTMemoryBufferLen(len(arg113)) mbTrans114 := thrift.NewTMemoryBufferLen(len(arg113))
defer mbTrans114.Close() defer mbTrans114.Close()
_, err115 := mbTrans114.WriteString(arg113) _, err115 := mbTrans114.WriteString(arg113)
if err115 != nil { if err115 != nil {
Usage() Usage()
return return
} }
factory116 := thrift.NewTJSONProtocolFactory() factory116 := thrift.NewTJSONProtocolFactory()
jsProt117 := factory116.GetProtocol(mbTrans114) jsProt117 := factory116.GetProtocol(mbTrans114)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err118 := argvalue0.Read(jsProt117) err118 := argvalue0.Read(jsProt117)
if err118 != nil { if err118 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetJobUpdateSummaries(context.Background(), value0)) fmt.Print(client.GetJobUpdateSummaries(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getJobUpdateDetails": case "getJobUpdateDetails":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDetails requires 1 args")
flag.Usage() flag.Usage()
} }
arg119 := flag.Arg(1) arg119 := flag.Arg(1)
mbTrans120 := thrift.NewTMemoryBufferLen(len(arg119)) mbTrans120 := thrift.NewTMemoryBufferLen(len(arg119))
defer mbTrans120.Close() defer mbTrans120.Close()
_, err121 := mbTrans120.WriteString(arg119) _, err121 := mbTrans120.WriteString(arg119)
if err121 != nil { if err121 != nil {
Usage() Usage()
return return
} }
factory122 := thrift.NewTJSONProtocolFactory() factory122 := thrift.NewTJSONProtocolFactory()
jsProt123 := factory122.GetProtocol(mbTrans120) jsProt123 := factory122.GetProtocol(mbTrans120)
argvalue0 := aurora.NewJobUpdateQuery() argvalue0 := aurora.NewJobUpdateQuery()
err124 := argvalue0.Read(jsProt123) err124 := argvalue0.Read(jsProt123)
if err124 != nil { if err124 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetJobUpdateDetails(context.Background(), value0)) fmt.Print(client.GetJobUpdateDetails(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getJobUpdateDiff": case "getJobUpdateDiff":
if flag.NArg()-1 != 1 { if flag.NArg() - 1 != 1 {
fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args") fmt.Fprintln(os.Stderr, "GetJobUpdateDiff requires 1 args")
flag.Usage() flag.Usage()
} }
arg125 := flag.Arg(1) arg125 := flag.Arg(1)
mbTrans126 := thrift.NewTMemoryBufferLen(len(arg125)) mbTrans126 := thrift.NewTMemoryBufferLen(len(arg125))
defer mbTrans126.Close() defer mbTrans126.Close()
_, err127 := mbTrans126.WriteString(arg125) _, err127 := mbTrans126.WriteString(arg125)
if err127 != nil { if err127 != nil {
Usage() Usage()
return return
} }
factory128 := thrift.NewTJSONProtocolFactory() factory128 := thrift.NewTJSONProtocolFactory()
jsProt129 := factory128.GetProtocol(mbTrans126) jsProt129 := factory128.GetProtocol(mbTrans126)
argvalue0 := aurora.NewJobUpdateRequest() argvalue0 := aurora.NewJobUpdateRequest()
err130 := argvalue0.Read(jsProt129) err130 := argvalue0.Read(jsProt129)
if err130 != nil { if err130 != nil {
Usage() Usage()
return return
} }
value0 := argvalue0 value0 := argvalue0
fmt.Print(client.GetJobUpdateDiff(context.Background(), value0)) fmt.Print(client.GetJobUpdateDiff(context.Background(), value0))
fmt.Print("\n") fmt.Print("\n")
break break
case "getTierConfigs": case "getTierConfigs":
if flag.NArg()-1 != 0 { if flag.NArg() - 1 != 0 {
fmt.Fprintln(os.Stderr, "GetTierConfigs requires 0 args") fmt.Fprintln(os.Stderr, "GetTierConfigs requires 0 args")
flag.Usage() flag.Usage()
} }
fmt.Print(client.GetTierConfigs(context.Background())) fmt.Print(client.GetTierConfigs(context.Background()))
fmt.Print("\n") fmt.Print("\n")
break break
case "": case "":
Usage() Usage()
break break
default: default:
fmt.Fprintln(os.Stderr, "Invalid function ", cmd) fmt.Fprintln(os.Stderr, "Invalid function ", cmd)
} }
} }