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
getDebounceJobId
* Get jobId that starts debounced state. * @deprecated use getDeduplicationJobId method * * @param id - debounce identifier
src/classes/queue-getters.ts:118
Method
getDeduplicationJobId
Get jobId from deduplicated state. Mirrors Queue#getDeduplicationJobId in the Node.js client: a plain GET against the `de` (
python/bullmq/backends/redis_backend.py:343
Method
getDeduplicationJobId
Get jobId from deduplicated state. @param deduplication_id: deduplication identifier
python/bullmq/backends/postgres_backend.py:649
Method
getDeduplicationJobId
(deduplicationId: string)
src/postgres/postgres-queue-backend.ts:1576
Method
getDeduplicationJobId
* Get jobId from deduplicated state. * * @param id - deduplication identifier
src/classes/queue-getters.ts:127
Method
getDeduplicationJobId
(deduplicationId: string)
src/classes/redis-queue-backend.ts:2482
Method
getDelayed
(self, start = 0, end=-1)
python/bullmq/queue.py:413
Method
getDelayed
* Returns the jobs that are in the "delayed" status. * @param start - zero based index from where to start returning jobs. * @param end - zero b
src/classes/queue-getters.ts:371
Method
getDelayedCount
* Returns the number of jobs in delayed status.
src/classes/queue-getters.ts:289
Method
getDependencies
( jobId: string, opts: DependenciesOpts, )
src/postgres/postgres-queue-backend.ts:1692
Method
getDependencies
* Get children job keys if this job is a parent and has children. * @remarks * Count options before Redis v7.2 works as expected with any quanti
src/classes/job.ts:1038
Method
getDependencies
* Returns the qualified job ids and the raw job data (if available) of the * children jobs of the given parent job. * It is possible to get eith
src/classes/queue-getters.ts:419
Method
getDependencies
( jobId: string, opts: DependenciesOpts = {}, )
src/classes/redis-queue-backend.ts:2540
Method
getDependencyCounts
(jobId: string, types: string[])
src/postgres/postgres-queue-backend.ts:1675
Method
getDependencyCounts
(jobId: string, types: string[])
src/classes/redis-queue-backend.ts:1414
Method
getFailed
* Returns the jobs that are in the "failed" status. * @param start - zero based index from where to start returning jobs. * @param end - zero ba
src/classes/queue-getters.ts:398
Method
getFailedCount
* Returns the number of jobs in failed status.
src/classes/queue-getters.ts:282
Method
getFilenamesByPattern
(pattern: string)
src/commands/script-loader.ts:237
Method
getGlobalConcurrency
* Get global concurrency value. * Returns null in case no value is set.
src/classes/queue-getters.ts:135
Method
getGlobalRateLimit
* Get global rate limit values. * Returns null in case no value is set.
src/classes/queue-getters.ts:147
Method
getIgnoredChildrenFailures
( jobId: string, )
src/postgres/postgres-queue-backend.ts:1820
Method
getIgnoredChildrenFailures
* Retrieves the failures of child jobs that were explicitly ignored while using ignoreDependencyOnFailure option. * This method is useful for inspe
src/classes/job.ts:1012
Method
getIgnoredChildrenFailures
( jobId: string, )
src/classes/redis-queue-backend.ts:2533
Method
getJobData
Return the stored data for a job, or ``None`` if it is missing.
python/bullmq/backend.py:300
Method
getJobData
(self, job_id: str)
python/bullmq/backends/redis_backend.py:360
Method
getJobData
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:675
Method
getJobData
(jobId: string)
src/postgres/postgres-queue-backend.ts:1568
Method
getJobData
(jobId: string)
src/classes/redis-queue-backend.ts:2474
Method
getJobLogs
Return a page of a job's logs together with the total log count.
python/bullmq/backend.py:304
Method
getJobLogs
( self, job_id: str, start: int = 0, end: int = -1, asc: bool = True )
python/bullmq/backends/redis_backend.py:364
Method
getJobLogs
(self, job_id: str, start: int = 0, end: int = -1, asc: bool = True)
python/bullmq/backends/postgres_backend.py:681
Method
getJobLogs
( jobId: string, start: number, end: number, asc: boolean, )
src/postgres/postgres-queue-backend.ts:1584
Method
getJobLogs
* Returns the logs for a given Job. * @param jobId - the id of the job to get the logs for. * @param start - zero based index from where to star
src/classes/queue-getters.ts:534
Method
getJobLogs
( jobId: string, start: number, end: number, asc: boolean, )
src/classes/redis-queue-backend.ts:2487
Method
getJobScheduler
Fetch a scheduler hash. Returns a `[raw_fields, score]` tuple where `raw_fields` is the flat HGETALL result (or None) and `score` is
python/bullmq/scripts.py:493
Method
getJobScheduler
Return a ``(fields, next_millis)`` pair for a single scheduler. ``fields`` is the metadata mapping (``name``, ``ic``, ``every``, ``pa
python/bullmq/backend.py:408
Method
getJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/redis_backend.py:486
Method
getJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/postgres_backend.py:900
Method
getJobScheduler
(id: string)
src/postgres/postgres-queue-backend.ts:1411
Method
getJobScheduler
* Get Job Scheduler by id * * @param id - identifier of scheduler.
src/classes/queue.ts:566
Method
getJobScheduler
(id: string)
src/classes/redis-queue-backend.ts:1794
Method
getJobSchedulerData
(key: string)
src/postgres/postgres-queue-backend.ts:1435
Method
getJobSchedulerData
(key: string)
src/classes/redis-queue-backend.ts:1811
Method
getJobSchedulers
Page through registered schedulers. `asc=True` returns earliest-next-fire first.
python/bullmq/job_scheduler.py:328
Method
getJobSchedulers
Return a page of registered schedulers as a list of ``(key, fields, next_millis)`` tuples (see :meth:`getJobScheduler` for the ``field
python/bullmq/backend.py:419
Method
getJobSchedulers
( self, start: int = 0, end: int = -1, asc: bool = False )
python/bullmq/backends/redis_backend.py:491
Method
getJobSchedulers
( self, start: int = 0, end: int = -1, asc: bool = False )
python/bullmq/backends/postgres_backend.py:909
Method
getJobSchedulers
( start = 0, end = -1, asc = false, )
src/classes/job-scheduler.ts:470
Method
getJobSchedulersCount
Return the total number of registered schedulers.
python/bullmq/backend.py:427
Method
getJobSchedulersCount
(self)
python/bullmq/backends/redis_backend.py:521
Method
getJobSchedulersCount
(self)
python/bullmq/backends/postgres_backend.py:938
Method
getJobSchedulersCount
()
src/postgres/postgres-queue-backend.ts:1463
Method
getJobSchedulersCount
* * Get the number of job schedulers. * * @returns The number of job schedulers.
src/classes/queue.ts:598
Method
getJobSchedulersCount
()
src/classes/redis-queue-backend.ts:1828
Method
getJobSchedulersRange
( start: number, end: number, asc: boolean, )
src/postgres/postgres-queue-backend.ts:1446
Method
getJobSchedulersRange
( start: number, end: number, asc: boolean, )
src/classes/redis-queue-backend.ts:1816
Method
getJobState
* Get current job state. * * @param jobId - job identifier. * @returns Returns one of these values: * 'completed', 'failed', 'delayed', 'a
src/classes/queue-getters.ts:229
Method
getJobs
(self, types, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/scripts.py:240
Method
getJobs
* Get jobs with raw hash data by type/state. * * @param array<string> $types * @param int $start * @param int $end * @param b
php/src/Scripts.php:365
Method
getJobs
* Fetches job ids and their job hashes for the provided states in a single * script, skipping ids whose job hash is missing (for example the deprec
src/classes/redis-queue-backend.ts:1344
Method
getKeepJobs
(shouldRemove: bool | dict | int | None)
python/bullmq/scripts.py:731
Method
getKeys
* Get all keys for a queue. * * @param string $name Queue name * @return array<string, string> Array of key names to full key paths
php/src/QueueKeys.php:33
Method
getMetadata
(context: Context)
tests/telemetry_interface.test.ts:140
Method
getMetrics
( type: 'completed' | 'failed', start = 0, end = -1, )
src/postgres/postgres-queue-backend.ts:1856
Method
getMetrics
( type: 'completed' | 'failed', start = 0, end = -1, )
src/classes/redis-queue-backend.ts:1986
Method
getMetricsSize
(opts: dict)
python/bullmq/scripts.py:744
Method
getPrefix
* Get the prefix used for keys. */
php/src/QueueKeys.php:22
Method
getPrioritized
* Returns the jobs that are in the "prioritized" status. * @param start - zero based index from where to start returning jobs. * @param end - ze
src/classes/queue-getters.ts:380
Method
getProcessedChildrenValues
Return the raw processed-children map (child key -> serialized value).
python/bullmq/backend.py:328
Method
getProcessedChildrenValues
(self, job_id: str)
python/bullmq/backends/redis_backend.py:393
Method
getProcessedChildrenValues
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:733
Method
getProcessedChildrenValues
( jobId: string, )
src/postgres/postgres-queue-backend.ts:1806
Method
getProcessedChildrenValues
( jobId: string, )
src/classes/redis-queue-backend.ts:2524
Method
getQueue
* Get the queue this job belongs to. */
php/src/Job.php:163
Method
getQueueMeta
()
src/postgres/postgres-queue-backend.ts:1977
Method
getQueueMeta
()
src/classes/redis-queue-backend.ts:2732
Method
getQueueMetaField
(field: string)
src/postgres/postgres-queue-backend.ts:1957
Method
getQueueMetaField
(field: string)
src/classes/redis-queue-backend.ts:2722
Method
getQueueMetaFields
(fields: string[])
src/postgres/postgres-queue-backend.ts:1965
Method
getQueueMetaFields
(fields: string[])
src/classes/redis-queue-backend.ts:2727
Method
getRanges
(self, types, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/scripts.py:245
Method
getRanges
Return a page of job ids for the given states/types.
python/bullmq/backend.py:322
Method
getRanges
( self, types: list, start: int = 0, end: int = 1, asc: bool = False )
python/bullmq/backends/redis_backend.py:388
Method
getRanges
(self, types: list, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/backends/postgres_backend.py:720
Method
getRanges
* Get ranges of jobs. * * @param array<string> $types * @param int $start * @param int $end * @param bool $asc * @return
php/src/Scripts.php:395
Method
getRanges
( types: JobType[], start = 0, end = -1, asc = false, )
src/postgres/postgres-queue-backend.ts:1655
Method
getRanges
( types: JobType[], start = 0, end = 1, asc = false, )
src/classes/redis-queue-backend.ts:1302
Method
getRateLimitTtl
Return the ttl (ms) of the current rate-limit window.
python/bullmq/backend.py:310
Method
getRateLimitTtl
(self)
python/bullmq/backends/redis_backend.py:379
Method
getRateLimitTtl
(self)
python/bullmq/backends/postgres_backend.py:692
Method
getRateLimitTtl
* Get rate limit TTL. * * @param int|null $maxJobs Maximum jobs to consider * @return int TTL in milliseconds */
php/src/Queue.php:589
Method
getRateLimitTtl
* Get rate limit TTL. * * @param int|null $maxJobs * @return int TTL in milliseconds, -2 if key doesn't exist, -1 if no expire */
php/src/Scripts.php:529
Method
getRateLimitTtl
(maxJobs?: number)
src/postgres/postgres-queue-backend.ts:1611
Method
getRateLimitTtl
* Returns the time to live for a rate limited key in milliseconds. * @param maxJobs - max jobs to be considered in rate limit state. If not passed
src/classes/queue-getters.ts:108
Method
getRateLimitTtl
(maxJobs?: number)
src/classes/redis-queue-backend.ts:1758
Method
getRedisVersion
* Get the Redis server version. * * @return string The Redis version * @throws \RuntimeException If the version cannot be retrieved
php/src/RedisConnection.php:67
Function
getRepeatJobIdCheckum
( repeatJobKey: string, repeatKeyHashAlgorithm: string, )
tests/utils/repeat_utils.ts:30
Function
getRepeatableJobKeyPrefix
( prefix: string, queueName: string, )
tests/utils/repeat_utils.ts:13
Method
getState
(self, job_id: str)
python/bullmq/scripts.py:530
Method
getState
(self)
python/bullmq/job.py:136
← previous
next →
2,201–2,300 of 3,768, ranked by callers