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
size_limit
Reject the job if its serialized payload exceeds `bytes` UTF-8 bytes.
rust/src/options.rs:781
Method
skip_lock_renewal
Skip lock renewal for this worker.
rust/src/options.rs:557
Method
skip_stalled_check
Skip the stalled-job check for this worker.
rust/src/options.rs:551
Method
skip_version_check
Skip the Redis server version compatibility check on startup.
rust/src/options.rs:303
Method
smembers
(key: string)
src/classes/node-redis-client.ts:664
Method
smembers
(key: string)
src/classes/node-redis-client.ts:974
Method
smembers
(key: string)
src/classes/bun-redis-client.ts:936
Method
smembers
(key: string)
src/classes/bun-redis-client.ts:1308
Method
smembers
(key: string)
src/classes/valkey-glide-client.ts:859
Method
smembers
(key: string)
src/classes/valkey-glide-client.ts:1251
Method
smembers
(key: string)
src/interfaces/redis-client.ts:261
Method
smembers
()
tests/bun-redis-nested-duplicate.test.ts:35
Method
smembers
()
tests/bun-redis.test.ts:157
Method
sscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/node-redis-client.ts:980
Method
sscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/bun-redis-client.ts:1315
Method
sscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/valkey-glide-client.ts:1257
Method
stack_trace_limit
Maximum number of stack-trace lines to store on failure.
rust/src/options.rs:763
Method
stalled_check
(&self)
rust/src/keys.rs:140
Method
stalled_interval
Set the interval between stalled-job checks.
rust/src/options.rs:483
Method
start
(jobJson: JobJsonSandbox, token?: string)
src/classes/child-processor.ts:92
Method
startSpan
(name: string, options?: SpanOptions)
tests/telemetry_interface.test.ts:120
Method
static_fetch_next_job
( conn: &RedisConnection, blocking_conn: &BlockingRedisConnection, keys: &QueueKeys,
rust/src/worker.rs:2107
Function
status
()
tests/events.redis.test.ts:234
Function
status
()
tests/worker.test.ts:1333
Method
status
* Expose connection status using the vocabulary that * {@link RedisConnection.waitUntilReady} expects: * 'wait' → not yet connected, call con
src/classes/node-redis-client.ts:210
Method
status
()
src/classes/bun-redis-client.ts:155
Method
status
()
src/classes/valkey-glide-client.ts:349
Method
stop
()
src/classes/child-processor.ts:136
Method
swallow
(_: unknown)
src/classes/bun-redis-client.ts:1436
Method
tearDown
(self)
python/tests/worker_disconnect_test.py:79
Method
tearDown
()
php/tests/QueueTest.php:39
Method
testBackoffNormalization
()
php/tests/JobOptionsTest.php:55
Method
testCanAddBulkJobs
()
php/tests/QueueTest.php:163
Method
testCanAddDelayedJob
()
php/tests/QueueTest.php:76
Method
testCanAddJob
()
php/tests/QueueTest.php:57
Method
testCanAddJobWithCustomId
()
php/tests/QueueTest.php:67
Method
testCanAddPrioritizedJob
()
php/tests/QueueTest.php:87
Method
testCanCleanJobs
()
php/tests/QueueTest.php:231
Method
testCanConvertJobToJson
()
php/tests/JobTest.php:49
Method
testCanConvertToArray
()
php/tests/JobOptionsTest.php:27
Method
testCanCreateFromArray
()
php/tests/JobOptionsTest.php:12
Method
testCanCreateJob
()
php/tests/JobTest.php:14
Method
testCanCreateJobWithOptions
()
php/tests/JobTest.php:24
Method
testCanCreateQueue
()
php/tests/QueueTest.php:51
Method
testCanGetCountsPerPriority
()
php/tests/QueueTest.php:240
Method
testCanGetDelayedJobs
()
php/tests/QueueTest.php:207
Method
testCanGetJob
()
php/tests/QueueTest.php:98
Method
testCanGetJobCountByTypes
()
php/tests/QueueTest.php:132
Method
testCanGetJobCounts
()
php/tests/QueueTest.php:117
Method
testCanGetPrioritizedJobs
()
php/tests/QueueTest.php:217
Method
testCanGetWaitingJobs
()
php/tests/QueueTest.php:178
Method
testCanObliterateQueue
()
php/tests/QueueTest.php:280
Method
testCanPauseAndResumeQueue
()
php/tests/QueueTest.php:142
Method
testCanPromoteDelayedJobs
()
php/tests/QueueTest.php:261
Method
testCanRemoveJob
()
php/tests/QueueTest.php:153
Method
testCanShareConnection
()
php/tests/QueueTest.php:361
Method
testCanUseCustomPrefix
()
php/tests/QueueTest.php:340
Method
testDefaultValues
()
php/tests/JobOptionsTest.php:44
Method
testGetJobReturnsNullForNonexistent
()
php/tests/QueueTest.php:110
Method
testGetJobsByMultipleTypes
()
php/tests/QueueTest.php:391
Method
testGetJobsByTypeSkipsDeletedJobHashAndPreservesOrder
()
php/tests/QueueTest.php:191
Method
testJobDataIntegrity
()
php/tests/QueueTest.php:402
Method
testJobHasTimestamp
()
php/tests/JobTest.php:38
Method
testJobWithAttemptsOption
()
php/tests/QueueTest.php:300
Method
testJobWithBackoffOption
()
php/tests/QueueTest.php:309
Method
testJobWithRemoveOnCompleteOption
()
php/tests/QueueTest.php:324
Method
testParentConfiguration
()
php/tests/JobOptionsTest.php:89
Method
testRemoveOnCompleteOptions
()
php/tests/JobOptionsTest.php:74
Method
test_abort_flips_signal
(self)
python/tests/job_cancellation_test.py:32
Method
test_abort_is_idempotent
(self)
python/tests/job_cancellation_test.py:42
Function
test_active_event_emitted
()
rust/tests/worker_test.rs:7373
Method
test_addBulk_does_not_raise_on_missing_parent
`addBulk` uses lenient semantics: a root command that returns a negative error code (e.g. parent does not exist) must NOT raise, must
python/tests/flow_test.py:349
Method
test_addBulk_should_process_children_before_parent
(self)
python/tests/flow_test.py:84
Method
test_add_after_close_returns_none
Adding a flow after the producer is closed must be a no-op rather than raising on a closed connection.
python/tests/flow_test.py:287
Function
test_add_bulk_empty
()
rust/tests/queue_test.rs:190
Function
test_add_bulk_jobs
()
rust/tests/queue_test.rs:164
Function
test_add_bulk_processing
()
rust/tests/worker_test.rs:6259
Function
test_add_bulk_with_options
()
rust/tests/queue_test.rs:205
Function
test_add_bulk_with_priority
()
rust/tests/worker_test.rs:6613
Method
test_add_does_not_mutate_queues_default_job_options
(self)
python/tests/flow_producer_test.py:21
Method
test_add_flow_uses_each_job_backend_scripts
(self)
python/tests/flow_producer_test.py:66
Function
test_add_job
()
rust/tests/queue_test.rs:51
Method
test_add_job
(self)
python/tests/queue_test.py:36
Function
test_add_job_lifo
()
rust/tests/queue_test.rs:546
Function
test_add_job_with_custom_id
()
rust/tests/queue_test.rs:72
Method
test_add_job_with_options
(self)
python/tests/queue_test.py:100
Function
test_add_job_with_parent_queue_name
()
rust/tests/queue_test.rs:95
Method
test_add_prioritized_jobs_are_returned_in_priority_order
Jobs added with priority should be retrievable via getPrioritized() ordered by priority (lowest number first = highest priority).
python/tests/priority_test.py:30
Method
test_add_raises_when_parent_does_not_exist
Adding a flow whose root references a non-existent parent must raise instead of silently dropping the job. Mirrors GH #3264 on the Nod
python/tests/flow_test.py:311
Method
test_asyncio_timeout_is_transient
(self)
python/tests/worker_disconnect_test.py:100
Function
test_attempts_made_increments_on_each_retry
()
rust/tests/worker_test.rs:5659
Function
test_attempts_made_is_correct
()
rust/tests/worker_test.rs:3463
Function
test_auto_retry_failed_job_with_attempts
()
rust/tests/worker_test.rs:2106
Function
test_auto_retry_without_backoff_retries_immediately
()
rust/tests/worker_test.rs:4563
Function
test_autorun_false_no_processing_until_run
()
rust/tests/worker_test.rs:7181
Function
test_autorun_false_then_run
()
rust/tests/queue_events_test.rs:198
Function
test_backoff_strategy_serialization
()
rust/src/types.rs:290
Function
test_base64_standard_matches_node
()
rust/src/keys.rs:261
Method
test_builtin_connection_refused_error_is_transient
(self)
python/tests/worker_disconnect_test.py:96
Method
test_caller_single_connection_client_does_not_raise
(self, _mock_load)
python/tests/redis_connection_test.py:20
← previous
next →
3,001–3,100 of 3,768, ranked by callers