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 callersMethodisTransactionControl

(args: GlideArg[])

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

↓ 1 callersMethodisWaiting

(self)

python/bullmq/job.py:182

↓ 1 callersMethodisWaiting

* @returns true if the job is waiting.

src/classes/job.ts:924

↓ 1 callersMethodis_cancelled

Check if cancellation has been requested.

rust/src/worker.rs:76

↓ 1 callersMethodis_maxed

Return `true` when the number of active jobs has reached the queue's global concurrency limit. Returns `false` when no global concurrency is configure

rust/src/queue.rs:1335

↓ 1 callersFunctionkey

(name: string)

tests/adapter-conformance.test.ts:42

↓ 1 callersMethodkill

( signal: 'SIGTERM' | 'SIGKILL' = 'SIGKILL', timeoutMs?: number, )

src/classes/child.ts:157

↓ 1 callersMethodkillProcess

(signal: 'SIGTERM' | 'SIGKILL' = 'SIGKILL')

src/classes/child.ts:149

↓ 1 callersMethodlPos

(key: string, value: string)

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

↓ 1 callersMethodlPush

(key: string, values: string[])

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

↓ 1 callersMethodlTrim

(key: string, start: number, end: number)

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

↓ 1 callersMethodleaf_job_keys

Build KEYS array for leaf job scripts.

rust/src/flow_producer.rs:842

↓ 1 callersFunctionlengthInUtf8Bytes

(str: string)

src/utils/index.ts:49

↓ 1 callersFunctionloadCommand

(filename, longName, writeFilenamePath)

scripts/commandTransform.js:42

↓ 1 callersMethodloadCommands

Load and register all Lua scripts on the Redis client. This is called once during initialization to avoid re-registering scri

python/bullmq/redis_connection.py:115

↓ 1 callersMethodloadCommands

( packageVersion: string, providedScripts?: Record<string, RawCommand>, )

src/classes/redis-connection.ts:383

↓ 1 callersFunctionloadIORedis

* Lazily loads the optional `ioredis` driver. Users on another Redis driver * (node-redis, Bun built-in, …) or on the PostgreSQL backend never hit th

src/classes/redis-connection.ts:84

↓ 1 callersFunctionloadPgModule

* Lazily loads the optional `pg` (node-postgres) driver. Redis-only users never * hit this path, so they never need `pg` installed. * * Only reache

src/postgres/postgres-connection.ts:59

↓ 1 callersFunctionloadScript

Load a Lua script by name from the commands directory.

python/bullmq/redis_connection.py:56

↓ 1 callersFunctionloadScript

( filename: string, cache?: Map<string, ScriptMetadata>, )

tests/script_loader.test.ts:139

↓ 1 callersFunctionloadScripts

(readDir, writeDir)

scripts/commandTransform.js:9

↓ 1 callersFunctionlockKey

(jobId: string)

tests/worker.redis.test.ts:385

↓ 1 callersFunctionlookupStrategy

( backoff: BackoffOptions, customStrategy?: BackoffStrategy, )

src/classes/backoffs.ts:65

↓ 1 callersFunctionlookup_strategy

( backoff: BackoffOptions, custom_strategy: Callable[..., int] | None, )

python/bullmq/backoffs.py:37

↓ 1 callersFunctionmain

()

python/benchmark_backends.py:138

↓ 1 callersMethodmainLoop

* This is the main loop in BullMQ. Its goals are to fetch jobs from the queue * as efficiently as possible, providing concurrency and minimal unnec

src/classes/worker.ts:615

↓ 1 callersFunctionmakeJob

(over: Partial<JobJson> = {})

tests/postgres/operations.test.ts:19

↓ 1 callersFunctionmakePooledConnection

* Builds a `PostgresConnection` wired to a fake user-supplied `pg.Pool`, whose * checked-out client exposes (or not) an underlying socket.

tests/postgres-listen-client-recovery.test.ts:64

↓ 1 callersFunctionmakeStandaloneConnection

* Builds a `PostgresConnection` instance wired to a fake `pg` module so the * standalone `LISTEN` client path can be exercised without a real databas

tests/postgres-listen-client-recovery.test.ts:33

↓ 1 callersFunctionmap_to_strings

Convert a stream entry's raw field map into a string map.

rust/src/queue_events.rs:350

↓ 1 callersFunctionmarkJobForDeferredFailure

(worker: Worker, job: Job)

tests/worker.test.ts:5030

↓ 1 callersFunctionmerge_job_options

Overlay `over` onto `base`: any field set in `over` replaces the value in `base`. Used to give job-level options precedence over queue defaults.

rust/src/flow_producer.rs:1179

↓ 1 callersFunctionmockFetch

(signal?: AbortSignal)

tests/job_cancellation.test.ts:356

↓ 1 callersMethodmoveJobFromActiveToWait

* Moves a (manually rate-limited) job from active back to wait.

src/interfaces/queue-backend.ts:338

↓ 1 callersMethodmoveLimitedBackToWait

( job: Job<DataType, ResultType, NameType, ProgressType>, token: string, )

src/classes/worker.ts:1478

↓ 1 callersMethodmoveStalledJobsToWait

()

src/classes/worker.ts:1454

↓ 1 callersMethodmoveStalledJobsToWaitArgs

()

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

↓ 1 callersMethodmoveToActive

(self, token: str)

python/bullmq/worker.py:251

↓ 1 callersMethodmoveToActive

(self, token: str, opts: dict)

python/bullmq/backends/postgres_backend.py:407

↓ 1 callersMethodmoveToActive

(token: string, name?: string)

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

↓ 1 callersMethodmoveToCompletedArgs

( job: MinimalJob<T, R, N>, returnvalue: R, removeOnComplete: boolean | number | KeepJobs, tok

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

↓ 1 callersMethodmoveToDelayedArgs

(self, job_id: str, timestamp: int, token: str, delay: int = 0, opts: dict = {})

python/bullmq/scripts.py:322

↓ 1 callersMethodmoveToDelayedArgs

( jobId: string, timestamp: number, token: string, delay: number, opts: MoveToDelayedOpts

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

↓ 1 callersMethodmoveToFailed

( self, job: "Job", failed_reason: str, remove_on_fail: Any, token: str, fetch_next: bool = Tr

python/bullmq/backends/postgres_backend.py:450

↓ 1 callersMethodmoveToFailedArgs

( job: MinimalJob<T, R, N>, failedReason: string, removeOnFailed: boolean | number | KeepJobs,

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

↓ 1 callersMethodmoveToWaitingChildrenArgs

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

python/bullmq/scripts.py:183

↓ 1 callersMethodmoveToWaitingChildrenArgs

( jobId: string, token: string, opts?: MoveToWaitingChildrenOpts, )

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

↓ 1 callersMethodmove_to_completed

Move the job to completed state (manual processing). Used when processing jobs manually via `worker.get_next_job()`. The lock token is taken from the

rust/src/job.rs:1098

↓ 1 callersMethodmove_to_failed

Move the job to failed state (manual processing). Used when processing jobs manually via `worker.get_next_job()`. The lock token is taken from the jo

rust/src/job.rs:1106

↓ 1 callersMethodmulti

()

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

↓ 1 callersMethodmulti

()

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

↓ 1 callersMethodname

The queue name.

rust/src/queue.rs:113

↓ 1 callersFunctionnewBackend

()

tests/postgres/operations.test.ts:35

↓ 1 callersFunctionnextTick

()

tests/job_scheduler.test.ts:2035

↓ 1 callersMethodnext_token

Generate a unique token for a job fetch.

rust/src/worker.rs:359

↓ 1 callersMethodnormalize

(backoff: int | BackoffOptions)

python/bullmq/backoffs.py:15

↓ 1 callersMethodnormalizeBackoff

* Normalize backoff settings. * * @param int|array{type: string, delay: int}|null $backoff * @return array{type: string, delay: int}|nu

php/src/JobOptions.php:230

↓ 1 callersMethodnormalizeError

(error: unknown)

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

↓ 1 callersFunctionnormalizeHashReply

(reply: unknown)

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

↓ 1 callersFunctionnormalizeScanReply

(reply: unknown)

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

↓ 1 callersFunctionnormalizeXRangeReply

(reply: unknown)

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

↓ 1 callersFunctionnormalizeXReadReply

(reply: unknown)

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

↓ 1 callersMethodnotifies

(self, timeout=None, stop_after=None)

python/tests/postgres_backend_test.py:319

↓ 1 callersMethodnumPending

* Returns the number of promises that are still pending (in-flight). * * @returns The number of unresolved promises currently in the queue.

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

↓ 1 callersMethodobliterate

Obliterate the queue (remove all keys). When `force` is true, automatically pauses the queue first.

rust/src/queue.rs:2271

↓ 1 callersFunctiononCompleted

()

tests/events.test.ts:432

↓ 1 callersFunctiononExitOnce

(child: ChildProcess | Worker)

src/classes/child.ts:227

↓ 1 callersMethodonce

( event: U, listener: WorkerListener<DataType, ResultType, NameType, ProgressType>[U], )

src/classes/worker.ts:468

↓ 1 callersFunctionoptsFromJSON

* Decodes the compact, stored job options ({@link RedisJobOptions}, short keys) * back into their public form ({@link JobsOptions}). Internal to this

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

↓ 1 callersMethodoptsFromJSON

( rawOpts?: string, optsDecode: Record<string, string> = optsDecodeMap, )

src/classes/job.ts:412

↓ 1 callersFunctionpack_delayed_job_opts

Internal: Pack job options into msgpack for delayed job creation.

rust/src/job_scheduler.rs:213

↓ 1 callersMethodpack_job_opts_from_options

Pack job options from a JobOptions struct into msgpack (for template opts).

rust/src/queue.rs:2638

↓ 1 callersFunctionpack_scheduler_opts

Internal: Pack scheduler options into msgpack for the Lua script.

rust/src/job_scheduler.rs:147

↓ 1 callersMethodpaginate_child_keys

Collect up to `limit` member keys from a set or hash without loading the entire collection into memory. Uses the `paginate` Lua script, which scans t

rust/src/flow_producer.rs:536

↓ 1 callersMethodparent

The parent job information.

rust/src/job.rs:227

↓ 1 callersMethodparseClientList

(list: string, matcher: (name: string) => boolean)

src/classes/queue-getters.ts:653

↓ 1 callersFunctionparseIncludedFiles

(script: string)

tests/script_loader.test.ts:20

↓ 1 callersMethodparseNodeKey

* Parses a flow child/dependency node key (`"<qualifiedName>:<id>"`) back * into the components needed to locate the job: its queue keyspace `prefi

src/interfaces/queue-backend.ts:191

↓ 1 callersMethodparseScript

* Parse a (top-level) lua script * @param filename - the full path to the script * @param content - the content of the script * @param cache

src/commands/script-loader.ts:351

↓ 1 callersFunctionparse_json_string_values

(input_dict: dict[str, str])

python/bullmq/utils.py:31

↓ 1 callersMethodpatchBlockingClusterClient

()

src/classes/redis-connection.ts:483

↓ 1 callersMethodpause

* Pauses the processing of this queue globally. * * We use an atomic RENAME operation on the wait queue. Since * we have blocking calls with

src/classes/queue.ts:495

↓ 1 callersMethodpauseArgs

(pause: boolean, emitEvent = true)

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

↓ 1 callersMethodpipe

Execute a pipeline.

rust/src/redis_connection.rs:96

↓ 1 callersMethodprefix

* @returns the prefix that is used.

src/interfaces/minimal-job.ts:161

↓ 1 callersFunctionprimeCounter

(client: IRedisClient, name: string)

tests/queue.test.ts:179

↓ 1 callersMethodprocessJob

(self, job: Job, token: str)

python/bullmq/worker.py:406

↓ 1 callersFunctionprocessing_drained

(active_job_count: usize, active_fetchers: usize)

rust/src/worker.rs:228

↓ 1 callersMethodpromoteArgs

(self, job_id: str)

python/bullmq/scripts.py:370

↓ 1 callersMethodpromoteJobs

Retry all the delayed jobs.

python/bullmq/queue.py:317

↓ 1 callersMethodpublishEvent

Publish a custom event to the queue's stream. `args` must include an `eventName` field that identifies the channel listeners

python/bullmq/queue_events_producer.py:72

↓ 1 callersMethodpublishEvent

* Publishes a custom event to the queue's event stream. * @returns The id of the appended event entry.

src/interfaces/queue-backend.ts:741

↓ 1 callersFunctionqualify

( ref: { qualifiedName: string; name: string }, queueName: string, )

tests/bulk.test.ts:22

↓ 1 callersFunctionqualify

( ref: { qualifiedName: string; name: string }, queueName: string, )

tests/stalled_jobs.test.ts:24

↓ 1 callersFunctionqualify

(name: string)

tests/sandboxed_process.test.ts:294

↓ 1 callersFunctionqualify

( ref: { qualifiedName: string; name: string }, queueName: string, )

tests/worker.test.ts:42

↓ 1 callersFunctionqualify

( ref: { qualifiedName: string; name: string }, queueName: string, )

tests/flow.test.ts:34

↓ 1 callersMethodquery

* Runs a query on the connection's pool, first awaiting the connection's * (memoized) readiness so the schema/functions exist. This mirrors how the

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

↓ 1 callersMethodqueueFromNode

(self, node: dict, prefix: str)

python/bullmq/flow_producer.py:81

↓ 1 callersMethodrPop

(key: string)

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

← previous next →1,101–1,200 of 3,768, ranked by callers