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

MethodonCompleted

src/classes/job.ts:1120

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

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

FunctiononError

tests/events.test.ts:441

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

src/classes/job.ts:1125

MethodonMessageHandler

src/classes/child.ts:182

(msg: PgNotification)

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

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

FunctiononUnhandled

tests/connection.test.ts:688

FunctiononUnhandled

tests/bun-redis.test.ts:391

Methodon_active

python/tests/worker_test.py:99

(args, event_id)

python/tests/queue_events_test.py:40

Methodon_completed

(args, event_id)

python/tests/queue_events_test.py:72

Methodon_completed

(completed_job, result)

python/tests/worker_test.py:612

Methodon_completed2

(completed_job, result)

python/tests/worker_test.py:738

Methodon_custom

(args, event_id)

python/tests/queue_events_test.py:163

Methodon_failed

python/tests/worker_test.py:587

Methodon_finished

(job: Job, result)

python/tests/queue_test.py:746

Methodon_parent_processed

python/tests/flow_test.py:193

Methodon_target

(args, event_id)

python/tests/queue_events_test.py:115

( event: U, listener: QueueListener<JobBase<DataType, ResultType, NameType>>[U], )

src/classes/queue.ts:215

( event: U, listener: FlowProducerListener[U], )

src/classes/flow-producer.ts:169

(event: U, listener: QEL[U])

src/classes/queue-events.ts:323

( event: 'ready' | 'error' | 'close', listener: (...args: any[]) => void, )

src/interfaces/queue-backend.ts:130

Set the job options.

rust/src/flow_producer.rs:67

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

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

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

Methodpack_update_scheduler_opts

Pack job options into msgpack format for the updateJobScheduler script.

rust/src/worker.rs:1446

( status: string, cursor = 0, count = 20, )

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

( key: string, opts: { start: number; end: number; fetchJobs?: boolean }, )

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

* Paginate a set or hash keys. * @param opts - options to define the pagination behaviour *

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

Methodpaginate_item_key

Extract the key from a paginate item: a bare member (set) or the field of a `[field, value]` pair (hash).

rust/src/flow_producer.rs:615

Attach this job to a parent job (flow / dependency chains).

rust/src/queue.rs:2772

Attach this job to a parent job (flow / dependency chains).

rust/src/options.rs:769

FunctionparentProcessor

tests/flow.test.ts:722

Methodparent_process

(job: Job, token: str)

python/tests/worker_test.py:429

Functionparent_state_should_be_waiting_children_after_add

rust/tests/flow_test.rs:448

MethodparseNodeKey

* Parses a PostgreSQL flow child key (`"<queue>:<id>"`) into its components. * There is no keyspace prefix, so `prefix` is always empty. Inverse of

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

MethodparseNodeKey

* Parses a Redis flow child key (`"<prefix>:<queue>:<id>"`) into its * components. Inverse of {@link toKey}.

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

Methodparse_added_job_id

(result: redis::Value)

rust/src/queue.rs:644

Methodparse_child_key

Parse a child job key as `prefix:queueName:jobId`.

rust/src/flow_producer.rs:1107

Functionparse_child_key_preserves_job_id_segments

rust/src/flow_producer.rs:1300

Functionparse_child_key_rejects_incomplete_keys

rust/src/flow_producer.rs:1308

Methodparse_hash_array

Parse a Redis hash array (alternating key/value) into a HashMap.

rust/src/queue.rs:2615

Methodparse_move_to_active_result

Parse the result of moveToActive script into a Job.

rust/src/worker.rs:2183

Methodparse_paginate_result

Parse the `paginate` reply `[cursor, offset, items, numItems, jobs]` into `(cursor, offset, item_keys)`. For hashes each item is a `[field, value]` pa

rust/src/flow_producer.rs:585

Functionparse_paginate_result_handles_hash_fields

rust/src/flow_producer.rs:1350

Functionparse_paginate_result_handles_set_members

rust/src/flow_producer.rs:1332

Functionparses_active_and_waiting_with_prev

rust/src/queue_events.rs:704

Functionparses_added_cleaned_and_removed

rust/src/queue_events.rs:729

Functionparses_completed_event

rust/src/queue_events.rs:599

Functionparses_deduplicated_and_duplicated

rust/src/queue_events.rs:784

Functionparses_delayed_number

rust/src/queue_events.rs:650

Functionparses_drained

rust/src/queue_events.rs:666

Functionparses_failed_event

rust/src/queue_events.rs:685

Functionparses_paused_resumed_and_error

rust/src/queue_events.rs:807

Functionparses_progress_json

rust/src/queue_events.rs:619

Functionparses_progress_string_fallback

rust/src/queue_events.rs:635

Functionparses_retries_exhausted_and_waiting_children

rust/src/queue_events.rs:761

Pause or resume a queue

python/bullmq/scripts.py:623

Pause or resume the whole queue.

python/bullmq/backend.py:232

Pauses the worker, preventing it from processing new jobs. This method waits for current jobs to finalize before returning.

python/bullmq/worker.py:607

(self, paused: bool = True)

python/bullmq/backends/redis_backend.py:275

(self, paused: bool = True)

python/bullmq/backends/postgres_backend.py:576

* Pause or resume the queue. * * @param bool $pause True to pause, false to resume * @return mixed */

php/src/Scripts.php:290

Pause the worker (finish active jobs but don't fetch new ones).

rust/src/worker.rs:719

rust/src/queue.rs:674

(pause: boolean)

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

(pause: boolean)

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

* * Pauses the processing of this queue only for this worker.

src/classes/worker.ts:1196

src/classes/child.ts:51

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

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

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

Methodpipeline_script_names

(node: &FlowJob)

rust/src/flow_producer.rs:713

Override the key prefix for this job (defaults to the producer's prefix).

rust/src/flow_producer.rs:73

rust/src/keys.rs:188

Set the key prefix for all queue keys.

rust/src/options.rs:288

* @returns the prefix that is used.

src/classes/job.ts:938

Job priority. Lower values are processed first; unset (or `0`) means the job is not prioritized and follows normal FIFO/LIFO ordering.

rust/src/options.rs:704

Functionprocess

(job: Job, token: str)

python/benchmark_backends.py:104

(job: Job, token: str)

python/tests/queue_test.py:202

(job: Job, token: str)

python/tests/bulk_test.py:32

(job, token=None)

python/tests/job_scheduler_test.py:100

(job: Job, token: str)

python/tests/delay_test.py:35

(job: Job, token: str)

python/tests/lock_manager_test.py:44

(job: Job, token: str, signal: AbortSignal)

python/tests/job_cancellation_test.py:86

(job: Job, token: str)

python/tests/worker_test.py:40

(job: Job, token: str)

python/tests/flow_test.py:42

(job: Job, token: str)

python/tests/worker_test.py:317

(job: Job, token: str)

python/tests/flow_test.py:51

(job: Job, token: str)

python/tests/worker_test.py:328

Methodprocess_child

(job: Job, token: str)

python/tests/flow_test.py:225

Methodprocess_fetched_job

Process a job that was successfully fetched from the queue. Returns the next job to process when the finishing script fetched one in the same round-t

rust/src/worker.rs:1052

Methodprocess_parent

(job: Job, token: str)

python/tests/flow_test.py:230

Methodprocessed_by

The worker name that processed this job.

rust/src/job.rs:237

Methodprocessed_on

Timestamp when processing started.

rust/src/job.rs:212

Functionprocessing_is_not_drained_while_fetcher_is_chaining_next_job

rust/src/worker.rs:2482

← previous next →2,601–2,700 of 3,768, ranked by callers