From 2d1f08c99406aef2c862563c740c44d8b2fea702 Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Tue, 14 May 2024 10:52:08 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- pkg/common/discoveryregister/discoveryregister.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/common/discoveryregister/discoveryregister.go b/pkg/common/discoveryregister/discoveryregister.go index f37fc9c10..1debc54e1 100644 --- a/pkg/common/discoveryregister/discoveryregister.go +++ b/pkg/common/discoveryregister/discoveryregister.go @@ -18,7 +18,7 @@ import ( "github.com/openimsdk/open-im-server/v3/pkg/common/config" "github.com/openimsdk/open-im-server/v3/pkg/common/discoveryregister/kubernetes" "github.com/openimsdk/tools/discovery" - getcd "github.com/openimsdk/tools/discovery/etcd" + "github.com/openimsdk/tools/discovery/etcd" "github.com/openimsdk/tools/discovery/zookeeper" "github.com/openimsdk/tools/errs" "time" @@ -39,12 +39,12 @@ func NewDiscoveryRegister(discovery *config.Discovery, share *config.Share) (dis case "k8s": return kubernetes.NewK8sDiscoveryRegister(share.RpcRegisterName.MessageGateway) case "etcd": - return getcd.NewSvcDiscoveryRegistry( + return etcd.NewSvcDiscoveryRegistry( discovery.Etcd.RootDirectory, discovery.Etcd.Address, - getcd.WithDialTimeout(10*time.Second), - getcd.WithMaxCallSendMsgSize(20*1024*1024), - getcd.WithUsernameAndPassword(discovery.Etcd.Username, discovery.Etcd.Password)) + etcd.WithDialTimeout(10*time.Second), + etcd.WithMaxCallSendMsgSize(20*1024*1024), + etcd.WithUsernameAndPassword(discovery.Etcd.Username, discovery.Etcd.Password)) case "direct": //return direct.NewConnDirect(config) default: