Documentation
¶
Index ¶
- func IsLimited(checkKey string) bool
- type ConfigChangeNotifyRequestHandler
- type ConfigClient
- 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.SearchConfigParam) (*model.ConfigPage, error)
- type ConfigConnectionEventListener
- type ConfigProxy
- type IConfigClient
- type IConfigProxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConfigChangeNotifyRequestHandler ¶
type ConfigChangeNotifyRequestHandler struct {
// contains filtered or unexported fields
}
func (*ConfigChangeNotifyRequestHandler) Name ¶ added in v2.0.2
func (c *ConfigChangeNotifyRequestHandler) Name() string
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 NewConfigClientWithRamCredentialProvider ¶ added in v2.3.0
func NewConfigClientWithRamCredentialProvider(nc nacos_client.INacosClient, provider security.RamCredentialProvider) (*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.SearchConfigParam) (*model.ConfigPage, error)
type ConfigConnectionEventListener ¶ added in v2.3.0
type ConfigConnectionEventListener struct {
// contains filtered or unexported fields
}
func NewConfigConnectionEventListener ¶ added in v2.3.0
func NewConfigConnectionEventListener(client *ConfigClient, taskId string) *ConfigConnectionEventListener
func (*ConfigConnectionEventListener) OnConnected ¶ added in v2.3.0
func (c *ConfigConnectionEventListener) OnConnected()
func (*ConfigConnectionEventListener) OnDisConnect ¶ added in v2.3.0
func (c *ConfigConnectionEventListener) OnDisConnect()
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.SearchConfigParam) (*model.ConfigPage, error)
// CloseClient Close the GRPC client
CloseClient()
}
type IConfigProxy ¶
type IConfigProxy interface {
// contains filtered or unexported methods
}
func NewConfigProxy ¶
func NewConfigProxy(ctx context.Context, serverConfig []constant.ServerConfig, clientConfig constant.ClientConfig, httpAgent http_agent.IHttpAgent) (IConfigProxy, error)
func NewConfigProxyWithRamCredentialProvider ¶ added in v2.3.0
func NewConfigProxyWithRamCredentialProvider(ctx context.Context, serverConfig []constant.ServerConfig, clientConfig constant.ClientConfig, httpAgent http_agent.IHttpAgent, provider security.RamCredentialProvider) (IConfigProxy, error)
Click to show internal directories.
Click to hide internal directories.