Versions in this module Expand all Collapse all v2 v2.1.1 Oct 12, 2022 Changes in this version + func NewNamingProxyDelegate(ctx context.Context, clientCfg constant.ClientConfig, ...) (naming_proxy.INamingProxy, error) + type Chooser struct + type INamingClient interface + CloseClient func() + DeregisterInstance func(param vo.DeregisterInstanceParam) (bool, error) + GetAllServicesInfo func(param vo.GetAllServiceInfoParam) (model.ServiceList, error) + GetService func(param vo.GetServiceParam) (model.Service, error) + RegisterInstance func(param vo.RegisterInstanceParam) (bool, error) + SelectAllInstances func(param vo.SelectAllInstancesParam) ([]model.Instance, error) + SelectInstances func(param vo.SelectInstancesParam) ([]model.Instance, error) + SelectOneHealthyInstance func(param vo.SelectOneHealthInstanceParam) (*model.Instance, error) + Subscribe func(param *vo.SubscribeParam) error + Unsubscribe func(param *vo.SubscribeParam) error + UpdateInstance func(param vo.UpdateInstanceParam) (bool, error) + type NamingClient struct + func NewNamingClient(nc nacos_client.INacosClient) (*NamingClient, error) + func (sc *NamingClient) CloseClient() + func (sc *NamingClient) DeregisterInstance(param vo.DeregisterInstanceParam) (bool, error) + func (sc *NamingClient) GetAllServicesInfo(param vo.GetAllServiceInfoParam) (model.ServiceList, error) + func (sc *NamingClient) GetService(param vo.GetServiceParam) (service model.Service, err error) + func (sc *NamingClient) RegisterInstance(param vo.RegisterInstanceParam) (bool, error) + func (sc *NamingClient) SelectAllInstances(param vo.SelectAllInstancesParam) ([]model.Instance, error) + func (sc *NamingClient) SelectInstances(param vo.SelectInstancesParam) ([]model.Instance, error) + func (sc *NamingClient) SelectOneHealthyInstance(param vo.SelectOneHealthInstanceParam) (*model.Instance, error) + func (sc *NamingClient) Subscribe(param *vo.SubscribeParam) error + func (sc *NamingClient) Unsubscribe(param *vo.SubscribeParam) (err error) + func (sc *NamingClient) UpdateInstance(param vo.UpdateInstanceParam) (bool, error) + type NamingProxyDelegate struct + func (proxy *NamingProxyDelegate) CloseClient() + func (proxy *NamingProxyDelegate) DeregisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error) + func (proxy *NamingProxyDelegate) GetServiceList(pageNo uint32, pageSize uint32, groupName, namespaceId string, ...) (model.ServiceList, error) + func (proxy *NamingProxyDelegate) QueryInstancesOfService(serviceName, groupName, clusters string, udpPort int, healthyOnly bool) (*model.Service, error) + func (proxy *NamingProxyDelegate) RegisterInstance(serviceName string, groupName string, instance model.Instance) (bool, error) + func (proxy *NamingProxyDelegate) ServerHealthy() bool + func (proxy *NamingProxyDelegate) Subscribe(serviceName, groupName string, clusters string) (model.Service, error) + func (proxy *NamingProxyDelegate) Unsubscribe(serviceName, groupName, clusters string) error + type ServiceInfoUpdater struct + func NewServiceInfoUpdater(ctx context.Context, serviceInfoHolder *naming_cache.ServiceInfoHolder, ...) *ServiceInfoUpdater
Go to main page