config_client

Documentation

Index

• type ConfigClient
  • func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error)
  • func (client *ConfigClient) CancelListenConfig(param vo.ConfigParam) (err error)
  • func (client *ConfigClient) DeleteConfig(param vo.ConfigParam) (deleted bool, err error)
  • func (client *ConfigClient) GetConfig(param vo.ConfigParam) (content string, err error)
  • func (client *ConfigClient) ListenConfig(param vo.ConfigParam) (err error)
  • func (client *ConfigClient) PublishAggr(param vo.ConfigParam) (published bool, err error)
  • func (client *ConfigClient) PublishConfig(param vo.ConfigParam) (published bool, err error)
  • func (client *ConfigClient) RemoveAggr(param vo.ConfigParam) (published bool, err error)
  • func (client *ConfigClient) SearchConfig(param vo.SearchConfigParam) (*model.ConfigPage, error)
• type ConfigProxy
  • func NewConfigProxy(serverConfig []constant.ServerConfig, clientConfig constant.ClientConfig, ...) (ConfigProxy, error)
  • func (cp *ConfigProxy) DeleteAggProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)
  • func (cp *ConfigProxy) DeleteConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)
  • func (cp *ConfigProxy) GetConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (string, error)
  • func (cp *ConfigProxy) GetServerList() []constant.ServerConfig
  • func (cp *ConfigProxy) ListenConfig(params map[string]string, isInitializing bool, ...) (string, error)
  • func (cp *ConfigProxy) PublishAggProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)
  • func (cp *ConfigProxy) PublishConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)
  • func (cp *ConfigProxy) SearchConfigProxy(param vo.SearchConfigParam, tenant, accessKey, secretKey string) (*model.ConfigPage, error)
• type IConfigClient

Types

type ConfigClient

type ConfigClient struct {
	nacos_client.INacosClient
	// contains filtered or unexported fields
}

func NewConfigClient

func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error)

func (*ConfigClient) CancelListenConfig

func (client *ConfigClient) CancelListenConfig(param vo.ConfigParam) (err error)

Cancel Listen Config

func (*ConfigClient) DeleteConfig

func (client *ConfigClient) DeleteConfig(param vo.ConfigParam) (deleted bool, err error)

func (*ConfigClient) GetConfig

func (client *ConfigClient) GetConfig(param vo.ConfigParam) (content string, err error)

func (*ConfigClient) ListenConfig

func (client *ConfigClient) ListenConfig(param vo.ConfigParam) (err error)

func (*ConfigClient) PublishAggr

func (client *ConfigClient) PublishAggr(param vo.ConfigParam) (published bool,
	err error)

func (*ConfigClient) PublishConfig

func (client *ConfigClient) PublishConfig(param vo.ConfigParam) (published bool,
	err error)

func (*ConfigClient) RemoveAggr

func (client *ConfigClient) RemoveAggr(param vo.ConfigParam) (published bool,
	err error)

func (*ConfigClient) SearchConfig

func (client *ConfigClient) SearchConfig(param vo.SearchConfigParam) (*model.ConfigPage, error)

type ConfigProxy

type ConfigProxy struct {
	// contains filtered or unexported fields
}

func NewConfigProxy

func NewConfigProxy(serverConfig []constant.ServerConfig, clientConfig constant.ClientConfig, httpAgent http_agent.IHttpAgent) (ConfigProxy, error)

func (*ConfigProxy) DeleteAggProxy

func (cp *ConfigProxy) DeleteAggProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)

func (*ConfigProxy) DeleteConfigProxy

func (cp *ConfigProxy) DeleteConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)

func (*ConfigProxy) GetConfigProxy

func (cp *ConfigProxy) GetConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (string, error)

func (*ConfigProxy) GetServerList

func (cp *ConfigProxy) GetServerList() []constant.ServerConfig

func (*ConfigProxy) ListenConfig

func (cp *ConfigProxy) ListenConfig(params map[string]string, isInitializing bool, tenant, accessKey, secretKey string) (string, error)

func (*ConfigProxy) PublishAggProxy

func (cp *ConfigProxy) PublishAggProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)

func (*ConfigProxy) PublishConfigProxy

func (cp *ConfigProxy) PublishConfigProxy(param vo.ConfigParam, tenant, accessKey, secretKey string) (bool, error)

func (*ConfigProxy) SearchConfigProxy

func (cp *ConfigProxy) SearchConfigProxy(param vo.SearchConfigParam, tenant, accessKey, secretKey string) (*model.ConfigPage, error)

type IConfigClient

type IConfigClient interface {
	// GetConfig use to get config from nacos server
	// dataId  require
	// group   require
	// tenant ==>nacos.namespace optional
	GetConfig(param vo.ConfigParam) (string, error)

	// PublishConfig use to publish config to nacos server
	// dataId  require
	// group   require
	// content require
	// tenant ==>nacos.namespace optional
	PublishConfig(param vo.ConfigParam) (bool, error)

	// DeleteConfig use to delete config
	// dataId  require
	// group   require
	// tenant ==>nacos.namespace optional
	DeleteConfig(param vo.ConfigParam) (bool, error)

	// ListenConfig use to listen config change,it will callback OnChange() when config change
	// dataId  require
	// group   require
	// onchange require
	// tenant ==>nacos.namespace optional
	ListenConfig(params vo.ConfigParam) (err error)

	//CancelListenConfig use to cancel listen config change
	// dataId  require
	// group   require
	// tenant ==>nacos.namespace optional
	CancelListenConfig(params vo.ConfigParam) (err error)

	// SearchConfig use to search nacos config
	// search  require search=accurate--精确搜索  search=blur--模糊搜索
	// group   option
	// dataId  option
	// tenant ==>nacos.namespace optional
	// pageNo  option,default is 1
	// pageSize option,default is 10
	SearchConfig(param vo.SearchConfigParam) (*model.ConfigPage, error)

	PublishAggr(param vo.ConfigParam) (published bool, err error)
}