workers

package
v3.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 15, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.