From d11ea115520d35124c8c2cbe7c7238ec47c8d4c5 Mon Sep 17 00:00:00 2001 From: dsx137 <70027572+dsx137@users.noreply.github.com> Date: Tue, 21 Jul 2026 15:06:28 +0800 Subject: [PATCH] refactor(core): select discovery backend from configured type --- .gitignore | 5 ++++- pkg/common/discoveryregister/discoveryregister.go | 13 ++++++------- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/.gitignore b/.gitignore index 77cf855b7..1b5cf874d 100644 --- a/.gitignore +++ b/.gitignore @@ -387,4 +387,7 @@ Sessionx.vim # End of https://www.toptal.com/developers/gitignore/api/go,git,vim,tags,test,emacs,backup,jetbrains .idea -dist/ \ No newline at end of file +dist/ + +.omo +.sisyphus \ No newline at end of file diff --git a/pkg/common/discoveryregister/discoveryregister.go b/pkg/common/discoveryregister/discoveryregister.go index 8c0850c54..5cacb53a3 100644 --- a/pkg/common/discoveryregister/discoveryregister.go +++ b/pkg/common/discoveryregister/discoveryregister.go @@ -15,6 +15,7 @@ package discoveryregister import ( + "strings" "time" "google.golang.org/grpc" @@ -39,16 +40,14 @@ func NewDiscoveryRegister(discovery *config.Discovery, watchNames []string) (dis } switch discoveryType { case config.KUBERNETES: - namespace := discovery.Kubernetes.Namespace - if namespace == "" { - namespace = "default" + for i := range watchNames { + watchNames[i] = strings.Split(watchNames[i], ":")[0] } - return kubernetes.NewConnManager( - namespace, - watchNames, + return kubernetes.NewConnManager(discovery.Kubernetes.Namespace, watchNames, grpc.WithDefaultCallOptions( - grpc.MaxCallSendMsgSize(20*1024*1024), + grpc.MaxCallSendMsgSize(1024*1024*20), ), + grpc.WithDefaultServiceConfig(`{"loadBalancingPolicy":"round_robin"}`), ) case config.ETCD: return etcd.NewSvcDiscoveryRegistry(