etcd

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 (*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