MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

Functionprocessor
()
tests/rate_limiter.test.ts:377
Methodprocessor
(job: Job, token: str)
python/tests/queue_events_test.py:64
Methodpromote
(self, job_id: str)
python/bullmq/scripts.py:381
Methodpromote
(self)
python/bullmq/job.py:103
Methodpromote
Promote a single delayed job so it can be processed as soon as possible.
python/bullmq/backend.py:205
Methodpromote
(self, job_id: str)
python/bullmq/backends/redis_backend.py:255
Methodpromote
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:550
Methodpromote
Promote a delayed job to the waiting state immediately.
rust/src/job.rs:966
Methodpromote
(jobId: string)
src/postgres/postgres-queue-backend.ts:1061
Methodpromote
* Promotes a delayed job so that it starts to be processed as soon as possible.
src/classes/job.ts:1210
Methodpromote
(jobId: string)
src/classes/redis-queue-backend.ts:2062
MethodpromoteJobs
Promote jobs in delayed state
python/bullmq/scripts.py:673
MethodpromoteJobs
Promote up to ``count`` delayed jobs back to wait. Returns a cursor.
python/bullmq/backend.py:228
MethodpromoteJobs
(self, count: int)
python/bullmq/backends/redis_backend.py:272
MethodpromoteJobs
(self, count: int)
python/bullmq/backends/postgres_backend.py:572
MethodpromoteJobs
* 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
MethodpromoteJobs
(count?: number)
src/postgres/postgres-queue-backend.ts:1112
MethodpromoteJobs
* 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
MethodpromoteJobs
(count = 1000)
src/classes/redis-queue-backend.ts:1920
MethodpublishEvent
( fields: Record<string, string | number>, _maxEvents: number, )
src/postgres/postgres-queue-backend.ts:2036
MethodpublishEvent
( fields: Record<string, string | number>, maxEvents: number, )
src/classes/redis-queue-backend.ts:2858
MethodpublishEvent
* 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
Functionpytest_collection_modifyitems
(config, items)
python/tests/conftest.py:52
MethodqualifiedName
The queue's fully-qualified name (cross-backend logical identifier).
python/bullmq/backend.py:98
MethodqualifiedName
(self)
python/bullmq/backends/redis_backend.py:154
MethodqualifiedName
(self)
python/bullmq/backends/postgres_backend.py:284
MethodqualifiedName
* 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
MethodqualifiedName
* 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
Methodqueue
Set the per-queue options for `queue_name`.
rust/src/flow_producer.rs:181
MethodqueueName
* @returns the queue name this job belongs to.
src/classes/job.ts:931
MethodqueueName
()
src/interfaces/minimal-job.ts:157
MethodqueueQualifiedName
* @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
Methodqueue_name
The queue name this job belongs to.
rust/src/job.rs:257
Methodquit
()
src/classes/node-redis-client.ts:376
Methodquit
()
src/classes/bun-redis-client.ts:495
Methodquit
()
src/classes/valkey-glide-client.ts:619
MethodraiseError
(msg: string, match: string)
src/commands/script-loader.ts:199
MethodrateLimit
* 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
Methodread
()
src/classes/node-redis-client.ts:821
MethodreadEvents
(id: string, blockTimeout: number)
src/postgres/postgres-queue-backend.ts:2049
MethodreadEvents
(id: string, blockTimeout: number)
src/classes/redis-queue-backend.ts:2869
Methodreason
(self)
python/bullmq/abort_controller.py:64
FunctionreconnectBlocking
()
tests/worker.test.ts:1391
MethodreconnectBlocking
()
src/postgres/postgres-queue-backend.ts:2275
Methodrecord
* 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
Methodrecord
(value: number, attributes?: Attributes)
tests/telemetry_interface.test.ts:59
Methodrecord
(value: number, attributes?: Attributes)
tests/telemetry_interface.test.ts:67
MethodrecordException
(exception: ExtendedException, time?: Time)
tests/telemetry_interface.test.ts:192
Functionredacts_password_only_and_keeps_ipv6_host
()
rust/src/redis_connection.rs:265
Functionredacts_username_password
()
rust/src/redis_connection.rs:259
MethodredisVersion
()
src/classes/redis-connection.ts:882
MethodredisVersion
()
src/classes/redis-queue-backend.ts:174
MethodredisVersion
* Returns the version of the Redis instance the client is connected to,
src/interfaces/script-queue-context.ts:28
Functionrejects_parent_queue_names_with_extra_colons
()
rust/src/keys.rs:301
Methodrelease
(child: Child)
src/classes/child-pool.ts:90
Methodrelease_concurrency_slot
Release a concurrency slot and notify waiters.
rust/src/worker.rs:1042
Methodremove
(self, job_id: str, remove_children: bool)
python/bullmq/scripts.py:503
Methodremove
(self, opts: dict = {})
python/bullmq/job.py:146
Methodremove
Remove a job and (optionally) its children.
python/bullmq/backend.py:248
Methodremove
(self, job_id: str, remove_children: bool)
python/bullmq/backends/redis_backend.py:287
Methodremove
(self, job_id: str, remove_children: bool)
python/bullmq/backends/postgres_backend.py:599
Methodremove
* 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
Methodremove
* Remove a job. * * @param string $jobId * @param bool $removeChildren * @return mixed */
php/src/Scripts.php:499
Methodremove
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
Methodremove
(jobId: string, removeChildren: boolean)
src/postgres/postgres-queue-backend.ts:1310
Methodremove
* 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
Methodremove
* 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
Methodremove
(jobId: string, removeChildren: boolean)
src/classes/redis-queue-backend.ts:986
MethodremoveAllListeners
(event?: string)
src/postgres/pg-types.ts:63
MethodremoveAllListeners
(event?: string | symbol)
src/interfaces/redis-client.ts:53
MethodremoveChildDependency
( jobId: string, parentKey: string, )
src/postgres/postgres-queue-backend.ts:1335
MethodremoveChildDependency
* 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
MethodremoveChildDependency
( jobId: string, parentKey: string, )
src/classes/redis-queue-backend.ts:1256
MethodremoveDebounceKey
* Removes a debounce key. * @deprecated use removeDeduplicationKey * * @param id - debounce identifier
src/classes/queue.ts:623
MethodremoveDeduplicationKey
( deduplicationId: string, jobId: string, )
src/postgres/postgres-queue-backend.ts:1358
MethodremoveDeduplicationKey
* 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
MethodremoveDeduplicationKey
* Removes a deduplication key. * * @param id - identifier
src/classes/queue.ts:643
MethodremoveDeduplicationKey
* 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
MethodremoveDeprecatedPriorityKey
Remove the deprecated priority helper key.
python/bullmq/backend.py:348
MethodremoveDeprecatedPriorityKey
Delete old priority helper key.
python/bullmq/queue.py:336
MethodremoveDeprecatedPriorityKey
(self)
python/bullmq/backends/redis_backend.py:425
MethodremoveDeprecatedPriorityKey
(self)
python/bullmq/backends/postgres_backend.py:758
MethodremoveDeprecatedPriorityKey
()
src/postgres/postgres-queue-backend.ts:2024
MethodremoveDeprecatedPriorityKey
* Delete old priority helper key.
src/classes/queue.ts:940
MethodremoveDeprecatedPriorityKey
()
src/classes/redis-queue-backend.ts:2760
MethodremoveJobScheduler
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
MethodremoveJobScheduler
Remove a scheduler. Returns 0 on success, 1 if absent.
python/bullmq/job_scheduler.py:312
MethodremoveJobScheduler
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
MethodremoveJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/redis_backend.py:475
MethodremoveJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/postgres_backend.py:886
MethodremoveJobScheduler
(jobSchedulerId: string)
src/postgres/postgres-queue-backend.ts:1403
MethodremoveJobScheduler
* * Removes a job scheduler. * * @param jobSchedulerId - identifier of the job scheduler. * * @returns
src/classes/queue.ts:610
MethodremoveJobScheduler
(jobSchedulerId: string)
src/classes/redis-queue-backend.ts:961
MethodremoveJobScheduler
(jobSchedulerId: string)
src/classes/job-scheduler.ts:344
MethodremoveListener
(event: string, listener: (...args: any[]) => void)
src/interfaces/queue-backend.ts:134
MethodremoveListener
(event: string, listener: (...args: any[]) => void)
src/interfaces/redis-client.ts:48
MethodremoveListener
( event: string | symbol, listener: (...args: any[]) => void, )
src/interfaces/minimal-queue.ts:32
MethodremoveListeners
()
src/classes/job.ts:1137
MethodremoveOrphanedJobs
* 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
MethodremoveOrphanedJobs
* 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
← previousnext →2,701–2,800 of 3,768, ranked by callers