func()

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
}