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
Function
processor
()
tests/rate_limiter.test.ts:377
Method
processor
(job: Job, token: str)
python/tests/queue_events_test.py:64
Method
promote
(self, job_id: str)
python/bullmq/scripts.py:381
Method
promote
(self)
python/bullmq/job.py:103
Method
promote
Promote a single delayed job so it can be processed as soon as possible.
python/bullmq/backend.py:205
Method
promote
(self, job_id: str)
python/bullmq/backends/redis_backend.py:255
Method
promote
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:550
Method
promote
Promote a delayed job to the waiting state immediately.
rust/src/job.rs:966
Method
promote
(jobId: string)
src/postgres/postgres-queue-backend.ts:1061
Method
promote
* Promotes a delayed job so that it starts to be processed as soon as possible.
src/classes/job.ts:1210
Method
promote
(jobId: string)
src/classes/redis-queue-backend.ts:2062
Method
promoteJobs
Promote jobs in delayed state
python/bullmq/scripts.py:673
Method
promoteJobs
Promote up to ``count`` delayed jobs back to wait. Returns a cursor.
python/bullmq/backend.py:228
Method
promoteJobs
(self, count: int)
python/bullmq/backends/redis_backend.py:272
Method
promoteJobs
(self, count: int)
python/bullmq/backends/postgres_backend.py:572
Method
promoteJobs
* Promote all delayed jobs to waiting. * * @param array{count?: int} $opts Options: * - count: Maximum number of jobs to promote per
php/src/Queue.php:562
Method
promoteJobs
(count?: number)
src/postgres/postgres-queue-backend.ts:1112
Method
promoteJobs
* Promote all the delayed jobs. * * @param opts - An object with the following properties: * - count number to limit how many jobs will be
src/classes/queue.ts:899
Method
promoteJobs
(count = 1000)
src/classes/redis-queue-backend.ts:1920
Method
publishEvent
( fields: Record<string, string | number>, _maxEvents: number, )
src/postgres/postgres-queue-backend.ts:2036
Method
publishEvent
( fields: Record<string, string | number>, maxEvents: number, )
src/classes/redis-queue-backend.ts:2858
Method
publishEvent
* Publish custom event to be processed in QueueEvents. * @param argsObj - Event payload * @param maxEvents - Max quantity of events to be saved
src/classes/queue-events-producer.ts:32
Function
pytest_collection_modifyitems
(config, items)
python/tests/conftest.py:52
Method
qualifiedName
The queue's fully-qualified name (cross-backend logical identifier).
python/bullmq/backend.py:98
Method
qualifiedName
(self)
python/bullmq/backends/redis_backend.py:154
Method
qualifiedName
(self)
python/bullmq/backends/postgres_backend.py:284
Method
qualifiedName
* The queue's qualified name. With a schema-based namespace there is no * prefix, so the qualified name is simply the queue name.
src/postgres/postgres-queue-backend.ts:435
Method
qualifiedName
* The queue's fully-qualified name (`"<prefix>:<queue>"`). This is the * cross-backend logical identifier (e.g. used as a flow parent reference).
src/classes/redis-queue-backend.ts:231
Method
queue
Set the per-queue options for `queue_name`.
rust/src/flow_producer.rs:181
Method
queueName
* @returns the queue name this job belongs to.
src/classes/job.ts:931
Method
queueName
()
src/interfaces/minimal-job.ts:157
Method
queueQualifiedName
* @returns it includes the prefix, the namespace separator :, and queue name. * @see {@link https://www.gnu.org/software/gawk/manual/html_node/Qual
src/interfaces/minimal-job.ts:166
Method
queue_name
The queue name this job belongs to.
rust/src/job.rs:257
Method
quit
()
src/classes/node-redis-client.ts:376
Method
quit
()
src/classes/bun-redis-client.ts:495
Method
quit
()
src/classes/valkey-glide-client.ts:619
Method
raiseError
(msg: string, match: string)
src/commands/script-loader.ts:199
Method
rateLimit
* Overrides the rate limit to be active for the next jobs. * @deprecated This method is deprecated and will be removed in v6. Use queue.rateLimit m
src/classes/worker.ts:760
Method
read
()
src/classes/node-redis-client.ts:821
Method
readEvents
(id: string, blockTimeout: number)
src/postgres/postgres-queue-backend.ts:2049
Method
readEvents
(id: string, blockTimeout: number)
src/classes/redis-queue-backend.ts:2869
Method
reason
(self)
python/bullmq/abort_controller.py:64
Function
reconnectBlocking
()
tests/worker.test.ts:1391
Method
reconnectBlocking
()
src/postgres/postgres-queue-backend.ts:2275
Method
record
* Records a value in the histogram. * * @param value - the value to record * @param attributes - optional attributes to associate with this m
src/interfaces/telemetry.ts:120
Method
record
(value: number, attributes?: Attributes)
tests/telemetry_interface.test.ts:59
Method
record
(value: number, attributes?: Attributes)
tests/telemetry_interface.test.ts:67
Method
recordException
(exception: ExtendedException, time?: Time)
tests/telemetry_interface.test.ts:192
Function
redacts_password_only_and_keeps_ipv6_host
()
rust/src/redis_connection.rs:265
Function
redacts_username_password
()
rust/src/redis_connection.rs:259
Method
redisVersion
()
src/classes/redis-connection.ts:882
Method
redisVersion
()
src/classes/redis-queue-backend.ts:174
Method
redisVersion
* Returns the version of the Redis instance the client is connected to,
src/interfaces/script-queue-context.ts:28
Function
rejects_parent_queue_names_with_extra_colons
()
rust/src/keys.rs:301
Method
release
(child: Child)
src/classes/child-pool.ts:90
Method
release_concurrency_slot
Release a concurrency slot and notify waiters.
rust/src/worker.rs:1042
Method
remove
(self, job_id: str, remove_children: bool)
python/bullmq/scripts.py:503
Method
remove
(self, opts: dict = {})
python/bullmq/job.py:146
Method
remove
Remove a job and (optionally) its children.
python/bullmq/backend.py:248
Method
remove
(self, job_id: str, remove_children: bool)
python/bullmq/backends/redis_backend.py:287
Method
remove
(self, job_id: str, remove_children: bool)
python/bullmq/backends/postgres_backend.py:599
Method
remove
* Remove a job from the queue. * * @param string $jobId The job ID to remove * @param bool $removeChildren Whether to also remove child
php/src/Queue.php:465
Method
remove
* Remove a job. * * @param string $jobId * @param bool $removeChildren * @return mixed */
php/src/Scripts.php:499
Method
remove
Remove a job by its ID, together with all of its dependencies. This mirrors the semantics of the Node.js `Queue#remove`, where the numeric result `1`
rust/src/queue.rs:1653
Method
remove
(jobId: string, removeChildren: boolean)
src/postgres/postgres-queue-backend.ts:1310
Method
remove
* Completely remove the job from the queue. * Note, this call will throw an exception if the job * is being processed when the call is performed
src/classes/job.ts:594
Method
remove
* Removes the given job from the queue as well as all its * dependencies. * * @param jobId - The id of the job to remove * @param opts - O
src/classes/queue.ts:674
Method
remove
(jobId: string, removeChildren: boolean)
src/classes/redis-queue-backend.ts:986
Method
removeAllListeners
(event?: string)
src/postgres/pg-types.ts:63
Method
removeAllListeners
(event?: string | symbol)
src/interfaces/redis-client.ts:53
Method
removeChildDependency
( jobId: string, parentKey: string, )
src/postgres/postgres-queue-backend.ts:1335
Method
removeChildDependency
* Removes child dependency from parent when child is not yet finished * * @returns True if the relationship existed and if it was removed.
src/classes/job.ts:564
Method
removeChildDependency
( jobId: string, parentKey: string, )
src/classes/redis-queue-backend.ts:1256
Method
removeDebounceKey
* Removes a debounce key. * @deprecated use removeDeduplicationKey * * @param id - debounce identifier
src/classes/queue.ts:623
Method
removeDeduplicationKey
( deduplicationId: string, jobId: string, )
src/postgres/postgres-queue-backend.ts:1358
Method
removeDeduplicationKey
* Removes a deduplication key if job is still the cause of deduplication. * @returns true if the deduplication key was removed.
src/classes/job.ts:1304
Method
removeDeduplicationKey
* Removes a deduplication key. * * @param id - identifier
src/classes/queue.ts:643
Method
removeDeduplicationKey
* Removes a deduplication key from Redis so that a new job with the same * deduplication id can be enqueued again. The key is only removed if it
src/classes/redis-queue-backend.ts:830
Method
removeDeprecatedPriorityKey
Remove the deprecated priority helper key.
python/bullmq/backend.py:348
Method
removeDeprecatedPriorityKey
Delete old priority helper key.
python/bullmq/queue.py:336
Method
removeDeprecatedPriorityKey
(self)
python/bullmq/backends/redis_backend.py:425
Method
removeDeprecatedPriorityKey
(self)
python/bullmq/backends/postgres_backend.py:758
Method
removeDeprecatedPriorityKey
()
src/postgres/postgres-queue-backend.ts:2024
Method
removeDeprecatedPriorityKey
* Delete old priority helper key.
src/classes/queue.ts:940
Method
removeDeprecatedPriorityKey
()
src/classes/redis-queue-backend.ts:2760
Method
removeJobScheduler
Remove a job scheduler and any pending next-iteration job. Returns 0 if the scheduler was removed, 1 if it did not exist.
python/bullmq/scripts.py:484
Method
removeJobScheduler
Remove a scheduler. Returns 0 on success, 1 if absent.
python/bullmq/job_scheduler.py:312
Method
removeJobScheduler
Remove a scheduler and its pending next-iteration job. Returns 0 if the scheduler was removed, 1 if it did not exist.
python/bullmq/backend.py:397
Method
removeJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/redis_backend.py:475
Method
removeJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/postgres_backend.py:886
Method
removeJobScheduler
(jobSchedulerId: string)
src/postgres/postgres-queue-backend.ts:1403
Method
removeJobScheduler
* * Removes a job scheduler. * * @param jobSchedulerId - identifier of the job scheduler. * * @returns
src/classes/queue.ts:610
Method
removeJobScheduler
(jobSchedulerId: string)
src/classes/redis-queue-backend.ts:961
Method
removeJobScheduler
(jobSchedulerId: string)
src/classes/job-scheduler.ts:344
Method
removeListener
(event: string, listener: (...args: any[]) => void)
src/interfaces/queue-backend.ts:134
Method
removeListener
(event: string, listener: (...args: any[]) => void)
src/interfaces/redis-client.ts:48
Method
removeListener
( event: string | symbol, listener: (...args: any[]) => void, )
src/interfaces/minimal-queue.ts:32
Method
removeListeners
()
src/classes/job.ts:1137
Method
removeOrphanedJobs
* Removes orphaned job hashes (job data present but not referenced by any * state set). This is a Redis keyspace-maintenance concern: on PostgreSQL
src/postgres/postgres-queue-backend.ts:1166
Method
removeOrphanedJobs
* Removes orphaned job keys that are stored in the backend but are not * referenced in any queue state set. * * Orphaned keys can occur in ra
src/classes/queue.ts:967
← previous
next →
2,701–2,800 of 3,768, ranked by callers