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)
• type Mutex
  • func (m *Mutex) Lock(ctx context.Context) error
  • func (m *Mutex) Unlock(ctx context.Context) 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)

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