memory

Documentation

Index

• type Locker
  • func NewLocker(seconds time.Duration, opts ...Option) *Locker
  • func (m *Locker) ForceRelease(context.Context) error
  • func (m *Locker) LockedOwner(context.Context) (string, error)
  • func (m *Locker) Owner() string
  • func (m *Locker) Release(context.Context) (bool, error)
  • func (m *Locker) Try(ctx context.Context, fn func() error) error
  • func (m *Locker) Until(ctx context.Context, timeout time.Duration, fn func() error) error
• type Option
  • func WithOwner(owner string) Option
  • func WithSleep(sleep time.Duration) Option

Types

type Locker

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

func NewLocker

func NewLocker(seconds time.Duration, opts ...Option) *Locker

func (*Locker) ForceRelease

func (m *Locker) ForceRelease(context.Context) error

func (*Locker) LockedOwner

func (m *Locker) LockedOwner(context.Context) (string, error)

func (*Locker) Owner

func (m *Locker) Owner() string

func (*Locker) Release

func (m *Locker) Release(context.Context) (bool, error)

func (*Locker) Try

func (m *Locker) Try(ctx context.Context, fn func() error) error

func (*Locker) Until

func (m *Locker) Until(ctx context.Context, timeout time.Duration, fn func() error) error

type Option

type Option func(*Locker)

func WithOwner

func WithOwner(owner string) Option

func WithSleep

func WithSleep(sleep time.Duration) Option