Functions — github.com/taskforcesh/bullmq

CodeHub MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

⨍ Functions 3,768◇ Types & classes 487↳ Endpoints 8

Return the current state of a job.

python/bullmq/backend.py:292

(self, job_id: str)

python/bullmq/backends/redis_backend.py:340

(self, job_id: str)

python/bullmq/backends/postgres_backend.py:662

* Get job state. * * @param string $jobId * @return string */

php/src/Scripts.php:342

(jobId: string)

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

* Get current state. * * @returns Returns one of these values: * 'completed', 'failed', 'delayed', 'active', 'waiting', 'waiting-children', '

src/classes/job.ts:955

(jobId: string)

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

MethodgetTrackedJobIds

* Gets a list of all tracked job IDs. * @returns Array of job IDs currently being tracked

src/classes/lock-manager.ts:218

MethodgetWaiting

* Returns the jobs that are in the "waiting" status. * @param start - zero based index from where to start returning jobs. * @param end - zero b

src/classes/queue-getters.ts:343

MethodgetWaitingChildren

* Returns the jobs that are in the "waiting-children" status. * I.E. parent jobs that have at least one child that has not completed yet. * @par

src/classes/queue-getters.ts:353

MethodgetWaitingCount

* Returns the number of jobs in waiting or paused statuses.

src/classes/queue-getters.ts:327

Methodget_active

Return jobs in the `active` state.

rust/src/queue.rs:1047

Methodget_active_count

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

rust/src/queue.rs:1233

Methodget_children_values

Get return values of all completed children of a parent job.

rust/src/queue.rs:1481

Methodget_debounce_job_id

Get the job ID that started a debounced state. Deprecated:** use [`Queue::get_deduplication_job_id`] instead. Provided for parity with the legacy Nod

rust/src/queue.rs:2158

Methodget_delayed_count

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

rust/src/queue.rs:1228

Methodget_dependencies_count

Get counts of dependencies for a parent job.

rust/src/queue.rs:1519

Methodget_failed_children_values

Get failure values of children that failed with ignoreDependencyOnFailure.

rust/src/queue.rs:1503

Methodget_global_concurrency

Return the global concurrency value, or `None` when not set.

rust/src/queue.rs:2059

Methodget_global_rate_limit

Return the global rate limit as `(max, duration)`, or `None` when not set.

rust/src/queue.rs:2073

Methodget_next_job_wrapped

python/bullmq/worker.py:181

Methodget_tracked_job_ids

python/bullmq/lock_manager.py:135

Methodget_unprocessed_dependencies

Get unprocessed dependencies (children still pending).

rust/src/queue.rs:1545

Methodget_waiting_children

Return jobs in the `waiting-children` state (parents with pending children).

rust/src/queue.rs:1042

Methodget_waiting_children_count

Return the number of jobs in the `waiting-children` state.

rust/src/queue.rs:1248

Methodget_waiting_count

Return the number of jobs in the `waiting` (and `paused`) state.

rust/src/queue.rs:1243

Methodget_workers_count

Return the number of workers currently connected to this queue.

rust/src/queue.rs:1284

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

(key: string, data: Record<string, string | number>)

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

Methodhandle_job_completed

( ctx: &LoopContext, job_id: &str, token: &str, return_value: &serde_json::Val

rust/src/worker.rs:1246

Methodhandle_job_failed

( ctx: &LoopContext, job_id: &str, token: &str, error: Error, job_atte

rust/src/worker.rs:1574

Methodhandle_retry

( ctx: &LoopContext, job_id: &str, token: &str, error: &Error, job_att

rust/src/worker.rs:1634

src/classes/ioredis-client.ts:344

MethodhasFilenamePattern

src/commands/script-loader.ts:235

MethodhasListenClientKeepAlive

* Whether TCP keepalive is enabled on the dedicated `LISTEN` connection, so a * silently dropped connection is detected (and the client rebuilt) in

src/postgres/postgres-connection.ts:363

(pattern: string | string[])

src/commands/script-loader.ts:223

MethodhasQueueMetaField

(field: string)

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

MethodhasQueueMetaField

(field: string)

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

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

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

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

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

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

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

Methodhex_upper

rust/src/options.rs:222

(key: string, field: string)

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

(key: string, field: string)

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

(key: string, field: string)

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

(key: string, field: string)

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

(key: string, field: string)

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

(key: string, field: string)

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

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

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

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

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

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

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

src/interfaces/redis-client.ts:252

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

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

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

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

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

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

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

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

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

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

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

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

( key: string, dataOrField: Record<string, string | number> | string, ...rest: any[] )

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

(key: string, data: Record<string, string | number>)

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

( key: string, dataOrField: Record<string, string | number> | string, ...rest: any[] )

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

(key: string, data: Record<string, string | number>)

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

( key: string, data: Record<string, string | number>, )

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

(key: string, data: Record<string, string | number>)

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

(key: string, data: Record<string, string | number>)

src/interfaces/redis-client.ts:253

rust/src/keys.rs:176

Methodignore_dependency_on_failure

Ignore this child's dependency on the parent when it fails.

rust/src/options.rs:793

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

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

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

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

tests/bun-redis.test.ts:160

(key: string, increment: number)

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

(key: string, increment: number)

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

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

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

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

(processorFile: string)

src/classes/child-processor.ts:39

Methodinto_future

rust/src/queue.rs:2794

MethodisClosing

* Truthy once {@link PostgresConnection.close} has begun.

src/postgres/postgres-connection.ts:439

MethodisCluster

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

MethodisFinished

( jobId: string, returnValue?: boolean, )

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

MethodisFinished

( jobId: string, returnValue = false, )

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

MethodisJobInState

Return whether a job id is present in the given state.

python/bullmq/backend.py:296

MethodisJobInState

(self, state: str, job_id: str)

python/bullmq/backends/redis_backend.py:354

MethodisJobInState

(self, state: str, job_id: str)

python/bullmq/backends/postgres_backend.py:670

MethodisJobInState

(state: string, jobId: string)

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

MethodisJobInState

* Checks whether a job with the given id is present in the provided queue * state.

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

MethodisJobScheduler

Return True if `job_scheduler_id` corresponds to a registered scheduler. Mirrors Node's `isJobScheduler`.

python/bullmq/job_scheduler.py:316

MethodisJobScheduler

Return whether ``job_scheduler_id`` is a registered scheduler.

python/bullmq/backend.py:404

MethodisJobScheduler

(self, job_scheduler_id: str)

python/bullmq/backends/redis_backend.py:478

MethodisJobScheduler

(self, job_scheduler_id: str)

python/bullmq/backends/postgres_backend.py:893

MethodisJobScheduler

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

MethodisJobScheduler

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

MethodisJobScheduler

* Checks if a given id corresponds to a registered job scheduler. * * This is used to disambiguate between new job scheduler ids (which may *

src/classes/job-scheduler.ts:440

* Check if the queue is maxed (rate limited). * * @return bool True if the queue is maxed */

php/src/Queue.php:578

* Check if queue is maxed (rate limited). * * @return bool */

php/src/Scripts.php:515

← previous next →2,301–2,400 of 3,768, ranked by callers