From f3fa65c8b21922640a54b1f1fa80fa5ec33c0e6e Mon Sep 17 00:00:00 2001 From: crusader Date: Wed, 25 Apr 2018 18:56:25 +0900 Subject: [PATCH] ing --- external/grpc/grpc.go | 9 ++++----- glide.yaml | 2 +- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/external/grpc/grpc.go b/external/grpc/grpc.go index e4aa10e..5b664b8 100644 --- a/external/grpc/grpc.go +++ b/external/grpc/grpc.go @@ -7,12 +7,12 @@ import ( "sync" "git.loafle.net/commons/logging-go" - oci "git.loafle.net/overflow/central_api/golang" + oci "git.loafle.net/overflow/central-api/golang" ocec "git.loafle.net/overflow/commons-go/external/config" "google.golang.org/grpc" ) -var grpcClient oci.OverflowApiServerClient +var grpcClient oci.CentralAPIClient func InitPackage(config *ocec.GRPC) { if nil == config { @@ -23,7 +23,7 @@ func InitPackage(config *ocec.GRPC) { if nil != err { logging.Logger().Panic(err) } - grpcClient = oci.NewOverflowApiServerClient(conn) + grpcClient = oci.NewCentralAPIClient(conn) logging.Logger().Infof("GRPC: connected to %s", config.Address) } @@ -31,7 +31,6 @@ func StartPackage(config *ocec.GRPC) { if nil == config { return } - } func StopPackage(config *ocec.GRPC) { @@ -66,7 +65,7 @@ func Exec(ctx context.Context, method string, params ...string) (string, error) execMtx.Lock() defer execMtx.Unlock() - so, err := grpcClient.(oci.OverflowApiServerClient).Exec(ctx, si) + so, err := grpcClient.(oci.CentralAPIClient).Exec(ctx, si) if nil != err { return "", err } diff --git a/glide.yaml b/glide.yaml index d9f2da4..8fa27f8 100644 --- a/glide.yaml +++ b/glide.yaml @@ -1,6 +1,5 @@ package: git.loafle.net/overflow/gateway import: -- package: git.loafle.net/overflow/central_api - package: git.loafle.net/commons/logging-go - package: google.golang.org/grpc version: ^1.11.2 @@ -8,3 +7,4 @@ import: version: ^2.0.0 - package: github.com/segmentio/kafka-go - package: git.loafle.net/commons/util-go +- package: git.loafle.net/overflow/central-api