lock

Feb 23, 2021

Changes in this version

+ type ErrAlreadyLocked struct

+ func (e *ErrAlreadyLocked) Error() string

+ type EtcdLock struct

+ func (l *EtcdLock) Release() error

+ type EtcdLocker struct

+ func (locker *EtcdLocker) Acquire(ctx context.Context, key string, ttl int) (Lock, error)

+ func (locker *EtcdLocker) Wait(ctx context.Context, key string) error

+ func (locker *EtcdLocker) WaitAcquire(ctx context.Context, key string, ttl int) (Lock, error)

+ type EtcdLockerOpt func(locker *EtcdLocker)

+ func WithCooldownTryLockDuration(timeout time.Duration) EtcdLockerOpt

+ func WithMaxTryLockTimeout(timeout time.Duration) EtcdLockerOpt

+ func WithTryLockTimeout(timeout time.Duration) EtcdLockerOpt

+ type Lock interface

+ Release func() error

+ type Locker interface

+ Acquire func(ctx context.Context, key string, ttl int) (Lock, error)

+ Wait func(ctx context.Context, key string) error

+ WaitAcquire func(ctx context.Context, key string, ttl int) (Lock, error)

+ func NewEtcdLocker(client *etcd.Client, opts ...EtcdLockerOpt) Locker