nacos

Documentation

Index

• func ListenConfigCallback(namespace, group, dataId, data string)
• type NacosClient
  • func InitNacosClient(config *config.CKManNacosConfig, log string) (*NacosClient, error)
  • func (c *NacosClient) DeregisterInstance(ip string, port int) (bool, error)
  • func (c *NacosClient) GetAllInstances() ([]model.Instance, error)
  • func (c *NacosClient) GetConfig() (string, error)
  • func (c *NacosClient) ListenConfig() error
  • func (c *NacosClient) PublishConfig(content string) error
  • func (c *NacosClient) RegisterInstance(ip string, port int, metadata map[string]string) (bool, error)
  • func (c *NacosClient) Start(ipHttp string, portHttp int) error
  • func (c *NacosClient) Stop(ip string, port int) error
  • func (c *NacosClient) Subscribe() error
  • func (c *NacosClient) SubscribeCallback(services []model.SubscribeService, err error)
  • func (c *NacosClient) Unsubscribe() error

Functions

func ListenConfigCallback

func ListenConfigCallback(namespace, group, dataId, data string)

Types

type NacosClient

type NacosClient struct {
	Enabled     bool
	ServiceName string
	GroupName   string
	DataId      string
	Naming      naming_client.INamingClient
	Config      config_client.IConfigClient
}

func InitNacosClient

func InitNacosClient(config *config.CKManNacosConfig, log string) (*NacosClient, error)

func (*NacosClient) DeregisterInstance

func (c *NacosClient) DeregisterInstance(ip string, port int) (bool, error)

func (*NacosClient) GetAllInstances

func (c *NacosClient) GetAllInstances() ([]model.Instance, error)

func (*NacosClient) GetConfig

func (c *NacosClient) GetConfig() (string, error)

func (*NacosClient) ListenConfig

func (c *NacosClient) ListenConfig() error

func (*NacosClient) PublishConfig

func (c *NacosClient) PublishConfig(content string) error

func (*NacosClient) RegisterInstance

func (c *NacosClient) RegisterInstance(ip string, port int, metadata map[string]string) (bool, error)

func (*NacosClient) Start

func (c *NacosClient) Start(ipHttp string, portHttp int) error

func (*NacosClient) Stop

func (c *NacosClient) Stop(ip string, port int) error

func (*NacosClient) Subscribe

func (c *NacosClient) Subscribe() error

func (*NacosClient) SubscribeCallback

func (c *NacosClient) SubscribeCallback(services []model.SubscribeService, err error)

func (*NacosClient) Unsubscribe

func (c *NacosClient) Unsubscribe() error