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

↓ 7 callersMethodsend

(command: string, args: RedisCommandArgument[])

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

↓ 7 callersMethodset_id

(&mut self, id: String)

rust/src/job.rs:290

↓ 7 callersFunctiontoGlideArg

(value: unknown)

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

↓ 7 callersMethodupsertJobScheduler

* Upserts a scheduler. * * A scheduler is a job factory that creates jobs at a given interval. * Upserting a scheduler will create a new job

src/classes/queue.ts:455

↓ 7 callersMethodwait

Resolve as soon as the signal is aborted. Use with `asyncio.wait(..., return_when=FIRST_COMPLETED)` to race cancellation against the a

python/bullmq/abort_controller.py:67

↓ 7 callersMethodxlen

(key: string)

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

↓ 7 callersMethodxread

* Read from one or more streams. * * @param streams - Array of stream/id pairs to read from * @param options - Optional BLOCK timeout and COU

src/interfaces/redis-client.ts:178

↓ 6 callersMethodGetJobStateAsync

<summary>Returns the current state of a job.</summary>

dotnet/src/BullMQ/Queue.cs:134

↓ 6 callersMethodPauseAsync

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

dotnet/src/BullMQ/Queue.cs:67

↓ 6 callersMethodaddJobArgs

* Build the arguments for adding a job. * * @param Job $job * @return array<mixed> */

php/src/Scripts.php:177

↓ 6 callersMethodclientName

* Builds the connection client name (used for `setName` and worker/queue * discovery). Redis: `"<prefix>:<base64(queue)><suffix>"`. Backends withou

src/interfaces/queue-backend.ts:198

↓ 6 callersFunctioncreateIORedisClient

( client: TClient, )

src/classes/ioredis-client.ts:51

↓ 6 callersMethoddel

(keys: string[])

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

↓ 6 callersMethoddestroy

()

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

↓ 6 callersMethodemit

( event: U, ...args: Parameters< QueueListener<JobBase<DataType, ResultType, NameType>>[U] >

src/classes/queue.ts:190

↓ 6 callersMethodexec

( batch: ValkeyGlideBatch, raiseOnError: boolean, options?: GlideCommandOptions, )

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

↓ 6 callersMethodgetCounts

(types: JobType[])

src/interfaces/queue-backend.ts:609

↓ 6 callersMethodgetCountsPerPriority

(priorities: number[])

src/interfaces/queue-backend.ts:611

↓ 6 callersMethodgetIgnoredChildrenFailures

* Returns the raw ignored-children failures map (child key → reason).

src/interfaces/queue-backend.ts:647

↓ 6 callersMethodgetJobSchedulersCount

Number of registered schedulers.

python/bullmq/queue.py:528

↓ 6 callersFunctiongetParentKey

(opts: ParentOptions)

src/utils/index.ts:247

↓ 6 callersMethodgetWaiting

* Get waiting jobs. * * @param int $start Start index * @param int $end End index * @return array<Job> */

php/src/Queue.php:382

↓ 6 callersMethodget_state

Get the current state of this job.

rust/src/job.rs:858

↓ 6 callersMethodhdel

(key: string, ...fields: string[])

src/interfaces/redis-client.ts:104

↓ 6 callersMethodhexists

(key: string, field: string)

src/interfaces/redis-client.ts:105

↓ 6 callersMethodinfo

()

src/interfaces/redis-client.ts:222

↓ 6 callersMethodisInState

(state: string)

src/classes/job.ts:1246

↓ 6 callersMethodisJobScheduler

* Returns whether an id corresponds to a registered job scheduler.

src/interfaces/queue-backend.ts:535

↓ 6 callersFunctionisNotConnectionError

(error: Error)

src/utils/index.ts:260

↓ 6 callersMethodlimiter

(&self)

rust/src/keys.rs:146

↓ 6 callersMethodmoveStalledJobsToWait

* Recovers stalled jobs (active jobs whose lock expired) back to wait. * @returns The ids of the jobs that were moved.

src/interfaces/queue-backend.ts:368

↓ 6 callersMethodmove_to_waiting_children

Move job from active to waiting-children state. This is used by step-based processors that need to wait for dynamically added child jobs before conti

rust/src/job.rs:555

↓ 6 callersFunctionnew_queue

(name: &str)

rust/tests/job_options_test.rs:17

↓ 6 callersMethodnormalize

( backoff: number | BackoffOptions, )

src/classes/backoffs.ts:37

↓ 6 callersMethodparent_key

The parent key (fully qualified Redis key to parent job).

rust/src/job.rs:232

↓ 6 callersMethodpaused

(&self)

rust/src/keys.rs:122

↓ 6 callersMethodpromoteJobs

* Promotes up to `count` delayed jobs back to wait. * @returns A cursor; `0` when there are no more jobs to promote.

src/interfaces/queue-backend.ts:388

↓ 6 callersMethodset_global_concurrency

Set global concurrency limit (stored in queue meta hash). Limits the total number of active jobs across all workers for this queue.

rust/src/queue.rs:1969

↓ 6 callersMethodstalled

(&self)

rust/src/keys.rs:134

↓ 6 callersMethodtoKey

(self, type: str)

python/bullmq/backends/redis_backend.py:161

↓ 5 callersMethodToStorageMap

<summary> Builds the storage options map (long form) from strongly-typed options. Only non-default values are included, matching how the reference run

dotnet/src/BullMQ/OptsCodec.cs:43

↓ 5 callersMethodclose

Stop consuming events and release the Redis connection. Idempotent: subsequent calls are no-ops. Works for both `autorun=True

python/bullmq/queue_events.py:212

↓ 5 callersMethodcompleted

(&self)

rust/src/keys.rs:110

↓ 5 callersMethodconnect

()

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

↓ 5 callersFunctioncreateNodeRedisClient

(client: unknown)

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

↓ 5 callersMethodcreateSandbox

* Creates and configures the sandbox for processing jobs. * This method can be overridden in subclasses to customize sandbox behavior. * * @p

src/classes/worker.ts:401

↓ 5 callersMethoddefineCommand

* Register a Lua script as a named command so it can later be invoked via * {@link runCommand}. * * @param name - Command name that wil

src/interfaces/redis-client.ts:71

↓ 5 callersMethodemit

(event: U, ...args: CustomParameters<QEL[U]>)

src/classes/queue-events.ts:297

↓ 5 callersFunctionerrorToJSON

(value: any)

src/utils/index.ts:342

↓ 5 callersMethodexport_prometheus_metrics

Export the queue's job counts and totals in the Prometheus text exposition format. Emits a `bullmq_job_count` gauge per job state plus `bullmq_job_co

rust/src/queue.rs:1359

↓ 5 callersMethodfromArray

* Create JobOptions from an associative array. * * @param array<string, mixed> $options */

php/src/JobOptions.php:110

↓ 5 callersMethodgetCompletedCount

(self)

python/bullmq/queue.py:395

↓ 5 callersMethodgetDeduplicationJobId

Get jobId from deduplicated state. @param id: deduplication identifier

python/bullmq/queue.py:269

↓ 5 callersMethodgetDeduplicationJobId

* Returns the job id currently holding the given deduplication key, if any.

src/interfaces/queue-backend.ts:592

↓ 5 callersMethodgetDelayed

* Get delayed jobs. * * @param int $start Start index * @param int $end End index * @return array<Job> */

php/src/Queue.php:406

↓ 5 callersMethodgetDependenciesCount

* Get children job counts if this job is a parent and has children. * * @returns dependencies count separated by processed, unprocessed, ignored

src/classes/job.ts:1056

↓ 5 callersMethodgetFailed

* Get failed jobs. * * @param int $start Start index * @param int $end End index * @return array<Job> */

php/src/Queue.php:442

↓ 5 callersMethodgetJobScheduler

Return the JSON-shaped scheduler record, or None.

python/bullmq/queue.py:520

↓ 5 callersMethodgetJobState

* Get the state of a job. * * @param string $jobId The job ID * @return string The job state (waiting, active, delayed, completed, fail

php/src/Queue.php:453

↓ 5 callersFunctiongetPostgresUrl

()

tests/postgres/utils/postgres-url.ts:12

↓ 5 callersMethodgetRateLimitTtl

* Returns the ttl (ms) of the current rate-limit window.

src/interfaces/queue-backend.ts:607

↓ 5 callersMethodinit

()

src/classes/child.ts:78

↓ 5 callersFunctionisConnectionClosedError

(err: any)

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

↓ 5 callersMethodisDelayed

Returns true if the job is delayed.

python/bullmq/job.py:164

↓ 5 callersFunctionisKeyValueArray

(value: unknown)

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

↓ 5 callersMethodisPaused

* Checks if the queue is paused. * * @return bool True if the queue is paused */

php/src/Queue.php:212

↓ 5 callersFunctionisRedisInstance

( obj: any, )

src/utils/index.ts:158

↓ 5 callersFunctionisRedisVersionLowerThan

( currentVersion: string, minimumVersion: string, currentDatabaseType: DatabaseType, desiredDatabaseTy

src/utils/index.ts:303

↓ 5 callersMethodllen

(key: string)

src/interfaces/redis-client.ts:143

↓ 5 callersMethodmake_script_context

Merge per-job options with queue default job options. Per-job options take precedence over defaults. Create a ScriptContext for jobs returned by queue

rust/src/queue.rs:304

↓ 5 callersMethodmapFinishError

* Re-throws a finish-op error (SQLSTATE `BM001`, whose DETAIL carries the * numeric `ErrorCode`) as the shared canonical error; passes anything els

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

↓ 5 callersMethodmoveToWait

* Moves a job to the wait or prioritized state. * * @param token - Worker token used to acquire completed job. * @returns Returns pttl.

src/classes/job.ts:688

↓ 5 callersMethodmove_to_delayed

Move the job to delayed state. This should be called from within a processor, followed by returning `Err(Error::Delayed)` to signal the worker not to

rust/src/job.rs:1243

↓ 5 callersFunctionnew_queue

(name: &str)

rust/tests/prometheus_test.rs:15

↓ 5 callersFunctionnew_queue

(name: &str)

rust/tests/meta_test.rs:15

↓ 5 callersFunctionnew_queue

(name: &str)

rust/tests/worker_options_test.rs:26

↓ 5 callersMethodpc

(&self)

rust/src/keys.rs:170

↓ 5 callersMethodpromote_jobs

Promote all delayed jobs to waiting. - `count`: max jobs to promote per batch (default: 1000)

rust/src/queue.rs:1897

↓ 5 callersMethodrecordJobMetrics

* Records job metrics if a meter is configured in telemetry options. * * @param state - The job state

src/classes/job.ts:830

↓ 5 callersMethodremoveAllListeners

(event?: string)

src/postgres/pg-types.ts:92

↓ 5 callersMethodremove_child_dependency

Remove this child's dependency from its parent. After calling this, the child job will no longer block the parent. If this was the last pending depen

rust/src/job.rs:492

↓ 5 callersMethodscan

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

src/interfaces/redis-client.ts:230

↓ 5 callersMethodsendCommand

(args: string[])

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

↓ 5 callersFunctionsetConnectionFactory

(factory: ConnectionFactory)

tests/utils/connection-factory.ts:13

↓ 5 callersMethodtimestamp

Timestamp when the job was created.

rust/src/job.rs:202

↓ 5 callersMethodtoArray

* Convert to an associative array. * * @return array<string, mixed> */

php/src/JobOptions.php:171

↓ 5 callersMethodupdate_progress

Update job progress in Redis. This calls the updateProgress Lua script which: - Sets the `progress` field on the job hash - Publishes a progress even

rust/src/job.rs:630

↓ 5 callersMethodwaitUntilFinished

* Returns a promise the resolves when the job has completed (containing the return value of the job), * or rejects when the job has failed (contain

src/classes/job.ts:1099

↓ 5 callersMethodxadd

* Append an entry to a stream. * * @param key - Stream key * @param id - Entry ID (typically `'*'` for auto-generated) * @param fie

src/interfaces/redis-client.ts:165

↓ 5 callersMethodzcard

(key: string)

src/interfaces/redis-client.ts:135

↓ 5 callersMethodzrevrange

( key: string, start: number, end: number, options?: { WITHSCORES?: boolean }, )

src/interfaces/redis-client.ts:129

↓ 5 callersMethodzscore

(key: string, member: string)

src/interfaces/redis-client.ts:136

↓ 4 callersMethodDisposeAsync

()

dotnet/src/BullMQ/Postgres/PostgresConnection.cs:574

↓ 4 callersMethodGetCountsAsync

(params string[] types)

dotnet/src/BullMQ/RedisBackend.cs:817

↓ 4 callersMethodGetJobAsync

<summary>Fetches a job by id, or null when it does not exist.</summary>

dotnet/src/BullMQ/Queue.cs:115

↓ 4 callersMethodGetKeys

<summary> The set of named sub-keys for a queue (e.g. <c>wait</c>, <c>active</c>, <c>delayed</c>, <c>meta</c>, <c>events</c>, ...). The empty key maps

dotnet/src/BullMQ/QueueKeys.cs:25

↓ 4 callersMethodMoveToActiveAsync

(string token, string? name = null)

dotnet/src/BullMQ/RedisBackend.cs:360

↓ 4 callersMethodToMillis

<summary>Coerces a date-ish value (ms int or ISO 8601 string) to epoch ms.</summary>

dotnet/src/BullMQ/RepeatStrategy.cs:70

↓ 4 callersFunction_install_client

Point the queue's backend at a fake client and make close() a no-op. ``get_workers`` reaches the datastore exclusively through ``queue.backen

python/tests/queue_getters_cluster_test.py:8

↓ 4 callersFunction_opts

(backend: str)

python/benchmark_backends.py:45

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