etcd

Documentation

Index

• Constants
• func NewSource(opts ...Option) config.Source
• type Option
  • func WithAddrs(addrs ...string) Option
  • func WithClient(client *clientv3.Client) Option
  • func WithDialTimeout(dialTimeout time.Duration) Option
  • func WithMode(mode config.Mode) Option
  • func WithPath(path string) Option
• type Source
  • func (s *Source) Close() error
  • func (s *Source) Load(ctx context.Context, file ...string) ([]*config.Configuration, error)
  • func (s *Source) Name() string
  • func (s *Source) Store(ctx context.Context, file string, content []byte) error
  • func (s *Source) Watch(ctx context.Context) (config.Watcher, error)

Constants

const Name = "etcd"

Functions

func NewSource

func NewSource(opts ...Option) config.Source

Types

type Option

type Option func(o *options)

func WithAddrs

func WithAddrs(addrs ...string) Option

WithAddrs 设置客户端连接地址

func WithClient

func WithClient(client *clientv3.Client) Option

WithClient 设置外部客户端

func WithDialTimeout

func WithDialTimeout(dialTimeout time.Duration) Option

WithDialTimeout 设置客户端拨号超时时间

func WithMode

func WithMode(mode config.Mode) Option

WithMode 设置读写模式

func WithPath

func WithPath(path string) Option

WithPath 设置命名空间

type Source

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

func (*Source) Close

func (s *Source) Close() error

Close 关闭资源

func (*Source) Load

func (s *Source) Load(ctx context.Context, file ...string) ([]*config.Configuration, error)

Load 加载配置项

func (*Source) Name

func (s *Source) Name() string

Name 配置源名称

func (*Source) Store

func (s *Source) Store(ctx context.Context, file string, content []byte) error

Store 保存配置项

func (*Source) Watch

func (s *Source) Watch(ctx context.Context) (config.Watcher, error)

Watch 监听配置项