Functions — github.com/taskforcesh/bullmq

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

⨍ Functions 3,768◇ Types & classes 487↳ Endpoints 8

* Blocks (up to `blockTimeout` ms) reading the queue's event stream for * entries newer than `id`, returning the raw stream entries (or a falsy val

src/interfaces/queue-backend.ts:751

↓ 1 callersMethodreconnectBlocking

* Re-establishes the dedicated blocking connection after an interrupt.

src/classes/redis-queue-backend.ts:419

↓ 1 callersMethodreconnectClusterIfNeeded

( client: BlockingClusterClient, timeoutMs: number, )

src/classes/redis-connection.ts:610

↓ 1 callersMethodrecordJobCountsMetric

* Records job counts as gauge metrics for telemetry purposes. * Each job state count is recorded with the queue name and state as attributes. *

src/classes/queue-getters.ts:202

↓ 1 callersMethodrecreateRaw

()

src/classes/valkey-glide-client.ts:501

↓ 1 callersMethodrejectPromise

(err: any)

src/classes/async-fifo-queue.ts:156

↓ 1 callersMethodreleaseBlockingClusterClientPatch

()

src/classes/redis-connection.ts:552

↓ 1 callersMethodremove

(self, job_id: str, opts: dict = {})

python/bullmq/queue.py:475

↓ 1 callersMethodremove

(child: Child)

src/classes/child-pool.ts:95

↓ 1 callersMethodremoveArgs

( jobId: string, removeChildren: boolean, )

src/classes/redis-queue-backend.ts:973

↓ 1 callersMethodremoveChildDependencyArgs

( jobId: string, parentKey: string, )

src/classes/redis-queue-backend.ts:1243

↓ 1 callersFunctionremoveChildJob

(node: JobNode)

tests/flow.test.ts:6022

↓ 1 callersFunctionremoveEmptyLines

(str: string)

src/commands/script-loader.ts:658

↓ 1 callersMethodremoveGlobalConcurrency

Clear the global concurrency cap. Returns the number of fields removed.

python/bullmq/queue.py:148

↓ 1 callersMethodremoveGlobalConcurrency

* Remove global concurrency value.

src/classes/queue.ts:289

↓ 1 callersMethodremoveGlobalRateLimit

Clear the global rate limit by removing both `max` and `duration` from the queue's meta hash. Mirrors `Queue.removeGlobalRateLimit`

python/bullmq/queue.py:179

↓ 1 callersMethodremoveGlobalRateLimit

* Remove global rate limit values.

src/classes/queue.ts:296

↓ 1 callersMethodremoveJobScheduler

Remove a job scheduler. Returns 0 on success, 1 if absent.

python/bullmq/queue.py:512

↓ 1 callersMethodremoveOrphanedJobsBatch

* Low-level Redis adapter helper: atomically check-and-delete a single batch * of candidate orphaned jobs. Driven by {@link removeOrphanedJobs}.

src/classes/redis-queue-backend.ts:2308

↓ 1 callersMethodremoveRateLimitKey

Removes the rate limit key. Returns the number of keys removed (0 or 1).

python/bullmq/queue.py:120

↓ 1 callersFunctionremoveUndefined

Strips `undefined` properties so the JSON shape matches the Redis backend.

src/postgres/postgres-queue-backend.ts:77

↓ 1 callersFunctionremoveUndefinedFields

( obj: Record<string, any>, )

src/utils/index.ts:378

↓ 1 callersMethodremove_deduplication_key

Remove a deduplication key if the stored job ID matches the given one. Uses the `removeDeduplicationKey` Lua script for atomic check-and-delete.

rust/src/queue.rs:2102

↓ 1 callersMethodremove_rate_limit_key

Remove the rate limit key, allowing processing to resume immediately.

rust/src/queue.rs:1955

↓ 1 callersMethodremove_without_children

Remove a job without removing its children. Children remain in their queues and lose their parent reference. The return value follows the same semant

rust/src/queue.rs:1661

↓ 1 callersFunctionreplaceAll

(str: string, find: string, replace: string)

src/commands/script-loader.ts:654

↓ 1 callersMethodreprocessJob

(self, job: Job, state: str, opts: dict = {})

python/bullmq/scripts.py:593

↓ 1 callersMethodresolveDependencies

* Recursively collect all scripts included in a file * @param file - the parent file * @param cache - a cache for file metadata to increase effi

src/commands/script-loader.ts:175

↓ 1 callersMethodresolvePromise

(data: T)

src/classes/async-fifo-queue.ts:151

↓ 1 callersMethodretryFinishedJob

* Reprocesses a finished (failed/completed) job, moving it back to wait.

src/interfaces/queue-backend.ts:353

↓ 1 callersMethodretryFinishedJobs

* Moves up to `count` finished jobs of the given `state` back to wait. * @returns A cursor; `0` when there are no more jobs to move.

src/interfaces/queue-backend.ts:378

↓ 1 callersMethodretryJobArgs

(self, job_id: str, lifo: bool, token: str, opts: dict = {})

python/bullmq/scripts.py:287

↓ 1 callersMethodretryJobArgs

( jobId: string, lifo: boolean, token: string, opts: MoveToDelayedOpts = {}, )

src/classes/redis-queue-backend.ts:1833

↓ 1 callersMethodrpop

(key: string)

src/classes/bun-redis-client.ts:1213

↓ 1 callersMethodrun

(self, sql: str, params: list)

python/bullmq/backends/postgres_connection.py:213

↓ 1 callersMethodrun

Start consuming events. Called automatically when [`QueueEventsOptions::autorun`] is `true`. Returns an error if the listener is already running.

rust/src/queue_events.rs:463

↓ 1 callersMethodrun

* Manually starts running the event consumming loop. This shall be used if you do not * use the default "autorun" option on the constructor.

src/classes/queue-events.ts:336

↓ 1 callersMethodrunCommand

(name: string, args: any[])

src/classes/valkey-glide-client.ts:680

↓ 1 callersFunctionrunMigrations

( client: PgQueryable, schema: string = DEFAULT_SCHEMA, options: { skipVersionCheck?: boolean } = {}, )

src/postgres/migrator.ts:243

↓ 1 callersFunctionrun_backend

(backend: str, jobs: int, parallelism: int, concurrencies: list)

python/benchmark_backends.py:123

↓ 1 callersMethodsCard

(key: string)

src/classes/node-redis-client.ts:135

↓ 1 callersMethodsScan

(key: string, cursor: string, options?: Record<string, unknown>)

src/classes/node-redis-client.ts:55

↓ 1 callersFunctionsandboxProcessTests

( { useWorkerThreads } = { useWorkerThreads: false }, )

tests/sandboxed_process.test.ts:279

↓ 1 callersFunctionsandboxProcessTests

( { mainFile, useWorkerThreads, }: { mainFile?: string; useWorkerThreads?: boolean } = { useWo

tests/child-pool.test.ts:17

↓ 1 callersMethodscan

( cursor: string | number, options: { MATCH?: string; COUNT?: number }, )

src/classes/valkey-glide-client.ts:966

↓ 1 callersMethodscriptLoad

(lua: string)

src/classes/node-redis-client.ts:79

↓ 1 callersFunctionscript_exists

(conn: &mut MultiplexedConnection, shas: &[&str])

rust/src/scripts.rs:334

↓ 1 callersMethodsend

(msg: any)

src/classes/child.ts:131

↓ 1 callersMethodsetGlobalConcurrency

Set the maximum number of jobs that all workers attached to this queue can process in parallel. A value of 1 effectively serializes

python/bullmq/queue.py:126

↓ 1 callersMethodsetName

(name: string)

src/postgres/postgres-queue-backend.ts:381

↓ 1 callersMethodsetSpanOnContext

* setSpanOnContext sets the span on the context. This is useful when you want * to propagate the span across the application. * * @param ctx

src/interfaces/telemetry.ts:214

↓ 1 callersMethodset_name

Set the Redis client connection name (`CLIENT SETNAME`). Used by workers so that `Queue::get_workers` can discover them via `CLIENT LIST`. Best-effor

rust/src/redis_connection.rs:193

↓ 1 callersMethodset_parent

Set the parent job info.

rust/src/job.rs:300

↓ 1 callersMethodset_parent_key

Set the parent key (fully qualified Redis key).

rust/src/job.rs:305

↓ 1 callersMethodset_queue_name

Set the queue name (for jobs loaded outside the worker context).

rust/src/job.rs:295

↓ 1 callersFunctionsha1

(data: string)

src/commands/script-loader.ts:646

↓ 1 callersMethodshouldReconnectClusterAfterError

( client: BlockingClusterClient, error: Error, )

src/classes/redis-connection.ts:622

↓ 1 callersMethodshouldRetryJob

(err: Error)

src/classes/job.ts:696

↓ 1 callersFunctionshould_convert_discarded_error

(error: &Error)

rust/src/worker.rs:218

↓ 1 callersFunctionsimulateApiCall

(signal?: AbortSignal)

tests/job_cancellation_advanced.test.ts:1178

↓ 1 callersMethodsmembers

(key: string)

src/classes/bun-redis-client.ts:97

↓ 1 callersMethodstalledChecker

()

src/classes/worker.ts:1377

↓ 1 callersMethodstartLockExtenderTimer

()

src/classes/lock-manager.ts:97

↓ 1 callersMethodstartSpan

* startSpan creates a new Span with the given name and options on an optional * context. If the context is not provided, the current active context

src/interfaces/telemetry.ts:196

↓ 1 callersMethodstart_lock_renewal

(&self)

rust/src/worker.rs:2386

↓ 1 callersMethodstart_main_loop

(&self)

rust/src/worker.rs:849

↓ 1 callersMethodstart_progress_forwarder

(&self)

rust/src/worker.rs:2271

↓ 1 callersMethodstart_stalled_check

(&self)

rust/src/worker.rs:2297

↓ 1 callersMethodstop

(self)

python/bullmq/timer.py:26

↓ 1 callersFunctionsupportCJS

()

src/classes/child-pool.ts:11

↓ 1 callersFunctiontestBasicFunctionality

()

tests/integration_dedicated_lock_thread.ts:5

↓ 1 callersFunctiontestRemoveOnFinish

( opts: boolean | number | KeepJobs, expectedCount: number, fail?: boolean, )

tests/worker.test.ts:1602

↓ 1 callersFunctiontestWorkerRemoveOnFinish

( opts: KeepJobs, expectedCount: number, fail?: boolean, )

tests/worker.test.ts:1681

↓ 1 callersMethodthrow_if_aborted

(self)

python/bullmq/abort_controller.py:73

↓ 1 callersFunctiontimes

(n: number, iteratee: (index: number) => T)

tests/utils/lodash.ts:35

↓ 1 callersMethodtoFlowEntry

* Builds the data needed to insert this job as part of a flow, without * touching the datastore. Used by FlowProducer to collect a whole flow tree

src/classes/job.ts:1282

↓ 1 callersMethodtoFlowError

* Translates numeric addJob Lua error codes returned by root flow exec. * * @param code - Numeric error code returned from Redis. * @param pa

src/classes/flow-producer.ts:645

↓ 1 callersMethodtoJson

* Convert job to JSON representation. * * @return array<string, mixed> */

php/src/Job.php:239

↓ 1 callersMethodtoKey

(self, name: str, name_type: str)

python/bullmq/queue_keys.py:18

↓ 1 callersMethodtoKey

* Generate a key for a specific type. * * @param string $name Queue name * @param string $type Key type */

php/src/QueueKeys.php:71

↓ 1 callersMethodtoKey

* Builds a namespaced identifier of the given `type` (`"<queue>:<type>"`), * used e.g. for flow dependency identifiers. No prefix is involved.

src/postgres/postgres-queue-backend.ts:451

↓ 1 callersMethodtrack_job

Register a job for lock renewal. `ts` is the timestamp (ms) at which the job became active; the manager uses it to decide when the fir

python/bullmq/lock_manager.py:68

↓ 1 callersMethodtranspileScripts

* Transpile lua scripts in one file, specifying an specific directory to be saved * @param pathname - the path to the directory containing the scri

scripts/generateRawScripts.ts:14

↓ 1 callersMethodtrim_events

Trim the event stream to approximately `max_length` entries.

rust/src/queue.rs:2222

↓ 1 callersMethoduntrack_job

Stop renewing the lock for the given job. Called when the job completes, fails, or is moved away from the active state.

python/bullmq/lock_manager.py:101

↓ 1 callersMethodupdateJobProgress

* Updates the given job's progress. * * @param jobId - The id of the job to update * @param progress - Number or object to be saved as progre

src/classes/queue.ts:704

↓ 1 callersMethodupdateStacktrace

(self)

python/bullmq/job.py:270

↓ 1 callersMethodupdateStacktrace

(err: Error)

src/classes/job.ts:1402

↓ 1 callersMethodwait

()

src/classes/async-fifo-queue.ts:168

↓ 1 callersMethodwaitAll

* Waits for all currently pending promises to settle. * * @returns A promise that resolves once every in-flight promise has resolved.

src/classes/async-fifo-queue.ts:117

↓ 1 callersMethodwaitForEvent

* Blocks (up to `blockTimeout` ms) until a new event is published for this * queue (via `LISTEN`/`NOTIFY` on the events channel), or the timeout

src/postgres/postgres-queue-backend.ts:2133

↓ 1 callersMethodwaitForJob

(self)

python/bullmq/worker.py:334

↓ 1 callersMethodwaitForJob

(blockUntil: number)

src/classes/worker.ts:799

↓ 1 callersMethodwaitForRateLimit

()

src/classes/worker.ts:596

↓ 1 callersFunctionwaitForWorkerReady

(worker: Worker)

tests/getters.test.ts:72

↓ 1 callersFunctionwaitForWorkers

( targetQueue: Queue, expectedCount: number, timeout = 2000, )

tests/getters.test.ts:79

↓ 1 callersFunctionwaitResponse

( requestId: string, receiver: Receiver, timeout: number, cmd: string, )

src/classes/child-processor.ts:344

↓ 1 callersFunctionwait_then_move

Helper that, given a job, polls until it has a failed dependency then tries to move to waiting children (propagating the resulting error).

rust/tests/flow_test.rs:7952

↓ 1 callersMethodwith

* Creates a new context and sets it as active for the fn passed as last argument * * @param context - the context to set as active * @param f

src/interfaces/telemetry.ts:152

↓ 1 callersFunctionwithMockedRuntimeModule

( requestToMock: string, exports: Record<string, unknown>, callback: () => Promise<T>, )

tests/valkey-glide-client.test.ts:13

← previous next →1,201–1,300 of 3,768, ranked by callers