sidekiq

Documentation

Index

• Variables
• func NewQueue(client redis.UniversalClient) work.Queue

Variables

var (
	ErrJobEmptyClass      = errors.New("sidekiq: empty job class")
	ErrJobMismatchedClass = errors.New("sidekiq: job class does not match queue id")
	ErrJobEmptyID         = errors.New("sidekiq: empty job id")
	ErrJobCreatedAt       = errors.New("sidekiq: job created_at should be > 0")
	ErrJobEnqueuedAt      = errors.New("sidekiq: job enqueued_at should be > 0")
	ErrJobArgs            = errors.New("sidekiq: job args should be an array")
)

sidekiq job validation errors

Functions

func NewQueue

func NewQueue(client redis.UniversalClient) work.Queue

NewQueue creates a new queue stored in redis with sidekiq-compatible format.

This assumes that there is another sidekiq instance that is already running, which moves scheduled jobs into corresponding queues. https://github.com/mperham/sidekiq/blob/e3839682a3d219b8a3708feab607c74241bc06b8/lib/sidekiq/scheduled.rb#L12

Enqueued jobs are directly placed on the scheduled job queues. Dequeued jobs are moved to work-compatible queue as soon as they can run immediately.