etcd

Documentation

Index

• type Mutex
  • func NewMutex(client *clientv3.Client, key string, opts ...concurrency.SessionOption) (mutex *Mutex, err error)
  • func (mutex *Mutex) Lock(timeout time.Duration) (err error)
  • func (mutex *Mutex) Unlock() (err error)
• type Watch
  • func WatchPrefix(client *etcdv3.Client, ctx context.Context, prefix string) (*Watch, error)
  • func (w *Watch) C() chan *clientv3.Event
  • func (w *Watch) Close() error
  • func (w *Watch) IncipientKeyValues() []*mvccpb.KeyValue

Types

type Mutex

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

Mutex ...

func NewMutex

func NewMutex(client *clientv3.Client, key string, opts ...concurrency.SessionOption) (mutex *Mutex, err error)

NewMutex ...

func (*Mutex) Lock

func (mutex *Mutex) Lock(timeout time.Duration) (err error)

Lock ...

func (*Mutex) Unlock

func (mutex *Mutex) Unlock() (err error)

Unlock ...

type Watch

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

Watch A watch only tells the latest revision

func WatchPrefix

func WatchPrefix(client *etcdv3.Client, ctx context.Context, prefix string) (*Watch, error)

NewWatch ...

func (*Watch) C

func (w *Watch) C() chan *clientv3.Event

C ...

func (*Watch) Close

func (w *Watch) Close() error

Close close watch

func (*Watch) IncipientKeyValues

func (w *Watch) IncipientKeyValues() []*mvccpb.KeyValue

IncipientKeyValues incipient key and values