MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

MethodisMaxed
()
src/postgres/postgres-queue-backend.ts:1517
MethodisMaxed
* Returns true if the queue is currently maxed.
src/classes/queue.ts:557
MethodisMaxed
()
src/classes/redis-queue-backend.ts:1678
MethodisPaused
Return whether the queue is currently paused.
python/bullmq/backend.py:332
MethodisPaused
(self)
python/bullmq/backends/redis_backend.py:396
MethodisPaused
(self)
python/bullmq/backends/postgres_backend.py:742
MethodisPaused
* Returns true if the queue is currently paused.
src/classes/queue.ts:550
MethodisPaused
* * Checks if worker is paused. * * @returns true if worker is paused, false otherwise.
src/classes/worker.ts:1263
MethodisRunning
* Checks if the lock manager is running.
src/classes/lock-manager.ts:183
MethodisVersionLowerThan
* Check if the Redis version is lower than the specified version. */
php/src/RedisConnection.php:98
MethodisWaitingChildren
Returns true if the job is waiting for children.
python/bullmq/job.py:170
Methodis_active
Check if the job is active (being processed).
rust/src/job.rs:909
Methodis_completed
Check if the job is completed.
rust/src/job.rs:899
Methodis_delayed
Check if the job is delayed.
rust/src/job.rs:919
Methodis_discarded
Whether [`Job::discard`] has been called on this job.
rust/src/job.rs:278
Methodis_failed
Check if the job has failed.
rust/src/job.rs:904
Methodis_paused
Whether the worker is paused.
rust/src/worker.rs:681
Methodis_paused
Check if the queue is paused.
rust/src/queue.rs:731
Methodis_running
(self)
python/bullmq/lock_manager.py:138
Methodis_running
Whether the consuming loop is currently running.
rust/src/queue_events.rs:455
Methodis_running
Whether the worker is currently running.
rust/src/worker.rs:676
Methodis_unreserved_userinfo_byte
(b: u8)
rust/src/options.rs:218
Methodis_waiting
Check if the job is waiting.
rust/src/job.rs:914
Methodis_waiting_children
Check if the job is waiting for its children to complete.
rust/src/job.rs:924
MethodjobScheduler
Lazily-instantiated JobScheduler that shares this worker's backend (same queue). Created on first use so that workers which never
python/bullmq/worker.py:264
MethodjobScheduler
Lazily-instantiated JobScheduler bound to this queue. Created on first use so that queues which never schedule pay no cost.
python/bullmq/queue.py:479
MethodjobScheduler
()
src/classes/queue.ts:251
MethodjobScheduler
()
src/classes/worker.ts:550
Methodjob_id
The job id associated with this event, if any.
rust/src/queue_events.rs:220
Methodjob_id
Use a custom, unique job id instead of an auto-generated one.
rust/src/queue.rs:2748
Methodjob_id
Use a custom, unique job id instead of an auto-generated one.
rust/src/options.rs:746
Functionjob_id_and_name_helpers_are_consistent
()
rust/src/queue_events.rs:825
Methodkeep_logs
Maximum number of log entries to retain for the job.
rust/src/queue.rs:2766
Methodkeep_logs
Maximum number of log entries to retain for the job.
rust/src/options.rs:740
Functionkeeps_url_without_userinfo
()
rust/src/redis_connection.rs:271
Methodkeys
The map of named sub-keys/identifiers for the queue.
python/bullmq/backend.py:103
Methodkeys
(self)
python/bullmq/backends/redis_backend.py:158
Methodkeys
(self)
python/bullmq/backends/postgres_backend.py:288
Methodkeys
The queue keys helper.
rust/src/queue_events.rs:450
Methodkeys
The queue keys helper.
rust/src/queue.rs:118
Methodkeys
* Backends that don't address jobs by key return an empty map; PostgreSQL * addresses rows by `(queue, id)` columns instead.
src/postgres/postgres-queue-backend.ts:443
Methodkeys
* The concrete Redis keys for this queue (wait, active, events, …).
src/classes/redis-queue-backend.ts:238
Methodkeys
(pattern: string)
src/classes/node-redis-client.ts:845
Methodkeys
(pattern: string)
src/classes/bun-redis-client.ts:1146
Methodkeys
(pattern: string)
src/classes/valkey-glide-client.ts:1021
Methodkilled
()
src/classes/child.ts:71
MethodlLen
(key: string)
src/classes/node-redis-client.ts:58
MethodlRange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:57
Functionleaf
(name: &str)
rust/src/flow_producer.rs:1220
Methodlifo
Add the job to the back of the queue (last-in-first-out ordering).
rust/src/queue.rs:2742
Methodlifo
Add the job to the back of the queue (last-in-first-out ordering).
rust/src/options.rs:722
Methodlimiter
Enable rate limiting (maximum jobs per window).
rust/src/options.rs:533
Functionlistener
(msg: { requestId: string; value: any })
src/classes/child-processor.ts:351
Methodllen
(key: string)
src/classes/node-redis-client.ts:647
Methodllen
(key: string)
src/classes/node-redis-client.ts:1013
Methodllen
(key: string)
src/classes/bun-redis-client.ts:918
Methodllen
(key: string)
src/classes/bun-redis-client.ts:1351
Methodllen
(key: string)
src/classes/valkey-glide-client.ts:840
Methodllen
(key: string)
src/classes/valkey-glide-client.ts:1286
Methodllen
(key: string)
src/interfaces/redis-client.ts:273
Methodload
* Attach all lua scripts in a given directory to a client instance * @param client - redis client to attach script to * @param pathname - the pa
src/commands/script-loader.ts:547
Functionload_command
Load a runtime command's SQL by name (without the ``.sql`` extension).
python/bullmq/postgres/sql_loader.py:53
Functionload_migration
Load a migration's SQL from its ``.sql`` file.
python/bullmq/postgres/sql_loader.py:67
Methodlock_duration
Set the job lock duration.
rust/src/options.rs:465
Methodlock_renew_time
Set the lock renewal interval (defaults to half the lock duration).
rust/src/options.rs:471
Methodlog
(self, logRow: str)
python/bullmq/job.py:267
Methodlog
Add a log entry to the job.
rust/src/job.rs:708
Methodlog
* Logs one row of log data. * * @param logRow - string with log data to be logged. * @returns The total number of log entries for this job so
src/classes/job.ts:555
Methodlpos
(key: string, value: string)
src/classes/node-redis-client.ts:656
Methodlpos
(key: string, value: string)
src/classes/bun-redis-client.ts:927
Methodlpos
(key: string, value: string)
src/classes/valkey-glide-client.ts:854
Methodlpush
(key: string, ...values: string[])
src/classes/node-redis-client.ts:900
Methodlpush
(key: string, ...values: string[])
src/classes/valkey-glide-client.ts:1080
Methodlrange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:643
Methodlrange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:1007
Methodlrange
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:909
Methodlrange
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:1344
Methodlrange
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:830
Methodlrange
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:1282
Methodlrange
(key: string, start: number, end: number)
src/interfaces/redis-client.ts:272
Methodltrim
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:651
Methodltrim
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:922
Methodltrim
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:844
Functionmain
()
rust/examples/benchmark.rs:212
Methodmanual_start
Do not start processing automatically; the worker must be started manually.
rust/src/options.rs:503
MethodmapKey
(key)
python/bullmq/scripts.py:47
Functionmaps_lock_mismatch_code
()
rust/src/error.rs:156
Functionmaps_missing_lock_code
()
rust/src/error.rs:144
MethodmarkReady
()
src/classes/bun-redis-client.ts:261
Methodmatcher
(name: str)
python/bullmq/queue.py:197
Methodmatcher
(name: string)
src/classes/queue-getters.ts:585
Functionmatches_unnamed_and_named_workers
()
rust/src/queue.rs:2978
Methodmax_children
Maximum number of children to retrieve per node (default: 20).
rust/src/flow_producer.rs:131
Methodmax_stalled_count
Set the maximum number of times a stalled job is re-queued before failing.
rust/src/options.rs:477
Methodmax_started_attempts
Limit how many times a job may start processing before it is failed.
rust/src/options.rs:545
MethodmaximumBlockTimeout
Largest meaningful blocking timeout (in seconds) for the blocking primitive. Defaults to the Redis-derived ceiling (10s). Backends whose bloc
python/bullmq/backend.py:77
MethodmaximumBlockTimeout
(self)
python/bullmq/worker.py:398
MethodmaximumBlockTimeout
(self)
python/bullmq/backends/postgres_backend.py:263
MethodmaximumBlockTimeout
* PostgreSQL `LISTEN`/`NOTIFY` keeps the connection open and re-arms the wait * to the next due delayed job, so there is no cheap-reconnect reason
src/postgres/postgres-queue-backend.ts:415
MethodmaximumBlockTimeout
* Largest meaningful block timeout (seconds). Capped at 10s because a * `BZPOPMIN` blocked longer than this risks issues on reconnection * (see
src/classes/redis-queue-backend.ts:402
← previousnext →2,401–2,500 of 3,768, ranked by callers