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

↓ 458 callersFunctiontest_queue_name

Generate a unique queue name for test isolation.

rust/tests/common/mod.rs:10

↓ 444 callersFunctioncleanup_queue

Clean up a queue after testing.

rust/tests/common/mod.rs:28

↓ 426 callersMethodadd

* Adds a value to the counter. * * @param value - the value to add (must be non-negative) * @param attributes - optional attributes to associ

src/interfaces/telemetry.ts:104

↓ 420 callersFunctiontest_connection

()

rust/tests/common/mod.rs:19

↓ 410 callersMethodclose

* Closes the backend and its underlying connection(s), waiting for any * in-flight work to settle. * * @param force - When `true`, forcibly t

src/interfaces/queue-backend.ts:82

↓ 266 callersMethodget

(key: string)

src/interfaces/redis-client.ts:111

↓ 165 callersMethodpush

(value: T)

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

↓ 144 callersMethodid

The job's unique ID.

rust/src/job.rs:155

↓ 124 callersMethodclose

Close the queue instance.

python/bullmq/queue.py:469

↓ 102 callersMethodnext_event

Receive the next worker event.

rust/src/worker.rs:691

↓ 101 callersMethodsend

(message: any, callback?: (error: Error | null) => void)

src/utils/index.ts:273

↓ 94 callersMethodoptions

Use `opts` as the base options, replacing anything set so far. Useful for reusing a prepared [`JobOptions`]; subsequent setters still override indivi

rust/src/queue.rs:2711

↓ 93 callersFunctiontest_flow_producer

Helper to create a FlowProducer with test connection.

rust/tests/flow_test.rs:22

↓ 93 callersFunctiontest_queue_with_prefix

Helper to create a Queue with a specific prefix.

rust/tests/flow_test.rs:31

↓ 88 callersMethodadd

Adds a new job to the queue. @param name: Name of the job to be added to the queue,. @param data: Arbitrary data to append t

python/bullmq/queue.py:40

↓ 88 callersMethodconn

Get a clone of the multiplexed connection for concurrent use.

rust/src/redis_connection.rs:80

↓ 79 callersMethodget_job_counts

Get the counts of jobs in each state.

rust/src/queue.rs:751

↓ 71 callersMethodupsert_job_scheduler

Create or update a job scheduler. Creates a scheduled repeating job that will run on a cron pattern or at fixed intervals. The scheduler is persisted

rust/src/queue.rs:2322

↓ 66 callersMethodget_job

Get a job by its ID.

rust/src/queue.rs:742

↓ 65 callersFunctionprocessor

(f: F)

rust/tests/flow_test.rs:44

↓ 64 callersMethodget_job_state

Get the state of a specific job.

rust/src/queue.rs:1602

↓ 62 callersMethodclose

Closes the worker and related redis connections. This method waits for current jobs to finalize before returning.

python/bullmq/worker.py:578

↓ 62 callersFunctiondelay

( ms: number, abortController?: AbortController, )

src/utils/index.ts:84

↓ 60 callersMethodtoKey

* Builds a namespaced sub-key/identifier of the given `type` for this queue * (e.g. a job's `"<qualifiedName>:<id>:dependencies"` key).

src/interfaces/queue-backend.ts:183

↓ 58 callersMethodwaitUntilReady

()

src/interfaces/connection.ts:7

↓ 57 callersMethodload

Loads this migration's SQL from its `.sql` file.

src/postgres/migrations/index.ts:16

↓ 53 callersMethodscripts

Get the script registry.

rust/src/redis_connection.rs:85

↓ 52 callersMethodon

(event: 'error', listener: (err: Error) => void)

src/postgres/pg-types.ts:90

↓ 50 callersMethodexecute

Execute this script via EVALSHA, falling back to EVAL on NOSCRIPT.

rust/src/scripts.rs:35

↓ 48 callersMethod_run

(self, command: str, params: list, *, op=None, job_id=None, parent_key=None, state=None)

python/bullmq/backends/postgres_backend.py:226

↓ 47 callersMethodexecCommand

* Executes a registered Lua script on the given Redis client, resolving the * versioned command name (e.g. `addJob:<packageVersion>`) so the script

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

↓ 47 callersMethodquit

()

src/interfaces/redis-client.ts:37

↓ 45 callersMethoddata

The job's data payload.

rust/src/job.rs:165

↓ 44 callersMethodwait

(&self)

rust/src/keys.rs:86

↓ 43 callersMethodkeys

(pattern: string)

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

↓ 42 callersMethodrunRawCommand

( args: GlideArg[], options?: GlideCommandOptions, )

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

↓ 40 callersMethodsendCommand

( command: string, args: RedisCommandArgument[], )

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

↓ 39 callersMethodemit

(event: string | symbol, ...args: any[])

src/interfaces/redis-client.ts:50

↓ 39 callersMethodon

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

src/classes/worker.ts:453

↓ 37 callersMethodpause

* Pauses or resumes the whole queue.

src/interfaces/queue-backend.ts:393

↓ 36 callersMethodObliterateAsync

<summary>Completely destroys the queue and all of its contents irreversibly.</summary>

dotnet/src/BullMQ/Queue.cs:324

↓ 35 callersFunctioncreateTestConnection

( opts?: ConnectionFactoryOpts, )

tests/utils/connection-factory.ts:30

↓ 35 callersMethodremove

* Removes a job and (optionally) its children. * @returns `1` if removed, `0` if it (or a dependency) was locked.

src/interfaces/queue-backend.ts:488

↓ 34 callersMethodrun

Start processing jobs.

rust/src/worker.rs:696

↓ 33 callersMethodAdd

(string key, object? value)

dotnet/src/BullMQ/JobScheduler.cs:173

↓ 29 callersMethodAddAsync

( IQueueBackend backend, string name = "job", object? data = null, JobsOptions? opts = null)

dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:43

↓ 29 callersMethodFirstMap

<summary>The first row as a column -> value map, or null when empty.</summary>

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

↓ 29 callersMethodsetAttributes

* setAttributes sets multiple attributes on the span. * * @param attributes - attributes to set

src/interfaces/telemetry.ts:229

↓ 28 callersMethodEvalAsync

<summary> Evaluates a shared Lua command by name, letting StackExchange.Redis cache the script hash and transparently fall back from <c>EVALSHA</c> to

dotnet/src/BullMQ/Redis/RedisConnection.cs:84

↓ 27 callersMethodfirst_map

The first row as a ``column -> value`` dict, or ``None``.

python/bullmq/backends/postgres_connection.py:83

↓ 27 callersMethodfrom

(k: KeepJobs)

rust/src/options.rs:844

↓ 27 callersMethodgetState

* Returns the current state of a job.

src/interfaces/queue-backend.ts:564

↓ 26 callersMethodjob_key

(&self, job_id: &str)

rust/src/keys.rs:72

↓ 24 callersMethodonce

(event: string, listener: (...args: any[]) => void)

src/interfaces/redis-client.ts:47

↓ 23 callersMethoddisconnect

(reconnect?: boolean)

src/interfaces/redis-client.ts:36

↓ 23 callersMethodgetJob

* Get a job by its ID. * * @param string $jobId The job ID * @return Job|null The job, or null if not found */

php/src/Queue.php:276

↓ 23 callersFunctiontoStringValue

(value: unknown)

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

↓ 22 callersFunctioncleanupQueue

( queueName: string, prefix: string = DEFAULT_PREFIX, )

tests/utils/cleanup-queue.ts:19

↓ 22 callersMethodconnect

()

src/postgres/pg-types.ts:88

↓ 22 callersMethodlog

* Logs one row of log data. * * @param logRow - string with log data to be logged.

src/interfaces/minimal-job.ts:156

↓ 21 callersMethodmeta

(&self)

rust/src/keys.rs:158

↓ 20 callersMethodEncode

<summary>Applies short-form encoding to the keys of an options map.</summary>

dotnet/src/BullMQ/OptsCodec.cs:27

↓ 20 callersMethodaddBulk

* Adds multiple jobs to the queue in bulk. * * @param array<array{name: string, data: mixed, opts?: JobOptions|array<string, mixed>}> $jobs

php/src/Queue.php:146

↓ 20 callersMethodas_str

Returns the Redis key suffix for this state.

rust/src/types.rs:28

↓ 20 callersMethodgetKeys

(self, keys: list[str])

python/bullmq/scripts.py:46

↓ 20 callersMethodname

The job's name.

rust/src/job.rs:160

↓ 20 callersMethodon

(event: string, listener: (...args: any[]) => void)

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

↓ 20 callersMethodresume

(&self)

rust/src/queue.rs:703

↓ 19 callersMethodemit

( event: U, ...args: Parameters< WorkerListener<DataType, ResultType, NameType, ProgressType>[U]

src/classes/worker.ts:422

↓ 19 callersMethodgetJobCounts

* Get job counts for all states. * * @return array{waiting: int, active: int, delayed: int, completed: int, failed: int, paused: int, priori

php/src/Queue.php:239

↓ 19 callersMethodkey_prefix

(&self)

rust/src/keys.rs:66

↓ 19 callersMethodset

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

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

↓ 18 callersFunction_to_int

(value: Any)

python/bullmq/backends/postgres_backend.py:104

↓ 18 callersMethodget

(key: string)

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

↓ 17 callersMethodfromId

(queue: Queue, jobId: str)

python/bullmq/job.py:360

↓ 17 callersMethodgetJobCountByTypes

* Get the total count of jobs in a specific state. * * @param string ...$types The job states to count (waiting, active, delayed, completed,

php/src/Queue.php:228

↓ 17 callersFunctionmake_events

Build QueueEvents that reads the full stream history (`"0"`), which removes the start-up race for freshly-created, uniquely-named test queues.

rust/tests/queue_events_test.rs:22

↓ 17 callersMethodobliterate

* Irreversibly destroys the queue and all of its contents. * @returns A cursor; `0` when obliteration is complete.

src/interfaces/queue-backend.ts:414

↓ 17 callersMethodset

( key: string, value: string | number, options?: { PX?: number; EX?: number }, )

src/interfaces/redis-client.ts:112

↓ 17 callersMethodupdateData

* Updates a job's data * * @param data - the data that will replace the current jobs data.

src/interfaces/minimal-job.ts:144

↓ 16 callersMethodCloseAsync

<summary>Closes the queue and its connection (when owned).</summary>

dotnet/src/BullMQ/Queue.cs:338

↓ 16 callersMethoddel

(...keys: string[])

src/interfaces/redis-client.ts:117

↓ 16 callersMethodfinishedErrors

({ code, jobId, parentKey, command, state, }: { code: number; jobId?: string;

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

↓ 16 callersFunctiongetRedisClient

( target: RedisBackedTarget, )

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

↓ 16 callersMethodhgetall

(key: string)

src/interfaces/redis-client.ts:99

↓ 16 callersFunctionremoveAllQueueData

( client: RemoveAllQueueDataClient, queueName: string, prefix = process.env.BULLMQ_TEST_PREFIX || 'bull'

src/utils/index.ts:199

↓ 16 callersMethodtoKey

(self, name: str)

python/bullmq/scripts.py:43

↓ 15 callersMethodRunAsync

<summary> Starts processing (only needed when <see cref="WorkerOptions.Autorun"/> is disabled). Returns a task that completes when the worker stops. <

dotnet/src/BullMQ/Worker.cs:128

↓ 15 callersFunction_now_ms

()

python/bullmq/backends/postgres_backend.py:81

↓ 15 callersMethodexecScript

* Execute a Lua script. * * @param string $scriptName * @param array<string> $keys * @param array<mixed> $args * @return mixe

php/src/Scripts.php:92

↓ 15 callersFunctionfinishedErrors

({ code, jobId, parentKey, command, state, }: { code: number; jobId?: string; parentKey?: stri

src/classes/finished-errors.ts:11

↓ 15 callersFunctionwait_for

Wait until an event matching `pred` is observed, or panic after `secs`.

rust/tests/queue_events_test.rs:37

↓ 14 callersMethodSerialize

(object? value)

dotnet/src/BullMQ/OptsCodec.cs:123

↓ 14 callersMethodabort

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

python/bullmq/abort_controller.py:86

↓ 14 callersFunctionafter

(n: number, func: F)

tests/utils/lodash.ts:1

↓ 14 callersMethodgetKeys

* Get keys by their names. * * @param array<string> $keyNames * @return array<string> */

php/src/Scripts.php:64

↓ 14 callersMethodget_dependencies_count

Get the count of dependencies by type. Returns counts of processed, unprocessed, failed, and ignored children.

rust/src/job.rs:377

↓ 14 callersMethodget_job_scheduler

Get a job scheduler by its ID.

rust/src/queue.rs:2482

↓ 14 callersMethodrun

* Loads a named `.sql` command file and runs it. The files contain no * schema/namespace references — the connection's `search_path` selects the

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

↓ 14 callersMethodupdate_data

Update job data in Redis.

rust/src/job.rs:673

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