etcd

Documentation

Index

• type Etcd
  • func Connect(endpoints []string, prefix string) (*Etcd, error)
  • func (etcd *Etcd) Dlock(ctx context.Context, key string, cb callback) error
  • func (etcd *Etcd) DlockWithTimeout(key string, timeout time.Duration, cb callback) error
  • func (etcd *Etcd) NewMutex(key string) (*Mutex, error)
  • func (etcd *Etcd) NewQueue(topic string) *Queue
• type Mutex
  • func (m *Mutex) Lock(ctx context.Context) error
  • func (m *Mutex) Unlock(ctx context.Context) error
• type Queue
  • func (q *Queue) Dequeue() (string, error)
  • func (q *Queue) Enqueue(val string) error

Types

type Etcd

type Etcd struct {
	*clientv3.Client
}

func Connect

func Connect(endpoints []string, prefix string) (*Etcd, error)

func (*Etcd) Dlock

func (etcd *Etcd) Dlock(ctx context.Context, key string, cb callback) error

func (*Etcd) DlockWithTimeout

func (etcd *Etcd) DlockWithTimeout(key string, timeout time.Duration, cb callback) error

func (*Etcd) NewMutex

func (etcd *Etcd) NewMutex(key string) (*Mutex, error)

func (*Etcd) NewQueue

func (etcd *Etcd) NewQueue(topic string) *Queue

type Mutex

type Mutex struct {
	*concurrency.Mutex
}

func (*Mutex) Lock

func (m *Mutex) Lock(ctx context.Context) error

Lock locks the mutex with a cancelable context. If the context is canceled while trying to acquire the lock, the mutex tries to clean its stale lock entry.

func (*Mutex) Unlock

func (m *Mutex) Unlock(ctx context.Context) error

type Queue

type Queue struct {
	*recipe.Queue
}

func (*Queue) Dequeue

func (q *Queue) Dequeue() (string, error)

Dequeue returns Enqueue()'d elements in FIFO order. If the queue is empty, Dequeue blocks until elements are available.

func (*Queue) Enqueue

func (q *Queue) Enqueue(val string) error