workers

Documentation

Index

• Variables
• func NewScheduleWorker(db *sql.DB, queue queue.Queuer, interval time.Duration) queue.Worker
• func NewTaskWorker(dequeuer queue.Dequeuer, handler queue.TaskHandler) queue.Worker

Variables

var (
	// ErrScheduleQueueIsEmpty occurs when there is no schedule with
	// the `next_execution_time` in the past
	ErrScheduleQueueIsEmpty = errors.New("nothing to schedule")
)

Functions

func NewScheduleWorker

func NewScheduleWorker(db *sql.DB, queue queue.Queuer, interval time.Duration) queue.Worker

NewScheduleWorker creates a new task scheduling worker

func NewTaskWorker

func NewTaskWorker(dequeuer queue.Dequeuer, handler queue.TaskHandler) queue.Worker

NewTaskWorker creates a new Task Worker instance