mutex

Documentation

Index

• Variables
• func SkipIfStillMutexRunning(opts ...Option) cron.JobWrapper
• type ExpirableJob
• type Job
• type Locker
• type MutexJob
  • func (m *MutexJob) IsMutexJob()
• type Option
  • func WithExpiration(expiration time.Duration) Option
  • func WithLocker(locker Locker) Option
  • func WithLogger(logger cron.Logger) Option
  • func WithPrefix(prefix string) Option

Variables

var ErrLocked = errors.New("crontab/jobwrapper/mutex: job is locked")

Functions

func SkipIfStillMutexRunning

func SkipIfStillMutexRunning(opts ...Option) cron.JobWrapper

Types

type ExpirableJob

type ExpirableJob features.Expirable

type Job

type Job interface {
	cron.Job
	features.Slug

	IsMutexJob()
}

type Locker

type Locker interface {
	Lock(slug string, expiration time.Duration) error
	Unlock(slug string) error
}

type MutexJob

type MutexJob struct{} //nolint:revive

func (*MutexJob) IsMutexJob

func (m *MutexJob) IsMutexJob()

type Option

type Option func(*options)

func WithExpiration

func WithExpiration(expiration time.Duration) Option

func WithLocker

func WithLocker(locker Locker) Option

func WithLogger

func WithLogger(logger cron.Logger) Option

func WithPrefix

func WithPrefix(prefix string) Option