`que`

Background jobs, workers, scheduling.

Load with: use que

Quick example

use que

result = queue("hello", 10)
prn(result)

Functions

Queue

queue(name, options)

Performs the operation. Takes name, options.

Memory driver

queue()

Performs the operation.

queue(store, job)

Performs the operation. Takes store, job.

queue(store)

Performs the operation. Takes store.

queue(store, job_id, result)

Performs the operation. Takes store, job_id, result.

queue(store, job_id, error)

Performs the operation. Takes store, job_id, error.

Redis driver

queue(queue, job)

Performs the operation. Takes queue, job.

queue(queue)

Performs the operation. Takes queue.

Job

jobne(type, payload, options)

Creates a new instance. Takes type, payload, options.

Producer

queue(queue, type, payload, options)

Performs the operation. Takes queue, type, payload, options.

queue(queue, jobs)

Performs the operation. Takes queue, jobs.

Consumer

queue(queue, processor)

Performs the operation. Takes queue, processor.

queue(queue)

Performs the operation. Takes queue.

queue(queue, job_id, result)

Performs the operation. Takes queue, job_id, result.

queue(queue, job_id, error)

Performs the operation. Takes queue, job_id, error.

Scheduled jobs

queue(queue, type, payload, cron_expr, options)

Performs the operation. Takes queue, type, payload, cron_expr, options.

queue(queue)

Performs the operation. Takes queue.

Job progress

jobpr(job, percent, message)

Processes or prints. Takes job, percent, message.

Dead letter queue

queue(queue, failed_job)

Performs the operation. Takes queue, failed_job.

Queue monitoring

queue(queue)

Performs the operation. Takes queue.

queue(queue, status)

Performs the operation. Takes queue, status.

Retry failed jobs

queue(queue, job_id)

Performs the operation. Takes queue, job_id.

Pause/Resume

queue(queue)

Performs the operation. Takes queue.

queue(queue)

Performs the operation. Takes queue.

Priority queue

queue(queue, type, payload, priority, options)

Performs the operation. Takes queue, type, payload, priority, options.

Notes

Queue data structure - FIFO, priority, circular.