From 3d81042da78a631ef49edaa04c39588c0fe5909a Mon Sep 17 00:00:00 2001 From: AndrewZuo01 Date: Tue, 16 Jan 2024 15:10:31 +0800 Subject: [PATCH] feat: multiple addresses --- pkg/common/discoveryregister/direct/directconn.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/pkg/common/discoveryregister/direct/directconn.go b/pkg/common/discoveryregister/direct/directconn.go index 9a83acd8c..0d8a7c2ff 100644 --- a/pkg/common/discoveryregister/direct/directconn.go +++ b/pkg/common/discoveryregister/direct/directconn.go @@ -99,14 +99,6 @@ func (cm *ConnManager) GetConns(ctx context.Context, } func (cm *ConnManager) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error) { - // Check if there are existing connections for the service - if conns, exists := cm.conns[serviceName]; exists && len(conns) > 0 { - log.ZDebug(ctx, "getConn", "len(conns)", len(conns)) - // Return a random connection from the existing connections - randomIndex := rand.Intn(len(conns)) - return conns[randomIndex], nil - } - // Get service addresses addresses := getServiceAddresses() address, ok := addresses[serviceName]