From 2f572cbc8149ae5b9ebb29809553ffca4c3ff0fb Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Sat, 11 May 2024 12:03:29 +0800 Subject: [PATCH] add etcd --- config/discovery.yml | 16 ++++++++++++++++ .../discoveryregister/discoveryregister.go | 2 +- 2 files changed, 17 insertions(+), 1 deletion(-) create mode 100644 config/discovery.yml diff --git a/config/discovery.yml b/config/discovery.yml new file mode 100644 index 000000000..6e0922ede --- /dev/null +++ b/config/discovery.yml @@ -0,0 +1,16 @@ + +enable: "etcd" +etcd: + schema: openim + address: [ http://localhost:2379 ] + username: '' + password: '' + + +zookeeper: + schema: openim + address: [ localhost:12181 ] + username: '' + password: '' + + diff --git a/pkg/common/discoveryregister/discoveryregister.go b/pkg/common/discoveryregister/discoveryregister.go index c2deb6cf2..dbf16eda0 100644 --- a/pkg/common/discoveryregister/discoveryregister.go +++ b/pkg/common/discoveryregister/discoveryregister.go @@ -46,7 +46,7 @@ func NewDiscoveryRegister(zookeeperConfig *config.ZooKeeper, share *config.Share case kubenetesConst: return kubernetes.NewK8sDiscoveryRegister(share.RpcRegisterName.MessageGateway) case etcdConst: - return getcd.NewSvcDiscoveryRegistry("etcd", []string{"http://localhost:2379"}) + return getcd.NewSvcDiscoveryRegistry("etcd", []string{"localhost:2379"}) case directConst: //return direct.NewConnDirect(config) default: