From 2c9caf0845f1fcab0959ffabce9853bb5aa40429 Mon Sep 17 00:00:00 2001 From: AndrewZuo01 Date: Tue, 16 Jan 2024 15:42:17 +0800 Subject: [PATCH] feat: multiple addresses --- pkg/common/discoveryregister/direct/directconn.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/common/discoveryregister/direct/directconn.go b/pkg/common/discoveryregister/direct/directconn.go index 0d8a7c2ff..8e6497ac2 100644 --- a/pkg/common/discoveryregister/direct/directconn.go +++ b/pkg/common/discoveryregister/direct/directconn.go @@ -153,7 +153,7 @@ func checkServiceHealth(address string) bool { const ( slashSeparator = "/" - // EndpointSepChar is the separator cha in endpoints. + // EndpointSepChar is the separator char in endpoints. EndpointSepChar = ',' subsetSize = 32 @@ -188,12 +188,14 @@ func (n nopResolver) Close() { func (cm *ConnManager) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) ( resolver.Resolver, error) { + endpoints := strings.FieldsFunc(GetEndpoints(target), func(r rune) bool { return r == EndpointSepChar }) + log.ZDebug(context.Background(), "Build", "endpoints", endpoints) endpoints = subset(endpoints, subsetSize) addrs := make([]resolver.Address, 0, len(endpoints)) - + log.ZDebug(context.Background(), "Build", "addrs", addrs) for _, val := range endpoints { addrs = append(addrs, resolver.Address{ Addr: val,