MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

Methodsize_limit
Reject the job if its serialized payload exceeds `bytes` UTF-8 bytes.
rust/src/options.rs:781
Methodskip_lock_renewal
Skip lock renewal for this worker.
rust/src/options.rs:557
Methodskip_stalled_check
Skip the stalled-job check for this worker.
rust/src/options.rs:551
Methodskip_version_check
Skip the Redis server version compatibility check on startup.
rust/src/options.rs:303
Methodsmembers
(key: string)
src/classes/node-redis-client.ts:664
Methodsmembers
(key: string)
src/classes/node-redis-client.ts:974
Methodsmembers
(key: string)
src/classes/bun-redis-client.ts:936
Methodsmembers
(key: string)
src/classes/bun-redis-client.ts:1308
Methodsmembers
(key: string)
src/classes/valkey-glide-client.ts:859
Methodsmembers
(key: string)
src/classes/valkey-glide-client.ts:1251
Methodsmembers
(key: string)
src/interfaces/redis-client.ts:261
Methodsmembers
()
tests/bun-redis-nested-duplicate.test.ts:35
Methodsmembers
()
tests/bun-redis.test.ts:157
Methodsscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/node-redis-client.ts:980
Methodsscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/bun-redis-client.ts:1315
Methodsscan
( key: string, cursor: string | number, options?: { COUNT?: number }, )
src/classes/valkey-glide-client.ts:1257
Methodstack_trace_limit
Maximum number of stack-trace lines to store on failure.
rust/src/options.rs:763
Methodstalled_check
(&self)
rust/src/keys.rs:140
Methodstalled_interval
Set the interval between stalled-job checks.
rust/src/options.rs:483
Methodstart
(jobJson: JobJsonSandbox, token?: string)
src/classes/child-processor.ts:92
MethodstartSpan
(name: string, options?: SpanOptions)
tests/telemetry_interface.test.ts:120
Methodstatic_fetch_next_job
( conn: &RedisConnection, blocking_conn: &BlockingRedisConnection, keys: &QueueKeys,
rust/src/worker.rs:2107
Functionstatus
()
tests/events.redis.test.ts:234
Functionstatus
()
tests/worker.test.ts:1333
Methodstatus
* Expose connection status using the vocabulary that * {@link RedisConnection.waitUntilReady} expects: * 'wait' → not yet connected, call con
src/classes/node-redis-client.ts:210
Methodstatus
()
src/classes/bun-redis-client.ts:155
Methodstatus
()
src/classes/valkey-glide-client.ts:349
Methodstop
()
src/classes/child-processor.ts:136
Methodswallow
(_: unknown)
src/classes/bun-redis-client.ts:1436
MethodtearDown
(self)
python/tests/worker_disconnect_test.py:79
MethodtearDown
()
php/tests/QueueTest.php:39
MethodtestBackoffNormalization
()
php/tests/JobOptionsTest.php:55
MethodtestCanAddBulkJobs
()
php/tests/QueueTest.php:163
MethodtestCanAddDelayedJob
()
php/tests/QueueTest.php:76
MethodtestCanAddJob
()
php/tests/QueueTest.php:57
MethodtestCanAddJobWithCustomId
()
php/tests/QueueTest.php:67
MethodtestCanAddPrioritizedJob
()
php/tests/QueueTest.php:87
MethodtestCanCleanJobs
()
php/tests/QueueTest.php:231
MethodtestCanConvertJobToJson
()
php/tests/JobTest.php:49
MethodtestCanConvertToArray
()
php/tests/JobOptionsTest.php:27
MethodtestCanCreateFromArray
()
php/tests/JobOptionsTest.php:12
MethodtestCanCreateJob
()
php/tests/JobTest.php:14
MethodtestCanCreateJobWithOptions
()
php/tests/JobTest.php:24
MethodtestCanCreateQueue
()
php/tests/QueueTest.php:51
MethodtestCanGetCountsPerPriority
()
php/tests/QueueTest.php:240
MethodtestCanGetDelayedJobs
()
php/tests/QueueTest.php:207
MethodtestCanGetJob
()
php/tests/QueueTest.php:98
MethodtestCanGetJobCountByTypes
()
php/tests/QueueTest.php:132
MethodtestCanGetJobCounts
()
php/tests/QueueTest.php:117
MethodtestCanGetPrioritizedJobs
()
php/tests/QueueTest.php:217
MethodtestCanGetWaitingJobs
()
php/tests/QueueTest.php:178
MethodtestCanObliterateQueue
()
php/tests/QueueTest.php:280
MethodtestCanPauseAndResumeQueue
()
php/tests/QueueTest.php:142
MethodtestCanPromoteDelayedJobs
()
php/tests/QueueTest.php:261
MethodtestCanRemoveJob
()
php/tests/QueueTest.php:153
MethodtestCanShareConnection
()
php/tests/QueueTest.php:361
MethodtestCanUseCustomPrefix
()
php/tests/QueueTest.php:340
MethodtestDefaultValues
()
php/tests/JobOptionsTest.php:44
MethodtestGetJobReturnsNullForNonexistent
()
php/tests/QueueTest.php:110
MethodtestGetJobsByMultipleTypes
()
php/tests/QueueTest.php:391
MethodtestGetJobsByTypeSkipsDeletedJobHashAndPreservesOrder
()
php/tests/QueueTest.php:191
MethodtestJobDataIntegrity
()
php/tests/QueueTest.php:402
MethodtestJobHasTimestamp
()
php/tests/JobTest.php:38
MethodtestJobWithAttemptsOption
()
php/tests/QueueTest.php:300
MethodtestJobWithBackoffOption
()
php/tests/QueueTest.php:309
MethodtestJobWithRemoveOnCompleteOption
()
php/tests/QueueTest.php:324
MethodtestParentConfiguration
()
php/tests/JobOptionsTest.php:89
MethodtestRemoveOnCompleteOptions
()
php/tests/JobOptionsTest.php:74
Methodtest_abort_flips_signal
(self)
python/tests/job_cancellation_test.py:32
Methodtest_abort_is_idempotent
(self)
python/tests/job_cancellation_test.py:42
Functiontest_active_event_emitted
()
rust/tests/worker_test.rs:7373
Methodtest_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
Methodtest_addBulk_should_process_children_before_parent
(self)
python/tests/flow_test.py:84
Methodtest_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
Functiontest_add_bulk_empty
()
rust/tests/queue_test.rs:190
Functiontest_add_bulk_jobs
()
rust/tests/queue_test.rs:164
Functiontest_add_bulk_processing
()
rust/tests/worker_test.rs:6259
Functiontest_add_bulk_with_options
()
rust/tests/queue_test.rs:205
Functiontest_add_bulk_with_priority
()
rust/tests/worker_test.rs:6613
Methodtest_add_does_not_mutate_queues_default_job_options
(self)
python/tests/flow_producer_test.py:21
Methodtest_add_flow_uses_each_job_backend_scripts
(self)
python/tests/flow_producer_test.py:66
Functiontest_add_job
()
rust/tests/queue_test.rs:51
Methodtest_add_job
(self)
python/tests/queue_test.py:36
Functiontest_add_job_lifo
()
rust/tests/queue_test.rs:546
Functiontest_add_job_with_custom_id
()
rust/tests/queue_test.rs:72
Methodtest_add_job_with_options
(self)
python/tests/queue_test.py:100
Functiontest_add_job_with_parent_queue_name
()
rust/tests/queue_test.rs:95
Methodtest_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
Methodtest_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
Methodtest_asyncio_timeout_is_transient
(self)
python/tests/worker_disconnect_test.py:100
Functiontest_attempts_made_increments_on_each_retry
()
rust/tests/worker_test.rs:5659
Functiontest_attempts_made_is_correct
()
rust/tests/worker_test.rs:3463
Functiontest_auto_retry_failed_job_with_attempts
()
rust/tests/worker_test.rs:2106
Functiontest_auto_retry_without_backoff_retries_immediately
()
rust/tests/worker_test.rs:4563
Functiontest_autorun_false_no_processing_until_run
()
rust/tests/worker_test.rs:7181
Functiontest_autorun_false_then_run
()
rust/tests/queue_events_test.rs:198
Functiontest_backoff_strategy_serialization
()
rust/src/types.rs:290
Functiontest_base64_standard_matches_node
()
rust/src/keys.rs:261
Methodtest_builtin_connection_refused_error_is_transient
(self)
python/tests/worker_disconnect_test.py:96
Methodtest_caller_single_connection_client_does_not_raise
(self, _mock_load)
python/tests/redis_connection_test.py:20
← previousnext →3,001–3,100 of 3,768, ranked by callers