Set the maximum time to wait when rate limited.

Enable time-series metrics collection.

Return the ordered list of migration ``.sql`` filenames.

Smallest meaningful blocking timeout (in seconds) for the blocking primitive.

* PostgreSQL `LISTEN`/`NOTIFY` has no minimum block granularity, so any * positive timeout is fine; we mirror the Redis backend's smallest unit.

* Smallest meaningful block timeout (seconds) given the blocking * connection's capabilities.

* Moves a job back from Active to Wait. * This script is used when a job has been manually rate limited and needs * to be moved back to wait fro

Recover stalled jobs (active jobs whose lock expired) back to wait.

* Looks for unlocked jobs in the active queue. * * The job was being worked on, but the worker process died and it failed to renew the lock.

Add an item to the queue

Atomically move the next eligible job from wait/prioritized to active.

Move an active job to completed and optionally fetch the next job. Returns ``{"result": next_job_data_or_None, "finishedOn": timestamp}``.

* Moves a job to the completed queue. * Returned job to be used with Queue.prototype.nextJobFromJobData. * * @param returnValue - The jobs su

Moves the job to the delay set. Only allowed while the job is active, i.e. called from inside a processor, and a DelayedError must be

Move a job to the delayed state, scheduling it after ``delay`` ms.

* Moves the job to the delay set. * * @param timestamp - timestamp when the job should be moved back to "wait" * @param token - token to chec

Move an active job to failed and optionally fetch the next job. Returns ``{"result": next_job_data_or_None, "finishedOn": timestamp}``.

* Moves a job to the failed queue. * * @param err - the jobs error message. * @param token - token to check job is locked by current worker

Move a parent job to the waiting-children state.

* Moves the job to the waiting-children set. * * @param token - Token to check job is locked by current worker * @param opts - The options ba

* Move parent job to waiting-children state. * * @returns true if job is successfully moved, false if there are pending dependencies. * @thro

Move a job from the active list back to wait (or prioritized, if it has a priority). Used when a processor signals a rate-limit via [`Error::RateLimit

Move a failed job to delayed queue for retry with backoff.

Move a job to permanent failure state. Returns the next job to process when `fetch_next` was honoured by the `moveToFinished` script (single round-tr

The event name as written to the stream (matches the Node.js event name).

Set the worker name (stored on processed jobs).

Create a flow job named `name` for `queue_name` with the given `data`. `data` may be any [`Serialize`] type (your own struct, a [`serde_json::Value`]

Create a new job with the given name, data, and options.

Create a new connection from options.

Create a new `QueueEvents` listener with default options. Uses a default Redis connection (`redis://127.0.0.1:6379`) and the `bull` key prefix. Use [

Create a new key context with the given prefix and queue name.

Create a new active (non-cancelled) token.

Create a new Queue with default options. Uses a default Redis connection (`redis://127.0.0.1:6379`) and the `bull` key prefix. Use [`Queue::with_opti

Create a new Lua script from name, key count, and content.

Create default queue options.

Wait for and return the next event, or `None` once the listener is closed and the buffer is drained.

Remove a queue completely

Irreversibly destroy the queue and all of its contents. Returns a cursor.

* Obliterate (completely destroy) the queue. * * This removes ALL data associated with the queue including jobs, logs, etc. * Use with

* Obliterate (completely destroy) the queue. * * @param int $count Maximum number of jobs to remove per iteration * @param bool $force

* Completely destroys the queue and all of its contents irreversibly. * This method will *pause* the queue and requires that there are no * acti

* Subscribes to normalized backend lifecycle events (`'ready'`, `'error'`, * `'close'`), derived from the underlying connection(s).