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 callersFunctiongetCircularReplacer

(rootReference: any)

src/utils/index.ts:328

↓ 1 callersFunctiongetClientName

(name: string)

tests/cluster.test.ts:47

↓ 1 callersMethodgetCompleted

(self, start = 0, end=-1)

python/bullmq/queue.py:410

↓ 1 callersFunctiongetConnectionFactory

()

tests/utils/connection-factory.ts:17

↓ 1 callersMethodgetCountsArgs

(types: JobType[])

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

↓ 1 callersMethodgetCountsPerPriorityArgs

(self, priorities)

python/bullmq/scripts.py:517

↓ 1 callersMethodgetCountsPerPriorityArgs

( priorities: number[], )

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

↓ 1 callersFunctiongetCurrentSchemaVersion

( client: PgQueryable, )

src/postgres/migrator.ts:304

↓ 1 callersMethodgetDependencyCounts

(jobId: string, types: string[])

src/interfaces/queue-backend.ts:620

↓ 1 callersMethodgetDependencyCountsArgs

( jobId: string, types: string[], )

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

↓ 1 callersFunctiongetDirname

()

src/postgres/sql-loader.ts:5

↓ 1 callersMethodgetFailed

(self, start = 0, end=-1)

python/bullmq/queue.py:416

↓ 1 callersMethodgetFailedChildrenValues

* Get job's children failure values that were ignored if any. * * @deprecated This method is deprecated and will be removed in v6. Use getIgnore

src/classes/job.ts:1023

↓ 1 callersMethodgetFlow

* Get a flow. * * @param opts - an object with options for getting a JobNode.

src/classes/flow-producer.ts:277

↓ 1 callersFunctiongetFreePort

()

src/classes/child.ts:233

↓ 1 callersMethodgetJob

(jobId: string)

src/classes/queue-getters.ts:36

↓ 1 callersMethodgetJobLogs

Returns the logs for a given Job. @param job_id: The id of the job to get the logs for. @param start: Zero based index from

python/bullmq/queue.py:258

↓ 1 callersMethodgetJobSchedulerArgs

(id: string)

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

↓ 1 callersMethodgetJobSchedulerData

* Returns the raw stored metadata hash for a job scheduler.

src/interfaces/queue-backend.ts:540

↓ 1 callersMethodgetJobSchedulers

Page through registered schedulers.

python/bullmq/queue.py:524

↓ 1 callersMethodgetJobSchedulersRange

* Returns a range of scheduler keys with their next-run scores, flattened as * `[key, score, key, score, …]`.

src/interfaces/queue-backend.ts:546

↓ 1 callersMethodgetJobState

(self, job_id: str)

python/bullmq/queue.py:392

↓ 1 callersMethodgetJobsArgs

(self, types, start: int = 0, end: int = 1, asc: bool = False)

python/bullmq/scripts.py:225

↓ 1 callersMethodgetJobsArgs

( types: JobType[], start: number, end: number, asc: boolean, )

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

↓ 1 callersMethodgetKeepJobs

( shouldRemove: undefined | boolean | number | KeepJobs, workerKeepJobs: undefined | KeepJobs, )

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

↓ 1 callersMethodgetMeta

* Get global queue configuration. * * @returns Returns the global queue configuration.

src/classes/queue-getters.ts:238

↓ 1 callersMethodgetMetadata

* Returns a serialized version of the current context. The metadata * is the mechanism used to propagate the context across a distributed * appl

src/interfaces/telemetry.ts:169

↓ 1 callersMethodgetMetrics

* Get queue metrics related to the queue. * * This method returns the gathered metrics for the queue. * The metrics are represented as an arr

src/classes/queue-getters.ts:635

↓ 1 callersFunctiongetMinimumClientVersion

(client: PgQueryable)

src/postgres/migrator.ts:334

↓ 1 callersMethodgetNextJobOpts

( nextMillis: number, jobSchedulerId: string, opts: JobSchedulerJobOptions, currentCount: numb

src/classes/job-scheduler.ts:302

↓ 1 callersFunctiongetNextMillis

( millis: number, opts: RepeatOptions, )

src/classes/job-scheduler.ts:532

↓ 1 callersMethodgetParentKey

* Get the parent key from parent options. * * @param array{id: string, queue: string}|null $parent */

php/src/Job.php:151

↓ 1 callersFunctiongetPkgJsonDir

()

src/commands/script-loader.ts:603

↓ 1 callersMethodgetQueueMeta

* Reads the entire queue metadata hash.

src/interfaces/queue-backend.ts:698

↓ 1 callersMethodgetQueueQualifiedName

(name: string)

src/classes/queue-keys.ts:39

↓ 1 callersMethodgetRanges

( types: JobType[], start = 0, end = 1, asc = false, )

src/classes/queue-getters.ts:446

↓ 1 callersMethodgetRangesArgs

(self, types, start: int = 0, end: int = 1, asc: bool = False)

python/bullmq/scripts.py:215

↓ 1 callersMethodgetRangesArgs

( types: JobType[], start: number, end: number, asc: boolean, )

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

↓ 1 callersMethodgetRateLimitDelay

(delay: number)

src/classes/worker.ts:876

↓ 1 callersMethodgetRateLimitTtlArgs

(maxJobs?: number)

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

↓ 1 callersMethodgetRedisVersionAndType

()

src/classes/redis-connection.ts:799

↓ 1 callersFunctiongetReturnValue

(value: Any)

python/bullmq/job.py:387

↓ 1 callersFunctiongetRootPath

()

tests/script_loader.test.ts:16

↓ 1 callersMethodgetScheduler

Return the JSON-shaped scheduler record, or None.

python/bullmq/job_scheduler.py:321

↓ 1 callersMethodgetScheduler

( id: string, )

src/classes/job-scheduler.ts:444

↓ 1 callersMethodgetSchedulerData

( key: string, next?: number, )

src/classes/job-scheduler.ts:348

↓ 1 callersMethodgetSchedulerNextJobId

({ nextMillis, jobSchedulerId, }: { jobSchedulerId: string; nextMillis: number | string; }

src/classes/job-scheduler.ts:490

↓ 1 callersMethodgetSchedulersCount

Total number of registered schedulers.

python/bullmq/job_scheduler.py:341

↓ 1 callersMethodgetSchedulersCount

()

src/classes/job-scheduler.ts:486

↓ 1 callersMethodgetSpanOperation

(shouldRetry: boolean, retryDelay: number)

src/classes/job.ts:813

↓ 1 callersMethodgetTemplateFromJSON

( rawData?: string, rawOpts?: string, )

src/classes/job-scheduler.ts:456

↓ 1 callersFunctiongetTraces

(stacktrace?: string)

src/classes/job.ts:1423

↓ 1 callersMethodgetUnrecoverableErrorMessage

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

src/classes/worker.ts:1095

↓ 1 callersMethodgetVersion

* Get library version. * * @returns the content of the `meta.version` field, or `null` when the meta * hash has not been populated yet (e.g.

src/classes/queue.ts:244

↓ 1 callersMethodgetWaiting

(self, start = 0, end=-1)

python/bullmq/queue.py:422

↓ 1 callersMethodgetWaitingChildren

(self, start = 0, end=-1)

python/bullmq/queue.py:425

↓ 1 callersMethodgetWaitingChildrenCount

* Returns the number of jobs in waiting-children status.

src/classes/queue-getters.ts:334

↓ 1 callersMethodget_active_job_count

(self)

python/bullmq/lock_manager.py:132

↓ 1 callersMethodget_completed

Return jobs in the `completed` state.

rust/src/queue.rs:1062

↓ 1 callersMethodget_counts_raw

Raw `getCounts` script call. Transforms `waiting` -> `wait` and returns one count per provided type, in order.

rust/src/queue.rs:1073

↓ 1 callersMethodget_delayed

Return jobs in the `delayed` state.

rust/src/queue.rs:1052

↓ 1 callersMethodget_failed

Return jobs in the `failed` state.

rust/src/queue.rs:1067

↓ 1 callersMethodget_ignored_children_failures

Retrieve the failures of child jobs that were ignored via `ignoreDependencyOnFailure`. Returns a map of `{queue_prefix:queue_name:job_id => failure_r

rust/src/job.rs:370

↓ 1 callersMethodget_node

Recursively load a node from Redis.

rust/src/flow_producer.rs:437

↓ 1 callersMethodget_prioritized

Return jobs in the `prioritized` state.

rust/src/queue.rs:1057

↓ 1 callersMethodget_prioritized_count

Return the number of jobs in the `prioritized` state.

rust/src/queue.rs:1238

↓ 1 callersMethodget_ranges

Return job IDs for the given states with pagination. `types` are state names (e.g. `"waiting"`, `"active"`, `"completed"`). `start`/`end` are zero-ba

rust/src/queue.rs:829

↓ 1 callersMethodget_rate_limit_ttl

Return the time-to-live (in ms) for the rate-limited key. `max_jobs` is the maximum number of jobs considered in the rate-limit state. When `None`, t

rust/src/queue.rs:2035

↓ 1 callersMethodget_unprocessed_dependencies

Get the unprocessed dependencies (children still pending). Returns a set of child job keys that haven't completed yet.

rust/src/job.rs:468

↓ 1 callersMethodget_version

Return the library version string stored in the `meta` hash. The Rust port records `bullmq-official:<version>` under the `library` field when the que

rust/src/queue.rs:1322

↓ 1 callersMethodget_workers_count

(self)

python/bullmq/queue.py:219

↓ 1 callersMethodhDel

(key: string, fields: string[])

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

↓ 1 callersMethodhExists

(key: string, field: string)

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

↓ 1 callersMethodhGet

(key: string, field: string)

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

↓ 1 callersMethodhScan

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

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

↓ 1 callersMethodhandleCompleted

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

src/classes/worker.ts:1109

↓ 1 callersMethodhandleFailed

( err: Error, job: Job<DataType, ResultType, NameType, ProgressType>, token: string, fetchNext

src/classes/worker.ts:1141

↓ 1 callersMethodhandleListenClientError

* Handles a fatal error on the dedicated `LISTEN` client. * * A `LISTEN` subscription lives on one specific physical connection: once that *

src/postgres/postgres-connection.ts:412

↓ 1 callersMethodhasProcessExited

()

src/classes/child.ts:222

↓ 1 callersFunctionhash

(repeatKeyHashAlgorithm: string, payload: string)

tests/utils/repeat_utils.ts:26

↓ 1 callersMethodhmGet

(key: string, fields: string[])

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

↓ 1 callersMethodincr

(key: string)

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

↓ 1 callersMethodincr

(key: string)

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

↓ 1 callersMethodincrBy

(key: string, increment: number)

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

↓ 1 callersMethodinit

()

src/classes/redis-connection.ts:401

↓ 1 callersFunctioninitChild

()

src/classes/sandbox.ts:22

↓ 1 callersMethodinitChild

()

src/classes/child.ts:180

↓ 1 callersMethodinterpolate

* Construct the final version of a file by interpolating its includes in dependency order. * @param file - the file whose content we want to constr

src/commands/script-loader.ts:383

↓ 1 callersMethodinto_processor

(self)

rust/src/worker.rs:48

↓ 1 callersFunctioninvertObject

( obj: T, )

src/utils/index.ts:136

↓ 1 callersFunctionisBlockingCommand

(args: GlideArg[])

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

↓ 1 callersFunctionisBunConnectionClosedError

* Returns true when the error is one that Bun's Redis client throws because * the underlying TCP connection has been closed or is in the process of b

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

↓ 1 callersFunctionisClientLive

* Whether the client currently has a live connection. IORedis Cluster reports a * usable connection as `connect` rather than `ready` (see * `RedisCo

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

↓ 1 callersFunctionisEmpty

(obj: object)

src/utils/index.ts:53

↓ 1 callersMethodisFailed

Returns true if the job has failed.

python/bullmq/job.py:158

↓ 1 callersMethodisFinished

* Returns whether a job has finished and (optionally) its result.

src/interfaces/queue-backend.ts:569

↓ 1 callersMethodisJobInList

(self, list_key: str, job_id: str)

python/bullmq/scripts.py:545

↓ 1 callersMethodisMaxedArgs

()

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

↓ 1 callersFunctionisNumericSegment

* Returns true when key[from..to) is composed only of ASCII digits.

src/classes/job-scheduler.ts:31

↓ 1 callersFunctionisPgPool

(value: unknown)

src/postgres/pg-types.ts:124

← previous next →1,001–1,100 of 3,768, ranked by callers