diff --git a/client_test.go b/client_test.go index 4541f4d0..12f29bbc 100644 --- a/client_test.go +++ b/client_test.go @@ -20,9 +20,9 @@ import ( "testing" "time" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" "github.com/stretchr/testify/assert" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) const ( diff --git a/connection.go b/connection.go index 3c4963af..cf359dc8 100644 --- a/connection.go +++ b/connection.go @@ -18,8 +18,8 @@ import ( "time" "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" "golang.org/x/net/http2" ) diff --git a/connection_pool.go b/connection_pool.go index 5b922c48..63a2d736 100644 --- a/connection_pool.go +++ b/connection_pool.go @@ -17,7 +17,7 @@ import ( "sync" "time" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) type ConnectionPool struct { diff --git a/examples/basic_example/graph_client_basic_example.go b/examples/basic_example/graph_client_basic_example.go index 9fb0fb0d..5835028b 100644 --- a/examples/basic_example/graph_client_basic_example.go +++ b/examples/basic_example/graph_client_basic_example.go @@ -11,7 +11,7 @@ package main import ( "fmt" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/examples/contex_request_cancellation_example/contex_request_cancellation_example.go b/examples/contex_request_cancellation_example/contex_request_cancellation_example.go index 5ed6df95..76a662b0 100644 --- a/examples/contex_request_cancellation_example/contex_request_cancellation_example.go +++ b/examples/contex_request_cancellation_example/contex_request_cancellation_example.go @@ -3,7 +3,7 @@ package main import ( "context" "fmt" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" "strings" ) diff --git a/examples/goroutines_example/graph_client_goroutines_example.go b/examples/goroutines_example/graph_client_goroutines_example.go index 34d2047b..d25e255f 100644 --- a/examples/goroutines_example/graph_client_goroutines_example.go +++ b/examples/goroutines_example/graph_client_goroutines_example.go @@ -15,7 +15,7 @@ import ( "sync" "time" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/examples/json_example/parse_json_example.go b/examples/json_example/parse_json_example.go index 9356ab67..6104beff 100644 --- a/examples/json_example/parse_json_example.go +++ b/examples/json_example/parse_json_example.go @@ -14,7 +14,7 @@ import ( "fmt" "time" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/examples/parameter_example/parameter_example.go b/examples/parameter_example/parameter_example.go index 77f9aaff..ca81f0d4 100644 --- a/examples/parameter_example/parameter_example.go +++ b/examples/parameter_example/parameter_example.go @@ -12,7 +12,7 @@ import ( "strings" "sync" - nebulago "github.com/egasimov/nebula-go/v3" + nebulago "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/examples/session_pool_example/session_pool_example.go b/examples/session_pool_example/session_pool_example.go index b7d7eb68..f0d3e60a 100644 --- a/examples/session_pool_example/session_pool_example.go +++ b/examples/session_pool_example/session_pool_example.go @@ -15,7 +15,7 @@ import ( "sync" "time" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/examples/ssl_example/graph_client_ssl_example.go b/examples/ssl_example/graph_client_ssl_example.go index 35aefe89..96783b66 100644 --- a/examples/ssl_example/graph_client_ssl_example.go +++ b/examples/ssl_example/graph_client_ssl_example.go @@ -12,7 +12,7 @@ import ( "context" "fmt" - nebula "github.com/egasimov/nebula-go/v3" + nebula "github.com/vesoft-inc/nebula-go/v3" ) const ( diff --git a/go.mod b/go.mod index c83dc8a6..b117275d 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/egasimov/nebula-go/v3 +module github.com/vesoft-inc/nebula-go/v3 go 1.21 diff --git a/nebula/graph/graph-consts.go b/nebula/graph/graph-consts.go index cefeb401..3aac1114 100644 --- a/nebula/graph/graph-consts.go +++ b/nebula/graph/graph-consts.go @@ -11,7 +11,7 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) diff --git a/nebula/graph/graph.go b/nebula/graph/graph.go index 322cc02c..cef19371 100644 --- a/nebula/graph/graph.go +++ b/nebula/graph/graph.go @@ -11,7 +11,7 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) diff --git a/nebula/graph/graph_service-remote/graph_service-remote.go b/nebula/graph/graph_service-remote/graph_service-remote.go index bd0e9cb2..fd2ace08 100755 --- a/nebula/graph/graph_service-remote/graph_service-remote.go +++ b/nebula/graph/graph_service-remote/graph_service-remote.go @@ -13,8 +13,8 @@ import ( "strconv" "strings" thrift "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) var _ = nebula.GoUnusedProtection__ @@ -73,7 +73,7 @@ func main() { flag.BoolVar(&useHttp, "http", false, "Use http") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Parse() - + if len(urlString) > 0 { var err error parsedUrl, err = url.Parse(urlString) @@ -90,7 +90,7 @@ func main() { flag.Usage() } } - + cmd := flag.Arg(0) var err error var cfg *thrift.TConfiguration = nil @@ -151,7 +151,7 @@ func main() { fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) os.Exit(1) } - + switch cmd { case "authenticate": if flag.NArg() - 1 != 2 { @@ -212,7 +212,7 @@ func main() { mbTrans63 := thrift.NewTMemoryBufferLen(len(arg62)) defer mbTrans63.Close() _, err64 := mbTrans63.WriteString(arg62) - if err64 != nil { + if err64 != nil { Usage() return } @@ -262,7 +262,7 @@ func main() { mbTrans73 := thrift.NewTMemoryBufferLen(len(arg72)) defer mbTrans73.Close() _, err74 := mbTrans73.WriteString(arg72) - if err74 != nil { + if err74 != nil { Usage() return } diff --git a/nebula/meta/meta-consts.go b/nebula/meta/meta-consts.go index 4a958745..8a541c5f 100644 --- a/nebula/meta/meta-consts.go +++ b/nebula/meta/meta-consts.go @@ -11,7 +11,7 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) diff --git a/nebula/meta/meta.go b/nebula/meta/meta.go index 9c74f81c..e061e1a9 100644 --- a/nebula/meta/meta.go +++ b/nebula/meta/meta.go @@ -12,7 +12,7 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) @@ -48,10 +48,10 @@ func (p AlterSchemaOp) String() string { func AlterSchemaOpFromString(s string) (AlterSchemaOp, error) { switch s { - case "ADD": return AlterSchemaOp_ADD, nil - case "CHANGE": return AlterSchemaOp_CHANGE, nil - case "DROP": return AlterSchemaOp_DROP, nil - case "UNKNOWN": return AlterSchemaOp_UNKNOWN, nil + case "ADD": return AlterSchemaOp_ADD, nil + case "CHANGE": return AlterSchemaOp_CHANGE, nil + case "DROP": return AlterSchemaOp_DROP, nil + case "UNKNOWN": return AlterSchemaOp_UNKNOWN, nil } return AlterSchemaOp(0), fmt.Errorf("not a valid AlterSchemaOp string") } @@ -109,11 +109,11 @@ func (p RoleType) String() string { func RoleTypeFromString(s string) (RoleType, error) { switch s { - case "GOD": return RoleType_GOD, nil - case "ADMIN": return RoleType_ADMIN, nil - case "DBA": return RoleType_DBA, nil - case "USER": return RoleType_USER, nil - case "GUEST": return RoleType_GUEST, nil + case "GOD": return RoleType_GOD, nil + case "ADMIN": return RoleType_ADMIN, nil + case "DBA": return RoleType_DBA, nil + case "USER": return RoleType_USER, nil + case "GUEST": return RoleType_GUEST, nil } return RoleType(0), fmt.Errorf("not a valid RoleType string") } @@ -169,10 +169,10 @@ func (p GeoShape) String() string { func GeoShapeFromString(s string) (GeoShape, error) { switch s { - case "ANY": return GeoShape_ANY, nil - case "POINT": return GeoShape_POINT, nil - case "LINESTRING": return GeoShape_LINESTRING, nil - case "POLYGON": return GeoShape_POLYGON, nil + case "ANY": return GeoShape_ANY, nil + case "POINT": return GeoShape_POINT, nil + case "LINESTRING": return GeoShape_LINESTRING, nil + case "POLYGON": return GeoShape_POLYGON, nil } return GeoShape(0), fmt.Errorf("not a valid GeoShape string") } @@ -224,8 +224,8 @@ func (p IsolationLevel) String() string { func IsolationLevelFromString(s string) (IsolationLevel, error) { switch s { - case "DEFAULT": return IsolationLevel_DEFAULT, nil - case "TOSS": return IsolationLevel_TOSS, nil + case "DEFAULT": return IsolationLevel_DEFAULT, nil + case "TOSS": return IsolationLevel_TOSS, nil } return IsolationLevel(0), fmt.Errorf("not a valid IsolationLevel string") } @@ -279,9 +279,9 @@ func (p HostStatus) String() string { func HostStatusFromString(s string) (HostStatus, error) { switch s { - case "ONLINE": return HostStatus_ONLINE, nil - case "OFFLINE": return HostStatus_OFFLINE, nil - case "UNKNOWN": return HostStatus_UNKNOWN, nil + case "ONLINE": return HostStatus_ONLINE, nil + case "OFFLINE": return HostStatus_OFFLINE, nil + case "UNKNOWN": return HostStatus_UNKNOWN, nil } return HostStatus(0), fmt.Errorf("not a valid HostStatus string") } @@ -333,8 +333,8 @@ func (p SnapshotStatus) String() string { func SnapshotStatusFromString(s string) (SnapshotStatus, error) { switch s { - case "VALID": return SnapshotStatus_VALID, nil - case "INVALID": return SnapshotStatus_INVALID, nil + case "VALID": return SnapshotStatus_VALID, nil + case "INVALID": return SnapshotStatus_INVALID, nil } return SnapshotStatus(0), fmt.Errorf("not a valid SnapshotStatus string") } @@ -384,7 +384,7 @@ func (p AlterSpaceOp) String() string { func AlterSpaceOpFromString(s string) (AlterSpaceOp, error) { switch s { - case "ADD_ZONE": return AlterSpaceOp_ADD_ZONE, nil + case "ADD_ZONE": return AlterSpaceOp_ADD_ZONE, nil } return AlterSpaceOp(0), fmt.Errorf("not a valid AlterSpaceOp string") } @@ -442,11 +442,11 @@ func (p JobOp) String() string { func JobOpFromString(s string) (JobOp, error) { switch s { - case "ADD": return JobOp_ADD, nil - case "SHOW_All": return JobOp_SHOW_All, nil - case "SHOW": return JobOp_SHOW, nil - case "STOP": return JobOp_STOP, nil - case "RECOVER": return JobOp_RECOVER, nil + case "ADD": return JobOp_ADD, nil + case "SHOW_All": return JobOp_SHOW_All, nil + case "SHOW": return JobOp_SHOW, nil + case "STOP": return JobOp_STOP, nil + case "RECOVER": return JobOp_RECOVER, nil } return JobOp(0), fmt.Errorf("not a valid JobOp string") } @@ -518,18 +518,18 @@ func (p JobType) String() string { func JobTypeFromString(s string) (JobType, error) { switch s { - case "COMPACT": return JobType_COMPACT, nil - case "FLUSH": return JobType_FLUSH, nil - case "REBUILD_TAG_INDEX": return JobType_REBUILD_TAG_INDEX, nil - case "REBUILD_EDGE_INDEX": return JobType_REBUILD_EDGE_INDEX, nil - case "REBUILD_FULLTEXT_INDEX": return JobType_REBUILD_FULLTEXT_INDEX, nil - case "STATS": return JobType_STATS, nil - case "DATA_BALANCE": return JobType_DATA_BALANCE, nil - case "DOWNLOAD": return JobType_DOWNLOAD, nil - case "INGEST": return JobType_INGEST, nil - case "LEADER_BALANCE": return JobType_LEADER_BALANCE, nil - case "ZONE_BALANCE": return JobType_ZONE_BALANCE, nil - case "UNKNOWN": return JobType_UNKNOWN, nil + case "COMPACT": return JobType_COMPACT, nil + case "FLUSH": return JobType_FLUSH, nil + case "REBUILD_TAG_INDEX": return JobType_REBUILD_TAG_INDEX, nil + case "REBUILD_EDGE_INDEX": return JobType_REBUILD_EDGE_INDEX, nil + case "REBUILD_FULLTEXT_INDEX": return JobType_REBUILD_FULLTEXT_INDEX, nil + case "STATS": return JobType_STATS, nil + case "DATA_BALANCE": return JobType_DATA_BALANCE, nil + case "DOWNLOAD": return JobType_DOWNLOAD, nil + case "INGEST": return JobType_INGEST, nil + case "LEADER_BALANCE": return JobType_LEADER_BALANCE, nil + case "ZONE_BALANCE": return JobType_ZONE_BALANCE, nil + case "UNKNOWN": return JobType_UNKNOWN, nil } return JobType(0), fmt.Errorf("not a valid JobType string") } @@ -589,12 +589,12 @@ func (p JobStatus) String() string { func JobStatusFromString(s string) (JobStatus, error) { switch s { - case "QUEUE": return JobStatus_QUEUE, nil - case "RUNNING": return JobStatus_RUNNING, nil - case "FINISHED": return JobStatus_FINISHED, nil - case "FAILED": return JobStatus_FAILED, nil - case "STOPPED": return JobStatus_STOPPED, nil - case "INVALID": return JobStatus_INVALID, nil + case "QUEUE": return JobStatus_QUEUE, nil + case "RUNNING": return JobStatus_RUNNING, nil + case "FINISHED": return JobStatus_FINISHED, nil + case "FAILED": return JobStatus_FAILED, nil + case "STOPPED": return JobStatus_STOPPED, nil + case "INVALID": return JobStatus_INVALID, nil } return JobStatus(0), fmt.Errorf("not a valid JobStatus string") } @@ -654,12 +654,12 @@ func (p ListHostType) String() string { func ListHostTypeFromString(s string) (ListHostType, error) { switch s { - case "ALLOC": return ListHostType_ALLOC, nil - case "GRAPH": return ListHostType_GRAPH, nil - case "META": return ListHostType_META, nil - case "STORAGE": return ListHostType_STORAGE, nil - case "AGENT": return ListHostType_AGENT, nil - case "STORAGE_LISTENER": return ListHostType_STORAGE_LISTENER, nil + case "ALLOC": return ListHostType_ALLOC, nil + case "GRAPH": return ListHostType_GRAPH, nil + case "META": return ListHostType_META, nil + case "STORAGE": return ListHostType_STORAGE, nil + case "AGENT": return ListHostType_AGENT, nil + case "STORAGE_LISTENER": return ListHostType_STORAGE_LISTENER, nil } return ListHostType(0), fmt.Errorf("not a valid ListHostType string") } @@ -719,12 +719,12 @@ func (p HostRole) String() string { func HostRoleFromString(s string) (HostRole, error) { switch s { - case "GRAPH": return HostRole_GRAPH, nil - case "META": return HostRole_META, nil - case "STORAGE": return HostRole_STORAGE, nil - case "STORAGE_LISTENER": return HostRole_STORAGE_LISTENER, nil - case "AGENT": return HostRole_AGENT, nil - case "UNKNOWN": return HostRole_UNKNOWN, nil + case "GRAPH": return HostRole_GRAPH, nil + case "META": return HostRole_META, nil + case "STORAGE": return HostRole_STORAGE, nil + case "STORAGE_LISTENER": return HostRole_STORAGE_LISTENER, nil + case "AGENT": return HostRole_AGENT, nil + case "UNKNOWN": return HostRole_UNKNOWN, nil } return HostRole(0), fmt.Errorf("not a valid HostRole string") } @@ -780,10 +780,10 @@ func (p TaskResult_) String() string { func TaskResult_FromString(s string) (TaskResult_, error) { switch s { - case "SUCCEEDED": return TaskResult__SUCCEEDED, nil - case "FAILED": return TaskResult__FAILED, nil - case "IN_PROGRESS": return TaskResult__IN_PROGRESS, nil - case "INVALID": return TaskResult__INVALID, nil + case "SUCCEEDED": return TaskResult__SUCCEEDED, nil + case "FAILED": return TaskResult__FAILED, nil + case "IN_PROGRESS": return TaskResult__IN_PROGRESS, nil + case "INVALID": return TaskResult__INVALID, nil } return TaskResult_(0), fmt.Errorf("not a valid TaskResult_ string") } @@ -841,11 +841,11 @@ func (p ConfigModule) String() string { func ConfigModuleFromString(s string) (ConfigModule, error) { switch s { - case "UNKNOWN": return ConfigModule_UNKNOWN, nil - case "ALL": return ConfigModule_ALL, nil - case "GRAPH": return ConfigModule_GRAPH, nil - case "META": return ConfigModule_META, nil - case "STORAGE": return ConfigModule_STORAGE, nil + case "UNKNOWN": return ConfigModule_UNKNOWN, nil + case "ALL": return ConfigModule_ALL, nil + case "GRAPH": return ConfigModule_GRAPH, nil + case "META": return ConfigModule_META, nil + case "STORAGE": return ConfigModule_STORAGE, nil } return ConfigModule(0), fmt.Errorf("not a valid ConfigModule string") } @@ -901,10 +901,10 @@ func (p ConfigMode) String() string { func ConfigModeFromString(s string) (ConfigMode, error) { switch s { - case "IMMUTABLE": return ConfigMode_IMMUTABLE, nil - case "REBOOT": return ConfigMode_REBOOT, nil - case "MUTABLE": return ConfigMode_MUTABLE, nil - case "IGNORED": return ConfigMode_IGNORED, nil + case "IMMUTABLE": return ConfigMode_IMMUTABLE, nil + case "REBOOT": return ConfigMode_REBOOT, nil + case "MUTABLE": return ConfigMode_MUTABLE, nil + case "IGNORED": return ConfigMode_IGNORED, nil } return ConfigMode(0), fmt.Errorf("not a valid ConfigMode string") } @@ -956,8 +956,8 @@ func (p ListenerType) String() string { func ListenerTypeFromString(s string) (ListenerType, error) { switch s { - case "UNKNOWN": return ListenerType_UNKNOWN, nil - case "ELASTICSEARCH": return ListenerType_ELASTICSEARCH, nil + case "UNKNOWN": return ListenerType_UNKNOWN, nil + case "ELASTICSEARCH": return ListenerType_ELASTICSEARCH, nil } return ListenerType(0), fmt.Errorf("not a valid ListenerType string") } @@ -1007,7 +1007,7 @@ func (p ExternalServiceType) String() string { func ExternalServiceTypeFromString(s string) (ExternalServiceType, error) { switch s { - case "ELASTICSEARCH": return ExternalServiceType_ELASTICSEARCH, nil + case "ELASTICSEARCH": return ExternalServiceType_ELASTICSEARCH, nil } return ExternalServiceType(0), fmt.Errorf("not a valid ExternalServiceType string") } @@ -1059,8 +1059,8 @@ func (p QueryStatus) String() string { func QueryStatusFromString(s string) (QueryStatus, error) { switch s { - case "RUNNING": return QueryStatus_RUNNING, nil - case "KILLING": return QueryStatus_KILLING, nil + case "RUNNING": return QueryStatus_RUNNING, nil + case "KILLING": return QueryStatus_KILLING, nil } return QueryStatus(0), fmt.Errorf("not a valid QueryStatus string") } diff --git a/nebula/meta/meta_service-remote/meta_service-remote.go b/nebula/meta/meta_service-remote/meta_service-remote.go index ded4c15b..d12a008c 100755 --- a/nebula/meta/meta_service-remote/meta_service-remote.go +++ b/nebula/meta/meta_service-remote/meta_service-remote.go @@ -13,8 +13,8 @@ import ( "strconv" "strings" thrift "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" ) var _ = nebula.GoUnusedProtection__ @@ -151,7 +151,7 @@ func main() { flag.BoolVar(&useHttp, "http", false, "Use http") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Parse() - + if len(urlString) > 0 { var err error parsedUrl, err = url.Parse(urlString) @@ -168,7 +168,7 @@ func main() { flag.Usage() } } - + cmd := flag.Arg(0) var err error var cfg *thrift.TConfiguration = nil @@ -229,7 +229,7 @@ func main() { fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) os.Exit(1) } - + switch cmd { case "createSpace": if flag.NArg() - 1 != 1 { 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 index 373fffe2..f7dbb0f8 100755 --- a/nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go +++ b/nebula/storage/graph_storage_service-remote/graph_storage_service-remote.go @@ -13,9 +13,9 @@ import ( "strconv" "strings" thrift "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" - "github.com/egasimov/nebula-go/v3/nebula/storage" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula/storage" ) var _ = nebula.GoUnusedProtection__ @@ -89,7 +89,7 @@ func main() { flag.BoolVar(&useHttp, "http", false, "Use http") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Parse() - + if len(urlString) > 0 { var err error parsedUrl, err = url.Parse(urlString) @@ -106,7 +106,7 @@ func main() { flag.Usage() } } - + cmd := flag.Arg(0) var err error var cfg *thrift.TConfiguration = nil @@ -167,7 +167,7 @@ func main() { fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) os.Exit(1) } - + switch cmd { case "getNeighbors": if flag.NArg() - 1 != 1 { diff --git a/nebula/storage/internal_storage_service-remote/internal_storage_service-remote.go b/nebula/storage/internal_storage_service-remote/internal_storage_service-remote.go index 30a63f26..32de924e 100755 --- a/nebula/storage/internal_storage_service-remote/internal_storage_service-remote.go +++ b/nebula/storage/internal_storage_service-remote/internal_storage_service-remote.go @@ -13,9 +13,9 @@ import ( "strconv" "strings" thrift "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" - "github.com/egasimov/nebula-go/v3/nebula/storage" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula/storage" ) var _ = nebula.GoUnusedProtection__ @@ -71,7 +71,7 @@ func main() { flag.BoolVar(&useHttp, "http", false, "Use http") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Parse() - + if len(urlString) > 0 { var err error parsedUrl, err = url.Parse(urlString) @@ -88,7 +88,7 @@ func main() { flag.Usage() } } - + cmd := flag.Arg(0) var err error var cfg *thrift.TConfiguration = nil @@ -149,7 +149,7 @@ func main() { fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) os.Exit(1) } - + switch cmd { case "chainAddEdges": if flag.NArg() - 1 != 1 { diff --git a/nebula/storage/storage-consts.go b/nebula/storage/storage-consts.go index d2f0201f..10c4588a 100644 --- a/nebula/storage/storage-consts.go +++ b/nebula/storage/storage-consts.go @@ -11,8 +11,8 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" ) diff --git a/nebula/storage/storage.go b/nebula/storage/storage.go index e14acf3a..563deb7e 100644 --- a/nebula/storage/storage.go +++ b/nebula/storage/storage.go @@ -12,8 +12,8 @@ import ( thrift "github.com/apache/thrift/lib/go/thrift" "strings" "regexp" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" ) @@ -52,11 +52,11 @@ func (p StatType) String() string { func StatTypeFromString(s string) (StatType, error) { switch s { - case "SUM": return StatType_SUM, nil - case "COUNT": return StatType_COUNT, nil - case "AVG": return StatType_AVG, nil - case "MAX": return StatType_MAX, nil - case "MIN": return StatType_MIN, nil + case "SUM": return StatType_SUM, nil + case "COUNT": return StatType_COUNT, nil + case "AVG": return StatType_AVG, nil + case "MAX": return StatType_MAX, nil + case "MIN": return StatType_MIN, nil } return StatType(0), fmt.Errorf("not a valid StatType string") } @@ -108,8 +108,8 @@ func (p OrderDirection) String() string { func OrderDirectionFromString(s string) (OrderDirection, error) { switch s { - case "ASCENDING": return OrderDirection_ASCENDING, nil - case "DESCENDING": return OrderDirection_DESCENDING, nil + case "ASCENDING": return OrderDirection_ASCENDING, nil + case "DESCENDING": return OrderDirection_DESCENDING, nil } return OrderDirection(0), fmt.Errorf("not a valid OrderDirection string") } @@ -163,9 +163,9 @@ func (p EdgeDirection) String() string { func EdgeDirectionFromString(s string) (EdgeDirection, error) { switch s { - case "BOTH": return EdgeDirection_BOTH, nil - case "IN_EDGE": return EdgeDirection_IN_EDGE, nil - case "OUT_EDGE": return EdgeDirection_OUT_EDGE, nil + case "BOTH": return EdgeDirection_BOTH, nil + case "IN_EDGE": return EdgeDirection_IN_EDGE, nil + case "OUT_EDGE": return EdgeDirection_OUT_EDGE, nil } return EdgeDirection(0), fmt.Errorf("not a valid EdgeDirection string") } @@ -217,8 +217,8 @@ func (p ScanType) String() string { func ScanTypeFromString(s string) (ScanType, error) { switch s { - case "PREFIX": return ScanType_PREFIX, nil - case "RANGE": return ScanType_RANGE, nil + case "PREFIX": return ScanType_PREFIX, nil + case "RANGE": return ScanType_RANGE, nil } return ScanType(0), fmt.Errorf("not a valid ScanType string") } @@ -270,8 +270,8 @@ func (p EngineSignType) String() string { func EngineSignTypeFromString(s string) (EngineSignType, error) { switch s { - case "BLOCK_ON": return EngineSignType_BLOCK_ON, nil - case "BLOCK_OFF": return EngineSignType_BLOCK_OFF, nil + case "BLOCK_ON": return EngineSignType_BLOCK_ON, nil + case "BLOCK_OFF": return EngineSignType_BLOCK_OFF, nil } return EngineSignType(0), fmt.Errorf("not a valid EngineSignType string") } 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 index ffa03c7f..9f9d0cc1 100755 --- a/nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go +++ b/nebula/storage/storage_admin_service-remote/storage_admin_service-remote.go @@ -13,9 +13,9 @@ import ( "strconv" "strings" thrift "github.com/apache/thrift/lib/go/thrift" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/meta" - "github.com/egasimov/nebula-go/v3/nebula/storage" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/meta" + "github.com/vesoft-inc/nebula-go/v3/nebula/storage" ) var _ = nebula.GoUnusedProtection__ @@ -82,7 +82,7 @@ func main() { flag.BoolVar(&useHttp, "http", false, "Use http") flag.Var(headers, "H", "Headers to set on the http(s) request (e.g. -H \"Key: Value\")") flag.Parse() - + if len(urlString) > 0 { var err error parsedUrl, err = url.Parse(urlString) @@ -99,7 +99,7 @@ func main() { flag.Usage() } } - + cmd := flag.Arg(0) var err error var cfg *thrift.TConfiguration = nil @@ -160,7 +160,7 @@ func main() { fmt.Fprintln(os.Stderr, "Error opening socket to ", host, ":", port, " ", err) os.Exit(1) } - + switch cmd { case "transLeader": if flag.NArg() - 1 != 1 { diff --git a/result_set.go b/result_set.go index c0e7f218..cabd47cb 100644 --- a/result_set.go +++ b/result_set.go @@ -19,8 +19,8 @@ import ( "strings" "time" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) type ResultSet struct { diff --git a/result_set_test.go b/result_set_test.go index 713794ab..3de3be3c 100644 --- a/result_set_test.go +++ b/result_set_test.go @@ -13,9 +13,9 @@ import ( "sort" "testing" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" "github.com/stretchr/testify/assert" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) var testTimezone timezoneInfo = timezoneInfo{0, []byte("UTC")} diff --git a/session.go b/session.go index f1a83264..569658d6 100644 --- a/session.go +++ b/session.go @@ -13,8 +13,8 @@ import ( "fmt" "sync" - "github.com/egasimov/nebula-go/v3/nebula" - graph "github.com/egasimov/nebula-go/v3/nebula/graph" + "github.com/vesoft-inc/nebula-go/v3/nebula" + graph "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) type timezoneInfo struct { diff --git a/session_pool.go b/session_pool.go index f0b70d12..f8c5d8d0 100644 --- a/session_pool.go +++ b/session_pool.go @@ -16,8 +16,8 @@ import ( "sync" "time" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" ) // SessionPool is a pool that manages sessions internally. diff --git a/session_pool_test.go b/session_pool_test.go index 6f947f81..3d1c9b04 100644 --- a/session_pool_test.go +++ b/session_pool_test.go @@ -17,9 +17,9 @@ import ( "testing" "time" - "github.com/egasimov/nebula-go/v3/nebula" - "github.com/egasimov/nebula-go/v3/nebula/graph" "github.com/stretchr/testify/assert" + "github.com/vesoft-inc/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula/graph" "golang.org/x/net/context" ) diff --git a/value_wrapper.go b/value_wrapper.go index e7bbe674..8b3a2b31 100644 --- a/value_wrapper.go +++ b/value_wrapper.go @@ -14,7 +14,7 @@ import ( "strconv" "strings" - "github.com/egasimov/nebula-go/v3/nebula" + "github.com/vesoft-inc/nebula-go/v3/nebula" ) type ValueWrapper struct {