etcdv3lock

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) LockWithCtx(ctx context.Context) error
  • func (mutex *Mutex) TryLock(timeout time.Duration) (err error)
  • func (mutex *Mutex) UnLockWithCtx(ctx context.Context) error
  • func (mutex *Mutex) Unlock() (err error)

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)

func (*Mutex) Lock

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

Lock ...

func (*Mutex) LockWithCtx

func (mutex *Mutex) LockWithCtx(ctx context.Context) error

LockWithCtx ...

func (*Mutex) TryLock

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

TryLock ...

func (*Mutex) UnLockWithCtx

func (mutex *Mutex) UnLockWithCtx(ctx context.Context) error

LockWithCtx ...

func (*Mutex) Unlock

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

Unlock ...