config_client

Documentation

Index

• type ConfigChangeNotifyRequestHandler
  • func (c *ConfigChangeNotifyRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *rpc.RpcClient) rpc_response.IResponse
• type ConfigClient
  • func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error)
  • func (client *ConfigClient) CancelListenConfig(param vo.ConfigParam) (err error)
  • func (client *ConfigClient) CloseClient()
  • 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) PublishConfig(param vo.ConfigParam) (published bool, err error)
  • func (client *ConfigClient) SearchConfig(param vo.SearchConfigParm) (*model.ConfigPage, error)
• type ConfigProxy
• type IConfigClient
• type IConfigProxy
  • func NewConfigProxy(serverConfig []constant.ServerConfig, clientConfig constant.ClientConfig, ...) (IConfigProxy, error)

Types

type ConfigChangeNotifyRequestHandler

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

func (*ConfigChangeNotifyRequestHandler) RequestReply

func (c *ConfigChangeNotifyRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *rpc.RpcClient) rpc_response.IResponse

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) CloseClient

func (client *ConfigClient) CloseClient()

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) PublishConfig

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

func (*ConfigClient) SearchConfig

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

type ConfigProxy

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

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.SearchConfigParm) (*model.ConfigPage, error)

	// CloseClient Close the GRPC client
	CloseClient()
}

type IConfigProxy

type IConfigProxy interface {
	// contains filtered or unexported methods
}

func NewConfigProxy

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