etcd

Documentation

Index

• type Config
• type KV
  • func NewKV(cfg Config, logger kitlog.Logger) *KV
  • func (k *KV) Del(ctx context.Context, key string) error
  • func (k *KV) Get(ctx context.Context, key string) ([]byte, error)
  • func (k *KV) GetPrefix(ctx context.Context, prefix string) (map[string][]byte, error)
  • func (k *KV) Put(ctx context.Context, key string, value string) error
  • func (k *KV) Start(ctx context.Context) error
  • func (k *KV) Stop(ctx context.Context) error
  • func (k *KV) Watch(ctx context.Context, prefix string, withPrevVal bool) <-chan kv.WatchResp

Types

type Config

type Config struct {
	Endpoints            []string      `fig:"endpoints"`
	DialTimeout          time.Duration `fig:"dial_timeout" default:"20s"`
	DialKeepAliveTime    time.Duration `fig:"dial_keep_alive_time" default:"30s"`
	DialKeepAliveTimeout time.Duration `fig:"dial_keep_alive_timeout" default:"10s"`
	KeepAliveTime        time.Duration `fig:"keep_alive" default:"10s"`
	Timeout              time.Duration `fig:"keep_alive" default:"20m"`
}

Config contains etcd configuration parameters.

type KV

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

KV represents an etcd key-value store implementation.

func NewKV

func NewKV(cfg Config, logger kitlog.Logger) *KV

NewKV returns a new etcd key-value store instance.

func (*KV) Del

func (k *KV) Del(ctx context.Context, key string) error

Del deletes a value associated to a given key.

func (*KV) Get

func (k *KV) Get(ctx context.Context, key string) ([]byte, error)

Get retrieves a value associated to a given key.

func (*KV) GetPrefix

func (k *KV) GetPrefix(ctx context.Context, prefix string) (map[string][]byte, error)

GetPrefix retrieves all values whose key matches prefix.

func (*KV) Put

func (k *KV) Put(ctx context.Context, key string, value string) error

Put stores a new value associated to a given key.

func (*KV) Start

func (k *KV) Start(ctx context.Context) error

Start initializes etcd key-value store.

func (*KV) Stop

func (k *KV) Stop(ctx context.Context) error

Stop closes etcd underlying connection.

func (*KV) Watch

func (k *KV) Watch(ctx context.Context, prefix string, withPrevVal bool) <-chan kv.WatchResp

Watch watches on a key or prefix.