etcdutil

README

etcdutil

utility library for etcd watcher & lease

Documentation

Index

• Variables
• type Lease
  • func NewLease(client *clientv3.Client, key, value string, ttl int64, onError func(error)) (*Lease, error)
  • func (l *Lease) Stop()
• type Watcher
  • func NewWatcher(client *clientv3.Client, handler WatcherHandler, key string, ...) *Watcher
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop() error
• type WatcherHandler

Variables

var ErrLeaseInterrupted error = errors.New("lease interrupted")

Types

type Lease

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

func NewLease

func NewLease(client *clientv3.Client, key, value string, ttl int64, onError func(error)) (*Lease, error)

func (*Lease) Stop

func (l *Lease) Stop()

type Watcher

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

func NewWatcher

func NewWatcher(client *clientv3.Client, handler WatcherHandler, key string, opts ...clientv3.OpOption) *Watcher

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) Stop

func (w *Watcher) Stop() error

type WatcherHandler

type WatcherHandler interface {
	OnPut(key, value []byte)
	OnDelete(key []byte)
	OnError(error)
	OnResetBegin()
	OnResetEnd()
}