worker

Documentation

Index

• type Action
• type Worker
  • func NewWorker(name string, logger moira.Logger, lock moira.Lock, action Action) *Worker
  • func (worker *Worker) Run(stop <-chan struct{})
  • func (worker *Worker) SetLockRetryDelay(lockRetryDelay time.Duration)

Types

type Action

type Action func(stop <-chan struct{}) error

Action is the shorthand to `func(stop <-chan struct{}) error`

type Worker

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

Worker simplifies usage of the lock

func NewWorker

func NewWorker(name string, logger moira.Logger, lock moira.Lock, action Action) *Worker

NewWorker creates Worker

func (*Worker) Run

func (worker *Worker) Run(stop <-chan struct{})

Run the worker

func (*Worker) SetLockRetryDelay

func (worker *Worker) SetLockRetryDelay(lockRetryDelay time.Duration)

SetLockRetryDelay changes the delay between unsuccessful acquire attempts of the lock