locker_with_retry

Documentation

Index

• type LockerWithRetry
  • func NewLockerWithRetry(ctx context.Context, locker lockgate.Locker, opts LockerWithRetryOptions) *LockerWithRetry
  • func (locker *LockerWithRetry) Acquire(lockName string, opts lockgate.AcquireOptions) (acquired bool, handle lockgate.LockHandle, err error)
  • func (locker *LockerWithRetry) Release(lock lockgate.LockHandle) (err error)
• type LockerWithRetryOptions

Types

type LockerWithRetry

type LockerWithRetry struct {
	Locker  lockgate.Locker
	Options LockerWithRetryOptions
	Ctx     context.Context
}

func NewLockerWithRetry

func NewLockerWithRetry(ctx context.Context, locker lockgate.Locker, opts LockerWithRetryOptions) *LockerWithRetry

func (*LockerWithRetry) Acquire

func (locker *LockerWithRetry) Acquire(lockName string, opts lockgate.AcquireOptions) (acquired bool, handle lockgate.LockHandle, err error)

func (*LockerWithRetry) Release

func (locker *LockerWithRetry) Release(lock lockgate.LockHandle) (err error)

type LockerWithRetryOptions

type LockerWithRetryOptions struct {
	MaxAcquireAttempts int
	MaxReleaseAttempts int
}