Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/taskforcesh/bullmq
/ functions
Functions
3,768 in github.com/taskforcesh/bullmq
⨍
Functions
3,768
◇
Types & classes
487
↳
Endpoints
8
Method
isMaxed
()
src/postgres/postgres-queue-backend.ts:1517
Method
isMaxed
* Returns true if the queue is currently maxed.
src/classes/queue.ts:557
Method
isMaxed
()
src/classes/redis-queue-backend.ts:1678
Method
isPaused
Return whether the queue is currently paused.
python/bullmq/backend.py:332
Method
isPaused
(self)
python/bullmq/backends/redis_backend.py:396
Method
isPaused
(self)
python/bullmq/backends/postgres_backend.py:742
Method
isPaused
* Returns true if the queue is currently paused.
src/classes/queue.ts:550
Method
isPaused
* * Checks if worker is paused. * * @returns true if worker is paused, false otherwise.
src/classes/worker.ts:1263
Method
isRunning
* Checks if the lock manager is running.
src/classes/lock-manager.ts:183
Method
isVersionLowerThan
* Check if the Redis version is lower than the specified version. */
php/src/RedisConnection.php:98
Method
isWaitingChildren
Returns true if the job is waiting for children.
python/bullmq/job.py:170
Method
is_active
Check if the job is active (being processed).
rust/src/job.rs:909
Method
is_completed
Check if the job is completed.
rust/src/job.rs:899
Method
is_delayed
Check if the job is delayed.
rust/src/job.rs:919
Method
is_discarded
Whether [`Job::discard`] has been called on this job.
rust/src/job.rs:278
Method
is_failed
Check if the job has failed.
rust/src/job.rs:904
Method
is_paused
Whether the worker is paused.
rust/src/worker.rs:681
Method
is_paused
Check if the queue is paused.
rust/src/queue.rs:731
Method
is_running
(self)
python/bullmq/lock_manager.py:138
Method
is_running
Whether the consuming loop is currently running.
rust/src/queue_events.rs:455
Method
is_running
Whether the worker is currently running.
rust/src/worker.rs:676
Method
is_unreserved_userinfo_byte
(b: u8)
rust/src/options.rs:218
Method
is_waiting
Check if the job is waiting.
rust/src/job.rs:914
Method
is_waiting_children
Check if the job is waiting for its children to complete.
rust/src/job.rs:924
Method
jobScheduler
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
Method
jobScheduler
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
Method
jobScheduler
()
src/classes/queue.ts:251
Method
jobScheduler
()
src/classes/worker.ts:550
Method
job_id
The job id associated with this event, if any.
rust/src/queue_events.rs:220
Method
job_id
Use a custom, unique job id instead of an auto-generated one.
rust/src/queue.rs:2748
Method
job_id
Use a custom, unique job id instead of an auto-generated one.
rust/src/options.rs:746
Function
job_id_and_name_helpers_are_consistent
()
rust/src/queue_events.rs:825
Method
keep_logs
Maximum number of log entries to retain for the job.
rust/src/queue.rs:2766
Method
keep_logs
Maximum number of log entries to retain for the job.
rust/src/options.rs:740
Function
keeps_url_without_userinfo
()
rust/src/redis_connection.rs:271
Method
keys
The map of named sub-keys/identifiers for the queue.
python/bullmq/backend.py:103
Method
keys
(self)
python/bullmq/backends/redis_backend.py:158
Method
keys
(self)
python/bullmq/backends/postgres_backend.py:288
Method
keys
The queue keys helper.
rust/src/queue_events.rs:450
Method
keys
The queue keys helper.
rust/src/queue.rs:118
Method
keys
* 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
Method
keys
* The concrete Redis keys for this queue (wait, active, events, …).
src/classes/redis-queue-backend.ts:238
Method
keys
(pattern: string)
src/classes/node-redis-client.ts:845
Method
keys
(pattern: string)
src/classes/bun-redis-client.ts:1146
Method
keys
(pattern: string)
src/classes/valkey-glide-client.ts:1021
Method
killed
()
src/classes/child.ts:71
Method
lLen
(key: string)
src/classes/node-redis-client.ts:58
Method
lRange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:57
Function
leaf
(name: &str)
rust/src/flow_producer.rs:1220
Method
lifo
Add the job to the back of the queue (last-in-first-out ordering).
rust/src/queue.rs:2742
Method
lifo
Add the job to the back of the queue (last-in-first-out ordering).
rust/src/options.rs:722
Method
limiter
Enable rate limiting (maximum jobs per window).
rust/src/options.rs:533
Function
listener
(msg: { requestId: string; value: any })
src/classes/child-processor.ts:351
Method
llen
(key: string)
src/classes/node-redis-client.ts:647
Method
llen
(key: string)
src/classes/node-redis-client.ts:1013
Method
llen
(key: string)
src/classes/bun-redis-client.ts:918
Method
llen
(key: string)
src/classes/bun-redis-client.ts:1351
Method
llen
(key: string)
src/classes/valkey-glide-client.ts:840
Method
llen
(key: string)
src/classes/valkey-glide-client.ts:1286
Method
llen
(key: string)
src/interfaces/redis-client.ts:273
Method
load
* 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
Function
load_command
Load a runtime command's SQL by name (without the ``.sql`` extension).
python/bullmq/postgres/sql_loader.py:53
Function
load_migration
Load a migration's SQL from its ``.sql`` file.
python/bullmq/postgres/sql_loader.py:67
Method
lock_duration
Set the job lock duration.
rust/src/options.rs:465
Method
lock_renew_time
Set the lock renewal interval (defaults to half the lock duration).
rust/src/options.rs:471
Method
log
(self, logRow: str)
python/bullmq/job.py:267
Method
log
Add a log entry to the job.
rust/src/job.rs:708
Method
log
* 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
Method
lpos
(key: string, value: string)
src/classes/node-redis-client.ts:656
Method
lpos
(key: string, value: string)
src/classes/bun-redis-client.ts:927
Method
lpos
(key: string, value: string)
src/classes/valkey-glide-client.ts:854
Method
lpush
(key: string, ...values: string[])
src/classes/node-redis-client.ts:900
Method
lpush
(key: string, ...values: string[])
src/classes/valkey-glide-client.ts:1080
Method
lrange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:643
Method
lrange
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:1007
Method
lrange
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:909
Method
lrange
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:1344
Method
lrange
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:830
Method
lrange
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:1282
Method
lrange
(key: string, start: number, end: number)
src/interfaces/redis-client.ts:272
Method
ltrim
(key: string, start: number, end: number)
src/classes/node-redis-client.ts:651
Method
ltrim
(key: string, start: number, end: number)
src/classes/bun-redis-client.ts:922
Method
ltrim
(key: string, start: number, end: number)
src/classes/valkey-glide-client.ts:844
Function
main
()
rust/examples/benchmark.rs:212
Method
manual_start
Do not start processing automatically; the worker must be started manually.
rust/src/options.rs:503
Method
mapKey
(key)
python/bullmq/scripts.py:47
Function
maps_lock_mismatch_code
()
rust/src/error.rs:156
Function
maps_missing_lock_code
()
rust/src/error.rs:144
Method
markReady
()
src/classes/bun-redis-client.ts:261
Method
matcher
(name: str)
python/bullmq/queue.py:197
Method
matcher
(name: string)
src/classes/queue-getters.ts:585
Function
matches_unnamed_and_named_workers
()
rust/src/queue.rs:2978
Method
max_children
Maximum number of children to retrieve per node (default: 20).
rust/src/flow_producer.rs:131
Method
max_stalled_count
Set the maximum number of times a stalled job is re-queued before failing.
rust/src/options.rs:477
Method
max_started_attempts
Limit how many times a job may start processing before it is failed.
rust/src/options.rs:545
Method
maximumBlockTimeout
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
Method
maximumBlockTimeout
(self)
python/bullmq/worker.py:398
Method
maximumBlockTimeout
(self)
python/bullmq/backends/postgres_backend.py:263
Method
maximumBlockTimeout
* 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
Method
maximumBlockTimeout
* 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
← previous
next →
2,401–2,500 of 3,768, ranked by callers