etcdkv

Documentation

Index

• type KV
  • func New(cli *etcdv3.Client) *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 KV

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

KV represents an etcd key-value store implementation.

func New

func New(cli *etcdv3.Client) *KV

New 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.