in plugin/registry/nacos/nacos.go [76:104]
func (r *Registry) Start() error {
var p vo.NacosClientParam
var addresses []string
if len(r.cfg.AddressList) > 0 {
addresses = strings.Split(r.cfg.AddressList, ",")
}
for _, address := range addresses {
ip, port, err := net.SplitHostPort(address)
if err != nil {
return err
}
p.ServerConfigs = append(p.ServerConfigs, constant.ServerConfig{IpAddr: ip, Port: gconv.Uint64(port)})
}
p.ClientConfig = &constant.ClientConfig{
TimeoutMs: uint64(defaultConnectTimeout.Milliseconds()),
CacheDir: r.cfg.CacheDir,
}
cli, err := clients.NewNamingClient(p)
if err != nil {
return err
}
r.startStatus.Store(true)
r.client = cli
return nil
}