config_client

package
v1.2.4 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2023 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigChangeNotifyRequestHandler

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

func (*ConfigChangeNotifyRequestHandler) Name

func (*ConfigChangeNotifyRequestHandler) RequestReply

type ConfigClient

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

func NewConfigClient

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

func (*ConfigClient) CancelListenConfig

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

Cancel Listen Config

func (*ConfigClient) CloseClient

func (client *ConfigClient) CloseClient()

func (*ConfigClient) DeleteConfig

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

func (*ConfigClient) GetConfig

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

func (*ConfigClient) ListenConfig

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

func (*ConfigClient) PublishConfig

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

func (*ConfigClient) SearchConfig

func (client *ConfigClient) SearchConfig(param vo2.SearchConfigParm) (*model2.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 vo2.ConfigParam) (string, error)

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

	// DeleteConfig use to delete config
	// dataId  require
	// group   require
	// tenant ==>nacos.namespace optional
	DeleteConfig(param vo2.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 vo2.ConfigParam) (err error)

	//CancelListenConfig use to cancel listen config change
	// dataId  require
	// group   require
	// tenant ==>nacos.namespace optional
	CancelListenConfig(params vo2.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 vo2.SearchConfigParm) (*model2.ConfigPage, error)

	// CloseClient Close the GRPC client
	CloseClient()
}

type IConfigProxy

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

func NewConfigProxy

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

Jump to

Keyboard shortcuts

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