From 143def1b0d24dbe3f79d898cab7f6366a832544c Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 10 May 2023 11:52:12 +0800 Subject: [PATCH] zk --- go.mod | 2 +- go.sum | 2 ++ pkg/startrpc/start.go | 2 +- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/go.mod b/go.mod index 81b27f38d..ea3939a5e 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.18 require ( firebase.google.com/go v3.13.0+incompatible - github.com/OpenIMSDK/openKeeper v0.9.9-0.20230509114426-eb05252b1e67 + github.com/OpenIMSDK/openKeeper v0.9.9-0.20230510034455-23b10ebc00a8 github.com/OpenIMSDK/open_utils v1.0.8 github.com/Shopify/sarama v1.32.0 github.com/antonfisher/nested-logrus-formatter v1.3.1 diff --git a/go.sum b/go.sum index bde1b45fe..a617a4cdb 100644 --- a/go.sum +++ b/go.sum @@ -393,6 +393,8 @@ github.com/OpenIMSDK/openKeeper v0.9.9-0.20230426053850-80d254440004 h1:+1t9eKPK github.com/OpenIMSDK/openKeeper v0.9.9-0.20230426053850-80d254440004/go.mod h1:HwHgo+p3E+aAeiLOSyDwVB2zFJtu+QvnFNlfNjFG9vA= github.com/OpenIMSDK/openKeeper v0.9.9-0.20230509114426-eb05252b1e67 h1:I6QLciX4LlavBMNyeqkp90DJV+uKcwke7NZ9OKMIjV8= github.com/OpenIMSDK/openKeeper v0.9.9-0.20230509114426-eb05252b1e67/go.mod h1:HwHgo+p3E+aAeiLOSyDwVB2zFJtu+QvnFNlfNjFG9vA= +github.com/OpenIMSDK/openKeeper v0.9.9-0.20230510034455-23b10ebc00a8 h1:iHdOqsumPO6Pu2YINN/DDbuHlP/adTqqBSULCGSS714= +github.com/OpenIMSDK/openKeeper v0.9.9-0.20230510034455-23b10ebc00a8/go.mod h1:HwHgo+p3E+aAeiLOSyDwVB2zFJtu+QvnFNlfNjFG9vA= github.com/OpenIMSDK/open_utils v1.0.8 h1:IopxWgJwEF5ZAPsRuiZZOfcxNOQOCt/p8VDENcHN9r4= github.com/OpenIMSDK/open_utils v1.0.8/go.mod h1:FLoaQblWUVKQgqt2LrNzfSZLT6D3DICBn1kcOMDLUOI= github.com/Shopify/sarama v1.29.0 h1:ARid8o8oieau9XrHI55f/L3EoRAhm9px6sonbD7yuUE= diff --git a/pkg/startrpc/start.go b/pkg/startrpc/start.go index a843db01c..8c4f48ab1 100644 --- a/pkg/startrpc/start.go +++ b/pkg/startrpc/start.go @@ -34,7 +34,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c if err != nil { return utils.Wrap1(err) } - defer zkClient.Close() + defer zkClient.CloseZK() zkClient.AddOption(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())) registerIP, err := network.GetRpcRegisterIP(config.Config.RpcRegisterIP) if err != nil {