etcd

Documentation

Index

• func NewEtcd(conf *Config) (*clientv3.Client, error)
• func NewEtcdByOption(opts ...Option) (*clientv3.Client, error)
• type Config
• type Option
  • func WithDialTimeout(d time.Duration) Option
  • func WithEndpoints(addr []string) Option
• type Watcher
  • func NewWatcher(ctx context.Context, key string, client *clientv3.Client) (*Watcher, error)
  • func (w *Watcher) Run(ctx context.Context, f func(key string, val []byte), g func(key string)) <-chan error
  • func (w *Watcher) Start(ctx context.Context) ([]*mvccpb.KeyValue, error)
  • func (w *Watcher) Stop() error

Functions

func NewEtcd

func NewEtcd(conf *Config) (*clientv3.Client, error)

func NewEtcdByOption

func NewEtcdByOption(opts ...Option) (*clientv3.Client, error)

Types

type Config

type Config struct {
	Addr []string `yaml:"addr"`
	TTL  int      `yaml:"ttl"`
}

type Option

type Option func(*clientv3.Config)

func WithDialTimeout

func WithDialTimeout(d time.Duration) Option

func WithEndpoints

func WithEndpoints(addr []string) Option

type Watcher

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

func NewWatcher

func NewWatcher(ctx context.Context, key string, client *clientv3.Client) (*Watcher, error)

func (*Watcher) Run

func (w *Watcher) Run(ctx context.Context, f func(key string, val []byte), g func(key string)) <-chan error

Run f func put g func delete

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context) ([]*mvccpb.KeyValue, error)

func (*Watcher) Stop

func (w *Watcher) Stop() error