config_client

package
v2.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsLimited

func IsLimited(checkKey string) bool

IsLimited return true when request is limited

Types

type ConfigChangeNotifyRequestHandler

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

func (*ConfigChangeNotifyRequestHandler) Name

func (*ConfigChangeNotifyRequestHandler) RequestReply

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.SearchConfigParam) (*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.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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL