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

MethodcleanJobsByState

( state: string, timestamp: number, limit = 0, )

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

MethodcleanJobsByState

* Remove jobs in a specific state. * * @returns Id jobs from the deleted records.

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

MethodcleanJobsInSet

Remove jobs in a given state that are older than ``grace`` ms.

python/bullmq/backend.py:240

MethodcleanJobsInSet

(self, set: str, grace: int = 0, limit: int = 0)

python/bullmq/backends/redis_backend.py:281

MethodcleanJobsInSet

(self, set: str, grace: int = 0, limit: int = 0)

python/bullmq/backends/postgres_backend.py:584

Methodcleanup

()

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

Methodcleanup

()

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

MethodclearLogs

(jobId: string, keepLogs?: number)

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

MethodclearLogs

* Clears job's logs * * @param keepLogs - the amount of log entries to preserve

src/classes/job.ts:583

MethodclearLogs

(jobId: string, keepLogs?: number)

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

Methodclient

Get the underlying client for creating additional connections.

rust/src/redis_connection.rs:102

Methodclient

()

src/classes/redis-connection.ts:379

Methodclient

()

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

Methodclient

* Returns a promise that resolves to a redis client. Normally used only by subclasses.

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

MethodclientList

()

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

MethodclientList

()

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

MethodclientList

()

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

MethodclientName

Build the connection client name (used for ``setName`` and discovery).

python/bullmq/backend.py:111

MethodclientName

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

python/bullmq/backends/redis_backend.py:164

MethodclientName

* Returns a backend identifier used by the generic API; PostgreSQL discovery * relies on {@link setName} setting `application_name` on the dedicate

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

MethodclientName

(suffix = '')

src/classes/queue-base.ts:139

MethodclientName

* Builds the Redis client name (`"<prefix>:<base64(queue)><suffix>"`), used * for `CLIENT SETNAME` and worker/queue discovery via `CLIENT LIST`.

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

MethodclientSetName

(name: string)

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

MethodclientSetName

(name: string)

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

Methodclose

Close the backend and its owned connection(s). When ``force`` is ``True`` the connection(s) are torn down without waiting for in-flig

python/bullmq/backend.py:50

Methodclose

Cancel the renewal loop and forget all tracked jobs. Idempotent.

python/bullmq/lock_manager.py:141

Methodclose

(self)

python/bullmq/backends/postgres_connection.py:287

Methodclose

* Close the Redis connection. */

php/src/RedisConnection.php:56

Methodclose

Close the connection.

rust/src/redis_connection.rs:119

Methodclose

Stop consuming events and release the dedicated connection.

rust/src/queue_events.rs:577

Methodclose

(force = false)

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

Methodclose

* * Closes the connection and returns a promise that resolves when the connection is closed.

src/classes/queue-base.ts:147

Methodclose

(force = false)

src/classes/redis-connection.ts:756

Methodclose

* Close the queue instance. *

src/classes/queue.ts:507

Methodclose

* * Closes the connection and returns a promise that resolves when the connection is closed.

src/classes/flow-producer.ts:667

Methodclose

* Closes the backend and its underlying connection(s). * * The dedicated blocking connection (if any) is closed first so that an * in-flight

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

Methodclose

* Closes the connection and returns a promise that resolves when the connection is closed.

src/classes/queue-events-producer.ts:48

Methodclose

()

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

Methodclose

* Stops consuming events and close the underlying Redis connection if necessary. * * @returns

src/classes/queue-events.ts:409

Methodclose

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

src/classes/worker.ts:1289

Methodclose

* Stops the lock manager and clears all timers.

src/classes/lock-manager.ts:132

Methodclose

(...args: any[])

src/interfaces/redis-options.ts:39

Methodclose

()

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

Methodclose

()

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

Methodclose

()

tests/bun-redis.test.ts:144

Methodclosing

()

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

Methodcollect_pipeline_script_names

(node: &FlowJob, names: &mut Vec<&'static str>)

rust/src/flow_producer.rs:719

Methodcompleting

(job: Job, result)

python/tests/queue_test.py:237

Methodcompleting

(job: Job, result)

python/tests/bulk_test.py:46

Methodcompleting

(job: Job, result)

python/tests/delay_test.py:42

Methodcompleting

(job: Job, result)

python/tests/worker_test.py:371

Methodcompleting1

(job: Job, result)

python/tests/queue_test.py:272

Methodcompleting2

(job: Job, result)

python/tests/queue_test.py:295

Methodconcurrency

The worker's concurrency setting.

rust/src/worker.rs:656

Methodconcurrency

Set how many jobs are processed concurrently.

rust/src/options.rs:459

Methodconcurrency

(concurrency: number)

src/classes/worker.ts:535

Methodconn

The raw main Redis client.

python/bullmq/backends/redis_backend.py:77

Methodconnect

()

src/postgres/pg-types.ts:80

Methodconnect

()

src/interfaces/redis-client.ts:35

Methodconnect

(...args: any[])

src/interfaces/redis-options.ts:36

Methodconnect

()

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

Methodconnect

()

tests/bun-redis.test.ts:140

Methodconnection

Set the Redis connection configuration.

rust/src/flow_producer.rs:203

Methodconnection

Set the Redis connection configuration.

rust/src/options.rs:282

Methodconstructor

( message: string, path: string, stack: string[] = [], line?: number, position = 0, )

src/commands/script-loader.ts:66

Methodconstructor

(extraMappings?: { [key: string]: string })

src/commands/script-loader.ts:101

Methodconstructor

( public readonly serverVersion: string, public readonly minimumVersion: number, )

src/postgres/migrator.ts:50

Methodconstructor

( public readonly minimumClientVersion: number, public readonly clientVersion: number, )

src/postgres/migrator.ts:117

Methodconstructor

(public readonly schema: string)

src/postgres/migrator.ts:134

Methodconstructor

(connection: PostgresConnectionOptions)

src/postgres/postgres-connection.ts:186

Methodconstructor

( public connection: PostgresConnection, protected readonly queueName: string, protected readonly

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

Methodconstructor

( protected queue: MinimalQueue, /** * The name of the Job */ public name: NameType,

src/classes/job.ts:178

Methodconstructor

* * @param name - The name of the queue. * @param opts - Options for the queue. * @param backendFactory - Factory used to build the {@link IQ

src/classes/queue-base.ts:43

Methodconstructor

( opts: ConnectionOptions, private readonly extraOptions?: { shared?: boolean; blocking?:

src/classes/redis-connection.ts:204

Methodconstructor

( name: string, opts?: QueueOptions, backendFactory?: BackendFactory<B>, )

src/classes/queue.ts:161

Methodconstructor

( public opts: FlowProducerOptions = { connection: {} }, backendFactory: BackendFactory<B> = getDefaul

src/classes/flow-producer.ts:116

Methodconstructor

( public connection: RedisConnection, protected readonly name: string, keys: KeysMap, toKey: (

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

Methodconstructor

( name: string, opts: QueueEventsProducerOptions = { connection: {}, }, backendFactory?:

src/classes/queue-events-producer.ts:8

Methodconstructor

( private send: (msg: any) => Promise<void>, private receiver: Receiver, )

src/classes/child-processor.ts:34

Methodconstructor

( name: string, opts: RepeatBaseOptions, backendFactory?: BackendFactory, )

src/classes/job-scheduler.ts:99

Methodconstructor

(private readonly raw: TClient)

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

Methodconstructor

( private readonly raw: any, private readonly scripts: Map<string, LuaScript>, )

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

Methodconstructor

( name: string, { connection, autorun = true, ...opts }: QueueEventsOptions = { connection: {},

src/classes/queue-events.ts:263

Methodconstructor

(public readonly prefix = 'bull')

src/classes/queue-keys.ts:4

Methodconstructor

({ mainFile = supportCJS() ? path.join(process.cwd(), 'dist/cjs/classes/main.js') : path.join(

src/classes/child-pool.ts:24

Methodconstructor

( private raw: TClient, opts?: { lazyConnect?: boolean; rawFactory?: () => Promise<TClient

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

Methodconstructor

( private readonly scripts: Map<string, LuaScript>, private readonly transactional: boolean, priva

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

Methodconstructor

( name: string, processor?: | string | URL | null | Processor<DataType, Result

src/classes/worker.ts:231

Methodconstructor

(value: T)

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

Methodconstructor

()

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

Methodconstructor

(private ignoreErrors = false)

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

Methodconstructor

( private mainFile: string, public processFile: string, private opts: SandboxedOptions = { u

src/classes/child.ts:41

Methodconstructor

( protected worker: LockManagerWorkerContext, protected opts: LockManagerOptions, )

src/classes/lock-manager.ts:27

Methodconstructor

( rawOrPromise: ValkeyGlideRawClient | Promise<ValkeyGlideRawClient>, private readonly connectionName?

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

Methodconstructor

( private readonly adapter: ValkeyGlideAdapter, private readonly scripts: Map<string, LuaScript>, )

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

Methodconstructor

(message: string = UNRECOVERABLE_ERROR)

src/classes/errors/unrecoverable-error.ts:11

Methodconstructor

(message: string = RATE_LIMIT_ERROR)

src/classes/errors/rate-limit-error.ts:10

Methodconstructor

(message: string = DELAYED_ERROR)

src/classes/errors/delayed-error.ts:11

Methodconstructor

(message: string = WAITING_ERROR)

src/classes/errors/waiting-error.ts:10

Methodconstructor

(message: string = WAITING_CHILDREN_ERROR)

src/classes/errors/waiting-children-error.ts:11

← previous next →1,901–2,000 of 3,768, ranked by callers