config

Documentation

Index

• Variables
• func Close() error
• func Exist(ctx context.Context, key string) (bool, error)
• func InitDefaultClient(ctx context.Context, config *Config) error
• func NewConfigCenterPlugin(_ context.Context) application.Plugin
• func RegistryImplementation(typeName string, fn RegistryImplementationFunc)
• func Set(ctx context.Context, key, value string) error
• func Trans2EtcdConfig(ctx context.Context, config *Config) clientv3.Config
• func Trans2NacosConfig(_ context.Context, config *Config) (clientConfig *constant.ClientConfig, serverConfigs []constant.ServerConfig, ...)
• func Watch(ctx context.Context, item *Item, callback func(item *Item)) error
• type Client
  • func GetClientImplementation(ctx context.Context, typeName string) (Client, error)
• type Config
• type EtcdConfigClient
  • func (s *EtcdConfigClient) Close() error
  • func (s *EtcdConfigClient) Exist(ctx context.Context, key string) (bool, error)
  • func (s *EtcdConfigClient) Get(ctx context.Context, key string) (*Item, error)
  • func (s *EtcdConfigClient) Init(ctx context.Context, conf *Config) error
  • func (s *EtcdConfigClient) Set(ctx context.Context, key, value string) error
  • func (s *EtcdConfigClient) Watch(ctx context.Context, item *Item, callback func(item *Item)) error
• type Item
  • func Get(ctx context.Context, key string) (*Item, error)
  • func NewItem(namespace, key, value string) *Item
  • func (i *Item) GetValue() string
  • func (i *Item) SetValue(value string)
• type NacosConfigClient
  • func (s *NacosConfigClient) Close() error
  • func (s *NacosConfigClient) Exist(ctx context.Context, key string) (bool, error)
  • func (s *NacosConfigClient) Get(ctx context.Context, key string) (*Item, error)
  • func (s *NacosConfigClient) Init(ctx context.Context, conf *Config) error
  • func (s *NacosConfigClient) Set(_ context.Context, key, value string) error
  • func (s *NacosConfigClient) Watch(ctx context.Context, item *Item, callback func(item *Item)) error
• type Plugin
  • func (p *Plugin) Config(_ context.Context, conf []byte) error
  • func (p *Plugin) Init(ctx context.Context) error
  • func (p *Plugin) Run(ctx context.Context) error
• type RegistryImplementationFunc

Variables

var (
	EtcdDefaultDailTimeout          = time.Second
	EtcdDefaultDialKeepAliveTime    = 3 * time.Second
	EtcdDefaultDialKeepAliveTimeout = 3 * time.Second
)

var RegistryImplementationTypeNameEtcd = "etcd"

var RegistryImplementationTypeNameNacos = "nacos"

Functions

func Close

func Close() error

func Exist

func Exist(ctx context.Context, key string) (bool, error)

func InitDefaultClient

func InitDefaultClient(ctx context.Context, config *Config) error

func NewConfigCenterPlugin

func NewConfigCenterPlugin(_ context.Context) application.Plugin

NewConfigCenterPlugin 配置中心组件

func RegistryImplementation

func RegistryImplementation(typeName string, fn RegistryImplementationFunc)

func Set

func Set(ctx context.Context, key, value string) error

func Trans2EtcdConfig

func Trans2EtcdConfig(ctx context.Context, config *Config) clientv3.Config

func Trans2NacosConfig

func Trans2NacosConfig(_ context.Context, config *Config) (clientConfig *constant.ClientConfig, serverConfigs []constant.ServerConfig, err error)

func Watch

func Watch(ctx context.Context, item *Item, callback func(item *Item)) error

Types

type Client

type Client interface {
	Close() error
	Init(ctx context.Context, config *Config) error
	Set(ctx context.Context, key, value string) error
	Get(ctx context.Context, key string) (*Item, error)
	Watch(ctx context.Context, item *Item, callback func(item *Item)) error
	Exist(ctx context.Context, key string) (bool, error)
}

func GetClientImplementation

func GetClientImplementation(ctx context.Context, typeName string) (Client, error)

GetClientImplementation get client implementation by typeName

type Config

type Config struct {
	Type      string `yaml:"type" json:"type"`
	Endpoints string `yaml:"endpoints" json:"endpoints"`
	Namespace string `yaml:"namespace" json:"namespace"`

	Username string `yaml:"username" json:"userName"`
	Password string `yaml:"password" json:"password"`

	Settings map[string]string `yaml:"settings" json:"settings"`
}

type EtcdConfigClient

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

func (*EtcdConfigClient) Close

func (s *EtcdConfigClient) Close() error

func (*EtcdConfigClient) Exist

func (s *EtcdConfigClient) Exist(ctx context.Context, key string) (bool, error)

func (*EtcdConfigClient) Get

func (s *EtcdConfigClient) Get(ctx context.Context, key string) (*Item, error)

func (*EtcdConfigClient) Init

func (s *EtcdConfigClient) Init(ctx context.Context, conf *Config) error

func (*EtcdConfigClient) Set

func (s *EtcdConfigClient) Set(ctx context.Context, key, value string) error

func (*EtcdConfigClient) Watch

func (s *EtcdConfigClient) Watch(ctx context.Context, item *Item, callback func(item *Item)) error

type Item

type Item struct {
	Namespace string `json:"namespace"`
	Key       string `json:"key"`

	*sync.RWMutex `json:"-"`
	// contains filtered or unexported fields
}

func Get

func Get(ctx context.Context, key string) (*Item, error)

func NewItem

func NewItem(namespace, key, value string) *Item

func (*Item) GetValue

func (i *Item) GetValue() string

func (*Item) SetValue

func (i *Item) SetValue(value string)

type NacosConfigClient

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

func (*NacosConfigClient) Close

func (s *NacosConfigClient) Close() error

func (*NacosConfigClient) Exist

func (s *NacosConfigClient) Exist(ctx context.Context, key string) (bool, error)

func (*NacosConfigClient) Get

func (s *NacosConfigClient) Get(ctx context.Context, key string) (*Item, error)

func (*NacosConfigClient) Init

func (s *NacosConfigClient) Init(ctx context.Context, conf *Config) error

func (*NacosConfigClient) Set

func (s *NacosConfigClient) Set(_ context.Context, key, value string) error

func (*NacosConfigClient) Watch

func (s *NacosConfigClient) Watch(ctx context.Context, item *Item, callback func(item *Item)) error

type Plugin

type Plugin struct {
	application.Plugin
	// contains filtered or unexported fields
}

func (*Plugin) Config

func (p *Plugin) Config(_ context.Context, conf []byte) error

func (*Plugin) Init

func (p *Plugin) Init(ctx context.Context) error

func (*Plugin) Run

func (p *Plugin) Run(ctx context.Context) error

type RegistryImplementationFunc

type RegistryImplementationFunc func(ctx context.Context) Client