dblock

Documentation

Index

• Constants
• func IsLockingFailed(err error) bool
• type Lock
  • func (l *Lock) Active() bool
  • func (l *Lock) Ctx() context.Context
  • func (l *Lock) Name() string
  • func (l *Lock) Release() bool
• type Locker
  • func New(db *ent.Client, leaseSeconds int64) *Locker
  • func (l *Locker) TryAcquire(pctx context.Context, id string, heartbeatSeconds int64) (*Lock, error)

Constants

const LeaseSeconds = 5

Functions

func IsLockingFailed

func IsLockingFailed(err error) bool

Types

type Lock

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

func (*Lock) Active

func (l *Lock) Active() bool

func (*Lock) Ctx

func (l *Lock) Ctx() context.Context

func (*Lock) Name

func (l *Lock) Name() string

func (*Lock) Release

func (l *Lock) Release() bool

type Locker

type Locker struct {
	Logger *slog.Logger
	// contains filtered or unexported fields
}

func New

func New(db *ent.Client, leaseSeconds int64) *Locker

func (*Locker) TryAcquire

func (l *Locker) TryAcquire(pctx context.Context, id string, heartbeatSeconds int64) (*Lock, error)