This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch 0.13.0interfaces in repository https://gitbox.apache.org/repos/asf/iotdb-client-go.git
commit 7c7c3b3c33f42a8dbada877842e19e8897c4e544 Author: HTHou <[email protected]> AuthorDate: Fri Jul 22 19:04:25 2022 +0800 [To rel/0.13] update 0.13.0 interfaces --- rpc/t_s_i_service-remote/t_s_i_service-remote.go | 1359 ++++++++++++++++++++++ 1 file changed, 1359 insertions(+) diff --git a/rpc/t_s_i_service-remote/t_s_i_service-remote.go b/rpc/t_s_i_service-remote/t_s_i_service-remote.go new file mode 100755 index 0000000..4cba058 --- /dev/null +++ b/rpc/t_s_i_service-remote/t_s_i_service-remote.go @@ -0,0 +1,1359 @@ +// Code generated by Thrift Compiler (0.14.1). DO NOT EDIT. + +package main + +import ( + "context" + "flag" + "fmt" + "math" + "net" + "net/url" + "os" + "strconv" + "strings" + "github.com/apache/thrift/lib/go/thrift" + "rpc" +) + +var _ = rpc.GoUnusedProtection__ + +func Usage() { + fmt.Fprintln(os.Stderr, "Usage of ", os.Args[0], " [-h host:port] [-u url] [-f[ramed]] function [arg1 [arg2...]]:") + flag.PrintDefaults() + fmt.Fprintln(os.Stderr, "\nFunctions:") + fmt.Fprintln(os.Stderr, " TSOpenSessionResp openSession(TSOpenSessionReq req)") + fmt.Fprintln(os.Stderr, " TSStatus closeSession(TSCloseSessionReq req)") + fmt.Fprintln(os.Stderr, " TSExecuteStatementResp executeStatement(TSExecuteStatementReq req)") + fmt.Fprintln(os.Stderr, " TSStatus executeBatchStatement(TSExecuteBatchStatementReq req)") + fmt.Fprintln(os.Stderr, " TSExecuteStatementResp executeQueryStatement(TSExecuteStatementReq req)") + fmt.Fprintln(os.Stderr, " TSExecuteStatementResp executeUpdateStatement(TSExecuteStatementReq req)") + fmt.Fprintln(os.Stderr, " TSFetchResultsResp fetchResults(TSFetchResultsReq req)") + fmt.Fprintln(os.Stderr, " TSFetchMetadataResp fetchMetadata(TSFetchMetadataReq req)") + fmt.Fprintln(os.Stderr, " TSStatus cancelOperation(TSCancelOperationReq req)") + fmt.Fprintln(os.Stderr, " TSStatus closeOperation(TSCloseOperationReq req)") + fmt.Fprintln(os.Stderr, " TSGetTimeZoneResp getTimeZone(i64 sessionId)") + fmt.Fprintln(os.Stderr, " TSStatus setTimeZone(TSSetTimeZoneReq req)") + fmt.Fprintln(os.Stderr, " ServerProperties getProperties()") + fmt.Fprintln(os.Stderr, " TSStatus setStorageGroup(i64 sessionId, string storageGroup)") + fmt.Fprintln(os.Stderr, " TSStatus createTimeseries(TSCreateTimeseriesReq req)") + fmt.Fprintln(os.Stderr, " TSStatus createAlignedTimeseries(TSCreateAlignedTimeseriesReq req)") + fmt.Fprintln(os.Stderr, " TSStatus createMultiTimeseries(TSCreateMultiTimeseriesReq req)") + fmt.Fprintln(os.Stderr, " TSStatus deleteTimeseries(i64 sessionId, path)") + fmt.Fprintln(os.Stderr, " TSStatus deleteStorageGroups(i64 sessionId, storageGroup)") + fmt.Fprintln(os.Stderr, " TSStatus insertRecord(TSInsertRecordReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertStringRecord(TSInsertStringRecordReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertTablet(TSInsertTabletReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertTablets(TSInsertTabletsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertRecords(TSInsertRecordsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertRecordsOfOneDevice(TSInsertRecordsOfOneDeviceReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertStringRecordsOfOneDevice(TSInsertStringRecordsOfOneDeviceReq req)") + fmt.Fprintln(os.Stderr, " TSStatus insertStringRecords(TSInsertStringRecordsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertTablet(TSInsertTabletReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertTablets(TSInsertTabletsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertRecord(TSInsertRecordReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertStringRecord(TSInsertStringRecordReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertRecords(TSInsertRecordsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertRecordsOfOneDevice(TSInsertRecordsOfOneDeviceReq req)") + fmt.Fprintln(os.Stderr, " TSStatus testInsertStringRecords(TSInsertStringRecordsReq req)") + fmt.Fprintln(os.Stderr, " TSStatus deleteData(TSDeleteDataReq req)") + fmt.Fprintln(os.Stderr, " TSExecuteStatementResp executeRawDataQuery(TSRawDataQueryReq req)") + fmt.Fprintln(os.Stderr, " TSExecuteStatementResp executeLastDataQuery(TSLastDataQueryReq req)") + fmt.Fprintln(os.Stderr, " i64 requestStatementId(i64 sessionId)") + fmt.Fprintln(os.Stderr, " TSStatus createSchemaTemplate(TSCreateSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus appendSchemaTemplate(TSAppendSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus pruneSchemaTemplate(TSPruneSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSQueryTemplateResp querySchemaTemplate(TSQueryTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus setSchemaTemplate(TSSetSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus unsetSchemaTemplate(TSUnsetSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus setUsingTemplate(TSSetUsingTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus unsetUsingTemplate(i64 sessionId, string templateName, string prefixPath)") + fmt.Fprintln(os.Stderr, " TSStatus dropSchemaTemplate(TSDropSchemaTemplateReq req)") + fmt.Fprintln(os.Stderr, " TSStatus executeOperationSync(TSOperationSyncWriteReq req)") + fmt.Fprintln(os.Stderr) + os.Exit(0) +} + +type httpHeaders map[string]string + +func (h httpHeaders) String() string { + var m map[string]string = h + return fmt.Sprintf("%s", m) +} + +func (h httpHeaders) Set(value string) error { + parts := strings.Split(value, ": ") + if len(parts) != 2 { + return fmt.Errorf("header should be of format 'Key: Value'") + } + h[parts[0]] = parts[1] + return nil +} + +func main() { + flag.Usage = Usage + var host string + var port int + var protocol string + var urlString string + var framed bool + var useHttp bool + headers := make(httpHeaders) + var parsedUrl *url.URL + var trans thrift.TTransport + _ = strconv.Atoi + _ = math.Abs + flag.Usage = Usage + flag.StringVar(&host, "h", "localhost", "Specify host and port") + flag.IntVar(&port, "p", 9090, "Specify port") + flag.StringVar(&protocol, "P", "binary", "Specify the protocol (binary, compact, simplejson, json)") + flag.StringVar(&urlString, "u", "", "Specify the url") + flag.BoolVar(&framed, "framed", false, "Use framed transport") + 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.Parse() + + if len(urlString) > 0 { + var err error + parsedUrl, err = url.Parse(urlString) + if err != nil { + fmt.Fprintln(os.Stderr, "Error parsing URL: ", err) + flag.Usage() + } + host = parsedUrl.Host + useHttp = len(parsedUrl.Scheme) <= 0 || parsedUrl.Scheme == "http" || parsedUrl.Scheme == "https" + } else if useHttp { + _, err := url.Parse(fmt.Sprint("http://";, host, ":", port)) + if err != nil { + fmt.Fprintln(os.Stderr, "Error parsing URL: ", err) + flag.Usage() + } + } + + cmd := flag.Arg(0) + var err error + if useHttp { + trans, err = thrift.NewTHttpClient(parsedUrl.String()) + if len(headers) > 0 { + httptrans := trans.(*thrift.THttpClient) + for key, value := range headers { + httptrans.SetHeader(key, value) + } + } + } else { + portStr := fmt.Sprint(port) + if strings.Contains(host, ":") { + host, portStr, err = net.SplitHostPort(host) + if err != nil { + fmt.Fprintln(os.Stderr, "error with host:", err) + os.Exit(1) + } + } + trans, err = thrift.NewTSocket(net.JoinHostPort(host, portStr)) + if err != nil { + fmt.Fprintln(os.Stderr, "error resolving address:", err) + os.Exit(1) + } + if framed { + trans = thrift.NewTFramedTransport(trans) + } + } + if err != nil { + fmt.Fprintln(os.Stderr, "Error creating transport", err) + os.Exit(1) + } + defer trans.Close() + var protocolFactory thrift.TProtocolFactory + switch protocol { + case "compact": + protocolFactory = thrift.NewTCompactProtocolFactory() + break + case "simplejson": + protocolFactory = thrift.NewTSimpleJSONProtocolFactory() + break + case "json": + protocolFactory = thrift.NewTJSONProtocolFactory() + break + case "binary", "": + protocolFactory = thrift.NewTBinaryProtocolFactoryDefault() + break + default: + fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) + Usage() + os.Exit(1) + } + iprot := protocolFactory.GetProtocol(trans) + oprot := protocolFactory.GetProtocol(trans) + client := rpc.NewTSIServiceClient(thrift.NewTStandardClient(iprot, oprot)) + if err := trans.Open(); err != nil { + fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) + os.Exit(1) + } + + switch cmd { + case "openSession": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "OpenSession requires 1 args") + flag.Usage() + } + arg311 := flag.Arg(1) + mbTrans312 := thrift.NewTMemoryBufferLen(len(arg311)) + defer mbTrans312.Close() + _, err313 := mbTrans312.WriteString(arg311) + if err313 != nil { + Usage() + return + } + factory314 := thrift.NewTJSONProtocolFactory() + jsProt315 := factory314.GetProtocol(mbTrans312) + argvalue0 := rpc.NewTSOpenSessionReq() + err316 := argvalue0.Read(context.Background(), jsProt315) + if err316 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.OpenSession(context.Background(), value0)) + fmt.Print("\n") + break + case "closeSession": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CloseSession requires 1 args") + flag.Usage() + } + arg317 := flag.Arg(1) + mbTrans318 := thrift.NewTMemoryBufferLen(len(arg317)) + defer mbTrans318.Close() + _, err319 := mbTrans318.WriteString(arg317) + if err319 != nil { + Usage() + return + } + factory320 := thrift.NewTJSONProtocolFactory() + jsProt321 := factory320.GetProtocol(mbTrans318) + argvalue0 := rpc.NewTSCloseSessionReq() + err322 := argvalue0.Read(context.Background(), jsProt321) + if err322 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CloseSession(context.Background(), value0)) + fmt.Print("\n") + break + case "executeStatement": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteStatement requires 1 args") + flag.Usage() + } + arg323 := flag.Arg(1) + mbTrans324 := thrift.NewTMemoryBufferLen(len(arg323)) + defer mbTrans324.Close() + _, err325 := mbTrans324.WriteString(arg323) + if err325 != nil { + Usage() + return + } + factory326 := thrift.NewTJSONProtocolFactory() + jsProt327 := factory326.GetProtocol(mbTrans324) + argvalue0 := rpc.NewTSExecuteStatementReq() + err328 := argvalue0.Read(context.Background(), jsProt327) + if err328 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteStatement(context.Background(), value0)) + fmt.Print("\n") + break + case "executeBatchStatement": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteBatchStatement requires 1 args") + flag.Usage() + } + arg329 := flag.Arg(1) + mbTrans330 := thrift.NewTMemoryBufferLen(len(arg329)) + defer mbTrans330.Close() + _, err331 := mbTrans330.WriteString(arg329) + if err331 != nil { + Usage() + return + } + factory332 := thrift.NewTJSONProtocolFactory() + jsProt333 := factory332.GetProtocol(mbTrans330) + argvalue0 := rpc.NewTSExecuteBatchStatementReq() + err334 := argvalue0.Read(context.Background(), jsProt333) + if err334 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteBatchStatement(context.Background(), value0)) + fmt.Print("\n") + break + case "executeQueryStatement": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteQueryStatement requires 1 args") + flag.Usage() + } + arg335 := flag.Arg(1) + mbTrans336 := thrift.NewTMemoryBufferLen(len(arg335)) + defer mbTrans336.Close() + _, err337 := mbTrans336.WriteString(arg335) + if err337 != nil { + Usage() + return + } + factory338 := thrift.NewTJSONProtocolFactory() + jsProt339 := factory338.GetProtocol(mbTrans336) + argvalue0 := rpc.NewTSExecuteStatementReq() + err340 := argvalue0.Read(context.Background(), jsProt339) + if err340 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteQueryStatement(context.Background(), value0)) + fmt.Print("\n") + break + case "executeUpdateStatement": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteUpdateStatement requires 1 args") + flag.Usage() + } + arg341 := flag.Arg(1) + mbTrans342 := thrift.NewTMemoryBufferLen(len(arg341)) + defer mbTrans342.Close() + _, err343 := mbTrans342.WriteString(arg341) + if err343 != nil { + Usage() + return + } + factory344 := thrift.NewTJSONProtocolFactory() + jsProt345 := factory344.GetProtocol(mbTrans342) + argvalue0 := rpc.NewTSExecuteStatementReq() + err346 := argvalue0.Read(context.Background(), jsProt345) + if err346 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteUpdateStatement(context.Background(), value0)) + fmt.Print("\n") + break + case "fetchResults": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "FetchResults requires 1 args") + flag.Usage() + } + arg347 := flag.Arg(1) + mbTrans348 := thrift.NewTMemoryBufferLen(len(arg347)) + defer mbTrans348.Close() + _, err349 := mbTrans348.WriteString(arg347) + if err349 != nil { + Usage() + return + } + factory350 := thrift.NewTJSONProtocolFactory() + jsProt351 := factory350.GetProtocol(mbTrans348) + argvalue0 := rpc.NewTSFetchResultsReq() + err352 := argvalue0.Read(context.Background(), jsProt351) + if err352 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.FetchResults(context.Background(), value0)) + fmt.Print("\n") + break + case "fetchMetadata": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "FetchMetadata requires 1 args") + flag.Usage() + } + arg353 := flag.Arg(1) + mbTrans354 := thrift.NewTMemoryBufferLen(len(arg353)) + defer mbTrans354.Close() + _, err355 := mbTrans354.WriteString(arg353) + if err355 != nil { + Usage() + return + } + factory356 := thrift.NewTJSONProtocolFactory() + jsProt357 := factory356.GetProtocol(mbTrans354) + argvalue0 := rpc.NewTSFetchMetadataReq() + err358 := argvalue0.Read(context.Background(), jsProt357) + if err358 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.FetchMetadata(context.Background(), value0)) + fmt.Print("\n") + break + case "cancelOperation": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CancelOperation requires 1 args") + flag.Usage() + } + arg359 := flag.Arg(1) + mbTrans360 := thrift.NewTMemoryBufferLen(len(arg359)) + defer mbTrans360.Close() + _, err361 := mbTrans360.WriteString(arg359) + if err361 != nil { + Usage() + return + } + factory362 := thrift.NewTJSONProtocolFactory() + jsProt363 := factory362.GetProtocol(mbTrans360) + argvalue0 := rpc.NewTSCancelOperationReq() + err364 := argvalue0.Read(context.Background(), jsProt363) + if err364 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CancelOperation(context.Background(), value0)) + fmt.Print("\n") + break + case "closeOperation": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CloseOperation requires 1 args") + flag.Usage() + } + arg365 := flag.Arg(1) + mbTrans366 := thrift.NewTMemoryBufferLen(len(arg365)) + defer mbTrans366.Close() + _, err367 := mbTrans366.WriteString(arg365) + if err367 != nil { + Usage() + return + } + factory368 := thrift.NewTJSONProtocolFactory() + jsProt369 := factory368.GetProtocol(mbTrans366) + argvalue0 := rpc.NewTSCloseOperationReq() + err370 := argvalue0.Read(context.Background(), jsProt369) + if err370 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CloseOperation(context.Background(), value0)) + fmt.Print("\n") + break + case "getTimeZone": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "GetTimeZone requires 1 args") + flag.Usage() + } + argvalue0, err371 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err371 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.GetTimeZone(context.Background(), value0)) + fmt.Print("\n") + break + case "setTimeZone": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "SetTimeZone requires 1 args") + flag.Usage() + } + arg372 := flag.Arg(1) + mbTrans373 := thrift.NewTMemoryBufferLen(len(arg372)) + defer mbTrans373.Close() + _, err374 := mbTrans373.WriteString(arg372) + if err374 != nil { + Usage() + return + } + factory375 := thrift.NewTJSONProtocolFactory() + jsProt376 := factory375.GetProtocol(mbTrans373) + argvalue0 := rpc.NewTSSetTimeZoneReq() + err377 := argvalue0.Read(context.Background(), jsProt376) + if err377 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.SetTimeZone(context.Background(), value0)) + fmt.Print("\n") + break + case "getProperties": + if flag.NArg() - 1 != 0 { + fmt.Fprintln(os.Stderr, "GetProperties requires 0 args") + flag.Usage() + } + fmt.Print(client.GetProperties(context.Background())) + fmt.Print("\n") + break + case "setStorageGroup": + if flag.NArg() - 1 != 2 { + fmt.Fprintln(os.Stderr, "SetStorageGroup requires 2 args") + flag.Usage() + } + argvalue0, err378 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err378 != nil { + Usage() + return + } + value0 := argvalue0 + argvalue1 := flag.Arg(2) + value1 := argvalue1 + fmt.Print(client.SetStorageGroup(context.Background(), value0, value1)) + fmt.Print("\n") + break + case "createTimeseries": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CreateTimeseries requires 1 args") + flag.Usage() + } + arg380 := flag.Arg(1) + mbTrans381 := thrift.NewTMemoryBufferLen(len(arg380)) + defer mbTrans381.Close() + _, err382 := mbTrans381.WriteString(arg380) + if err382 != nil { + Usage() + return + } + factory383 := thrift.NewTJSONProtocolFactory() + jsProt384 := factory383.GetProtocol(mbTrans381) + argvalue0 := rpc.NewTSCreateTimeseriesReq() + err385 := argvalue0.Read(context.Background(), jsProt384) + if err385 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CreateTimeseries(context.Background(), value0)) + fmt.Print("\n") + break + case "createAlignedTimeseries": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CreateAlignedTimeseries requires 1 args") + flag.Usage() + } + arg386 := flag.Arg(1) + mbTrans387 := thrift.NewTMemoryBufferLen(len(arg386)) + defer mbTrans387.Close() + _, err388 := mbTrans387.WriteString(arg386) + if err388 != nil { + Usage() + return + } + factory389 := thrift.NewTJSONProtocolFactory() + jsProt390 := factory389.GetProtocol(mbTrans387) + argvalue0 := rpc.NewTSCreateAlignedTimeseriesReq() + err391 := argvalue0.Read(context.Background(), jsProt390) + if err391 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CreateAlignedTimeseries(context.Background(), value0)) + fmt.Print("\n") + break + case "createMultiTimeseries": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CreateMultiTimeseries requires 1 args") + flag.Usage() + } + arg392 := flag.Arg(1) + mbTrans393 := thrift.NewTMemoryBufferLen(len(arg392)) + defer mbTrans393.Close() + _, err394 := mbTrans393.WriteString(arg392) + if err394 != nil { + Usage() + return + } + factory395 := thrift.NewTJSONProtocolFactory() + jsProt396 := factory395.GetProtocol(mbTrans393) + argvalue0 := rpc.NewTSCreateMultiTimeseriesReq() + err397 := argvalue0.Read(context.Background(), jsProt396) + if err397 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CreateMultiTimeseries(context.Background(), value0)) + fmt.Print("\n") + break + case "deleteTimeseries": + if flag.NArg() - 1 != 2 { + fmt.Fprintln(os.Stderr, "DeleteTimeseries requires 2 args") + flag.Usage() + } + argvalue0, err398 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err398 != nil { + Usage() + return + } + value0 := argvalue0 + arg399 := flag.Arg(2) + mbTrans400 := thrift.NewTMemoryBufferLen(len(arg399)) + defer mbTrans400.Close() + _, err401 := mbTrans400.WriteString(arg399) + if err401 != nil { + Usage() + return + } + factory402 := thrift.NewTJSONProtocolFactory() + jsProt403 := factory402.GetProtocol(mbTrans400) + containerStruct1 := rpc.NewTSIServiceDeleteTimeseriesArgs() + err404 := containerStruct1.ReadField2(context.Background(), jsProt403) + if err404 != nil { + Usage() + return + } + argvalue1 := containerStruct1.Path + value1 := argvalue1 + fmt.Print(client.DeleteTimeseries(context.Background(), value0, value1)) + fmt.Print("\n") + break + case "deleteStorageGroups": + if flag.NArg() - 1 != 2 { + fmt.Fprintln(os.Stderr, "DeleteStorageGroups requires 2 args") + flag.Usage() + } + argvalue0, err405 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err405 != nil { + Usage() + return + } + value0 := argvalue0 + arg406 := flag.Arg(2) + mbTrans407 := thrift.NewTMemoryBufferLen(len(arg406)) + defer mbTrans407.Close() + _, err408 := mbTrans407.WriteString(arg406) + if err408 != nil { + Usage() + return + } + factory409 := thrift.NewTJSONProtocolFactory() + jsProt410 := factory409.GetProtocol(mbTrans407) + containerStruct1 := rpc.NewTSIServiceDeleteStorageGroupsArgs() + err411 := containerStruct1.ReadField2(context.Background(), jsProt410) + if err411 != nil { + Usage() + return + } + argvalue1 := containerStruct1.StorageGroup + value1 := argvalue1 + fmt.Print(client.DeleteStorageGroups(context.Background(), value0, value1)) + fmt.Print("\n") + break + case "insertRecord": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertRecord requires 1 args") + flag.Usage() + } + arg412 := flag.Arg(1) + mbTrans413 := thrift.NewTMemoryBufferLen(len(arg412)) + defer mbTrans413.Close() + _, err414 := mbTrans413.WriteString(arg412) + if err414 != nil { + Usage() + return + } + factory415 := thrift.NewTJSONProtocolFactory() + jsProt416 := factory415.GetProtocol(mbTrans413) + argvalue0 := rpc.NewTSInsertRecordReq() + err417 := argvalue0.Read(context.Background(), jsProt416) + if err417 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertRecord(context.Background(), value0)) + fmt.Print("\n") + break + case "insertStringRecord": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertStringRecord requires 1 args") + flag.Usage() + } + arg418 := flag.Arg(1) + mbTrans419 := thrift.NewTMemoryBufferLen(len(arg418)) + defer mbTrans419.Close() + _, err420 := mbTrans419.WriteString(arg418) + if err420 != nil { + Usage() + return + } + factory421 := thrift.NewTJSONProtocolFactory() + jsProt422 := factory421.GetProtocol(mbTrans419) + argvalue0 := rpc.NewTSInsertStringRecordReq() + err423 := argvalue0.Read(context.Background(), jsProt422) + if err423 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertStringRecord(context.Background(), value0)) + fmt.Print("\n") + break + case "insertTablet": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertTablet requires 1 args") + flag.Usage() + } + arg424 := flag.Arg(1) + mbTrans425 := thrift.NewTMemoryBufferLen(len(arg424)) + defer mbTrans425.Close() + _, err426 := mbTrans425.WriteString(arg424) + if err426 != nil { + Usage() + return + } + factory427 := thrift.NewTJSONProtocolFactory() + jsProt428 := factory427.GetProtocol(mbTrans425) + argvalue0 := rpc.NewTSInsertTabletReq() + err429 := argvalue0.Read(context.Background(), jsProt428) + if err429 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertTablet(context.Background(), value0)) + fmt.Print("\n") + break + case "insertTablets": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertTablets requires 1 args") + flag.Usage() + } + arg430 := flag.Arg(1) + mbTrans431 := thrift.NewTMemoryBufferLen(len(arg430)) + defer mbTrans431.Close() + _, err432 := mbTrans431.WriteString(arg430) + if err432 != nil { + Usage() + return + } + factory433 := thrift.NewTJSONProtocolFactory() + jsProt434 := factory433.GetProtocol(mbTrans431) + argvalue0 := rpc.NewTSInsertTabletsReq() + err435 := argvalue0.Read(context.Background(), jsProt434) + if err435 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertTablets(context.Background(), value0)) + fmt.Print("\n") + break + case "insertRecords": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertRecords requires 1 args") + flag.Usage() + } + arg436 := flag.Arg(1) + mbTrans437 := thrift.NewTMemoryBufferLen(len(arg436)) + defer mbTrans437.Close() + _, err438 := mbTrans437.WriteString(arg436) + if err438 != nil { + Usage() + return + } + factory439 := thrift.NewTJSONProtocolFactory() + jsProt440 := factory439.GetProtocol(mbTrans437) + argvalue0 := rpc.NewTSInsertRecordsReq() + err441 := argvalue0.Read(context.Background(), jsProt440) + if err441 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertRecords(context.Background(), value0)) + fmt.Print("\n") + break + case "insertRecordsOfOneDevice": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertRecordsOfOneDevice requires 1 args") + flag.Usage() + } + arg442 := flag.Arg(1) + mbTrans443 := thrift.NewTMemoryBufferLen(len(arg442)) + defer mbTrans443.Close() + _, err444 := mbTrans443.WriteString(arg442) + if err444 != nil { + Usage() + return + } + factory445 := thrift.NewTJSONProtocolFactory() + jsProt446 := factory445.GetProtocol(mbTrans443) + argvalue0 := rpc.NewTSInsertRecordsOfOneDeviceReq() + err447 := argvalue0.Read(context.Background(), jsProt446) + if err447 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertRecordsOfOneDevice(context.Background(), value0)) + fmt.Print("\n") + break + case "insertStringRecordsOfOneDevice": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertStringRecordsOfOneDevice requires 1 args") + flag.Usage() + } + arg448 := flag.Arg(1) + mbTrans449 := thrift.NewTMemoryBufferLen(len(arg448)) + defer mbTrans449.Close() + _, err450 := mbTrans449.WriteString(arg448) + if err450 != nil { + Usage() + return + } + factory451 := thrift.NewTJSONProtocolFactory() + jsProt452 := factory451.GetProtocol(mbTrans449) + argvalue0 := rpc.NewTSInsertStringRecordsOfOneDeviceReq() + err453 := argvalue0.Read(context.Background(), jsProt452) + if err453 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertStringRecordsOfOneDevice(context.Background(), value0)) + fmt.Print("\n") + break + case "insertStringRecords": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "InsertStringRecords requires 1 args") + flag.Usage() + } + arg454 := flag.Arg(1) + mbTrans455 := thrift.NewTMemoryBufferLen(len(arg454)) + defer mbTrans455.Close() + _, err456 := mbTrans455.WriteString(arg454) + if err456 != nil { + Usage() + return + } + factory457 := thrift.NewTJSONProtocolFactory() + jsProt458 := factory457.GetProtocol(mbTrans455) + argvalue0 := rpc.NewTSInsertStringRecordsReq() + err459 := argvalue0.Read(context.Background(), jsProt458) + if err459 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.InsertStringRecords(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertTablet": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertTablet requires 1 args") + flag.Usage() + } + arg460 := flag.Arg(1) + mbTrans461 := thrift.NewTMemoryBufferLen(len(arg460)) + defer mbTrans461.Close() + _, err462 := mbTrans461.WriteString(arg460) + if err462 != nil { + Usage() + return + } + factory463 := thrift.NewTJSONProtocolFactory() + jsProt464 := factory463.GetProtocol(mbTrans461) + argvalue0 := rpc.NewTSInsertTabletReq() + err465 := argvalue0.Read(context.Background(), jsProt464) + if err465 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertTablet(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertTablets": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertTablets requires 1 args") + flag.Usage() + } + arg466 := flag.Arg(1) + mbTrans467 := thrift.NewTMemoryBufferLen(len(arg466)) + defer mbTrans467.Close() + _, err468 := mbTrans467.WriteString(arg466) + if err468 != nil { + Usage() + return + } + factory469 := thrift.NewTJSONProtocolFactory() + jsProt470 := factory469.GetProtocol(mbTrans467) + argvalue0 := rpc.NewTSInsertTabletsReq() + err471 := argvalue0.Read(context.Background(), jsProt470) + if err471 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertTablets(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertRecord": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertRecord requires 1 args") + flag.Usage() + } + arg472 := flag.Arg(1) + mbTrans473 := thrift.NewTMemoryBufferLen(len(arg472)) + defer mbTrans473.Close() + _, err474 := mbTrans473.WriteString(arg472) + if err474 != nil { + Usage() + return + } + factory475 := thrift.NewTJSONProtocolFactory() + jsProt476 := factory475.GetProtocol(mbTrans473) + argvalue0 := rpc.NewTSInsertRecordReq() + err477 := argvalue0.Read(context.Background(), jsProt476) + if err477 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertRecord(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertStringRecord": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertStringRecord requires 1 args") + flag.Usage() + } + arg478 := flag.Arg(1) + mbTrans479 := thrift.NewTMemoryBufferLen(len(arg478)) + defer mbTrans479.Close() + _, err480 := mbTrans479.WriteString(arg478) + if err480 != nil { + Usage() + return + } + factory481 := thrift.NewTJSONProtocolFactory() + jsProt482 := factory481.GetProtocol(mbTrans479) + argvalue0 := rpc.NewTSInsertStringRecordReq() + err483 := argvalue0.Read(context.Background(), jsProt482) + if err483 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertStringRecord(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertRecords": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertRecords requires 1 args") + flag.Usage() + } + arg484 := flag.Arg(1) + mbTrans485 := thrift.NewTMemoryBufferLen(len(arg484)) + defer mbTrans485.Close() + _, err486 := mbTrans485.WriteString(arg484) + if err486 != nil { + Usage() + return + } + factory487 := thrift.NewTJSONProtocolFactory() + jsProt488 := factory487.GetProtocol(mbTrans485) + argvalue0 := rpc.NewTSInsertRecordsReq() + err489 := argvalue0.Read(context.Background(), jsProt488) + if err489 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertRecords(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertRecordsOfOneDevice": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertRecordsOfOneDevice requires 1 args") + flag.Usage() + } + arg490 := flag.Arg(1) + mbTrans491 := thrift.NewTMemoryBufferLen(len(arg490)) + defer mbTrans491.Close() + _, err492 := mbTrans491.WriteString(arg490) + if err492 != nil { + Usage() + return + } + factory493 := thrift.NewTJSONProtocolFactory() + jsProt494 := factory493.GetProtocol(mbTrans491) + argvalue0 := rpc.NewTSInsertRecordsOfOneDeviceReq() + err495 := argvalue0.Read(context.Background(), jsProt494) + if err495 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertRecordsOfOneDevice(context.Background(), value0)) + fmt.Print("\n") + break + case "testInsertStringRecords": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "TestInsertStringRecords requires 1 args") + flag.Usage() + } + arg496 := flag.Arg(1) + mbTrans497 := thrift.NewTMemoryBufferLen(len(arg496)) + defer mbTrans497.Close() + _, err498 := mbTrans497.WriteString(arg496) + if err498 != nil { + Usage() + return + } + factory499 := thrift.NewTJSONProtocolFactory() + jsProt500 := factory499.GetProtocol(mbTrans497) + argvalue0 := rpc.NewTSInsertStringRecordsReq() + err501 := argvalue0.Read(context.Background(), jsProt500) + if err501 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.TestInsertStringRecords(context.Background(), value0)) + fmt.Print("\n") + break + case "deleteData": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "DeleteData requires 1 args") + flag.Usage() + } + arg502 := flag.Arg(1) + mbTrans503 := thrift.NewTMemoryBufferLen(len(arg502)) + defer mbTrans503.Close() + _, err504 := mbTrans503.WriteString(arg502) + if err504 != nil { + Usage() + return + } + factory505 := thrift.NewTJSONProtocolFactory() + jsProt506 := factory505.GetProtocol(mbTrans503) + argvalue0 := rpc.NewTSDeleteDataReq() + err507 := argvalue0.Read(context.Background(), jsProt506) + if err507 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.DeleteData(context.Background(), value0)) + fmt.Print("\n") + break + case "executeRawDataQuery": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteRawDataQuery requires 1 args") + flag.Usage() + } + arg508 := flag.Arg(1) + mbTrans509 := thrift.NewTMemoryBufferLen(len(arg508)) + defer mbTrans509.Close() + _, err510 := mbTrans509.WriteString(arg508) + if err510 != nil { + Usage() + return + } + factory511 := thrift.NewTJSONProtocolFactory() + jsProt512 := factory511.GetProtocol(mbTrans509) + argvalue0 := rpc.NewTSRawDataQueryReq() + err513 := argvalue0.Read(context.Background(), jsProt512) + if err513 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteRawDataQuery(context.Background(), value0)) + fmt.Print("\n") + break + case "executeLastDataQuery": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteLastDataQuery requires 1 args") + flag.Usage() + } + arg514 := flag.Arg(1) + mbTrans515 := thrift.NewTMemoryBufferLen(len(arg514)) + defer mbTrans515.Close() + _, err516 := mbTrans515.WriteString(arg514) + if err516 != nil { + Usage() + return + } + factory517 := thrift.NewTJSONProtocolFactory() + jsProt518 := factory517.GetProtocol(mbTrans515) + argvalue0 := rpc.NewTSLastDataQueryReq() + err519 := argvalue0.Read(context.Background(), jsProt518) + if err519 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteLastDataQuery(context.Background(), value0)) + fmt.Print("\n") + break + case "requestStatementId": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "RequestStatementId requires 1 args") + flag.Usage() + } + argvalue0, err520 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err520 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.RequestStatementId(context.Background(), value0)) + fmt.Print("\n") + break + case "createSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "CreateSchemaTemplate requires 1 args") + flag.Usage() + } + arg521 := flag.Arg(1) + mbTrans522 := thrift.NewTMemoryBufferLen(len(arg521)) + defer mbTrans522.Close() + _, err523 := mbTrans522.WriteString(arg521) + if err523 != nil { + Usage() + return + } + factory524 := thrift.NewTJSONProtocolFactory() + jsProt525 := factory524.GetProtocol(mbTrans522) + argvalue0 := rpc.NewTSCreateSchemaTemplateReq() + err526 := argvalue0.Read(context.Background(), jsProt525) + if err526 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.CreateSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "appendSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "AppendSchemaTemplate requires 1 args") + flag.Usage() + } + arg527 := flag.Arg(1) + mbTrans528 := thrift.NewTMemoryBufferLen(len(arg527)) + defer mbTrans528.Close() + _, err529 := mbTrans528.WriteString(arg527) + if err529 != nil { + Usage() + return + } + factory530 := thrift.NewTJSONProtocolFactory() + jsProt531 := factory530.GetProtocol(mbTrans528) + argvalue0 := rpc.NewTSAppendSchemaTemplateReq() + err532 := argvalue0.Read(context.Background(), jsProt531) + if err532 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.AppendSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "pruneSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "PruneSchemaTemplate requires 1 args") + flag.Usage() + } + arg533 := flag.Arg(1) + mbTrans534 := thrift.NewTMemoryBufferLen(len(arg533)) + defer mbTrans534.Close() + _, err535 := mbTrans534.WriteString(arg533) + if err535 != nil { + Usage() + return + } + factory536 := thrift.NewTJSONProtocolFactory() + jsProt537 := factory536.GetProtocol(mbTrans534) + argvalue0 := rpc.NewTSPruneSchemaTemplateReq() + err538 := argvalue0.Read(context.Background(), jsProt537) + if err538 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.PruneSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "querySchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "QuerySchemaTemplate requires 1 args") + flag.Usage() + } + arg539 := flag.Arg(1) + mbTrans540 := thrift.NewTMemoryBufferLen(len(arg539)) + defer mbTrans540.Close() + _, err541 := mbTrans540.WriteString(arg539) + if err541 != nil { + Usage() + return + } + factory542 := thrift.NewTJSONProtocolFactory() + jsProt543 := factory542.GetProtocol(mbTrans540) + argvalue0 := rpc.NewTSQueryTemplateReq() + err544 := argvalue0.Read(context.Background(), jsProt543) + if err544 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.QuerySchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "setSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "SetSchemaTemplate requires 1 args") + flag.Usage() + } + arg545 := flag.Arg(1) + mbTrans546 := thrift.NewTMemoryBufferLen(len(arg545)) + defer mbTrans546.Close() + _, err547 := mbTrans546.WriteString(arg545) + if err547 != nil { + Usage() + return + } + factory548 := thrift.NewTJSONProtocolFactory() + jsProt549 := factory548.GetProtocol(mbTrans546) + argvalue0 := rpc.NewTSSetSchemaTemplateReq() + err550 := argvalue0.Read(context.Background(), jsProt549) + if err550 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.SetSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "unsetSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "UnsetSchemaTemplate requires 1 args") + flag.Usage() + } + arg551 := flag.Arg(1) + mbTrans552 := thrift.NewTMemoryBufferLen(len(arg551)) + defer mbTrans552.Close() + _, err553 := mbTrans552.WriteString(arg551) + if err553 != nil { + Usage() + return + } + factory554 := thrift.NewTJSONProtocolFactory() + jsProt555 := factory554.GetProtocol(mbTrans552) + argvalue0 := rpc.NewTSUnsetSchemaTemplateReq() + err556 := argvalue0.Read(context.Background(), jsProt555) + if err556 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.UnsetSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "setUsingTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "SetUsingTemplate requires 1 args") + flag.Usage() + } + arg557 := flag.Arg(1) + mbTrans558 := thrift.NewTMemoryBufferLen(len(arg557)) + defer mbTrans558.Close() + _, err559 := mbTrans558.WriteString(arg557) + if err559 != nil { + Usage() + return + } + factory560 := thrift.NewTJSONProtocolFactory() + jsProt561 := factory560.GetProtocol(mbTrans558) + argvalue0 := rpc.NewTSSetUsingTemplateReq() + err562 := argvalue0.Read(context.Background(), jsProt561) + if err562 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.SetUsingTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "unsetUsingTemplate": + if flag.NArg() - 1 != 3 { + fmt.Fprintln(os.Stderr, "UnsetUsingTemplate requires 3 args") + flag.Usage() + } + argvalue0, err563 := (strconv.ParseInt(flag.Arg(1), 10, 64)) + if err563 != nil { + Usage() + return + } + value0 := argvalue0 + argvalue1 := flag.Arg(2) + value1 := argvalue1 + argvalue2 := flag.Arg(3) + value2 := argvalue2 + fmt.Print(client.UnsetUsingTemplate(context.Background(), value0, value1, value2)) + fmt.Print("\n") + break + case "dropSchemaTemplate": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "DropSchemaTemplate requires 1 args") + flag.Usage() + } + arg566 := flag.Arg(1) + mbTrans567 := thrift.NewTMemoryBufferLen(len(arg566)) + defer mbTrans567.Close() + _, err568 := mbTrans567.WriteString(arg566) + if err568 != nil { + Usage() + return + } + factory569 := thrift.NewTJSONProtocolFactory() + jsProt570 := factory569.GetProtocol(mbTrans567) + argvalue0 := rpc.NewTSDropSchemaTemplateReq() + err571 := argvalue0.Read(context.Background(), jsProt570) + if err571 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.DropSchemaTemplate(context.Background(), value0)) + fmt.Print("\n") + break + case "executeOperationSync": + if flag.NArg() - 1 != 1 { + fmt.Fprintln(os.Stderr, "ExecuteOperationSync requires 1 args") + flag.Usage() + } + arg572 := flag.Arg(1) + mbTrans573 := thrift.NewTMemoryBufferLen(len(arg572)) + defer mbTrans573.Close() + _, err574 := mbTrans573.WriteString(arg572) + if err574 != nil { + Usage() + return + } + factory575 := thrift.NewTJSONProtocolFactory() + jsProt576 := factory575.GetProtocol(mbTrans573) + argvalue0 := rpc.NewTSOperationSyncWriteReq() + err577 := argvalue0.Read(context.Background(), jsProt576) + if err577 != nil { + Usage() + return + } + value0 := argvalue0 + fmt.Print(client.ExecuteOperationSync(context.Background(), value0)) + fmt.Print("\n") + break + case "": + Usage() + break + default: + fmt.Fprintln(os.Stderr, "Invalid function ", cmd) + } +}
