From df7576f28419cf9731c72c6cc4fb57ab4b454a1f Mon Sep 17 00:00:00 2001 From: Tiago Peczenyj Date: Mon, 2 May 2022 22:41:45 +0200 Subject: [PATCH 1/2] remove remote services, the code is not necessary to use this project as a nebula driver --- .../graph_service-remote.go | 282 -- .../meta_service-remote.go | 2334 ----------------- .../graph_storage_service-remote.go | 644 ----- .../storage_admin_service-remote.go | 488 ---- 4 files changed, 3748 deletions(-) delete mode 100755 nebula/graph/graph_service-remote/graph_service-remote.go delete mode 100755 nebula/meta/meta_service-remote/meta_service-remote.go delete mode 100755 nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go delete mode 100755 nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go diff --git a/nebula/graph/graph_service-remote/graph_service-remote.go b/nebula/graph/graph_service-remote/graph_service-remote.go deleted file mode 100755 index 1bc4dd2d..00000000 --- a/nebula/graph/graph_service-remote/graph_service-remote.go +++ /dev/null @@ -1,282 +0,0 @@ -// Autogenerated by Thrift Compiler (facebook) -// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -// @generated - -package main - -import ( - "flag" - "fmt" - "math" - "net" - "net/url" - "os" - "strconv" - "strings" - thrift "github.com/facebook/fbthrift/thrift/lib/go/thrift" - "../../github.com/vesoft-inc/nebula-go/v3/nebula/graph" -) - -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, " AuthResponse authenticate(string username, string password)") - fmt.Fprintln(os.Stderr, " void signout(i64 sessionId)") - fmt.Fprintln(os.Stderr, " ExecutionResponse execute(i64 sessionId, string stmt)") - fmt.Fprintln(os.Stderr, " ExecutionResponse executeWithParameter(i64 sessionId, string stmt, parameterMap)") - fmt.Fprintln(os.Stderr, " string executeJson(i64 sessionId, string stmt)") - fmt.Fprintln(os.Stderr, " string executeJsonWithParameter(i64 sessionId, string stmt, parameterMap)") - fmt.Fprintln(os.Stderr, " VerifyClientVersionResp verifyClientVersion(VerifyClientVersionReq req)") - fmt.Fprintln(os.Stderr) - os.Exit(0) -} - -func main() { - flag.Usage = Usage - var host string - var port int - var protocol string - var urlString string - var framed bool - var useHttp bool - var parsedUrl url.URL - var trans thrift.Transport - _ = strconv.Atoi - _ = math.Abs - flag.Usage = Usage - flag.StringVar(&host, "h", "localhost", "Specify host") - 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.Parse() - - if len(urlString) > 0 { - 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" - } 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.NewHTTPPostClient(parsedUrl.String()) - } 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.NewSocket(thrift.SocketAddr(net.JoinHostPort(host, portStr))) - if err != nil { - fmt.Fprintln(os.Stderr, "error resolving address:", err) - os.Exit(1) - } - if framed { - trans = thrift.NewFramedTransport(trans) - } - } - if err != nil { - fmt.Fprintln(os.Stderr, "Error creating transport", err) - os.Exit(1) - } - defer trans.Close() - var protocolFactory thrift.ProtocolFactory - switch protocol { - case "compact": - protocolFactory = thrift.NewCompactProtocolFactory() - break - case "simplejson": - protocolFactory = thrift.NewSimpleJSONProtocolFactory() - break - case "json": - protocolFactory = thrift.NewJSONProtocolFactory() - break - case "binary", "": - protocolFactory = thrift.NewBinaryProtocolFactoryDefault() - break - default: - fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) - Usage() - os.Exit(1) - } - client := graph.NewGraphServiceClientFactory(trans, protocolFactory) - if err := trans.Open(); err != nil { - fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) - os.Exit(1) - } - - switch cmd { - case "authenticate": - if flag.NArg() - 1 != 2 { - fmt.Fprintln(os.Stderr, "Authenticate requires 2 args") - flag.Usage() - } - argvalue0 := []byte(flag.Arg(1)) - value0 := argvalue0 - argvalue1 := []byte(flag.Arg(2)) - value1 := argvalue1 - fmt.Print(client.Authenticate(value0, value1)) - fmt.Print("\n") - break - case "signout": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "Signout requires 1 args") - flag.Usage() - } - argvalue0, err17 := (strconv.ParseInt(flag.Arg(1), 10, 64)) - if err17 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.Signout(value0)) - fmt.Print("\n") - break - case "execute": - if flag.NArg() - 1 != 2 { - fmt.Fprintln(os.Stderr, "Execute requires 2 args") - flag.Usage() - } - argvalue0, err18 := (strconv.ParseInt(flag.Arg(1), 10, 64)) - if err18 != nil { - Usage() - return - } - value0 := argvalue0 - argvalue1 := []byte(flag.Arg(2)) - value1 := argvalue1 - fmt.Print(client.Execute(value0, value1)) - fmt.Print("\n") - break - case "executeWithParameter": - if flag.NArg() - 1 != 3 { - fmt.Fprintln(os.Stderr, "ExecuteWithParameter requires 3 args") - flag.Usage() - } - argvalue0, err20 := (strconv.ParseInt(flag.Arg(1), 10, 64)) - if err20 != nil { - Usage() - return - } - value0 := argvalue0 - argvalue1 := []byte(flag.Arg(2)) - value1 := argvalue1 - arg22 := flag.Arg(3) - mbTrans23 := thrift.NewMemoryBufferLen(len(arg22)) - defer mbTrans23.Close() - _, err24 := mbTrans23.WriteString(arg22) - if err24 != nil { - Usage() - return - } - factory25 := thrift.NewSimpleJSONProtocolFactory() - jsProt26 := factory25.GetProtocol(mbTrans23) - containerStruct2 := graph.NewGraphServiceExecuteWithParameterArgs() - err27 := containerStruct2.ReadField3(jsProt26) - if err27 != nil { - Usage() - return - } - argvalue2 := containerStruct2.ParameterMap - value2 := argvalue2 - fmt.Print(client.ExecuteWithParameter(value0, value1, value2)) - fmt.Print("\n") - break - case "executeJson": - if flag.NArg() - 1 != 2 { - fmt.Fprintln(os.Stderr, "ExecuteJson requires 2 args") - flag.Usage() - } - argvalue0, err28 := (strconv.ParseInt(flag.Arg(1), 10, 64)) - if err28 != nil { - Usage() - return - } - value0 := argvalue0 - argvalue1 := []byte(flag.Arg(2)) - value1 := argvalue1 - fmt.Print(client.ExecuteJson(value0, value1)) - fmt.Print("\n") - break - case "executeJsonWithParameter": - if flag.NArg() - 1 != 3 { - fmt.Fprintln(os.Stderr, "ExecuteJsonWithParameter requires 3 args") - flag.Usage() - } - argvalue0, err30 := (strconv.ParseInt(flag.Arg(1), 10, 64)) - if err30 != nil { - Usage() - return - } - value0 := argvalue0 - argvalue1 := []byte(flag.Arg(2)) - value1 := argvalue1 - arg32 := flag.Arg(3) - mbTrans33 := thrift.NewMemoryBufferLen(len(arg32)) - defer mbTrans33.Close() - _, err34 := mbTrans33.WriteString(arg32) - if err34 != nil { - Usage() - return - } - factory35 := thrift.NewSimpleJSONProtocolFactory() - jsProt36 := factory35.GetProtocol(mbTrans33) - containerStruct2 := graph.NewGraphServiceExecuteJsonWithParameterArgs() - err37 := containerStruct2.ReadField3(jsProt36) - if err37 != nil { - Usage() - return - } - argvalue2 := containerStruct2.ParameterMap - value2 := argvalue2 - fmt.Print(client.ExecuteJsonWithParameter(value0, value1, value2)) - fmt.Print("\n") - break - case "verifyClientVersion": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "VerifyClientVersion requires 1 args") - flag.Usage() - } - arg38 := flag.Arg(1) - mbTrans39 := thrift.NewMemoryBufferLen(len(arg38)) - defer mbTrans39.Close() - _, err40 := mbTrans39.WriteString(arg38) - if err40 != nil { - Usage() - return - } - factory41 := thrift.NewSimpleJSONProtocolFactory() - jsProt42 := factory41.GetProtocol(mbTrans39) - argvalue0 := graph.NewVerifyClientVersionReq() - err43 := argvalue0.Read(jsProt42) - if err43 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.VerifyClientVersion(value0)) - fmt.Print("\n") - break - case "": - Usage() - break - default: - fmt.Fprintln(os.Stderr, "Invalid function ", cmd) - } -} diff --git a/nebula/meta/meta_service-remote/meta_service-remote.go b/nebula/meta/meta_service-remote/meta_service-remote.go deleted file mode 100755 index ddff121e..00000000 --- a/nebula/meta/meta_service-remote/meta_service-remote.go +++ /dev/null @@ -1,2334 +0,0 @@ -// Autogenerated by Thrift Compiler (facebook) -// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -// @generated - -package main - -import ( - "flag" - "fmt" - "math" - "net" - "net/url" - "os" - "strconv" - "strings" - thrift "github.com/facebook/fbthrift/thrift/lib/go/thrift" - "../../github.com/vesoft-inc/nebula-go/v3/nebula/meta" -) - -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, " ExecResp createSpace(CreateSpaceReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropSpace(DropSpaceReq req)") - fmt.Fprintln(os.Stderr, " ExecResp clearSpace(ClearSpaceReq req)") - fmt.Fprintln(os.Stderr, " GetSpaceResp getSpace(GetSpaceReq req)") - fmt.Fprintln(os.Stderr, " ListSpacesResp listSpaces(ListSpacesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp alterSpace(AlterSpaceReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createSpaceAs(CreateSpaceAsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createTag(CreateTagReq req)") - fmt.Fprintln(os.Stderr, " ExecResp alterTag(AlterTagReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropTag(DropTagReq req)") - fmt.Fprintln(os.Stderr, " GetTagResp getTag(GetTagReq req)") - fmt.Fprintln(os.Stderr, " ListTagsResp listTags(ListTagsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createEdge(CreateEdgeReq req)") - fmt.Fprintln(os.Stderr, " ExecResp alterEdge(AlterEdgeReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropEdge(DropEdgeReq req)") - fmt.Fprintln(os.Stderr, " GetEdgeResp getEdge(GetEdgeReq req)") - fmt.Fprintln(os.Stderr, " ListEdgesResp listEdges(ListEdgesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp addHosts(AddHostsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp addHostsIntoZone(AddHostsIntoZoneReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropHosts(DropHostsReq req)") - fmt.Fprintln(os.Stderr, " ListHostsResp listHosts(ListHostsReq req)") - fmt.Fprintln(os.Stderr, " GetPartsAllocResp getPartsAlloc(GetPartsAllocReq req)") - fmt.Fprintln(os.Stderr, " ListPartsResp listParts(ListPartsReq req)") - fmt.Fprintln(os.Stderr, " GetWorkerIdResp getWorkerId(GetWorkerIdReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createTagIndex(CreateTagIndexReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropTagIndex(DropTagIndexReq req)") - fmt.Fprintln(os.Stderr, " GetTagIndexResp getTagIndex(GetTagIndexReq req)") - fmt.Fprintln(os.Stderr, " ListTagIndexesResp listTagIndexes(ListTagIndexesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp rebuildTagIndex(RebuildIndexReq req)") - fmt.Fprintln(os.Stderr, " ListIndexStatusResp listTagIndexStatus(ListIndexStatusReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createEdgeIndex(CreateEdgeIndexReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropEdgeIndex(DropEdgeIndexReq req)") - fmt.Fprintln(os.Stderr, " GetEdgeIndexResp getEdgeIndex(GetEdgeIndexReq req)") - fmt.Fprintln(os.Stderr, " ListEdgeIndexesResp listEdgeIndexes(ListEdgeIndexesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp rebuildEdgeIndex(RebuildIndexReq req)") - fmt.Fprintln(os.Stderr, " ListIndexStatusResp listEdgeIndexStatus(ListIndexStatusReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createUser(CreateUserReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropUser(DropUserReq req)") - fmt.Fprintln(os.Stderr, " ExecResp alterUser(AlterUserReq req)") - fmt.Fprintln(os.Stderr, " ExecResp grantRole(GrantRoleReq req)") - fmt.Fprintln(os.Stderr, " ExecResp revokeRole(RevokeRoleReq req)") - fmt.Fprintln(os.Stderr, " ListUsersResp listUsers(ListUsersReq req)") - fmt.Fprintln(os.Stderr, " ListRolesResp listRoles(ListRolesReq req)") - fmt.Fprintln(os.Stderr, " ListRolesResp getUserRoles(GetUserRolesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp changePassword(ChangePasswordReq req)") - fmt.Fprintln(os.Stderr, " HBResp heartBeat(HBReq req)") - fmt.Fprintln(os.Stderr, " AgentHBResp agentHeartbeat(AgentHBReq req)") - fmt.Fprintln(os.Stderr, " ExecResp regConfig(RegConfigReq req)") - fmt.Fprintln(os.Stderr, " GetConfigResp getConfig(GetConfigReq req)") - fmt.Fprintln(os.Stderr, " ExecResp setConfig(SetConfigReq req)") - fmt.Fprintln(os.Stderr, " ListConfigsResp listConfigs(ListConfigsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createSnapshot(CreateSnapshotReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropSnapshot(DropSnapshotReq req)") - fmt.Fprintln(os.Stderr, " ListSnapshotsResp listSnapshots(ListSnapshotsReq req)") - fmt.Fprintln(os.Stderr, " AdminJobResp runAdminJob(AdminJobReq req)") - fmt.Fprintln(os.Stderr, " ExecResp mergeZone(MergeZoneReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropZone(DropZoneReq req)") - fmt.Fprintln(os.Stderr, " ExecResp divideZone(DivideZoneReq req)") - fmt.Fprintln(os.Stderr, " ExecResp renameZone(RenameZoneReq req)") - fmt.Fprintln(os.Stderr, " GetZoneResp getZone(GetZoneReq req)") - fmt.Fprintln(os.Stderr, " ListZonesResp listZones(ListZonesReq req)") - fmt.Fprintln(os.Stderr, " ExecResp addListener(AddListenerReq req)") - fmt.Fprintln(os.Stderr, " ExecResp removeListener(RemoveListenerReq req)") - fmt.Fprintln(os.Stderr, " ListListenerResp listListener(ListListenerReq req)") - fmt.Fprintln(os.Stderr, " GetStatsResp getStats(GetStatsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp signInService(SignInServiceReq req)") - fmt.Fprintln(os.Stderr, " ExecResp signOutService(SignOutServiceReq req)") - fmt.Fprintln(os.Stderr, " ListServiceClientsResp listServiceClients(ListServiceClientsReq req)") - fmt.Fprintln(os.Stderr, " ExecResp createFTIndex(CreateFTIndexReq req)") - fmt.Fprintln(os.Stderr, " ExecResp dropFTIndex(DropFTIndexReq req)") - fmt.Fprintln(os.Stderr, " ListFTIndexesResp listFTIndexes(ListFTIndexesReq req)") - fmt.Fprintln(os.Stderr, " CreateSessionResp createSession(CreateSessionReq req)") - fmt.Fprintln(os.Stderr, " UpdateSessionsResp updateSessions(UpdateSessionsReq req)") - fmt.Fprintln(os.Stderr, " ListSessionsResp listSessions(ListSessionsReq req)") - fmt.Fprintln(os.Stderr, " GetSessionResp getSession(GetSessionReq req)") - fmt.Fprintln(os.Stderr, " ExecResp removeSession(RemoveSessionReq req)") - fmt.Fprintln(os.Stderr, " ExecResp killQuery(KillQueryReq req)") - fmt.Fprintln(os.Stderr, " ExecResp reportTaskFinish(ReportTaskReq req)") - fmt.Fprintln(os.Stderr, " CreateBackupResp createBackup(CreateBackupReq req)") - fmt.Fprintln(os.Stderr, " ExecResp restoreMeta(RestoreMetaReq req)") - fmt.Fprintln(os.Stderr, " ListClusterInfoResp listCluster(ListClusterInfoReq req)") - fmt.Fprintln(os.Stderr, " GetMetaDirInfoResp getMetaDirInfo(GetMetaDirInfoReq req)") - fmt.Fprintln(os.Stderr, " VerifyClientVersionResp verifyClientVersion(VerifyClientVersionReq req)") - fmt.Fprintln(os.Stderr, " SaveGraphVersionResp saveGraphVersion(SaveGraphVersionReq req)") - fmt.Fprintln(os.Stderr, " GetSegmentIdResp getSegmentId(GetSegmentIdReq req)") - fmt.Fprintln(os.Stderr) - os.Exit(0) -} - -func main() { - flag.Usage = Usage - var host string - var port int - var protocol string - var urlString string - var framed bool - var useHttp bool - var parsedUrl url.URL - var trans thrift.Transport - _ = strconv.Atoi - _ = math.Abs - flag.Usage = Usage - flag.StringVar(&host, "h", "localhost", "Specify host") - 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.Parse() - - if len(urlString) > 0 { - 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" - } 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.NewHTTPPostClient(parsedUrl.String()) - } 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.NewSocket(thrift.SocketAddr(net.JoinHostPort(host, portStr))) - if err != nil { - fmt.Fprintln(os.Stderr, "error resolving address:", err) - os.Exit(1) - } - if framed { - trans = thrift.NewFramedTransport(trans) - } - } - if err != nil { - fmt.Fprintln(os.Stderr, "Error creating transport", err) - os.Exit(1) - } - defer trans.Close() - var protocolFactory thrift.ProtocolFactory - switch protocol { - case "compact": - protocolFactory = thrift.NewCompactProtocolFactory() - break - case "simplejson": - protocolFactory = thrift.NewSimpleJSONProtocolFactory() - break - case "json": - protocolFactory = thrift.NewJSONProtocolFactory() - break - case "binary", "": - protocolFactory = thrift.NewBinaryProtocolFactoryDefault() - break - default: - fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) - Usage() - os.Exit(1) - } - client := meta.NewMetaServiceClientFactory(trans, protocolFactory) - if err := trans.Open(); err != nil { - fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) - os.Exit(1) - } - - switch cmd { - case "createSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateSpace requires 1 args") - flag.Usage() - } - arg106 := flag.Arg(1) - mbTrans107 := thrift.NewMemoryBufferLen(len(arg106)) - defer mbTrans107.Close() - _, err108 := mbTrans107.WriteString(arg106) - if err108 != nil { - Usage() - return - } - factory109 := thrift.NewSimpleJSONProtocolFactory() - jsProt110 := factory109.GetProtocol(mbTrans107) - argvalue0 := meta.NewCreateSpaceReq() - err111 := argvalue0.Read(jsProt110) - if err111 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateSpace(value0)) - fmt.Print("\n") - break - case "dropSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropSpace requires 1 args") - flag.Usage() - } - arg112 := flag.Arg(1) - mbTrans113 := thrift.NewMemoryBufferLen(len(arg112)) - defer mbTrans113.Close() - _, err114 := mbTrans113.WriteString(arg112) - if err114 != nil { - Usage() - return - } - factory115 := thrift.NewSimpleJSONProtocolFactory() - jsProt116 := factory115.GetProtocol(mbTrans113) - argvalue0 := meta.NewDropSpaceReq() - err117 := argvalue0.Read(jsProt116) - if err117 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropSpace(value0)) - fmt.Print("\n") - break - case "clearSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ClearSpace requires 1 args") - flag.Usage() - } - arg118 := flag.Arg(1) - mbTrans119 := thrift.NewMemoryBufferLen(len(arg118)) - defer mbTrans119.Close() - _, err120 := mbTrans119.WriteString(arg118) - if err120 != nil { - Usage() - return - } - factory121 := thrift.NewSimpleJSONProtocolFactory() - jsProt122 := factory121.GetProtocol(mbTrans119) - argvalue0 := meta.NewClearSpaceReq() - err123 := argvalue0.Read(jsProt122) - if err123 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ClearSpace(value0)) - fmt.Print("\n") - break - case "getSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetSpace requires 1 args") - flag.Usage() - } - arg124 := flag.Arg(1) - mbTrans125 := thrift.NewMemoryBufferLen(len(arg124)) - defer mbTrans125.Close() - _, err126 := mbTrans125.WriteString(arg124) - if err126 != nil { - Usage() - return - } - factory127 := thrift.NewSimpleJSONProtocolFactory() - jsProt128 := factory127.GetProtocol(mbTrans125) - argvalue0 := meta.NewGetSpaceReq() - err129 := argvalue0.Read(jsProt128) - if err129 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetSpace(value0)) - fmt.Print("\n") - break - case "listSpaces": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListSpaces requires 1 args") - flag.Usage() - } - arg130 := flag.Arg(1) - mbTrans131 := thrift.NewMemoryBufferLen(len(arg130)) - defer mbTrans131.Close() - _, err132 := mbTrans131.WriteString(arg130) - if err132 != nil { - Usage() - return - } - factory133 := thrift.NewSimpleJSONProtocolFactory() - jsProt134 := factory133.GetProtocol(mbTrans131) - argvalue0 := meta.NewListSpacesReq() - err135 := argvalue0.Read(jsProt134) - if err135 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListSpaces(value0)) - fmt.Print("\n") - break - case "alterSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AlterSpace requires 1 args") - flag.Usage() - } - arg136 := flag.Arg(1) - mbTrans137 := thrift.NewMemoryBufferLen(len(arg136)) - defer mbTrans137.Close() - _, err138 := mbTrans137.WriteString(arg136) - if err138 != nil { - Usage() - return - } - factory139 := thrift.NewSimpleJSONProtocolFactory() - jsProt140 := factory139.GetProtocol(mbTrans137) - argvalue0 := meta.NewAlterSpaceReq() - err141 := argvalue0.Read(jsProt140) - if err141 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AlterSpace(value0)) - fmt.Print("\n") - break - case "createSpaceAs": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateSpaceAs requires 1 args") - flag.Usage() - } - arg142 := flag.Arg(1) - mbTrans143 := thrift.NewMemoryBufferLen(len(arg142)) - defer mbTrans143.Close() - _, err144 := mbTrans143.WriteString(arg142) - if err144 != nil { - Usage() - return - } - factory145 := thrift.NewSimpleJSONProtocolFactory() - jsProt146 := factory145.GetProtocol(mbTrans143) - argvalue0 := meta.NewCreateSpaceAsReq() - err147 := argvalue0.Read(jsProt146) - if err147 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateSpaceAs(value0)) - fmt.Print("\n") - break - case "createTag": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateTag requires 1 args") - flag.Usage() - } - arg148 := flag.Arg(1) - mbTrans149 := thrift.NewMemoryBufferLen(len(arg148)) - defer mbTrans149.Close() - _, err150 := mbTrans149.WriteString(arg148) - if err150 != nil { - Usage() - return - } - factory151 := thrift.NewSimpleJSONProtocolFactory() - jsProt152 := factory151.GetProtocol(mbTrans149) - argvalue0 := meta.NewCreateTagReq() - err153 := argvalue0.Read(jsProt152) - if err153 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateTag(value0)) - fmt.Print("\n") - break - case "alterTag": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AlterTag requires 1 args") - flag.Usage() - } - arg154 := flag.Arg(1) - mbTrans155 := thrift.NewMemoryBufferLen(len(arg154)) - defer mbTrans155.Close() - _, err156 := mbTrans155.WriteString(arg154) - if err156 != nil { - Usage() - return - } - factory157 := thrift.NewSimpleJSONProtocolFactory() - jsProt158 := factory157.GetProtocol(mbTrans155) - argvalue0 := meta.NewAlterTagReq() - err159 := argvalue0.Read(jsProt158) - if err159 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AlterTag(value0)) - fmt.Print("\n") - break - case "dropTag": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropTag requires 1 args") - flag.Usage() - } - arg160 := flag.Arg(1) - mbTrans161 := thrift.NewMemoryBufferLen(len(arg160)) - defer mbTrans161.Close() - _, err162 := mbTrans161.WriteString(arg160) - if err162 != nil { - Usage() - return - } - factory163 := thrift.NewSimpleJSONProtocolFactory() - jsProt164 := factory163.GetProtocol(mbTrans161) - argvalue0 := meta.NewDropTagReq() - err165 := argvalue0.Read(jsProt164) - if err165 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropTag(value0)) - fmt.Print("\n") - break - case "getTag": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetTag requires 1 args") - flag.Usage() - } - arg166 := flag.Arg(1) - mbTrans167 := thrift.NewMemoryBufferLen(len(arg166)) - defer mbTrans167.Close() - _, err168 := mbTrans167.WriteString(arg166) - if err168 != nil { - Usage() - return - } - factory169 := thrift.NewSimpleJSONProtocolFactory() - jsProt170 := factory169.GetProtocol(mbTrans167) - argvalue0 := meta.NewGetTagReq() - err171 := argvalue0.Read(jsProt170) - if err171 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetTag(value0)) - fmt.Print("\n") - break - case "listTags": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListTags requires 1 args") - flag.Usage() - } - arg172 := flag.Arg(1) - mbTrans173 := thrift.NewMemoryBufferLen(len(arg172)) - defer mbTrans173.Close() - _, err174 := mbTrans173.WriteString(arg172) - if err174 != nil { - Usage() - return - } - factory175 := thrift.NewSimpleJSONProtocolFactory() - jsProt176 := factory175.GetProtocol(mbTrans173) - argvalue0 := meta.NewListTagsReq() - err177 := argvalue0.Read(jsProt176) - if err177 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListTags(value0)) - fmt.Print("\n") - break - case "createEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateEdge requires 1 args") - flag.Usage() - } - arg178 := flag.Arg(1) - mbTrans179 := thrift.NewMemoryBufferLen(len(arg178)) - defer mbTrans179.Close() - _, err180 := mbTrans179.WriteString(arg178) - if err180 != nil { - Usage() - return - } - factory181 := thrift.NewSimpleJSONProtocolFactory() - jsProt182 := factory181.GetProtocol(mbTrans179) - argvalue0 := meta.NewCreateEdgeReq() - err183 := argvalue0.Read(jsProt182) - if err183 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateEdge(value0)) - fmt.Print("\n") - break - case "alterEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AlterEdge requires 1 args") - flag.Usage() - } - arg184 := flag.Arg(1) - mbTrans185 := thrift.NewMemoryBufferLen(len(arg184)) - defer mbTrans185.Close() - _, err186 := mbTrans185.WriteString(arg184) - if err186 != nil { - Usage() - return - } - factory187 := thrift.NewSimpleJSONProtocolFactory() - jsProt188 := factory187.GetProtocol(mbTrans185) - argvalue0 := meta.NewAlterEdgeReq() - err189 := argvalue0.Read(jsProt188) - if err189 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AlterEdge(value0)) - fmt.Print("\n") - break - case "dropEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropEdge requires 1 args") - flag.Usage() - } - arg190 := flag.Arg(1) - mbTrans191 := thrift.NewMemoryBufferLen(len(arg190)) - defer mbTrans191.Close() - _, err192 := mbTrans191.WriteString(arg190) - if err192 != nil { - Usage() - return - } - factory193 := thrift.NewSimpleJSONProtocolFactory() - jsProt194 := factory193.GetProtocol(mbTrans191) - argvalue0 := meta.NewDropEdgeReq() - err195 := argvalue0.Read(jsProt194) - if err195 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropEdge(value0)) - fmt.Print("\n") - break - case "getEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetEdge requires 1 args") - flag.Usage() - } - arg196 := flag.Arg(1) - mbTrans197 := thrift.NewMemoryBufferLen(len(arg196)) - defer mbTrans197.Close() - _, err198 := mbTrans197.WriteString(arg196) - if err198 != nil { - Usage() - return - } - factory199 := thrift.NewSimpleJSONProtocolFactory() - jsProt200 := factory199.GetProtocol(mbTrans197) - argvalue0 := meta.NewGetEdgeReq() - err201 := argvalue0.Read(jsProt200) - if err201 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetEdge(value0)) - fmt.Print("\n") - break - case "listEdges": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListEdges requires 1 args") - flag.Usage() - } - arg202 := flag.Arg(1) - mbTrans203 := thrift.NewMemoryBufferLen(len(arg202)) - defer mbTrans203.Close() - _, err204 := mbTrans203.WriteString(arg202) - if err204 != nil { - Usage() - return - } - factory205 := thrift.NewSimpleJSONProtocolFactory() - jsProt206 := factory205.GetProtocol(mbTrans203) - argvalue0 := meta.NewListEdgesReq() - err207 := argvalue0.Read(jsProt206) - if err207 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListEdges(value0)) - fmt.Print("\n") - break - case "addHosts": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddHosts requires 1 args") - flag.Usage() - } - arg208 := flag.Arg(1) - mbTrans209 := thrift.NewMemoryBufferLen(len(arg208)) - defer mbTrans209.Close() - _, err210 := mbTrans209.WriteString(arg208) - if err210 != nil { - Usage() - return - } - factory211 := thrift.NewSimpleJSONProtocolFactory() - jsProt212 := factory211.GetProtocol(mbTrans209) - argvalue0 := meta.NewAddHostsReq() - err213 := argvalue0.Read(jsProt212) - if err213 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddHosts(value0)) - fmt.Print("\n") - break - case "addHostsIntoZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddHostsIntoZone requires 1 args") - flag.Usage() - } - arg214 := flag.Arg(1) - mbTrans215 := thrift.NewMemoryBufferLen(len(arg214)) - defer mbTrans215.Close() - _, err216 := mbTrans215.WriteString(arg214) - if err216 != nil { - Usage() - return - } - factory217 := thrift.NewSimpleJSONProtocolFactory() - jsProt218 := factory217.GetProtocol(mbTrans215) - argvalue0 := meta.NewAddHostsIntoZoneReq() - err219 := argvalue0.Read(jsProt218) - if err219 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddHostsIntoZone(value0)) - fmt.Print("\n") - break - case "dropHosts": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropHosts requires 1 args") - flag.Usage() - } - arg220 := flag.Arg(1) - mbTrans221 := thrift.NewMemoryBufferLen(len(arg220)) - defer mbTrans221.Close() - _, err222 := mbTrans221.WriteString(arg220) - if err222 != nil { - Usage() - return - } - factory223 := thrift.NewSimpleJSONProtocolFactory() - jsProt224 := factory223.GetProtocol(mbTrans221) - argvalue0 := meta.NewDropHostsReq() - err225 := argvalue0.Read(jsProt224) - if err225 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropHosts(value0)) - fmt.Print("\n") - break - case "listHosts": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListHosts requires 1 args") - flag.Usage() - } - arg226 := flag.Arg(1) - mbTrans227 := thrift.NewMemoryBufferLen(len(arg226)) - defer mbTrans227.Close() - _, err228 := mbTrans227.WriteString(arg226) - if err228 != nil { - Usage() - return - } - factory229 := thrift.NewSimpleJSONProtocolFactory() - jsProt230 := factory229.GetProtocol(mbTrans227) - argvalue0 := meta.NewListHostsReq() - err231 := argvalue0.Read(jsProt230) - if err231 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListHosts(value0)) - fmt.Print("\n") - break - case "getPartsAlloc": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetPartsAlloc requires 1 args") - flag.Usage() - } - arg232 := flag.Arg(1) - mbTrans233 := thrift.NewMemoryBufferLen(len(arg232)) - defer mbTrans233.Close() - _, err234 := mbTrans233.WriteString(arg232) - if err234 != nil { - Usage() - return - } - factory235 := thrift.NewSimpleJSONProtocolFactory() - jsProt236 := factory235.GetProtocol(mbTrans233) - argvalue0 := meta.NewGetPartsAllocReq() - err237 := argvalue0.Read(jsProt236) - if err237 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetPartsAlloc(value0)) - fmt.Print("\n") - break - case "listParts": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListParts requires 1 args") - flag.Usage() - } - arg238 := flag.Arg(1) - mbTrans239 := thrift.NewMemoryBufferLen(len(arg238)) - defer mbTrans239.Close() - _, err240 := mbTrans239.WriteString(arg238) - if err240 != nil { - Usage() - return - } - factory241 := thrift.NewSimpleJSONProtocolFactory() - jsProt242 := factory241.GetProtocol(mbTrans239) - argvalue0 := meta.NewListPartsReq() - err243 := argvalue0.Read(jsProt242) - if err243 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListParts(value0)) - fmt.Print("\n") - break - case "getWorkerId": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetWorkerId requires 1 args") - flag.Usage() - } - arg244 := flag.Arg(1) - mbTrans245 := thrift.NewMemoryBufferLen(len(arg244)) - defer mbTrans245.Close() - _, err246 := mbTrans245.WriteString(arg244) - if err246 != nil { - Usage() - return - } - factory247 := thrift.NewSimpleJSONProtocolFactory() - jsProt248 := factory247.GetProtocol(mbTrans245) - argvalue0 := meta.NewGetWorkerIdReq() - err249 := argvalue0.Read(jsProt248) - if err249 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetWorkerId(value0)) - fmt.Print("\n") - break - case "createTagIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateTagIndex requires 1 args") - flag.Usage() - } - arg250 := flag.Arg(1) - mbTrans251 := thrift.NewMemoryBufferLen(len(arg250)) - defer mbTrans251.Close() - _, err252 := mbTrans251.WriteString(arg250) - if err252 != nil { - Usage() - return - } - factory253 := thrift.NewSimpleJSONProtocolFactory() - jsProt254 := factory253.GetProtocol(mbTrans251) - argvalue0 := meta.NewCreateTagIndexReq() - err255 := argvalue0.Read(jsProt254) - if err255 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateTagIndex(value0)) - fmt.Print("\n") - break - case "dropTagIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropTagIndex requires 1 args") - flag.Usage() - } - arg256 := flag.Arg(1) - mbTrans257 := thrift.NewMemoryBufferLen(len(arg256)) - defer mbTrans257.Close() - _, err258 := mbTrans257.WriteString(arg256) - if err258 != nil { - Usage() - return - } - factory259 := thrift.NewSimpleJSONProtocolFactory() - jsProt260 := factory259.GetProtocol(mbTrans257) - argvalue0 := meta.NewDropTagIndexReq() - err261 := argvalue0.Read(jsProt260) - if err261 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropTagIndex(value0)) - fmt.Print("\n") - break - case "getTagIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetTagIndex requires 1 args") - flag.Usage() - } - arg262 := flag.Arg(1) - mbTrans263 := thrift.NewMemoryBufferLen(len(arg262)) - defer mbTrans263.Close() - _, err264 := mbTrans263.WriteString(arg262) - if err264 != nil { - Usage() - return - } - factory265 := thrift.NewSimpleJSONProtocolFactory() - jsProt266 := factory265.GetProtocol(mbTrans263) - argvalue0 := meta.NewGetTagIndexReq() - err267 := argvalue0.Read(jsProt266) - if err267 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetTagIndex(value0)) - fmt.Print("\n") - break - case "listTagIndexes": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListTagIndexes requires 1 args") - flag.Usage() - } - arg268 := flag.Arg(1) - mbTrans269 := thrift.NewMemoryBufferLen(len(arg268)) - defer mbTrans269.Close() - _, err270 := mbTrans269.WriteString(arg268) - if err270 != nil { - Usage() - return - } - factory271 := thrift.NewSimpleJSONProtocolFactory() - jsProt272 := factory271.GetProtocol(mbTrans269) - argvalue0 := meta.NewListTagIndexesReq() - err273 := argvalue0.Read(jsProt272) - if err273 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListTagIndexes(value0)) - fmt.Print("\n") - break - case "rebuildTagIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RebuildTagIndex requires 1 args") - flag.Usage() - } - arg274 := flag.Arg(1) - mbTrans275 := thrift.NewMemoryBufferLen(len(arg274)) - defer mbTrans275.Close() - _, err276 := mbTrans275.WriteString(arg274) - if err276 != nil { - Usage() - return - } - factory277 := thrift.NewSimpleJSONProtocolFactory() - jsProt278 := factory277.GetProtocol(mbTrans275) - argvalue0 := meta.NewRebuildIndexReq() - err279 := argvalue0.Read(jsProt278) - if err279 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RebuildTagIndex(value0)) - fmt.Print("\n") - break - case "listTagIndexStatus": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListTagIndexStatus requires 1 args") - flag.Usage() - } - arg280 := flag.Arg(1) - mbTrans281 := thrift.NewMemoryBufferLen(len(arg280)) - defer mbTrans281.Close() - _, err282 := mbTrans281.WriteString(arg280) - if err282 != nil { - Usage() - return - } - factory283 := thrift.NewSimpleJSONProtocolFactory() - jsProt284 := factory283.GetProtocol(mbTrans281) - argvalue0 := meta.NewListIndexStatusReq() - err285 := argvalue0.Read(jsProt284) - if err285 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListTagIndexStatus(value0)) - fmt.Print("\n") - break - case "createEdgeIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateEdgeIndex requires 1 args") - flag.Usage() - } - arg286 := flag.Arg(1) - mbTrans287 := thrift.NewMemoryBufferLen(len(arg286)) - defer mbTrans287.Close() - _, err288 := mbTrans287.WriteString(arg286) - if err288 != nil { - Usage() - return - } - factory289 := thrift.NewSimpleJSONProtocolFactory() - jsProt290 := factory289.GetProtocol(mbTrans287) - argvalue0 := meta.NewCreateEdgeIndexReq() - err291 := argvalue0.Read(jsProt290) - if err291 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateEdgeIndex(value0)) - fmt.Print("\n") - break - case "dropEdgeIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropEdgeIndex requires 1 args") - flag.Usage() - } - arg292 := flag.Arg(1) - mbTrans293 := thrift.NewMemoryBufferLen(len(arg292)) - defer mbTrans293.Close() - _, err294 := mbTrans293.WriteString(arg292) - if err294 != nil { - Usage() - return - } - factory295 := thrift.NewSimpleJSONProtocolFactory() - jsProt296 := factory295.GetProtocol(mbTrans293) - argvalue0 := meta.NewDropEdgeIndexReq() - err297 := argvalue0.Read(jsProt296) - if err297 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropEdgeIndex(value0)) - fmt.Print("\n") - break - case "getEdgeIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetEdgeIndex requires 1 args") - flag.Usage() - } - arg298 := flag.Arg(1) - mbTrans299 := thrift.NewMemoryBufferLen(len(arg298)) - defer mbTrans299.Close() - _, err300 := mbTrans299.WriteString(arg298) - if err300 != nil { - Usage() - return - } - factory301 := thrift.NewSimpleJSONProtocolFactory() - jsProt302 := factory301.GetProtocol(mbTrans299) - argvalue0 := meta.NewGetEdgeIndexReq() - err303 := argvalue0.Read(jsProt302) - if err303 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetEdgeIndex(value0)) - fmt.Print("\n") - break - case "listEdgeIndexes": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListEdgeIndexes requires 1 args") - flag.Usage() - } - arg304 := flag.Arg(1) - mbTrans305 := thrift.NewMemoryBufferLen(len(arg304)) - defer mbTrans305.Close() - _, err306 := mbTrans305.WriteString(arg304) - if err306 != nil { - Usage() - return - } - factory307 := thrift.NewSimpleJSONProtocolFactory() - jsProt308 := factory307.GetProtocol(mbTrans305) - argvalue0 := meta.NewListEdgeIndexesReq() - err309 := argvalue0.Read(jsProt308) - if err309 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListEdgeIndexes(value0)) - fmt.Print("\n") - break - case "rebuildEdgeIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RebuildEdgeIndex requires 1 args") - flag.Usage() - } - arg310 := flag.Arg(1) - mbTrans311 := thrift.NewMemoryBufferLen(len(arg310)) - defer mbTrans311.Close() - _, err312 := mbTrans311.WriteString(arg310) - if err312 != nil { - Usage() - return - } - factory313 := thrift.NewSimpleJSONProtocolFactory() - jsProt314 := factory313.GetProtocol(mbTrans311) - argvalue0 := meta.NewRebuildIndexReq() - err315 := argvalue0.Read(jsProt314) - if err315 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RebuildEdgeIndex(value0)) - fmt.Print("\n") - break - case "listEdgeIndexStatus": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListEdgeIndexStatus requires 1 args") - flag.Usage() - } - arg316 := flag.Arg(1) - mbTrans317 := thrift.NewMemoryBufferLen(len(arg316)) - defer mbTrans317.Close() - _, err318 := mbTrans317.WriteString(arg316) - if err318 != nil { - Usage() - return - } - factory319 := thrift.NewSimpleJSONProtocolFactory() - jsProt320 := factory319.GetProtocol(mbTrans317) - argvalue0 := meta.NewListIndexStatusReq() - err321 := argvalue0.Read(jsProt320) - if err321 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListEdgeIndexStatus(value0)) - fmt.Print("\n") - break - case "createUser": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateUser requires 1 args") - flag.Usage() - } - arg322 := flag.Arg(1) - mbTrans323 := thrift.NewMemoryBufferLen(len(arg322)) - defer mbTrans323.Close() - _, err324 := mbTrans323.WriteString(arg322) - if err324 != nil { - Usage() - return - } - factory325 := thrift.NewSimpleJSONProtocolFactory() - jsProt326 := factory325.GetProtocol(mbTrans323) - argvalue0 := meta.NewCreateUserReq() - err327 := argvalue0.Read(jsProt326) - if err327 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateUser(value0)) - fmt.Print("\n") - break - case "dropUser": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropUser requires 1 args") - flag.Usage() - } - arg328 := flag.Arg(1) - mbTrans329 := thrift.NewMemoryBufferLen(len(arg328)) - defer mbTrans329.Close() - _, err330 := mbTrans329.WriteString(arg328) - if err330 != nil { - Usage() - return - } - factory331 := thrift.NewSimpleJSONProtocolFactory() - jsProt332 := factory331.GetProtocol(mbTrans329) - argvalue0 := meta.NewDropUserReq() - err333 := argvalue0.Read(jsProt332) - if err333 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropUser(value0)) - fmt.Print("\n") - break - case "alterUser": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AlterUser requires 1 args") - flag.Usage() - } - arg334 := flag.Arg(1) - mbTrans335 := thrift.NewMemoryBufferLen(len(arg334)) - defer mbTrans335.Close() - _, err336 := mbTrans335.WriteString(arg334) - if err336 != nil { - Usage() - return - } - factory337 := thrift.NewSimpleJSONProtocolFactory() - jsProt338 := factory337.GetProtocol(mbTrans335) - argvalue0 := meta.NewAlterUserReq() - err339 := argvalue0.Read(jsProt338) - if err339 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AlterUser(value0)) - fmt.Print("\n") - break - case "grantRole": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GrantRole requires 1 args") - flag.Usage() - } - arg340 := flag.Arg(1) - mbTrans341 := thrift.NewMemoryBufferLen(len(arg340)) - defer mbTrans341.Close() - _, err342 := mbTrans341.WriteString(arg340) - if err342 != nil { - Usage() - return - } - factory343 := thrift.NewSimpleJSONProtocolFactory() - jsProt344 := factory343.GetProtocol(mbTrans341) - argvalue0 := meta.NewGrantRoleReq() - err345 := argvalue0.Read(jsProt344) - if err345 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GrantRole(value0)) - fmt.Print("\n") - break - case "revokeRole": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RevokeRole requires 1 args") - flag.Usage() - } - arg346 := flag.Arg(1) - mbTrans347 := thrift.NewMemoryBufferLen(len(arg346)) - defer mbTrans347.Close() - _, err348 := mbTrans347.WriteString(arg346) - if err348 != nil { - Usage() - return - } - factory349 := thrift.NewSimpleJSONProtocolFactory() - jsProt350 := factory349.GetProtocol(mbTrans347) - argvalue0 := meta.NewRevokeRoleReq() - err351 := argvalue0.Read(jsProt350) - if err351 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RevokeRole(value0)) - fmt.Print("\n") - break - case "listUsers": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListUsers requires 1 args") - flag.Usage() - } - arg352 := flag.Arg(1) - mbTrans353 := thrift.NewMemoryBufferLen(len(arg352)) - defer mbTrans353.Close() - _, err354 := mbTrans353.WriteString(arg352) - if err354 != nil { - Usage() - return - } - factory355 := thrift.NewSimpleJSONProtocolFactory() - jsProt356 := factory355.GetProtocol(mbTrans353) - argvalue0 := meta.NewListUsersReq() - err357 := argvalue0.Read(jsProt356) - if err357 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListUsers(value0)) - fmt.Print("\n") - break - case "listRoles": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListRoles requires 1 args") - flag.Usage() - } - arg358 := flag.Arg(1) - mbTrans359 := thrift.NewMemoryBufferLen(len(arg358)) - defer mbTrans359.Close() - _, err360 := mbTrans359.WriteString(arg358) - if err360 != nil { - Usage() - return - } - factory361 := thrift.NewSimpleJSONProtocolFactory() - jsProt362 := factory361.GetProtocol(mbTrans359) - argvalue0 := meta.NewListRolesReq() - err363 := argvalue0.Read(jsProt362) - if err363 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListRoles(value0)) - fmt.Print("\n") - break - case "getUserRoles": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetUserRoles requires 1 args") - flag.Usage() - } - arg364 := flag.Arg(1) - mbTrans365 := thrift.NewMemoryBufferLen(len(arg364)) - defer mbTrans365.Close() - _, err366 := mbTrans365.WriteString(arg364) - if err366 != nil { - Usage() - return - } - factory367 := thrift.NewSimpleJSONProtocolFactory() - jsProt368 := factory367.GetProtocol(mbTrans365) - argvalue0 := meta.NewGetUserRolesReq() - err369 := argvalue0.Read(jsProt368) - if err369 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetUserRoles(value0)) - fmt.Print("\n") - break - case "changePassword": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ChangePassword requires 1 args") - flag.Usage() - } - arg370 := flag.Arg(1) - mbTrans371 := thrift.NewMemoryBufferLen(len(arg370)) - defer mbTrans371.Close() - _, err372 := mbTrans371.WriteString(arg370) - if err372 != nil { - Usage() - return - } - factory373 := thrift.NewSimpleJSONProtocolFactory() - jsProt374 := factory373.GetProtocol(mbTrans371) - argvalue0 := meta.NewChangePasswordReq() - err375 := argvalue0.Read(jsProt374) - if err375 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ChangePassword(value0)) - fmt.Print("\n") - break - case "heartBeat": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "HeartBeat requires 1 args") - flag.Usage() - } - arg376 := flag.Arg(1) - mbTrans377 := thrift.NewMemoryBufferLen(len(arg376)) - defer mbTrans377.Close() - _, err378 := mbTrans377.WriteString(arg376) - if err378 != nil { - Usage() - return - } - factory379 := thrift.NewSimpleJSONProtocolFactory() - jsProt380 := factory379.GetProtocol(mbTrans377) - argvalue0 := meta.NewHBReq() - err381 := argvalue0.Read(jsProt380) - if err381 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.HeartBeat(value0)) - fmt.Print("\n") - break - case "agentHeartbeat": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AgentHeartbeat requires 1 args") - flag.Usage() - } - arg382 := flag.Arg(1) - mbTrans383 := thrift.NewMemoryBufferLen(len(arg382)) - defer mbTrans383.Close() - _, err384 := mbTrans383.WriteString(arg382) - if err384 != nil { - Usage() - return - } - factory385 := thrift.NewSimpleJSONProtocolFactory() - jsProt386 := factory385.GetProtocol(mbTrans383) - argvalue0 := meta.NewAgentHBReq() - err387 := argvalue0.Read(jsProt386) - if err387 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AgentHeartbeat(value0)) - fmt.Print("\n") - break - case "regConfig": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RegConfig requires 1 args") - flag.Usage() - } - arg388 := flag.Arg(1) - mbTrans389 := thrift.NewMemoryBufferLen(len(arg388)) - defer mbTrans389.Close() - _, err390 := mbTrans389.WriteString(arg388) - if err390 != nil { - Usage() - return - } - factory391 := thrift.NewSimpleJSONProtocolFactory() - jsProt392 := factory391.GetProtocol(mbTrans389) - argvalue0 := meta.NewRegConfigReq() - err393 := argvalue0.Read(jsProt392) - if err393 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RegConfig(value0)) - fmt.Print("\n") - break - case "getConfig": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetConfig requires 1 args") - flag.Usage() - } - arg394 := flag.Arg(1) - mbTrans395 := thrift.NewMemoryBufferLen(len(arg394)) - defer mbTrans395.Close() - _, err396 := mbTrans395.WriteString(arg394) - if err396 != nil { - Usage() - return - } - factory397 := thrift.NewSimpleJSONProtocolFactory() - jsProt398 := factory397.GetProtocol(mbTrans395) - argvalue0 := meta.NewGetConfigReq() - err399 := argvalue0.Read(jsProt398) - if err399 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetConfig(value0)) - fmt.Print("\n") - break - case "setConfig": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "SetConfig requires 1 args") - flag.Usage() - } - arg400 := flag.Arg(1) - mbTrans401 := thrift.NewMemoryBufferLen(len(arg400)) - defer mbTrans401.Close() - _, err402 := mbTrans401.WriteString(arg400) - if err402 != nil { - Usage() - return - } - factory403 := thrift.NewSimpleJSONProtocolFactory() - jsProt404 := factory403.GetProtocol(mbTrans401) - argvalue0 := meta.NewSetConfigReq() - err405 := argvalue0.Read(jsProt404) - if err405 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.SetConfig(value0)) - fmt.Print("\n") - break - case "listConfigs": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListConfigs requires 1 args") - flag.Usage() - } - arg406 := flag.Arg(1) - mbTrans407 := thrift.NewMemoryBufferLen(len(arg406)) - defer mbTrans407.Close() - _, err408 := mbTrans407.WriteString(arg406) - if err408 != nil { - Usage() - return - } - factory409 := thrift.NewSimpleJSONProtocolFactory() - jsProt410 := factory409.GetProtocol(mbTrans407) - argvalue0 := meta.NewListConfigsReq() - err411 := argvalue0.Read(jsProt410) - if err411 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListConfigs(value0)) - fmt.Print("\n") - break - case "createSnapshot": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateSnapshot requires 1 args") - flag.Usage() - } - arg412 := flag.Arg(1) - mbTrans413 := thrift.NewMemoryBufferLen(len(arg412)) - defer mbTrans413.Close() - _, err414 := mbTrans413.WriteString(arg412) - if err414 != nil { - Usage() - return - } - factory415 := thrift.NewSimpleJSONProtocolFactory() - jsProt416 := factory415.GetProtocol(mbTrans413) - argvalue0 := meta.NewCreateSnapshotReq() - err417 := argvalue0.Read(jsProt416) - if err417 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateSnapshot(value0)) - fmt.Print("\n") - break - case "dropSnapshot": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropSnapshot requires 1 args") - flag.Usage() - } - arg418 := flag.Arg(1) - mbTrans419 := thrift.NewMemoryBufferLen(len(arg418)) - defer mbTrans419.Close() - _, err420 := mbTrans419.WriteString(arg418) - if err420 != nil { - Usage() - return - } - factory421 := thrift.NewSimpleJSONProtocolFactory() - jsProt422 := factory421.GetProtocol(mbTrans419) - argvalue0 := meta.NewDropSnapshotReq() - err423 := argvalue0.Read(jsProt422) - if err423 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropSnapshot(value0)) - fmt.Print("\n") - break - case "listSnapshots": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListSnapshots requires 1 args") - flag.Usage() - } - arg424 := flag.Arg(1) - mbTrans425 := thrift.NewMemoryBufferLen(len(arg424)) - defer mbTrans425.Close() - _, err426 := mbTrans425.WriteString(arg424) - if err426 != nil { - Usage() - return - } - factory427 := thrift.NewSimpleJSONProtocolFactory() - jsProt428 := factory427.GetProtocol(mbTrans425) - argvalue0 := meta.NewListSnapshotsReq() - err429 := argvalue0.Read(jsProt428) - if err429 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListSnapshots(value0)) - fmt.Print("\n") - break - case "runAdminJob": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RunAdminJob requires 1 args") - flag.Usage() - } - arg430 := flag.Arg(1) - mbTrans431 := thrift.NewMemoryBufferLen(len(arg430)) - defer mbTrans431.Close() - _, err432 := mbTrans431.WriteString(arg430) - if err432 != nil { - Usage() - return - } - factory433 := thrift.NewSimpleJSONProtocolFactory() - jsProt434 := factory433.GetProtocol(mbTrans431) - argvalue0 := meta.NewAdminJobReq() - err435 := argvalue0.Read(jsProt434) - if err435 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RunAdminJob(value0)) - fmt.Print("\n") - break - case "mergeZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "MergeZone requires 1 args") - flag.Usage() - } - arg436 := flag.Arg(1) - mbTrans437 := thrift.NewMemoryBufferLen(len(arg436)) - defer mbTrans437.Close() - _, err438 := mbTrans437.WriteString(arg436) - if err438 != nil { - Usage() - return - } - factory439 := thrift.NewSimpleJSONProtocolFactory() - jsProt440 := factory439.GetProtocol(mbTrans437) - argvalue0 := meta.NewMergeZoneReq() - err441 := argvalue0.Read(jsProt440) - if err441 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.MergeZone(value0)) - fmt.Print("\n") - break - case "dropZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropZone requires 1 args") - flag.Usage() - } - arg442 := flag.Arg(1) - mbTrans443 := thrift.NewMemoryBufferLen(len(arg442)) - defer mbTrans443.Close() - _, err444 := mbTrans443.WriteString(arg442) - if err444 != nil { - Usage() - return - } - factory445 := thrift.NewSimpleJSONProtocolFactory() - jsProt446 := factory445.GetProtocol(mbTrans443) - argvalue0 := meta.NewDropZoneReq() - err447 := argvalue0.Read(jsProt446) - if err447 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropZone(value0)) - fmt.Print("\n") - break - case "divideZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DivideZone requires 1 args") - flag.Usage() - } - arg448 := flag.Arg(1) - mbTrans449 := thrift.NewMemoryBufferLen(len(arg448)) - defer mbTrans449.Close() - _, err450 := mbTrans449.WriteString(arg448) - if err450 != nil { - Usage() - return - } - factory451 := thrift.NewSimpleJSONProtocolFactory() - jsProt452 := factory451.GetProtocol(mbTrans449) - argvalue0 := meta.NewDivideZoneReq() - err453 := argvalue0.Read(jsProt452) - if err453 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DivideZone(value0)) - fmt.Print("\n") - break - case "renameZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RenameZone requires 1 args") - flag.Usage() - } - arg454 := flag.Arg(1) - mbTrans455 := thrift.NewMemoryBufferLen(len(arg454)) - defer mbTrans455.Close() - _, err456 := mbTrans455.WriteString(arg454) - if err456 != nil { - Usage() - return - } - factory457 := thrift.NewSimpleJSONProtocolFactory() - jsProt458 := factory457.GetProtocol(mbTrans455) - argvalue0 := meta.NewRenameZoneReq() - err459 := argvalue0.Read(jsProt458) - if err459 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RenameZone(value0)) - fmt.Print("\n") - break - case "getZone": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetZone requires 1 args") - flag.Usage() - } - arg460 := flag.Arg(1) - mbTrans461 := thrift.NewMemoryBufferLen(len(arg460)) - defer mbTrans461.Close() - _, err462 := mbTrans461.WriteString(arg460) - if err462 != nil { - Usage() - return - } - factory463 := thrift.NewSimpleJSONProtocolFactory() - jsProt464 := factory463.GetProtocol(mbTrans461) - argvalue0 := meta.NewGetZoneReq() - err465 := argvalue0.Read(jsProt464) - if err465 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetZone(value0)) - fmt.Print("\n") - break - case "listZones": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListZones requires 1 args") - flag.Usage() - } - arg466 := flag.Arg(1) - mbTrans467 := thrift.NewMemoryBufferLen(len(arg466)) - defer mbTrans467.Close() - _, err468 := mbTrans467.WriteString(arg466) - if err468 != nil { - Usage() - return - } - factory469 := thrift.NewSimpleJSONProtocolFactory() - jsProt470 := factory469.GetProtocol(mbTrans467) - argvalue0 := meta.NewListZonesReq() - err471 := argvalue0.Read(jsProt470) - if err471 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListZones(value0)) - fmt.Print("\n") - break - case "addListener": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddListener requires 1 args") - flag.Usage() - } - arg472 := flag.Arg(1) - mbTrans473 := thrift.NewMemoryBufferLen(len(arg472)) - defer mbTrans473.Close() - _, err474 := mbTrans473.WriteString(arg472) - if err474 != nil { - Usage() - return - } - factory475 := thrift.NewSimpleJSONProtocolFactory() - jsProt476 := factory475.GetProtocol(mbTrans473) - argvalue0 := meta.NewAddListenerReq() - err477 := argvalue0.Read(jsProt476) - if err477 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddListener(value0)) - fmt.Print("\n") - break - case "removeListener": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RemoveListener requires 1 args") - flag.Usage() - } - arg478 := flag.Arg(1) - mbTrans479 := thrift.NewMemoryBufferLen(len(arg478)) - defer mbTrans479.Close() - _, err480 := mbTrans479.WriteString(arg478) - if err480 != nil { - Usage() - return - } - factory481 := thrift.NewSimpleJSONProtocolFactory() - jsProt482 := factory481.GetProtocol(mbTrans479) - argvalue0 := meta.NewRemoveListenerReq() - err483 := argvalue0.Read(jsProt482) - if err483 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RemoveListener(value0)) - fmt.Print("\n") - break - case "listListener": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListListener requires 1 args") - flag.Usage() - } - arg484 := flag.Arg(1) - mbTrans485 := thrift.NewMemoryBufferLen(len(arg484)) - defer mbTrans485.Close() - _, err486 := mbTrans485.WriteString(arg484) - if err486 != nil { - Usage() - return - } - factory487 := thrift.NewSimpleJSONProtocolFactory() - jsProt488 := factory487.GetProtocol(mbTrans485) - argvalue0 := meta.NewListListenerReq() - err489 := argvalue0.Read(jsProt488) - if err489 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListListener(value0)) - fmt.Print("\n") - break - case "getStats": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetStats requires 1 args") - flag.Usage() - } - arg490 := flag.Arg(1) - mbTrans491 := thrift.NewMemoryBufferLen(len(arg490)) - defer mbTrans491.Close() - _, err492 := mbTrans491.WriteString(arg490) - if err492 != nil { - Usage() - return - } - factory493 := thrift.NewSimpleJSONProtocolFactory() - jsProt494 := factory493.GetProtocol(mbTrans491) - argvalue0 := meta.NewGetStatsReq() - err495 := argvalue0.Read(jsProt494) - if err495 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetStats(value0)) - fmt.Print("\n") - break - case "signInService": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "SignInService requires 1 args") - flag.Usage() - } - arg496 := flag.Arg(1) - mbTrans497 := thrift.NewMemoryBufferLen(len(arg496)) - defer mbTrans497.Close() - _, err498 := mbTrans497.WriteString(arg496) - if err498 != nil { - Usage() - return - } - factory499 := thrift.NewSimpleJSONProtocolFactory() - jsProt500 := factory499.GetProtocol(mbTrans497) - argvalue0 := meta.NewSignInServiceReq() - err501 := argvalue0.Read(jsProt500) - if err501 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.SignInService(value0)) - fmt.Print("\n") - break - case "signOutService": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "SignOutService requires 1 args") - flag.Usage() - } - arg502 := flag.Arg(1) - mbTrans503 := thrift.NewMemoryBufferLen(len(arg502)) - defer mbTrans503.Close() - _, err504 := mbTrans503.WriteString(arg502) - if err504 != nil { - Usage() - return - } - factory505 := thrift.NewSimpleJSONProtocolFactory() - jsProt506 := factory505.GetProtocol(mbTrans503) - argvalue0 := meta.NewSignOutServiceReq() - err507 := argvalue0.Read(jsProt506) - if err507 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.SignOutService(value0)) - fmt.Print("\n") - break - case "listServiceClients": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListServiceClients requires 1 args") - flag.Usage() - } - arg508 := flag.Arg(1) - mbTrans509 := thrift.NewMemoryBufferLen(len(arg508)) - defer mbTrans509.Close() - _, err510 := mbTrans509.WriteString(arg508) - if err510 != nil { - Usage() - return - } - factory511 := thrift.NewSimpleJSONProtocolFactory() - jsProt512 := factory511.GetProtocol(mbTrans509) - argvalue0 := meta.NewListServiceClientsReq() - err513 := argvalue0.Read(jsProt512) - if err513 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListServiceClients(value0)) - fmt.Print("\n") - break - case "createFTIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateFTIndex requires 1 args") - flag.Usage() - } - arg514 := flag.Arg(1) - mbTrans515 := thrift.NewMemoryBufferLen(len(arg514)) - defer mbTrans515.Close() - _, err516 := mbTrans515.WriteString(arg514) - if err516 != nil { - Usage() - return - } - factory517 := thrift.NewSimpleJSONProtocolFactory() - jsProt518 := factory517.GetProtocol(mbTrans515) - argvalue0 := meta.NewCreateFTIndexReq() - err519 := argvalue0.Read(jsProt518) - if err519 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateFTIndex(value0)) - fmt.Print("\n") - break - case "dropFTIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropFTIndex requires 1 args") - flag.Usage() - } - arg520 := flag.Arg(1) - mbTrans521 := thrift.NewMemoryBufferLen(len(arg520)) - defer mbTrans521.Close() - _, err522 := mbTrans521.WriteString(arg520) - if err522 != nil { - Usage() - return - } - factory523 := thrift.NewSimpleJSONProtocolFactory() - jsProt524 := factory523.GetProtocol(mbTrans521) - argvalue0 := meta.NewDropFTIndexReq() - err525 := argvalue0.Read(jsProt524) - if err525 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropFTIndex(value0)) - fmt.Print("\n") - break - case "listFTIndexes": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListFTIndexes requires 1 args") - flag.Usage() - } - arg526 := flag.Arg(1) - mbTrans527 := thrift.NewMemoryBufferLen(len(arg526)) - defer mbTrans527.Close() - _, err528 := mbTrans527.WriteString(arg526) - if err528 != nil { - Usage() - return - } - factory529 := thrift.NewSimpleJSONProtocolFactory() - jsProt530 := factory529.GetProtocol(mbTrans527) - argvalue0 := meta.NewListFTIndexesReq() - err531 := argvalue0.Read(jsProt530) - if err531 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListFTIndexes(value0)) - fmt.Print("\n") - break - case "createSession": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateSession requires 1 args") - flag.Usage() - } - arg532 := flag.Arg(1) - mbTrans533 := thrift.NewMemoryBufferLen(len(arg532)) - defer mbTrans533.Close() - _, err534 := mbTrans533.WriteString(arg532) - if err534 != nil { - Usage() - return - } - factory535 := thrift.NewSimpleJSONProtocolFactory() - jsProt536 := factory535.GetProtocol(mbTrans533) - argvalue0 := meta.NewCreateSessionReq() - err537 := argvalue0.Read(jsProt536) - if err537 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateSession(value0)) - fmt.Print("\n") - break - case "updateSessions": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "UpdateSessions requires 1 args") - flag.Usage() - } - arg538 := flag.Arg(1) - mbTrans539 := thrift.NewMemoryBufferLen(len(arg538)) - defer mbTrans539.Close() - _, err540 := mbTrans539.WriteString(arg538) - if err540 != nil { - Usage() - return - } - factory541 := thrift.NewSimpleJSONProtocolFactory() - jsProt542 := factory541.GetProtocol(mbTrans539) - argvalue0 := meta.NewUpdateSessionsReq() - err543 := argvalue0.Read(jsProt542) - if err543 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.UpdateSessions(value0)) - fmt.Print("\n") - break - case "listSessions": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListSessions requires 1 args") - flag.Usage() - } - arg544 := flag.Arg(1) - mbTrans545 := thrift.NewMemoryBufferLen(len(arg544)) - defer mbTrans545.Close() - _, err546 := mbTrans545.WriteString(arg544) - if err546 != nil { - Usage() - return - } - factory547 := thrift.NewSimpleJSONProtocolFactory() - jsProt548 := factory547.GetProtocol(mbTrans545) - argvalue0 := meta.NewListSessionsReq() - err549 := argvalue0.Read(jsProt548) - if err549 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListSessions(value0)) - fmt.Print("\n") - break - case "getSession": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetSession requires 1 args") - flag.Usage() - } - arg550 := flag.Arg(1) - mbTrans551 := thrift.NewMemoryBufferLen(len(arg550)) - defer mbTrans551.Close() - _, err552 := mbTrans551.WriteString(arg550) - if err552 != nil { - Usage() - return - } - factory553 := thrift.NewSimpleJSONProtocolFactory() - jsProt554 := factory553.GetProtocol(mbTrans551) - argvalue0 := meta.NewGetSessionReq() - err555 := argvalue0.Read(jsProt554) - if err555 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetSession(value0)) - fmt.Print("\n") - break - case "removeSession": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RemoveSession requires 1 args") - flag.Usage() - } - arg556 := flag.Arg(1) - mbTrans557 := thrift.NewMemoryBufferLen(len(arg556)) - defer mbTrans557.Close() - _, err558 := mbTrans557.WriteString(arg556) - if err558 != nil { - Usage() - return - } - factory559 := thrift.NewSimpleJSONProtocolFactory() - jsProt560 := factory559.GetProtocol(mbTrans557) - argvalue0 := meta.NewRemoveSessionReq() - err561 := argvalue0.Read(jsProt560) - if err561 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RemoveSession(value0)) - fmt.Print("\n") - break - case "killQuery": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "KillQuery requires 1 args") - flag.Usage() - } - arg562 := flag.Arg(1) - mbTrans563 := thrift.NewMemoryBufferLen(len(arg562)) - defer mbTrans563.Close() - _, err564 := mbTrans563.WriteString(arg562) - if err564 != nil { - Usage() - return - } - factory565 := thrift.NewSimpleJSONProtocolFactory() - jsProt566 := factory565.GetProtocol(mbTrans563) - argvalue0 := meta.NewKillQueryReq() - err567 := argvalue0.Read(jsProt566) - if err567 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.KillQuery(value0)) - fmt.Print("\n") - break - case "reportTaskFinish": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ReportTaskFinish requires 1 args") - flag.Usage() - } - arg568 := flag.Arg(1) - mbTrans569 := thrift.NewMemoryBufferLen(len(arg568)) - defer mbTrans569.Close() - _, err570 := mbTrans569.WriteString(arg568) - if err570 != nil { - Usage() - return - } - factory571 := thrift.NewSimpleJSONProtocolFactory() - jsProt572 := factory571.GetProtocol(mbTrans569) - argvalue0 := meta.NewReportTaskReq() - err573 := argvalue0.Read(jsProt572) - if err573 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ReportTaskFinish(value0)) - fmt.Print("\n") - break - case "createBackup": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateBackup requires 1 args") - flag.Usage() - } - arg574 := flag.Arg(1) - mbTrans575 := thrift.NewMemoryBufferLen(len(arg574)) - defer mbTrans575.Close() - _, err576 := mbTrans575.WriteString(arg574) - if err576 != nil { - Usage() - return - } - factory577 := thrift.NewSimpleJSONProtocolFactory() - jsProt578 := factory577.GetProtocol(mbTrans575) - argvalue0 := meta.NewCreateBackupReq() - err579 := argvalue0.Read(jsProt578) - if err579 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateBackup(value0)) - fmt.Print("\n") - break - case "restoreMeta": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RestoreMeta requires 1 args") - flag.Usage() - } - arg580 := flag.Arg(1) - mbTrans581 := thrift.NewMemoryBufferLen(len(arg580)) - defer mbTrans581.Close() - _, err582 := mbTrans581.WriteString(arg580) - if err582 != nil { - Usage() - return - } - factory583 := thrift.NewSimpleJSONProtocolFactory() - jsProt584 := factory583.GetProtocol(mbTrans581) - argvalue0 := meta.NewRestoreMetaReq() - err585 := argvalue0.Read(jsProt584) - if err585 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RestoreMeta(value0)) - fmt.Print("\n") - break - case "listCluster": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ListCluster requires 1 args") - flag.Usage() - } - arg586 := flag.Arg(1) - mbTrans587 := thrift.NewMemoryBufferLen(len(arg586)) - defer mbTrans587.Close() - _, err588 := mbTrans587.WriteString(arg586) - if err588 != nil { - Usage() - return - } - factory589 := thrift.NewSimpleJSONProtocolFactory() - jsProt590 := factory589.GetProtocol(mbTrans587) - argvalue0 := meta.NewListClusterInfoReq() - err591 := argvalue0.Read(jsProt590) - if err591 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ListCluster(value0)) - fmt.Print("\n") - break - case "getMetaDirInfo": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetMetaDirInfo requires 1 args") - flag.Usage() - } - arg592 := flag.Arg(1) - mbTrans593 := thrift.NewMemoryBufferLen(len(arg592)) - defer mbTrans593.Close() - _, err594 := mbTrans593.WriteString(arg592) - if err594 != nil { - Usage() - return - } - factory595 := thrift.NewSimpleJSONProtocolFactory() - jsProt596 := factory595.GetProtocol(mbTrans593) - argvalue0 := meta.NewGetMetaDirInfoReq() - err597 := argvalue0.Read(jsProt596) - if err597 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetMetaDirInfo(value0)) - fmt.Print("\n") - break - case "verifyClientVersion": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "VerifyClientVersion requires 1 args") - flag.Usage() - } - arg598 := flag.Arg(1) - mbTrans599 := thrift.NewMemoryBufferLen(len(arg598)) - defer mbTrans599.Close() - _, err600 := mbTrans599.WriteString(arg598) - if err600 != nil { - Usage() - return - } - factory601 := thrift.NewSimpleJSONProtocolFactory() - jsProt602 := factory601.GetProtocol(mbTrans599) - argvalue0 := meta.NewVerifyClientVersionReq() - err603 := argvalue0.Read(jsProt602) - if err603 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.VerifyClientVersion(value0)) - fmt.Print("\n") - break - case "saveGraphVersion": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "SaveGraphVersion requires 1 args") - flag.Usage() - } - arg604 := flag.Arg(1) - mbTrans605 := thrift.NewMemoryBufferLen(len(arg604)) - defer mbTrans605.Close() - _, err606 := mbTrans605.WriteString(arg604) - if err606 != nil { - Usage() - return - } - factory607 := thrift.NewSimpleJSONProtocolFactory() - jsProt608 := factory607.GetProtocol(mbTrans605) - argvalue0 := meta.NewSaveGraphVersionReq() - err609 := argvalue0.Read(jsProt608) - if err609 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.SaveGraphVersion(value0)) - fmt.Print("\n") - break - case "getSegmentId": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetSegmentId requires 1 args") - flag.Usage() - } - arg610 := flag.Arg(1) - mbTrans611 := thrift.NewMemoryBufferLen(len(arg610)) - defer mbTrans611.Close() - _, err612 := mbTrans611.WriteString(arg610) - if err612 != nil { - Usage() - return - } - factory613 := thrift.NewSimpleJSONProtocolFactory() - jsProt614 := factory613.GetProtocol(mbTrans611) - argvalue0 := meta.NewGetSegmentIdReq() - err615 := argvalue0.Read(jsProt614) - if err615 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetSegmentId(value0)) - fmt.Print("\n") - break - case "": - Usage() - break - default: - fmt.Fprintln(os.Stderr, "Invalid function ", cmd) - } -} diff --git a/nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go b/nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go deleted file mode 100755 index 740ce4ad..00000000 --- a/nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go +++ /dev/null @@ -1,644 +0,0 @@ -// Autogenerated by Thrift Compiler (facebook) -// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -// @generated - -package main - -import ( - "flag" - "fmt" - "math" - "net" - "net/url" - "os" - "strconv" - "strings" - thrift "github.com/facebook/fbthrift/thrift/lib/go/thrift" - "../../github.com/vesoft-inc/nebula-go/v3/nebula/storage" -) - -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, " GetNeighborsResponse getNeighbors(GetNeighborsRequest req)") - fmt.Fprintln(os.Stderr, " GetPropResponse getProps(GetPropRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse addVertices(AddVerticesRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse addEdges(AddEdgesRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse deleteEdges(DeleteEdgesRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse deleteVertices(DeleteVerticesRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse deleteTags(DeleteTagsRequest req)") - fmt.Fprintln(os.Stderr, " UpdateResponse updateVertex(UpdateVertexRequest req)") - fmt.Fprintln(os.Stderr, " UpdateResponse updateEdge(UpdateEdgeRequest req)") - fmt.Fprintln(os.Stderr, " ScanResponse scanVertex(ScanVertexRequest req)") - fmt.Fprintln(os.Stderr, " ScanResponse scanEdge(ScanEdgeRequest req)") - fmt.Fprintln(os.Stderr, " GetUUIDResp getUUID(GetUUIDReq req)") - fmt.Fprintln(os.Stderr, " LookupIndexResp lookupIndex(LookupIndexRequest req)") - fmt.Fprintln(os.Stderr, " GetNeighborsResponse lookupAndTraverse(LookupAndTraverseRequest req)") - fmt.Fprintln(os.Stderr, " UpdateResponse chainUpdateEdge(UpdateEdgeRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse chainAddEdges(AddEdgesRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse chainDeleteEdges(DeleteEdgesRequest req)") - fmt.Fprintln(os.Stderr, " KVGetResponse get(KVGetRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse put(KVPutRequest req)") - fmt.Fprintln(os.Stderr, " ExecResponse remove(KVRemoveRequest req)") - fmt.Fprintln(os.Stderr) - os.Exit(0) -} - -func main() { - flag.Usage = Usage - var host string - var port int - var protocol string - var urlString string - var framed bool - var useHttp bool - var parsedUrl url.URL - var trans thrift.Transport - _ = strconv.Atoi - _ = math.Abs - flag.Usage = Usage - flag.StringVar(&host, "h", "localhost", "Specify host") - 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.Parse() - - if len(urlString) > 0 { - 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" - } 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.NewHTTPPostClient(parsedUrl.String()) - } 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.NewSocket(thrift.SocketAddr(net.JoinHostPort(host, portStr))) - if err != nil { - fmt.Fprintln(os.Stderr, "error resolving address:", err) - os.Exit(1) - } - if framed { - trans = thrift.NewFramedTransport(trans) - } - } - if err != nil { - fmt.Fprintln(os.Stderr, "Error creating transport", err) - os.Exit(1) - } - defer trans.Close() - var protocolFactory thrift.ProtocolFactory - switch protocol { - case "compact": - protocolFactory = thrift.NewCompactProtocolFactory() - break - case "simplejson": - protocolFactory = thrift.NewSimpleJSONProtocolFactory() - break - case "json": - protocolFactory = thrift.NewJSONProtocolFactory() - break - case "binary", "": - protocolFactory = thrift.NewBinaryProtocolFactoryDefault() - break - default: - fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) - Usage() - os.Exit(1) - } - client := storage.NewGraphStorageServiceClientFactory(trans, protocolFactory) - if err := trans.Open(); err != nil { - fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) - os.Exit(1) - } - - switch cmd { - case "getNeighbors": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetNeighbors requires 1 args") - flag.Usage() - } - arg99 := flag.Arg(1) - mbTrans100 := thrift.NewMemoryBufferLen(len(arg99)) - defer mbTrans100.Close() - _, err101 := mbTrans100.WriteString(arg99) - if err101 != nil { - Usage() - return - } - factory102 := thrift.NewSimpleJSONProtocolFactory() - jsProt103 := factory102.GetProtocol(mbTrans100) - argvalue0 := storage.NewGetNeighborsRequest() - err104 := argvalue0.Read(jsProt103) - if err104 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetNeighbors(value0)) - fmt.Print("\n") - break - case "getProps": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetProps requires 1 args") - flag.Usage() - } - arg105 := flag.Arg(1) - mbTrans106 := thrift.NewMemoryBufferLen(len(arg105)) - defer mbTrans106.Close() - _, err107 := mbTrans106.WriteString(arg105) - if err107 != nil { - Usage() - return - } - factory108 := thrift.NewSimpleJSONProtocolFactory() - jsProt109 := factory108.GetProtocol(mbTrans106) - argvalue0 := storage.NewGetPropRequest() - err110 := argvalue0.Read(jsProt109) - if err110 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetProps(value0)) - fmt.Print("\n") - break - case "addVertices": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddVertices requires 1 args") - flag.Usage() - } - arg111 := flag.Arg(1) - mbTrans112 := thrift.NewMemoryBufferLen(len(arg111)) - defer mbTrans112.Close() - _, err113 := mbTrans112.WriteString(arg111) - if err113 != nil { - Usage() - return - } - factory114 := thrift.NewSimpleJSONProtocolFactory() - jsProt115 := factory114.GetProtocol(mbTrans112) - argvalue0 := storage.NewAddVerticesRequest() - err116 := argvalue0.Read(jsProt115) - if err116 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddVertices(value0)) - fmt.Print("\n") - break - case "addEdges": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddEdges requires 1 args") - flag.Usage() - } - arg117 := flag.Arg(1) - mbTrans118 := thrift.NewMemoryBufferLen(len(arg117)) - defer mbTrans118.Close() - _, err119 := mbTrans118.WriteString(arg117) - if err119 != nil { - Usage() - return - } - factory120 := thrift.NewSimpleJSONProtocolFactory() - jsProt121 := factory120.GetProtocol(mbTrans118) - argvalue0 := storage.NewAddEdgesRequest() - err122 := argvalue0.Read(jsProt121) - if err122 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddEdges(value0)) - fmt.Print("\n") - break - case "deleteEdges": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DeleteEdges requires 1 args") - flag.Usage() - } - arg123 := flag.Arg(1) - mbTrans124 := thrift.NewMemoryBufferLen(len(arg123)) - defer mbTrans124.Close() - _, err125 := mbTrans124.WriteString(arg123) - if err125 != nil { - Usage() - return - } - factory126 := thrift.NewSimpleJSONProtocolFactory() - jsProt127 := factory126.GetProtocol(mbTrans124) - argvalue0 := storage.NewDeleteEdgesRequest() - err128 := argvalue0.Read(jsProt127) - if err128 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DeleteEdges(value0)) - fmt.Print("\n") - break - case "deleteVertices": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DeleteVertices requires 1 args") - flag.Usage() - } - arg129 := flag.Arg(1) - mbTrans130 := thrift.NewMemoryBufferLen(len(arg129)) - defer mbTrans130.Close() - _, err131 := mbTrans130.WriteString(arg129) - if err131 != nil { - Usage() - return - } - factory132 := thrift.NewSimpleJSONProtocolFactory() - jsProt133 := factory132.GetProtocol(mbTrans130) - argvalue0 := storage.NewDeleteVerticesRequest() - err134 := argvalue0.Read(jsProt133) - if err134 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DeleteVertices(value0)) - fmt.Print("\n") - break - case "deleteTags": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DeleteTags requires 1 args") - flag.Usage() - } - arg135 := flag.Arg(1) - mbTrans136 := thrift.NewMemoryBufferLen(len(arg135)) - defer mbTrans136.Close() - _, err137 := mbTrans136.WriteString(arg135) - if err137 != nil { - Usage() - return - } - factory138 := thrift.NewSimpleJSONProtocolFactory() - jsProt139 := factory138.GetProtocol(mbTrans136) - argvalue0 := storage.NewDeleteTagsRequest() - err140 := argvalue0.Read(jsProt139) - if err140 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DeleteTags(value0)) - fmt.Print("\n") - break - case "updateVertex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "UpdateVertex requires 1 args") - flag.Usage() - } - arg141 := flag.Arg(1) - mbTrans142 := thrift.NewMemoryBufferLen(len(arg141)) - defer mbTrans142.Close() - _, err143 := mbTrans142.WriteString(arg141) - if err143 != nil { - Usage() - return - } - factory144 := thrift.NewSimpleJSONProtocolFactory() - jsProt145 := factory144.GetProtocol(mbTrans142) - argvalue0 := storage.NewUpdateVertexRequest() - err146 := argvalue0.Read(jsProt145) - if err146 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.UpdateVertex(value0)) - fmt.Print("\n") - break - case "updateEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "UpdateEdge requires 1 args") - flag.Usage() - } - arg147 := flag.Arg(1) - mbTrans148 := thrift.NewMemoryBufferLen(len(arg147)) - defer mbTrans148.Close() - _, err149 := mbTrans148.WriteString(arg147) - if err149 != nil { - Usage() - return - } - factory150 := thrift.NewSimpleJSONProtocolFactory() - jsProt151 := factory150.GetProtocol(mbTrans148) - argvalue0 := storage.NewUpdateEdgeRequest() - err152 := argvalue0.Read(jsProt151) - if err152 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.UpdateEdge(value0)) - fmt.Print("\n") - break - case "scanVertex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ScanVertex requires 1 args") - flag.Usage() - } - arg153 := flag.Arg(1) - mbTrans154 := thrift.NewMemoryBufferLen(len(arg153)) - defer mbTrans154.Close() - _, err155 := mbTrans154.WriteString(arg153) - if err155 != nil { - Usage() - return - } - factory156 := thrift.NewSimpleJSONProtocolFactory() - jsProt157 := factory156.GetProtocol(mbTrans154) - argvalue0 := storage.NewScanVertexRequest() - err158 := argvalue0.Read(jsProt157) - if err158 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ScanVertex(value0)) - fmt.Print("\n") - break - case "scanEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ScanEdge requires 1 args") - flag.Usage() - } - arg159 := flag.Arg(1) - mbTrans160 := thrift.NewMemoryBufferLen(len(arg159)) - defer mbTrans160.Close() - _, err161 := mbTrans160.WriteString(arg159) - if err161 != nil { - Usage() - return - } - factory162 := thrift.NewSimpleJSONProtocolFactory() - jsProt163 := factory162.GetProtocol(mbTrans160) - argvalue0 := storage.NewScanEdgeRequest() - err164 := argvalue0.Read(jsProt163) - if err164 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ScanEdge(value0)) - fmt.Print("\n") - break - case "getUUID": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetUUID requires 1 args") - flag.Usage() - } - arg165 := flag.Arg(1) - mbTrans166 := thrift.NewMemoryBufferLen(len(arg165)) - defer mbTrans166.Close() - _, err167 := mbTrans166.WriteString(arg165) - if err167 != nil { - Usage() - return - } - factory168 := thrift.NewSimpleJSONProtocolFactory() - jsProt169 := factory168.GetProtocol(mbTrans166) - argvalue0 := storage.NewGetUUIDReq() - err170 := argvalue0.Read(jsProt169) - if err170 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetUUID(value0)) - fmt.Print("\n") - break - case "lookupIndex": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "LookupIndex requires 1 args") - flag.Usage() - } - arg171 := flag.Arg(1) - mbTrans172 := thrift.NewMemoryBufferLen(len(arg171)) - defer mbTrans172.Close() - _, err173 := mbTrans172.WriteString(arg171) - if err173 != nil { - Usage() - return - } - factory174 := thrift.NewSimpleJSONProtocolFactory() - jsProt175 := factory174.GetProtocol(mbTrans172) - argvalue0 := storage.NewLookupIndexRequest() - err176 := argvalue0.Read(jsProt175) - if err176 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.LookupIndex(value0)) - fmt.Print("\n") - break - case "lookupAndTraverse": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "LookupAndTraverse requires 1 args") - flag.Usage() - } - arg177 := flag.Arg(1) - mbTrans178 := thrift.NewMemoryBufferLen(len(arg177)) - defer mbTrans178.Close() - _, err179 := mbTrans178.WriteString(arg177) - if err179 != nil { - Usage() - return - } - factory180 := thrift.NewSimpleJSONProtocolFactory() - jsProt181 := factory180.GetProtocol(mbTrans178) - argvalue0 := storage.NewLookupAndTraverseRequest() - err182 := argvalue0.Read(jsProt181) - if err182 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.LookupAndTraverse(value0)) - fmt.Print("\n") - break - case "chainUpdateEdge": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ChainUpdateEdge requires 1 args") - flag.Usage() - } - arg183 := flag.Arg(1) - mbTrans184 := thrift.NewMemoryBufferLen(len(arg183)) - defer mbTrans184.Close() - _, err185 := mbTrans184.WriteString(arg183) - if err185 != nil { - Usage() - return - } - factory186 := thrift.NewSimpleJSONProtocolFactory() - jsProt187 := factory186.GetProtocol(mbTrans184) - argvalue0 := storage.NewUpdateEdgeRequest() - err188 := argvalue0.Read(jsProt187) - if err188 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ChainUpdateEdge(value0)) - fmt.Print("\n") - break - case "chainAddEdges": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ChainAddEdges requires 1 args") - flag.Usage() - } - arg189 := flag.Arg(1) - mbTrans190 := thrift.NewMemoryBufferLen(len(arg189)) - defer mbTrans190.Close() - _, err191 := mbTrans190.WriteString(arg189) - if err191 != nil { - Usage() - return - } - factory192 := thrift.NewSimpleJSONProtocolFactory() - jsProt193 := factory192.GetProtocol(mbTrans190) - argvalue0 := storage.NewAddEdgesRequest() - err194 := argvalue0.Read(jsProt193) - if err194 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ChainAddEdges(value0)) - fmt.Print("\n") - break - case "chainDeleteEdges": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ChainDeleteEdges requires 1 args") - flag.Usage() - } - arg195 := flag.Arg(1) - mbTrans196 := thrift.NewMemoryBufferLen(len(arg195)) - defer mbTrans196.Close() - _, err197 := mbTrans196.WriteString(arg195) - if err197 != nil { - Usage() - return - } - factory198 := thrift.NewSimpleJSONProtocolFactory() - jsProt199 := factory198.GetProtocol(mbTrans196) - argvalue0 := storage.NewDeleteEdgesRequest() - err200 := argvalue0.Read(jsProt199) - if err200 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ChainDeleteEdges(value0)) - fmt.Print("\n") - break - case "get": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "Get requires 1 args") - flag.Usage() - } - arg201 := flag.Arg(1) - mbTrans202 := thrift.NewMemoryBufferLen(len(arg201)) - defer mbTrans202.Close() - _, err203 := mbTrans202.WriteString(arg201) - if err203 != nil { - Usage() - return - } - factory204 := thrift.NewSimpleJSONProtocolFactory() - jsProt205 := factory204.GetProtocol(mbTrans202) - argvalue0 := storage.NewKVGetRequest() - err206 := argvalue0.Read(jsProt205) - if err206 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.Get(value0)) - fmt.Print("\n") - break - case "put": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "Put requires 1 args") - flag.Usage() - } - arg207 := flag.Arg(1) - mbTrans208 := thrift.NewMemoryBufferLen(len(arg207)) - defer mbTrans208.Close() - _, err209 := mbTrans208.WriteString(arg207) - if err209 != nil { - Usage() - return - } - factory210 := thrift.NewSimpleJSONProtocolFactory() - jsProt211 := factory210.GetProtocol(mbTrans208) - argvalue0 := storage.NewKVPutRequest() - err212 := argvalue0.Read(jsProt211) - if err212 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.Put(value0)) - fmt.Print("\n") - break - case "remove": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "Remove requires 1 args") - flag.Usage() - } - arg213 := flag.Arg(1) - mbTrans214 := thrift.NewMemoryBufferLen(len(arg213)) - defer mbTrans214.Close() - _, err215 := mbTrans214.WriteString(arg213) - if err215 != nil { - Usage() - return - } - factory216 := thrift.NewSimpleJSONProtocolFactory() - jsProt217 := factory216.GetProtocol(mbTrans214) - argvalue0 := storage.NewKVRemoveRequest() - err218 := argvalue0.Read(jsProt217) - if err218 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.Remove(value0)) - fmt.Print("\n") - break - case "": - Usage() - break - default: - fmt.Fprintln(os.Stderr, "Invalid function ", cmd) - } -} diff --git a/nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go b/nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go deleted file mode 100755 index 3ea924fc..00000000 --- a/nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go +++ /dev/null @@ -1,488 +0,0 @@ -// Autogenerated by Thrift Compiler (facebook) -// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -// @generated - -package main - -import ( - "flag" - "fmt" - "math" - "net" - "net/url" - "os" - "strconv" - "strings" - thrift "github.com/facebook/fbthrift/thrift/lib/go/thrift" - "../../github.com/vesoft-inc/nebula-go/v3/nebula/storage" -) - -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, " AdminExecResp transLeader(TransLeaderReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp addPart(AddPartReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp addLearner(AddLearnerReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp removePart(RemovePartReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp memberChange(MemberChangeReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp waitingForCatchUpData(CatchUpDataReq req)") - fmt.Fprintln(os.Stderr, " CreateCPResp createCheckpoint(CreateCPRequest req)") - fmt.Fprintln(os.Stderr, " DropCPResp dropCheckpoint(DropCPRequest req)") - fmt.Fprintln(os.Stderr, " BlockingSignResp blockingWrites(BlockingSignRequest req)") - fmt.Fprintln(os.Stderr, " GetLeaderPartsResp getLeaderParts(GetLeaderReq req)") - fmt.Fprintln(os.Stderr, " AdminExecResp checkPeers(CheckPeersReq req)") - fmt.Fprintln(os.Stderr, " AddTaskResp addAdminTask(AddTaskRequest req)") - fmt.Fprintln(os.Stderr, " StopTaskResp stopAdminTask(StopTaskRequest req)") - fmt.Fprintln(os.Stderr, " ClearSpaceResp clearSpace(ClearSpaceReq req)") - fmt.Fprintln(os.Stderr) - os.Exit(0) -} - -func main() { - flag.Usage = Usage - var host string - var port int - var protocol string - var urlString string - var framed bool - var useHttp bool - var parsedUrl url.URL - var trans thrift.Transport - _ = strconv.Atoi - _ = math.Abs - flag.Usage = Usage - flag.StringVar(&host, "h", "localhost", "Specify host") - 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.Parse() - - if len(urlString) > 0 { - 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" - } 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.NewHTTPPostClient(parsedUrl.String()) - } 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.NewSocket(thrift.SocketAddr(net.JoinHostPort(host, portStr))) - if err != nil { - fmt.Fprintln(os.Stderr, "error resolving address:", err) - os.Exit(1) - } - if framed { - trans = thrift.NewFramedTransport(trans) - } - } - if err != nil { - fmt.Fprintln(os.Stderr, "Error creating transport", err) - os.Exit(1) - } - defer trans.Close() - var protocolFactory thrift.ProtocolFactory - switch protocol { - case "compact": - protocolFactory = thrift.NewCompactProtocolFactory() - break - case "simplejson": - protocolFactory = thrift.NewSimpleJSONProtocolFactory() - break - case "json": - protocolFactory = thrift.NewJSONProtocolFactory() - break - case "binary", "": - protocolFactory = thrift.NewBinaryProtocolFactoryDefault() - break - default: - fmt.Fprintln(os.Stderr, "Invalid protocol specified: ", protocol) - Usage() - os.Exit(1) - } - client := storage.NewStorageAdminServiceClientFactory(trans, protocolFactory) - if err := trans.Open(); err != nil { - fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) - os.Exit(1) - } - - switch cmd { - case "transLeader": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "TransLeader requires 1 args") - flag.Usage() - } - arg221 := flag.Arg(1) - mbTrans222 := thrift.NewMemoryBufferLen(len(arg221)) - defer mbTrans222.Close() - _, err223 := mbTrans222.WriteString(arg221) - if err223 != nil { - Usage() - return - } - factory224 := thrift.NewSimpleJSONProtocolFactory() - jsProt225 := factory224.GetProtocol(mbTrans222) - argvalue0 := storage.NewTransLeaderReq() - err226 := argvalue0.Read(jsProt225) - if err226 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.TransLeader(value0)) - fmt.Print("\n") - break - case "addPart": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddPart requires 1 args") - flag.Usage() - } - arg227 := flag.Arg(1) - mbTrans228 := thrift.NewMemoryBufferLen(len(arg227)) - defer mbTrans228.Close() - _, err229 := mbTrans228.WriteString(arg227) - if err229 != nil { - Usage() - return - } - factory230 := thrift.NewSimpleJSONProtocolFactory() - jsProt231 := factory230.GetProtocol(mbTrans228) - argvalue0 := storage.NewAddPartReq() - err232 := argvalue0.Read(jsProt231) - if err232 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddPart(value0)) - fmt.Print("\n") - break - case "addLearner": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddLearner requires 1 args") - flag.Usage() - } - arg233 := flag.Arg(1) - mbTrans234 := thrift.NewMemoryBufferLen(len(arg233)) - defer mbTrans234.Close() - _, err235 := mbTrans234.WriteString(arg233) - if err235 != nil { - Usage() - return - } - factory236 := thrift.NewSimpleJSONProtocolFactory() - jsProt237 := factory236.GetProtocol(mbTrans234) - argvalue0 := storage.NewAddLearnerReq() - err238 := argvalue0.Read(jsProt237) - if err238 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddLearner(value0)) - fmt.Print("\n") - break - case "removePart": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "RemovePart requires 1 args") - flag.Usage() - } - arg239 := flag.Arg(1) - mbTrans240 := thrift.NewMemoryBufferLen(len(arg239)) - defer mbTrans240.Close() - _, err241 := mbTrans240.WriteString(arg239) - if err241 != nil { - Usage() - return - } - factory242 := thrift.NewSimpleJSONProtocolFactory() - jsProt243 := factory242.GetProtocol(mbTrans240) - argvalue0 := storage.NewRemovePartReq() - err244 := argvalue0.Read(jsProt243) - if err244 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.RemovePart(value0)) - fmt.Print("\n") - break - case "memberChange": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "MemberChange requires 1 args") - flag.Usage() - } - arg245 := flag.Arg(1) - mbTrans246 := thrift.NewMemoryBufferLen(len(arg245)) - defer mbTrans246.Close() - _, err247 := mbTrans246.WriteString(arg245) - if err247 != nil { - Usage() - return - } - factory248 := thrift.NewSimpleJSONProtocolFactory() - jsProt249 := factory248.GetProtocol(mbTrans246) - argvalue0 := storage.NewMemberChangeReq() - err250 := argvalue0.Read(jsProt249) - if err250 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.MemberChange(value0)) - fmt.Print("\n") - break - case "waitingForCatchUpData": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "WaitingForCatchUpData requires 1 args") - flag.Usage() - } - arg251 := flag.Arg(1) - mbTrans252 := thrift.NewMemoryBufferLen(len(arg251)) - defer mbTrans252.Close() - _, err253 := mbTrans252.WriteString(arg251) - if err253 != nil { - Usage() - return - } - factory254 := thrift.NewSimpleJSONProtocolFactory() - jsProt255 := factory254.GetProtocol(mbTrans252) - argvalue0 := storage.NewCatchUpDataReq() - err256 := argvalue0.Read(jsProt255) - if err256 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.WaitingForCatchUpData(value0)) - fmt.Print("\n") - break - case "createCheckpoint": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CreateCheckpoint requires 1 args") - flag.Usage() - } - arg257 := flag.Arg(1) - mbTrans258 := thrift.NewMemoryBufferLen(len(arg257)) - defer mbTrans258.Close() - _, err259 := mbTrans258.WriteString(arg257) - if err259 != nil { - Usage() - return - } - factory260 := thrift.NewSimpleJSONProtocolFactory() - jsProt261 := factory260.GetProtocol(mbTrans258) - argvalue0 := storage.NewCreateCPRequest() - err262 := argvalue0.Read(jsProt261) - if err262 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CreateCheckpoint(value0)) - fmt.Print("\n") - break - case "dropCheckpoint": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "DropCheckpoint requires 1 args") - flag.Usage() - } - arg263 := flag.Arg(1) - mbTrans264 := thrift.NewMemoryBufferLen(len(arg263)) - defer mbTrans264.Close() - _, err265 := mbTrans264.WriteString(arg263) - if err265 != nil { - Usage() - return - } - factory266 := thrift.NewSimpleJSONProtocolFactory() - jsProt267 := factory266.GetProtocol(mbTrans264) - argvalue0 := storage.NewDropCPRequest() - err268 := argvalue0.Read(jsProt267) - if err268 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.DropCheckpoint(value0)) - fmt.Print("\n") - break - case "blockingWrites": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "BlockingWrites requires 1 args") - flag.Usage() - } - arg269 := flag.Arg(1) - mbTrans270 := thrift.NewMemoryBufferLen(len(arg269)) - defer mbTrans270.Close() - _, err271 := mbTrans270.WriteString(arg269) - if err271 != nil { - Usage() - return - } - factory272 := thrift.NewSimpleJSONProtocolFactory() - jsProt273 := factory272.GetProtocol(mbTrans270) - argvalue0 := storage.NewBlockingSignRequest() - err274 := argvalue0.Read(jsProt273) - if err274 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.BlockingWrites(value0)) - fmt.Print("\n") - break - case "getLeaderParts": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "GetLeaderParts requires 1 args") - flag.Usage() - } - arg275 := flag.Arg(1) - mbTrans276 := thrift.NewMemoryBufferLen(len(arg275)) - defer mbTrans276.Close() - _, err277 := mbTrans276.WriteString(arg275) - if err277 != nil { - Usage() - return - } - factory278 := thrift.NewSimpleJSONProtocolFactory() - jsProt279 := factory278.GetProtocol(mbTrans276) - argvalue0 := storage.NewGetLeaderReq() - err280 := argvalue0.Read(jsProt279) - if err280 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.GetLeaderParts(value0)) - fmt.Print("\n") - break - case "checkPeers": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "CheckPeers requires 1 args") - flag.Usage() - } - arg281 := flag.Arg(1) - mbTrans282 := thrift.NewMemoryBufferLen(len(arg281)) - defer mbTrans282.Close() - _, err283 := mbTrans282.WriteString(arg281) - if err283 != nil { - Usage() - return - } - factory284 := thrift.NewSimpleJSONProtocolFactory() - jsProt285 := factory284.GetProtocol(mbTrans282) - argvalue0 := storage.NewCheckPeersReq() - err286 := argvalue0.Read(jsProt285) - if err286 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.CheckPeers(value0)) - fmt.Print("\n") - break - case "addAdminTask": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "AddAdminTask requires 1 args") - flag.Usage() - } - arg287 := flag.Arg(1) - mbTrans288 := thrift.NewMemoryBufferLen(len(arg287)) - defer mbTrans288.Close() - _, err289 := mbTrans288.WriteString(arg287) - if err289 != nil { - Usage() - return - } - factory290 := thrift.NewSimpleJSONProtocolFactory() - jsProt291 := factory290.GetProtocol(mbTrans288) - argvalue0 := storage.NewAddTaskRequest() - err292 := argvalue0.Read(jsProt291) - if err292 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.AddAdminTask(value0)) - fmt.Print("\n") - break - case "stopAdminTask": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "StopAdminTask requires 1 args") - flag.Usage() - } - arg293 := flag.Arg(1) - mbTrans294 := thrift.NewMemoryBufferLen(len(arg293)) - defer mbTrans294.Close() - _, err295 := mbTrans294.WriteString(arg293) - if err295 != nil { - Usage() - return - } - factory296 := thrift.NewSimpleJSONProtocolFactory() - jsProt297 := factory296.GetProtocol(mbTrans294) - argvalue0 := storage.NewStopTaskRequest() - err298 := argvalue0.Read(jsProt297) - if err298 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.StopAdminTask(value0)) - fmt.Print("\n") - break - case "clearSpace": - if flag.NArg() - 1 != 1 { - fmt.Fprintln(os.Stderr, "ClearSpace requires 1 args") - flag.Usage() - } - arg299 := flag.Arg(1) - mbTrans300 := thrift.NewMemoryBufferLen(len(arg299)) - defer mbTrans300.Close() - _, err301 := mbTrans300.WriteString(arg299) - if err301 != nil { - Usage() - return - } - factory302 := thrift.NewSimpleJSONProtocolFactory() - jsProt303 := factory302.GetProtocol(mbTrans300) - argvalue0 := storage.NewClearSpaceReq() - err304 := argvalue0.Read(jsProt303) - if err304 != nil { - Usage() - return - } - value0 := argvalue0 - fmt.Print(client.ClearSpace(value0)) - fmt.Print("\n") - break - case "": - Usage() - break - default: - fmt.Fprintln(os.Stderr, "Invalid function ", cmd) - } -} From 8148a7b1fa756d2ab4f8ec93964e2b740c9dfcae Mon Sep 17 00:00:00 2001 From: Tiago Peczenyj Date: Fri, 6 May 2022 10:17:51 +0200 Subject: [PATCH 2/2] Create integration tests (#201) * add build tag for integration tests * add unit rule to run unit tests * add unit as phony * improve formatting of each _test file, enable coverate on functional tests * add badge for test results --- Makefile | 12 +++++++----- README.md | 18 +++++++++++------- client_test.go | 4 +++- session_test.go | 3 +++ ssl_connection_test.go | 3 +++ 5 files changed, 27 insertions(+), 13 deletions(-) diff --git a/Makefile b/Makefile index d1a8ffeb..b6658e18 100644 --- a/Makefile +++ b/Makefile @@ -1,14 +1,16 @@ -.PHONY: build test fmt up up-ssl down ssl-test run-examples +.PHONY: build unit test fmt up up-ssl down ssl-test run-examples default: build build: fmt go mod tidy go build - +unit: + go mod tidy + go test -v -race --covermode=atomic --coverprofile coverage.out test: go mod tidy - go test -v -race + go test -v -race --tags=integration --covermode=atomic --coverprofile coverage.out fmt: go fmt @@ -22,10 +24,10 @@ down: cd ./nebula-docker-compose && docker-compose down -v ssl-test: - ssl_test=true go test -v -run TestSslConnection; + ssl_test=true go test -v --tags=integration -run TestSslConnection; ssl-test-self-signed: - self_signed=true go test -v -run TestSslConnection; + self_signed=true go test -v --tags=integration -run TestSslConnection; run-examples: go run basic_example/graph_client_basic_example.go && \ diff --git a/README.md b/README.md index bff59714..ffac0ac4 100644 --- a/README.md +++ b/README.md @@ -1,5 +1,7 @@ # nebula-go + [![Go Reference](https://pkg.go.dev/badge/github.com/vesoft-inc/nebula-go/v3.svg)](https://pkg.go.dev/github.com/vesoft-inc/nebula-go/v3) +![functional tests](https://github.com/vesoft-inc/nebula-go/actions/workflows/test.yaml/badge.svg) **IMPORTANT: Code of Nebula go client has been transferred from [nebula-clients](https://github.com/vesoft-inc/nebula-clients) to this repository(nebula-go), and new releases in the future will be published in this repository. Please update your go.mod and imports correspondingly.** @@ -19,7 +21,6 @@ To Use the console with a stable release of Nebula Graph, please check the branc | **[v3.1.x](https://github.com/vesoft-inc/nebula-go/tree/v3.1.0)** | 3.1.x | | **[master](https://github.com/vesoft-inc/nebula-go/tree/master)** | 3.x-nightly | - Please be careful not to modify the files in the nebula directory, these codes were all generated by fbthrift. **NOTE** Installing Nebula Go v2.5.0 could cause **checksum mismatch**, use v2.5.1 instead. @@ -29,18 +30,21 @@ Please be careful not to modify the files in the nebula directory, these codes w ```shell $ go get -u -v github.com/vesoft-inc/nebula-go/v3@master ``` + You can specify the version of Nebula-go by substituting `` in `$ go get -u -v github.com/vesoft-inc/nebula-go@`. -For example: - - for v3: `$ go get -u -v github.com/vesoft-inc/nebula-go/v3@v3.1.0` - for v2: `$ go get -u -v github.com/vesoft-inc/nebula-go/v2@v2.6.0` +For example: + + for v3: `$ go get -u -v github.com/vesoft-inc/nebula-go/v3@v3.1.0` + for v2: `$ go get -u -v github.com/vesoft-inc/nebula-go/v2@v2.6.0` **Note**: You will get a message like this if you don't specify a tag: -> ``` + +> ```shell > $ go get -u -v github.com/vesoft-inc/nebula-go/v2@master > go: github.com/vesoft-inc/nebula-go/v2 master => v2.0.0-20210506025434-97d4168c5c4d > ``` -> Here the ` 20210506025434-97d4168c5c4d` is a version tag auto-generated by Github using commit date and SHA. +> +> Here the `20210506025434-97d4168c5c4d` is a version tag auto-generated by Github using commit date and SHA. > This should match the latest commit in the master branch. ## Usage example diff --git a/client_test.go b/client_test.go index 80a39f47..a6158967 100644 --- a/client_test.go +++ b/client_test.go @@ -1,3 +1,6 @@ +//go:build integration +// +build integration + /* * * Copyright (c) 2020 vesoft inc. All rights reserved. @@ -5,7 +8,6 @@ * This source code is licensed under Apache 2.0 License. * */ - package nebula_go import ( diff --git a/session_test.go b/session_test.go index a2933d57..e56a3aca 100644 --- a/session_test.go +++ b/session_test.go @@ -1,3 +1,6 @@ +//go:build integration +// +build integration + /* Copyright (c) 2021 vesoft inc. All rights reserved. * * This source code is licensed under Apache 2.0 License. diff --git a/ssl_connection_test.go b/ssl_connection_test.go index 3ebbd113..d5c27814 100644 --- a/ssl_connection_test.go +++ b/ssl_connection_test.go @@ -1,3 +1,6 @@ +//go:build integration +// +build integration + /* * * Copyright (c) 2020 vesoft inc. All rights reserved.