From 597ed734cf591c8643c53c482c84d09392725d21 Mon Sep 17 00:00:00 2001 From: dsx137 <70027572+dsx137@users.noreply.github.com> Date: Tue, 21 Jul 2026 15:07:12 +0800 Subject: [PATCH] refactor(core): select discovery backend from configured type --- pkg/common/discovery/discoveryregister.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/common/discovery/discoveryregister.go b/pkg/common/discovery/discoveryregister.go index f7b89dc91..551f41c73 100644 --- a/pkg/common/discovery/discoveryregister.go +++ b/pkg/common/discovery/discoveryregister.go @@ -46,10 +46,14 @@ func NewDiscoveryRegister(discovery *config.Discovery, watchNames []string) (dis } switch discoveryType { case config.KUBERNETES: + for i := range watchNames { + watchNames[i] = strings.Split(watchNames[i], ":")[0] + } return kubernetes.NewConnManager(discovery.Kubernetes.Namespace, watchNames, grpc.WithDefaultCallOptions( grpc.MaxCallSendMsgSize(1024*1024*20), ), + grpc.WithDefaultServiceConfig(`{"loadBalancingPolicy":"round_robin"}`), ) case config.ETCD: return etcd.NewSvcDiscoveryRegistry(