* Enable and set global concurrency value. * @param concurrency - Maximum number of simultaneous jobs that the workers can handle. * For instanc

Configure a global rate limit: at most `max_jobs` jobs across all workers within a rolling `duration_ms` window. Mirrors `Que

* Enable and set rate limit. * @param max - Max number of jobs to process in the time period specified in `duration` * @param duration - Time in

* Sets the `application_name` of the dedicated `LISTEN` connection — the * PostgreSQL analogue of Redis `CLIENT SETNAME` — and remembers it so it i

* Sets a human-readable name on the underlying connection (for * observability). No-op for backends that have no such concept.

* Sets the global rate-limit window for the next jobs.

Dynamically change the worker's concurrency. Updates the target number of concurrent fetchers for running worker loops. Existing loops are woken to r

Start the background renewal loop. Idempotent.

* * Manually starts the stalled checker. * The check will run once as soon as this method is called, and * then every opts.stalledInterval mi

Builds one entry of the JSONB batch consumed by `add_flow`.

* Adds a job to be tracked for lock renewal. * Returns an AbortController if shouldCreateController is true, undefined otherwise.

Trim the event stream to an approximately maxLength. @param maxLength:

* Removes a job from lock renewal tracking.

Update queue metadata (version).

* Returns a promise that resolves when active jobs are cleared * * @returns

<summary>Adds several jobs to the queue in a single efficient operation.</summary>

<summary> Removes jobs of the given type older than <paramref name="grace"/> ms. Returns the removed job ids. </summary>

<summary>Creates a shallow copy of these options.</summary>

<inheritdoc />

<summary>Removes waiting (and optionally delayed) jobs from the queue.</summary>

<summary>Returns a dedicated LISTEN connection subscribed to <c>bullmq_events</c> once.</summary>

<summary>Returns the dedicated LISTEN connection, subscribing to <c>bullmq_jobs</c> once.</summary>

<summary>Builds a <see cref="JobJson"/> from a Redis hash result.</summary>

<summary>Gets a script by command name, throwing if it is not embedded.</summary>

<summary>Returns the processed children values (child key -&gt; deserialized value).</summary>

<summary>Returns the number of completed jobs.</summary>

<summary>Returns the number of jobs for each requested priority.</summary>

<summary>Returns delayed jobs.</summary>

<summary>Returns the number of jobs in the given states.</summary>

<summary>Returns a scheduler record, or null when absent.</summary>

<summary>Returns the number of registered schedulers.</summary>

<summary>Returns the stored <c>meta.version</c> field, or null when unset.</summary>

<summary>Returns waiting jobs.</summary>

<summary>Returns whether an id corresponds to a registered scheduler.</summary>

<summary>Loads a runtime command's SQL by name (without the <c>.sql</c> extension).</summary>

<summary>Loads a migration's SQL by file name (without the <c>.sql</c> extension).</summary>

<summary>Appends a row to this job's log. Returns the total log count.</summary>

<summary>Returns the migration file names (without extension) ordered by version.</summary>

<summary>Parses the integer version prefix of a migration file name (<c>0001_schema</c> -&gt; 1).</summary>

<summary>Promotes all delayed jobs back to wait.</summary>

<summary>Removes a job scheduler. Returns true if it existed.</summary>

<summary>Resumes the processing of this queue globally.</summary>

<summary>Moves all failed (or completed) jobs back to wait.</summary>

<summary>Sets a human-readable client name on the underlying connection.</summary>

<summary>Builds a single namespaced sub-key of the given <paramref name="type"/>.</summary>

<summary>Replaces this job's data payload.</summary>

<summary>Waits up to <paramref name="timeout"/> for a NOTIFY on the events channel.</summary>

<summary>Blocks on the backend's wait primitive until a job may be available.</summary>

<summary>Waits up to <paramref name="timeout"/> for a NOTIFY on the job channel.</summary>

<summary>Waits until the listener's connection is ready.</summary>

<summary>Waits until the worker's connection is ready.</summary>

Turn the Lua-flat ``[k1, v1, k2, v2, ...]`` shape into a dict. ``redis-py`` may also already hand us a dict (depending on the response policy)

Compose the opts that the next iteration's Job is created with. Matches Node's `getNextJobOpts`.