locker

Oct 22, 2024

Changes in this version

type Locker

+ Get func(ctx context.Context) (Owner, error)

+ type NoopLocker struct

+ func (l NoopLocker) ForceRelease(context.Context) error

+ func (l NoopLocker) Get(context.Context) (Owner, error)

+ func (l NoopLocker) LockedOwner(context.Context) (Owner, error)

+ func (l NoopLocker) Release(context.Context, Owner) error

+ func (l NoopLocker) Try(context.Context, func()) error

+ func (l NoopLocker) Until(context.Context, time.Duration, func()) error

+ type Owner interface

+ Name func() string

+ Release func(ctx context.Context) error

+ func NewOwner(locker Locker, opts ...OwnerOption) Owner

+ type OwnerOption func(*owner)

+ func WithOwnerName(name string) OwnerOption

Jul 11, 2024

Changes in this version

+ var ErrLocked = errors.New("locker: locked")

+ var ErrNotLocked = errors.New("locker: not locked")

+ var ErrTimeout = errors.New("locker: timeout")

+ type Locker interface

+ ForceRelease func(ctx context.Context) error

+ LockedOwner func(ctx context.Context) (string, error)

+ Owner func() string

+ Release func(ctx context.Context) (bool, error)

+ Try func(ctx context.Context, fn func() error) error

+ Until func(ctx context.Context, timeout time.Duration, fn func() error) error