MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

MethodgetDebounceJobId
* Get jobId that starts debounced state. * @deprecated use getDeduplicationJobId method * * @param id - debounce identifier
src/classes/queue-getters.ts:118
MethodgetDeduplicationJobId
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
MethodgetDeduplicationJobId
Get jobId from deduplicated state. @param deduplication_id: deduplication identifier
python/bullmq/backends/postgres_backend.py:649
MethodgetDeduplicationJobId
(deduplicationId: string)
src/postgres/postgres-queue-backend.ts:1576
MethodgetDeduplicationJobId
* Get jobId from deduplicated state. * * @param id - deduplication identifier
src/classes/queue-getters.ts:127
MethodgetDeduplicationJobId
(deduplicationId: string)
src/classes/redis-queue-backend.ts:2482
MethodgetDelayed
(self, start = 0, end=-1)
python/bullmq/queue.py:413
MethodgetDelayed
* 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
MethodgetDelayedCount
* Returns the number of jobs in delayed status.
src/classes/queue-getters.ts:289
MethodgetDependencies
( jobId: string, opts: DependenciesOpts, )
src/postgres/postgres-queue-backend.ts:1692
MethodgetDependencies
* 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
MethodgetDependencies
* 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
MethodgetDependencies
( jobId: string, opts: DependenciesOpts = {}, )
src/classes/redis-queue-backend.ts:2540
MethodgetDependencyCounts
(jobId: string, types: string[])
src/postgres/postgres-queue-backend.ts:1675
MethodgetDependencyCounts
(jobId: string, types: string[])
src/classes/redis-queue-backend.ts:1414
MethodgetFailed
* 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
MethodgetFailedCount
* Returns the number of jobs in failed status.
src/classes/queue-getters.ts:282
MethodgetFilenamesByPattern
(pattern: string)
src/commands/script-loader.ts:237
MethodgetGlobalConcurrency
* Get global concurrency value. * Returns null in case no value is set.
src/classes/queue-getters.ts:135
MethodgetGlobalRateLimit
* Get global rate limit values. * Returns null in case no value is set.
src/classes/queue-getters.ts:147
MethodgetIgnoredChildrenFailures
( jobId: string, )
src/postgres/postgres-queue-backend.ts:1820
MethodgetIgnoredChildrenFailures
* 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
MethodgetIgnoredChildrenFailures
( jobId: string, )
src/classes/redis-queue-backend.ts:2533
MethodgetJobData
Return the stored data for a job, or ``None`` if it is missing.
python/bullmq/backend.py:300
MethodgetJobData
(self, job_id: str)
python/bullmq/backends/redis_backend.py:360
MethodgetJobData
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:675
MethodgetJobData
(jobId: string)
src/postgres/postgres-queue-backend.ts:1568
MethodgetJobData
(jobId: string)
src/classes/redis-queue-backend.ts:2474
MethodgetJobLogs
Return a page of a job's logs together with the total log count.
python/bullmq/backend.py:304
MethodgetJobLogs
( self, job_id: str, start: int = 0, end: int = -1, asc: bool = True )
python/bullmq/backends/redis_backend.py:364
MethodgetJobLogs
(self, job_id: str, start: int = 0, end: int = -1, asc: bool = True)
python/bullmq/backends/postgres_backend.py:681
MethodgetJobLogs
( jobId: string, start: number, end: number, asc: boolean, )
src/postgres/postgres-queue-backend.ts:1584
MethodgetJobLogs
* 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
MethodgetJobLogs
( jobId: string, start: number, end: number, asc: boolean, )
src/classes/redis-queue-backend.ts:2487
MethodgetJobScheduler
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
MethodgetJobScheduler
Return a ``(fields, next_millis)`` pair for a single scheduler. ``fields`` is the metadata mapping (``name``, ``ic``, ``every``, ``pa
python/bullmq/backend.py:408
MethodgetJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/redis_backend.py:486
MethodgetJobScheduler
(self, job_scheduler_id: str)
python/bullmq/backends/postgres_backend.py:900
MethodgetJobScheduler
(id: string)
src/postgres/postgres-queue-backend.ts:1411
MethodgetJobScheduler
* Get Job Scheduler by id * * @param id - identifier of scheduler.
src/classes/queue.ts:566
MethodgetJobScheduler
(id: string)
src/classes/redis-queue-backend.ts:1794
MethodgetJobSchedulerData
(key: string)
src/postgres/postgres-queue-backend.ts:1435
MethodgetJobSchedulerData
(key: string)
src/classes/redis-queue-backend.ts:1811
MethodgetJobSchedulers
Page through registered schedulers. `asc=True` returns earliest-next-fire first.
python/bullmq/job_scheduler.py:328
MethodgetJobSchedulers
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
MethodgetJobSchedulers
( self, start: int = 0, end: int = -1, asc: bool = False )
python/bullmq/backends/redis_backend.py:491
MethodgetJobSchedulers
( self, start: int = 0, end: int = -1, asc: bool = False )
python/bullmq/backends/postgres_backend.py:909
MethodgetJobSchedulers
( start = 0, end = -1, asc = false, )
src/classes/job-scheduler.ts:470
MethodgetJobSchedulersCount
Return the total number of registered schedulers.
python/bullmq/backend.py:427
MethodgetJobSchedulersCount
(self)
python/bullmq/backends/redis_backend.py:521
MethodgetJobSchedulersCount
(self)
python/bullmq/backends/postgres_backend.py:938
MethodgetJobSchedulersCount
()
src/postgres/postgres-queue-backend.ts:1463
MethodgetJobSchedulersCount
* * Get the number of job schedulers. * * @returns The number of job schedulers.
src/classes/queue.ts:598
MethodgetJobSchedulersCount
()
src/classes/redis-queue-backend.ts:1828
MethodgetJobSchedulersRange
( start: number, end: number, asc: boolean, )
src/postgres/postgres-queue-backend.ts:1446
MethodgetJobSchedulersRange
( start: number, end: number, asc: boolean, )
src/classes/redis-queue-backend.ts:1816
MethodgetJobState
* Get current job state. * * @param jobId - job identifier. * @returns Returns one of these values: * 'completed', 'failed', 'delayed', 'a
src/classes/queue-getters.ts:229
MethodgetJobs
(self, types, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/scripts.py:240
MethodgetJobs
* 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
MethodgetJobs
* 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
MethodgetKeepJobs
(shouldRemove: bool | dict | int | None)
python/bullmq/scripts.py:731
MethodgetKeys
* 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
MethodgetMetadata
(context: Context)
tests/telemetry_interface.test.ts:140
MethodgetMetrics
( type: 'completed' | 'failed', start = 0, end = -1, )
src/postgres/postgres-queue-backend.ts:1856
MethodgetMetrics
( type: 'completed' | 'failed', start = 0, end = -1, )
src/classes/redis-queue-backend.ts:1986
MethodgetMetricsSize
(opts: dict)
python/bullmq/scripts.py:744
MethodgetPrefix
* Get the prefix used for keys. */
php/src/QueueKeys.php:22
MethodgetPrioritized
* 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
MethodgetProcessedChildrenValues
Return the raw processed-children map (child key -> serialized value).
python/bullmq/backend.py:328
MethodgetProcessedChildrenValues
(self, job_id: str)
python/bullmq/backends/redis_backend.py:393
MethodgetProcessedChildrenValues
(self, job_id: str)
python/bullmq/backends/postgres_backend.py:733
MethodgetProcessedChildrenValues
( jobId: string, )
src/postgres/postgres-queue-backend.ts:1806
MethodgetProcessedChildrenValues
( jobId: string, )
src/classes/redis-queue-backend.ts:2524
MethodgetQueue
* Get the queue this job belongs to. */
php/src/Job.php:163
MethodgetQueueMeta
()
src/postgres/postgres-queue-backend.ts:1977
MethodgetQueueMeta
()
src/classes/redis-queue-backend.ts:2732
MethodgetQueueMetaField
(field: string)
src/postgres/postgres-queue-backend.ts:1957
MethodgetQueueMetaField
(field: string)
src/classes/redis-queue-backend.ts:2722
MethodgetQueueMetaFields
(fields: string[])
src/postgres/postgres-queue-backend.ts:1965
MethodgetQueueMetaFields
(fields: string[])
src/classes/redis-queue-backend.ts:2727
MethodgetRanges
(self, types, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/scripts.py:245
MethodgetRanges
Return a page of job ids for the given states/types.
python/bullmq/backend.py:322
MethodgetRanges
( self, types: list, start: int = 0, end: int = 1, asc: bool = False )
python/bullmq/backends/redis_backend.py:388
MethodgetRanges
(self, types: list, start: int = 0, end: int = 1, asc: bool = False)
python/bullmq/backends/postgres_backend.py:720
MethodgetRanges
* Get ranges of jobs. * * @param array<string> $types * @param int $start * @param int $end * @param bool $asc * @return
php/src/Scripts.php:395
MethodgetRanges
( types: JobType[], start = 0, end = -1, asc = false, )
src/postgres/postgres-queue-backend.ts:1655
MethodgetRanges
( types: JobType[], start = 0, end = 1, asc = false, )
src/classes/redis-queue-backend.ts:1302
MethodgetRateLimitTtl
Return the ttl (ms) of the current rate-limit window.
python/bullmq/backend.py:310
MethodgetRateLimitTtl
(self)
python/bullmq/backends/redis_backend.py:379
MethodgetRateLimitTtl
(self)
python/bullmq/backends/postgres_backend.py:692
MethodgetRateLimitTtl
* Get rate limit TTL. * * @param int|null $maxJobs Maximum jobs to consider * @return int TTL in milliseconds */
php/src/Queue.php:589
MethodgetRateLimitTtl
* 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
MethodgetRateLimitTtl
(maxJobs?: number)
src/postgres/postgres-queue-backend.ts:1611
MethodgetRateLimitTtl
* 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
MethodgetRateLimitTtl
(maxJobs?: number)
src/classes/redis-queue-backend.ts:1758
MethodgetRedisVersion
* Get the Redis server version. * * @return string The Redis version * @throws \RuntimeException If the version cannot be retrieved
php/src/RedisConnection.php:67
FunctiongetRepeatJobIdCheckum
( repeatJobKey: string, repeatKeyHashAlgorithm: string, )
tests/utils/repeat_utils.ts:30
FunctiongetRepeatableJobKeyPrefix
( prefix: string, queueName: string, )
tests/utils/repeat_utils.ts:13
MethodgetState
(self, job_id: str)
python/bullmq/scripts.py:530
MethodgetState
(self)
python/bullmq/job.py:136
← previousnext →2,201–2,300 of 3,768, ranked by callers