etcd

Documentation

Index

• func New() (*clientv3.Client, error)
• type Incrementer
  • func NewIncrementer(kv *KV) *Incrementer
  • func (inc *Incrementer) Increment(key string, size int) (int64, error)
• type KV
  • func NewKV() (*KV, error)
  • func (kv *KV) Close()
  • func (kv *KV) Delete(key string) error
  • func (kv *KV) Get(key string) (string, error)
  • func (kv *KV) Put(key string, value string) error
• type Watcher
  • func NewWatcher(kv *KV) *Watcher
  • func (w *Watcher) Close() error
  • func (w *Watcher) Watch(key string) <-chan string

Functions

func New

func New() (*clientv3.Client, error)

New returns a new etcd client

Types

type Incrementer

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

Incrementer implements the models.Incrementer

func NewIncrementer

func NewIncrementer(kv *KV) *Incrementer

NewIncrementer returns a new Incrementer

func (*Incrementer) Increment

func (inc *Incrementer) Increment(key string, size int) (int64, error)

Increment try to increment the value of the key

type KV

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

KV uses etcd as a KV

func NewKV

func NewKV() (*KV, error)

NewKV returns a new EtcdKV

func (*KV) Close

func (kv *KV) Close()

Close close db

func (*KV) Delete

func (kv *KV) Delete(key string) error

Delete deletes key/value

func (*KV) Get

func (kv *KV) Get(key string) (string, error)

Get gets the value for the key

func (*KV) Put

func (kv *KV) Put(key string, value string) error

Put puts key/value

type Watcher

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

Watcher watches a key

func NewWatcher

func NewWatcher(kv *KV) *Watcher

NewWatcher returns a new watcher

func (*Watcher) Close

func (w *Watcher) Close() error

Close closes the watch channel

func (*Watcher) Watch

func (w *Watcher) Watch(key string) <-chan string

Watch watches a key