worker

package

v2.5.0+incompatible Latest Latest Go to latest Published: Apr 12, 2019 License: MIT Imports: 3 Imported by: 6

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

Worker simplifies usage of the lock

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

NewWorker creates Worker

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

Run the worker

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

SetLockRetryDelay changes the delay between unsuccessful acquire attempts of the lock