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

* Emits events to worker listeners.

src/interfaces/lock-manager-worker-context.ts:21

Methodencode_backoff

(backoff: &crate::types::BackoffStrategy)

rust/src/queue.rs:573

Methodencode_deduplication

(dedup: &crate::options::DeduplicationOptions)

rust/src/queue.rs:602

Methodencode_remove_on_finish

(rof: &crate::types::RemoveOnFinish)

rust/src/queue.rs:534

Methodencode_userinfo_component

rust/src/options.rs:204

src/postgres/pg-types.ts:81

* end ends the span. * * Note: spans must be ended so that they can be exported.

src/interfaces/telemetry.ts:252

tests/telemetry_interface.test.ts:196

Functionescapes_special_characters

rust/src/queue.rs:3012

( sha: string, options: { keys: string[]; arguments: NodeRedisCommandArgument[] }, )

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

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

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

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

(self, query, params=None)

python/tests/postgres_backend_test.py:116

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

(...keys: string[])

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

(...keys: string[])

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

(...keys: string[])

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

src/classes/child.ts:63

MethodextendJobLocks

Extend locks for many jobs atomically in a single Lua call. Returns the list of job ids whose lock could not be renewed (bec

python/bullmq/scripts.py:811

MethodextendJobLocks

* Public accessor method for LockManager to extend locks. * This delegates to the protected scripts object.

src/classes/worker.ts:414

MethodextendLock

(self, jobId: str, token: str, duration: int, client: Redis = None)

python/bullmq/scripts.py:806

MethodextendLock

Extend the lock of a single active job.

python/bullmq/backend.py:256

MethodextendLock

(self, job_id: str, token: str, duration: int)

python/bullmq/backends/redis_backend.py:294

MethodextendLock

(self, job_id: str, token: str, duration: int)

python/bullmq/backends/postgres_backend.py:607

MethodextendLock

( jobId: string, token: string, duration: number, )

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

MethodextendLock

* Extend the lock for this job. * * @param token - unique token for the lock * @param duration - lock duration in milliseconds

src/classes/job.ts:629

MethodextendLock

( jobId: string, token: string, duration: number, client?: RedisClient | IRedisTransaction,

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

MethodextendLocks

Extend the lock of several active jobs at once.

python/bullmq/backend.py:260

MethodextendLocks

python/bullmq/worker.py:552

MethodextendLocks

( self, job_ids: list[str], tokens: list[str], duration: int )

python/bullmq/backends/redis_backend.py:297

MethodextendLocks

( jobIds: string[], tokens: string[], duration: number, )

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

MethodextendLocks

( jobIds: string[], tokens: string[], duration: number, )

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

FunctionextractRepeatableJobChecksumFromRedisKey

( redisKey: string, )

tests/utils/repeat_utils.ts:20

Methodextract_element_as_u64

Extract the next delayed timestamp from a moveToActive result array. The script returns [data, jobId, expireTime, nextTimestamp]. Extract a u64 value

rust/src/worker.rs:2255

Methodextract_job_id

Extract a job ID from a Redis value.

rust/src/flow_producer.rs:1035

Methodfail_parent_on_failure

Fail the parent job when this child fails.

rust/src/options.rs:787

Methodfailed_reason

The reason the job failed.

rust/src/job.rs:217

(job: Job, result)

python/tests/queue_test.py:213

(content: string, match: string)

src/commands/script-loader.ts:190

Methodfinished_on

Timestamp when processing finished.

rust/src/job.rs:207

python/tests/worker_disconnect_test.py:319

Functionflow_job_new_returns_serialization_errors

rust/src/flow_producer.rs:1315

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

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

(&self, f: &mut std::fmt::Formatter<'_>)

rust/src/job.rs:34

(&self, f: &mut std::fmt::Formatter<'_>)

rust/src/types.rs:57

(&self, f: &mut std::fmt::Formatter<'_>)

rust/src/options.rs:76

Return a sibling backend bound to a different queue that shares this backend's underlying connection(s). Used by :class:`FlowProducer`.

python/bullmq/backend.py:66

(self, queue_name: str, prefix: Optional[str] = None)

python/bullmq/backends/redis_backend.py:126

(self, queue_name: str, prefix: Optional[str] = None)

python/bullmq/backends/postgres_backend.py:254

(self, queue_name: str, prefix: str | None = None)

python/tests/flow_producer_test.py:15

(queueName: string, _prefix?: string)

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

* Returns a sibling backend bound to a different queue that shares this * backend's connection(s). Used by {@link FlowProducer} to operate on the

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

Functionformat_duration

rust/examples/benchmark.rs:27

Functionformat_number

rust/examples/benchmark.rs:35

FunctionforwardConnectionError

( emitter: EventEmitter, connection: EventEmitter, )

src/utils/index.ts:111

MethodfromMetadata

(activeContext: Context, metadataString: string)

tests/telemetry_interface.test.ts:154

Fetch a job from Redis by ID.

rust/src/job.rs:1495

Methodfrom_queue_options

Convenience constructor that derives options from [`QueueOptions`].

rust/src/queue_events.rs:405

Methodfrom_redis_hash

Deserialize a job from Redis hash fields.

rust/src/job.rs:1429

Methodfrom_redis_str

Parse a state from its Redis string representation.

rust/src/types.rs:42

Methodfrom_script_code

Create a script error from an error code returned by Lua.

rust/src/error.rs:117

src/classes/ioredis-client.ts:294

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

(&self, suffix: &str)

rust/src/keys.rs:78

Get a script by name.

rust/src/scripts.rs:100

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

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

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

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

tests/bun-redis.test.ts:154

MethodgetActive

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

python/bullmq/queue.py:407

MethodgetActive

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

src/classes/queue-getters.ts:362

MethodgetBackend

* Returns the datastore backend that powers this instance. * * The backend owns its connection(s) and exposes every datastore-agnostic * oper

src/classes/queue-base.ts:97

MethodgetBackend

* Returns the datastore backend that powers this flow producer. * * The backend owns its connection and exposes every datastore-agnostic * op

src/classes/flow-producer.ts:197

src/classes/flow-producer.ts:589

MethodgetClientList

Return the raw worker/client list(s) for the queue's datastore.

python/bullmq/backend.py:336

MethodgetClientList

python/bullmq/backends/redis_backend.py:402

MethodgetClientList

python/bullmq/backends/postgres_backend.py:746

MethodgetClientList

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

MethodgetClientList

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

MethodgetCompleted

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

src/classes/queue-getters.ts:389

MethodgetCompletedCount

* @returns Returns the number of jobs in completed status.

src/classes/queue-getters.ts:275

MethodgetCounts

python/bullmq/scripts.py:510

MethodgetCounts

Return the job counts across the given states/types, in order.

python/bullmq/backend.py:314

MethodgetCounts

(self, types: list)

python/bullmq/backends/redis_backend.py:382

MethodgetCounts

(self, types: list)

python/bullmq/backends/postgres_backend.py:696

MethodgetCounts

* Get job counts by types. * * @param array<string> $types * @return array<int> */

php/src/Scripts.php:305

MethodgetCounts

(types: JobType[])

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

MethodgetCounts

(types: JobType[])

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

MethodgetCountsPerPriority

(self, priorities)

python/bullmq/scripts.py:525

MethodgetCountsPerPriority

Return the number of jobs per priority, in order.

python/bullmq/backend.py:318

MethodgetCountsPerPriority

(self, priorities: list)

python/bullmq/backends/redis_backend.py:385

MethodgetCountsPerPriority

(self, priorities: list)

python/bullmq/backends/postgres_backend.py:716

MethodgetCountsPerPriority

* Get counts per priority. * * @param array<int> $priorities Array of priority levels to count * @return array<int, int> Priority to co

php/src/Queue.php:258

MethodgetCountsPerPriority

* Get counts per priority. * * @param array<int> $priorities * @return array<int> */

php/src/Scripts.php:324

MethodgetCountsPerPriority

(priorities: number[])

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

MethodgetCountsPerPriority

* Returns the number of jobs per priority.

src/classes/queue-getters.ts:310

MethodgetCountsPerPriority

(priorities: number[])

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

← previous next →2,101–2,200 of 3,768, ranked by callers