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

↓ 1 callersMethodcheckBlockingOptions

( msg: string, options?: RedisOptions, throwError = false, )

src/classes/redis-connection.ts:294

↓ 1 callersFunctioncheckCompleted

()

tests/worker.redis.test.ts:260

↓ 1 callersFunctioncheckDone

()

tests/job_cancellation_advanced.test.ts:599

↓ 1 callersFunctioncheck_meta_exists

Helper to check if a queue has a meta key set.

rust/tests/flow_test.rs:1006

↓ 1 callersFunctionchildSend

( proc: NodeJS.Process, msg: ChildMessage, )

src/utils/index.ts:298

↓ 1 callersMethodclean

* Cleans jobs from a queue. Similar to drain but keeps jobs within a certain * grace period. * * @param grace - The grace period in milliseco

src/classes/queue.ts:771

↓ 1 callersMethodcleanJobsByState

* Removes jobs in a given state that are older than `timestamp`. * @returns The ids of the removed jobs.

src/interfaces/queue-backend.ts:404

↓ 1 callersMethodcleanJobsInSet

(self, set: str, grace: int = 0, limit:int = 0)

python/bullmq/scripts.py:179

↓ 1 callersMethodcleanJobsInSet

* Clean jobs from a set. * * @param string $type * @param int $grace Time in milliseconds * @param int $limit Maximum number of jo

php/src/Scripts.php:430

↓ 1 callersMethodcleanJobsInSetArgs

(self, set: str, grace: int, limit:int = 0)

python/bullmq/scripts.py:171

↓ 1 callersFunctioncleanQueue

(name: string)

tests/bun-adapter-suite.test.ts:31

↓ 1 callersFunctioncleanQueue

(name: string)

tests/node-redis.test.ts:49

↓ 1 callersFunctioncleanQueue

(name: string)

tests/bun-redis.test.ts:49

↓ 1 callersMethodclearCache

* Clears the command cache

src/commands/script-loader.ts:575

↓ 1 callersMethodclearConnectionNameIfNeeded

( raw: ValkeyGlideRawClient, )

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

↓ 1 callersMethodclientName

(self, suffix: Optional[str] = None)

python/bullmq/backends/postgres_backend.py:294

↓ 1 callersFunctionclientReporting

(major: number)

tests/postgres/migration.test.ts:262

↓ 1 callersMethodclientSetName

(name: string)

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

↓ 1 callersMethodclose

Close the underlying Redis connection.

python/bullmq/queue_events_producer.py:108

↓ 1 callersMethodclose

Close the connection

python/bullmq/redis_connection.py:130

↓ 1 callersMethodclose

(self, force: bool = False)

python/bullmq/backends/redis_backend.py:93

↓ 1 callersMethodclose

(self, force: bool = False)

python/bullmq/backends/postgres_backend.py:244

↓ 1 callersMethodclose

* Close the queue connection. * * @return void */

php/src/Queue.php:599

↓ 1 callersMethodclose

Close the flow producer connection.

rust/src/flow_producer.rs:1129

↓ 1 callersMethodclose

* Closes the connection: releases the `LISTEN` client and (if owned) ends the * pool. Safe to call multiple times.

src/postgres/postgres-connection.ts:447

↓ 1 callersMethodclose

()

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

↓ 1 callersMethodcollectFlowEntry

* Collects a single job insert for a flow, preserving the same await point * as the previous transaction-based insert so that the relative order of

src/classes/flow-producer.ts:478

↓ 1 callersMethodcommandByType

( types: JobType[], count: boolean, callback: (key: string, dataType: string) => void, )

src/classes/queue-getters.ts:40

↓ 1 callersMethodconnect

()

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

↓ 1 callersMethodconnectClusterWithTimeout

( client: BlockingClusterClient, timeoutMs: number, )

src/classes/redis-connection.ts:668

↓ 1 callersMethodconsumeEvents

()

src/classes/queue-events.ts:354

↓ 1 callersFunctionconvertExecArgv

(execArgv: string[])

src/classes/child.ts:243

↓ 1 callersMethodcreateBackend

()

src/classes/job.ts:408

↓ 1 callersMethodcreateBackend

()

src/classes/queue-base.ts:101

↓ 1 callersFunctioncreateBlockingConnection

( name: string, opts: QueueBaseOptions, )

src/utils/create-backend.ts:18

↓ 1 callersMethodcreateClient

(config: Record<string, any>)

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

↓ 1 callersFunctioncreateCompatibilityBatch

()

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

↓ 1 callersFunctioncreateConnectedClient

()

tests/bun-adapter-suite.test.ts:24

↓ 1 callersFunctioncreateConnectedClient

()

tests/node-redis.test.ts:36

↓ 1 callersFunctioncreateConnectedClient

()

tests/bun-redis.test.ts:39

↓ 1 callersFunctioncreateConnection

(client: any)

tests/connection.test.ts:472

↓ 1 callersFunctioncreateGlideBatch

(isAtomic: boolean)

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

↓ 1 callersMethodcreateJob

( data: JobJson, jobId: string, )

src/classes/worker.ts:491

↓ 1 callersMethodcreateLockManager

* Creates and configures the lock manager for processing jobs. * This method can be overridden in subclasses to customize lock manager behavior.

src/classes/worker.ts:386

↓ 1 callersFunctioncreateMockClusterClient

(overrides: Record<string, any> = {})

tests/connection.test.ts:31

↓ 1 callersFunctioncreateProcessor

( name: string, resolve: (value: void | PromiseLike<void>) => void, reject: (value: vo

tests/delay.test.ts:298

↓ 1 callersFunctioncreateTestClient

()

tests/adapter-conformance.test.ts:28

↓ 1 callersFunctioncreate_postgres_backend

Backend factory: build a :class:`PostgresBackend` for ``name``.

python/bullmq/backends/postgres_backend.py:944

↓ 1 callersFunctioncreate_redis_backend

Default backend factory: build a :class:`RedisBackend` for ``name``. The queue classes call this so they depend only on the :class:`~bullmq.b

python/bullmq/backends/redis_backend.py:525

↓ 1 callersMethoddedicated_connection

Create a new dedicated connection (e.g., for blocking operations).

rust/src/redis_connection.rs:107

↓ 1 callersMethoddeferred_failure

Deferred failure reason (set when a child fails with failParentOnFailure). When set, the worker will fail this job without processing.

rust/src/job.rs:197

↓ 1 callersMethoddisableBlockingClusterReconnect

()

src/classes/redis-connection.ts:542

↓ 1 callersMethoddiscard

Marks the job to not be retried if it fails, even if `attempts` is set. This mirrors Node.js `Job.discard()`. For new code, returning [`Error::Unreco

rust/src/job.rs:273

↓ 1 callersMethoddiscarded_handle

Shared handle to the discard flag, used by the worker to observe a `discard()` call made inside the processor.

rust/src/job.rs:284

↓ 1 callersMethoddisconnect

(reconnect = false)

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

↓ 1 callersMethoddisconnectBlocking

* Interrupts the backend's in-flight blocking wait (so a worker can stop or * recover). No-op for backends without a dedicated blocking connection.

src/interfaces/queue-backend.ts:775

↓ 1 callersFunctiondoAsyncWork

tests/fixtures/fixture_processor_ttl.js:36

↓ 1 callersFunctiondoCleanup

tests/fixtures/fixture_processor_ttl.js:41

↓ 1 callersMethoddrainArgs

(delayed: boolean)

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

↓ 1 callersFunctiondropAll

()

tests/postgres/migration.test.ts:42

↓ 1 callersMethodduplicate

()

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

↓ 1 callersFunctionduration_as_millis

Convert a [`Duration`] to whole milliseconds, saturating at [`u64::MAX`].

rust/src/queue.rs:2915

↓ 1 callersMethodeffective_lock_renew_time

Effective lock renewal time.

rust/src/options.rs:575

↓ 1 callersMethodeffective_url

Build the effective connection URL. When [`host`](Self::host) is set, a URL is constructed from the typed fields (`scheme://[user][:pass]@host:port[/

rust/src/options.rs:158

↓ 1 callersMethodemit

( event: U, ...args: Parameters<FlowProducerListener[U]> )

src/classes/flow-producer.ts:146

↓ 1 callersFunctionenableSocketKeepAlive

* Best-effort: turns TCP keepalive on for an already-established client's * socket. Needed for the pooled `LISTEN` client, since a user-supplied * `

src/postgres/postgres-connection.ts:90

↓ 1 callersFunctionensureExt

(filename: string, ext = 'lua')

src/commands/script-loader.ts:580

↓ 1 callersFunctionensureLedgerTable

(client: PgQueryable)

src/postgres/migrator.ts:313

↓ 1 callersMethodensureListening

Subscribes the dedicated client to the shared jobs channel (once).

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

↓ 1 callersMethodensureListeningEvents

Subscribes the dedicated client to the shared events channel (once).

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

↓ 1 callersMethodensureOpen

()

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

↓ 1 callersMethodensureScriptsLoaded

* Ensure the given scripts are present in the server-side SCRIPT cache so * that subsequent EVALSHA calls (e.g. inside a MULTI/EXEC) won't fail wit

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

↓ 1 callersFunctionescapePrometheusLabelValue

* Escape a Prometheus label value per the text exposition format. * https://prometheus.io/docs/instrumenting/exposition_formats/ * * Backslashes, d

src/classes/queue-getters.ts:22

↓ 1 callersFunctionescape_prometheus_label_value

Escape a Prometheus label value (`\`, `"`, and newlines). Mirrors Node.js `escapePrometheusLabelValue`.

rust/src/queue.rs:2922

↓ 1 callersFunctionevery

( collection: readonly T[] | Record<string, T>, predicate: ( value: T, indexOrKey: number | string

tests/utils/lodash.ts:16

↓ 1 callersMethodexec

()

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

↓ 1 callersMethodexecQueuedCommands

( commands: { args: GlideArg[]; transform?: (value: unknown) => unknown }[], )

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

↓ 1 callersMethodexecuteImmediately

(args: GlideArg[])

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

↓ 1 callersFunctionexpectNoUnhandledError

( create: () => { close: () => Promise<void> }, )

tests/connection.test.ts:678

↓ 1 callersMethodexportPrometheusMetrics

* Export the metrics for the queue in the Prometheus format. * Automatically exports all the counts returned by getJobCounts(). * * @returns

src/classes/queue-getters.ts:684

↓ 1 callersMethodextendJobLocks

* Extends locks for multiple jobs.

src/interfaces/lock-manager-worker-context.ts:12

↓ 1 callersMethodextendLocks

(self, job_ids: list[str], tokens: list[str], duration: int)

python/bullmq/backends/postgres_backend.py:611

↓ 1 callersMethodextendLocks

(jobIds: string[])

src/classes/lock-manager.ts:46

↓ 1 callersMethodextend_lock

Extend the lock on this job. Useful for long-running jobs in manual processing mode to prevent the job from being considered stalled.

rust/src/job.rs:932

↓ 1 callersMethodfetchEvents

( cursor: string, )

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

↓ 1 callersMethodfetchone

(self)

python/tests/postgres_backend_test.py:119

↓ 1 callersMethodfinish

()

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

↓ 1 callersMethodfinishedErrors

* Create an exception from an error code. * * @param array{code: int, parentKey?: ?string, jobId?: string, command: string, state?: string}

php/src/Scripts.php:545

↓ 1 callersFunctionfinished_error

Map a negative status code returned by `moveToFinished` / `moveToCompleted` to a descriptive error, mirroring Node.js `Scripts.finishedErrors`. `comm

rust/src/worker.rs:406

↓ 1 callersMethodflatHashToArray

* Convert a flat Redis HGETALL response into an associative array. * * @param array<mixed> $flatHash * @return array<string, mixed>

php/src/Queue.php:363

↓ 1 callersFunctionflush

()

python/flush_redis.py:6

↓ 1 callersMethodflushAll

()

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

↓ 1 callersMethodforwardConnectionEvents

* Normalizes the events of the owned connection(s) into the backend's own * `'ready' | 'error' | 'close'` events.

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

↓ 1 callersMethodfromMetadata

* Creates a new context from a serialized version effectively * linking the new context to the parent context. * * @param activeContext - the

src/interfaces/telemetry.ts:178

↓ 1 callersMethodgetActiveJobCount

* Gets the number of jobs currently being tracked.

src/classes/lock-manager.ts:176

↓ 1 callersMethodgetBlockTimeout

(self, block_until: int)

python/bullmq/worker.py:375

↓ 1 callersMethodgetBlockTimeout

(blockUntil: number)

src/classes/worker.ts:851

↓ 1 callersFunctiongetBlockingRedisConnection

( target: RedisBackedTarget, )

tests/utils/get-redis-client.ts:67

↓ 1 callersFunctiongetCallerFile

()

src/commands/script-loader.ts:620

↓ 1 callersMethodgetChildren

( childrenKeys: string[], depth: number, maxChildren: number, )

src/classes/flow-producer.ts:584

← previous next →901–1,000 of 3,768, ranked by callers