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(