|
|
@ -38,7 +38,7 @@ func NewDiscoveryRegister(discovery *config.Discovery, share *config.Share) (dis
|
|
|
|
zookeeper.WithTimeout(10),
|
|
|
|
zookeeper.WithTimeout(10),
|
|
|
|
)
|
|
|
|
)
|
|
|
|
case "kubernetes":
|
|
|
|
case "kubernetes":
|
|
|
|
return kubernetes.NewK8sConnManager("default")
|
|
|
|
return kubernetes.NewKubernetesConnManager("default")
|
|
|
|
case "etcd":
|
|
|
|
case "etcd":
|
|
|
|
return etcd.NewSvcDiscoveryRegistry(
|
|
|
|
return etcd.NewSvcDiscoveryRegistry(
|
|
|
|
discovery.Etcd.RootDirectory,
|
|
|
|
discovery.Etcd.RootDirectory,
|
|
|
|