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

Methodconstructor

( message?: string, public readonly cause?: unknown, )

src/classes/errors/connection-closed-error.ts:19

Methodconstructor

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

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

Methodconstructor

(_isAtomic: boolean)

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

Methodconstructor

()

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

Methodconstructor

(name: string, enableMetrics = false)

tests/telemetry_interface.test.ts:110

Methodconstructor

(name: string, options?: SpanOptions)

tests/telemetry_interface.test.ts:172

Methodconstructor

(public readonly config: any)

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

Methodconstructor

(config: any)

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

Methodconstructor

(public target = 'redis://localhost:6379')

tests/bun-redis-nested-duplicate.test.ts:18

Methodconstructor

(target = 'redis://localhost:6379')

tests/bun-redis-nested-duplicate.test.ts:93

Methodconstructor

(public target = 'redis://DEFAULT:6379')

tests/bun-redis.test.ts:139

Methodconsume

( conn: RedisConnection, key: String, opts: QueueEventsOptions, closing: Arc<A

rust/src/queue_events.rs:492

Methodcontinue_parent_on_failure

Let the parent continue processing even if this child fails.

rust/src/options.rs:805

Functionconvert_to_int

(text: str)

python/bullmq/scripts.py:881

Methodcount

Returns the number of jobs waiting to be processed. This includes jobs that are "waiting" or "delayed" or "prioritized" or "waiting-children".

src/classes/queue-getters.ts:89

MethodcreateBackend

* Builds the worker's backend, which owns both the regular connection and a * dedicated blocking connection used by the `waitForJob` primitive.

src/classes/worker.ts:376

MethodcreateBulk

* Creates a bulk of jobs and adds them atomically to the given queue. * * @param queue - the queue where to add the jobs. * @param jobs - an

src/classes/job.ts:282

MethodcreateClient

(config: Record<string, any>)

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

MethodcreateCounter

(name: string, options?: MetricOptions)

tests/telemetry_interface.test.ts:77

MethodcreateGauge

(name: string, options?: MetricOptions)

tests/telemetry_interface.test.ts:95

MethodcreateHistogram

(name: string, options?: MetricOptions)

tests/telemetry_interface.test.ts:86

FunctioncreateRedisBackend

( name, opts, { blocking = false, withBlockingConnection = false } = {}, )

src/utils/create-backend.ts:52

FunctioncreateRepeatableJobKey

( jobName: string, jobId: string, endDate: string, tz: string, suffix: number, )

tests/utils/repeat_utils.ts:3

FunctioncustomCommand

(args: GlideArg[])

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

MethodcustomCommand

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

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

MethodcustomCommand

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

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

MethodcustomCommand

(args: GlideArg[])

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

MethoddatabaseType

()

src/classes/redis-connection.ts:886

MethoddatabaseType

()

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

MethoddatabaseType

* Returns the database type of the Redis instance the client is connected to,

src/interfaces/script-queue-context.ts:24

Methoddeduplication

Deduplicate the job using the given options.

rust/src/queue.rs:2778

Methoddeduplication

Deduplicate the job using the given options.

rust/src/options.rs:775

rust/src/queue_events.rs:68

Methoddefault

()

rust/src/worker.rs:101

Methoddefault

()

rust/src/scripts.rs:298

Methoddefault

()

rust/src/options.rs:136

MethoddefaultJobOptions

* Returns this instance current default job options.

src/classes/queue.ts:226

FunctiondefaultRepeatStrategy

( millis: number, opts: RepeatOptions, )

src/classes/job-scheduler.ts:501

Methoddefault_job_options

Set the default job options applied to jobs added to this queue.

rust/src/flow_producer.rs:161

Methoddefault_job_options

Set the default job options merged into every job added to this queue. Only `attempts`, `backoff`, `remove_on_complete`, `remove_on_fail`, `delay`, `

rust/src/options.rs:297

MethoddefineCommand

( name: string, definition: { numberOfKeys: number; lua: string }, )

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

MethoddefineCommand

( name: string, definition: { numberOfKeys: number; lua: string }, )

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

MethoddefineCommand

( name: string, definition: { numberOfKeys: number; lua: string; readOnly?: boolean }, )

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

MethoddefineCommand

(...args: any[])

src/interfaces/redis-options.ts:41

Methoddel

(keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

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

Methoddel

(...keys: string[])

src/interfaces/redis-client.ts:276

Methoddelay

Delay before the job becomes available for processing.

rust/src/options.rs:697

MethoddeleteDeduplicationKey

(deduplicationId: string)

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

MethoddeleteDeduplicationKey

(deduplicationId: string)

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

FunctiondeleteProperty

(target, prop)

src/classes/ioredis-client.ts:337

Methoddepth

Maximum tree depth to traverse (default: 10).

rust/src/flow_producer.rs:125

Methoddeserialize

(deserializer: D)

rust/src/types.rs:141

Functiondiscard_converts_real_failures_to_unrecoverable

()

rust/src/worker.rs:2469

Functiondiscard_preserves_worker_control_flow_errors

()

rust/src/worker.rs:2460

Methoddisconnect

Disconnect from Redis

python/bullmq/redis_connection.py:124

Methoddisconnect

Force-disconnect the underlying backend connection.

python/bullmq/flow_producer.py:314

Methoddisconnect

Forcibly disconnect the backend's underlying connection(s).

python/bullmq/backend.py:58

Methoddisconnect

(self)

python/bullmq/backends/redis_backend.py:118

Methoddisconnect

(self)

python/bullmq/backends/postgres_backend.py:248

Methoddisconnect

* Forcibly tears down the connection. For PostgreSQL there is no distinct * "disconnect without waiting" semantics beyond closing, so this delegate

src/postgres/postgres-connection.ts:483

Methoddisconnect

()

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

Methoddisconnect

* * Force disconnects a connection.

src/classes/queue-base.ts:159

Methoddisconnect

(wait = true)

src/classes/redis-connection.ts:697

Methoddisconnect

* * Force disconnects a connection.

src/classes/flow-producer.ts:678

Methoddisconnect

* Forcibly disconnects the backend's underlying connection(s).

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

Methoddisconnect

(reconnect = false)

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

Methoddisconnect

(reconnect?: boolean)

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

Methoddisconnect

* Forcibly disconnects the backend's underlying connection(s).

src/interfaces/queue-backend.ts:95

Methoddisconnect

(...args: any[])

src/interfaces/redis-options.ts:38

Methoddisconnect

()

tests/child_stdio_null.test.ts:73

MethoddisconnectBlocking

(_wait = true)

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

MethoddisconnectBlocking

* Interrupts the in-flight blocking wait by disconnecting the dedicated * blocking connection. No-op if there is none.

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

Methoddrain

Drains the queue, removes all jobs that are waiting or delayed, but not active, completed or failed. @param delayed:

python/bullmq/scripts.py:645

Methoddrain

Remove waiting (and optionally delayed) jobs from the queue.

python/bullmq/backend.py:236

Methoddrain

(self, delayed: bool = False)

python/bullmq/backends/redis_backend.py:278

Methoddrain

(self, delayed: bool = False)

python/bullmq/backends/postgres_backend.py:580

Methoddrain

* Drain the queue (remove all waiting and delayed jobs). * * @param bool $delayed Whether to also drain delayed jobs * @return void

php/src/Queue.php:490

Methoddrain

Drain the queue (remove all waiting and delayed jobs).

rust/src/queue.rs:1813

Methoddrain

(delayed: boolean)

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

Methoddrain

* Drains the queue, i.e., removes all jobs that are waiting * or delayed, but not active, completed or failed. * * @param delayed - Pass true

src/classes/queue.ts:746

Methoddrain

(delayed: boolean)

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

Methoddrain_delay

Set the delay applied when the queue is drained (no jobs available). Resolution is whole seconds.

rust/src/options.rs:491

Methoddrop

(&mut self)

rust/src/worker.rs:278

Methodduplicate

(...args: any[])

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

Methodduplicate

(...args: any[])

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

Methodduplicate

(...args: any[])

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

Methodduplicate

(...args: any[])

src/interfaces/redis-options.ts:37

Methodduplicate

()

tests/bun-redis-nested-duplicate.test.ts:26

Methodduplicate

()

tests/bun-redis-nested-duplicate.test.ts:97

Methodduplicate

()

tests/bun-redis.test.ts:147

Methodembedded_scripts

Returns the embedded compiled Lua scripts as (name, num_keys, content) tuples. These are the fully resolved scripts from `rust/src/commands/` (all in

rust/src/scripts.rs:134

Methodemit

(self, event_name: str, *args, **kwargs)

python/bullmq/event_emitter.py:15

Methodemit

* Emits an event. Normally used by subclasses to emit events. * * @param event - The emitted event. * @param args - * @returns

src/interfaces/minimal-queue.ts:30

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