commit 0a8b1c8b11ca320a48e92a0697312b1d200932d2
author Joe Zou <joezou@apache.org> Sun Nov 01 00:52:31 2020 +0800
committer Joe Zou <yixian.zou@gmail.com> Sun Nov 01 00:53:28 2020 +0800
tree 77999e27bd59e8abb8aa7e9f88ece098e027b72a
parent 8dc2e84be51623b910e7de642d9f6ee2bb71d5b8

Merge pull request #828 from watermelo/fix_etcd_reconnet

Fix: etcd cluster reconnect

remoting/etcdv3/facade.go

diff --git a/remoting/etcdv3/facade.go b/remoting/etcdv3/facade.go
index 52b1cce..614ba9a 100644
--- a/remoting/etcdv3/facade.go
+++ b/remoting/etcdv3/facade.go
@@ -63,7 +63,7 @@
 			r.ClientLock().Lock()
 			clientName := RegistryETCDV3Client
 			timeout, _ := time.ParseDuration(r.GetUrl().GetParam(constant.REGISTRY_TIMEOUT_KEY, constant.DEFAULT_REG_TIMEOUT))
-			endpoint := r.GetUrl().Location
+			endpoints := r.Client().endpoints
 			r.Client().Close()
 			r.SetClient(nil)
 			r.ClientLock().Unlock()
@@ -80,11 +80,11 @@
 				err = ValidateClient(
 					r,
 					WithName(clientName),
-					WithEndpoints(endpoint),
+					WithEndpoints(endpoints...),
 					WithTimeout(timeout),
 				)
 				logger.Infof("ETCDV3ProviderRegistry.validateETCDV3Client(etcd Addr{%s}) = error{%#v}",
-					endpoint, perrors.WithStack(err))
+					endpoints, perrors.WithStack(err))
 				if err == nil && r.RestartCallBack() {
 					break
 				}