etcdlock

Documentation

Index

• type Mutex
  • func New(cli *clientv3.Client, key string, ttl time.Duration) (*Mutex, error)
  • func (m *Mutex) Lock(ctx context.Context) (context.Context, error)
  • func (m *Mutex) TryLock(ctx context.Context) (context.Context, error)
  • func (m *Mutex) Unlock(ctx context.Context) error

Types

type Mutex

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

Mutex is etcdv3 lock

func New

func New(cli *clientv3.Client, key string, ttl time.Duration) (*Mutex, error)

New new a lock

func (*Mutex) Lock

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

Lock get locked

func (*Mutex) TryLock

func (m *Mutex) TryLock(ctx context.Context) (context.Context, error)

TryLock tries to lock returns error if the lock is already acquired by someone else

func (*Mutex) Unlock

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

Unlock unlock