diff --git a/classes/v1.Backoffs.html b/classes/v1.Backoffs.html
index 4eac6a2bfd..6e66c52a04 100644
--- a/classes/v1.Backoffs.html
+++ b/classes/v1.Backoffs.html
@@ -1,4 +1,4 @@
-
Backoffs | bullmq - v4.15.3
+Backoffs | bullmq - v4.15.4
@@ -128,7 +128,7 @@
@@ -73,7 +73,7 @@
@@ -128,7 +128,7 @@
getPrefixedQueueName
toKey
@@ -73,7 +73,7 @@
constructor
@@ -73,7 +73,7 @@
constructor
@@ -128,7 +128,7 @@
getPrefixedQueueName
toKey
@@ -73,7 +73,7 @@
constructor
@@ -73,7 +73,7 @@
constructor
@@ -37,7 +37,7 @@
Hierarchy
+
Defined in classes/async-fifo-queue.ts:13
@@ -75,7 +75,7 @@ Parameters
ignoreErrors: boolean = false
+
Defined in classes/async-fifo-queue.ts:34
Methods
@@ -90,7 +90,7 @@ Parameters
promise: Promise<T>
Returns void
+Defined in classes/async-fifo-queue.ts:38
+Defined in classes/async-fifo-queue.ts:97
+Defined in classes/async-fifo-queue.ts:68
+Defined in classes/async-fifo-queue.ts:72
+Defined in classes/async-fifo-queue.ts:64
+Defined in classes/async-fifo-queue.ts:60
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/backoffs.ts:8
@@ -54,7 +54,7 @@ Properties
Static
builtinStrategies
+
Defined in classes/backoffs.ts:9
Returns number | Promise<number>
+
Defined in classes/backoffs.ts:36
Returns BackoffOptions
+Defined in classes/backoffs.ts:23
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/child-pool.ts:11
@@ -60,7 +60,7 @@ Parameters
__namedParameters: ChildPoolOpts
Returns ChildPool
+
Defined in classes/child-pool.ts:16
Properties
@@ -72,7 +72,7 @@ Type declaration
[key: string]: Child[]
+Defined in classes/child-pool.ts:13
retained
retained: {
    [key: number]: Child;
} = {}
@@ -82,7 +82,7 @@ Type declaration
[key: number]: Child
+Defined in classes/child-pool.ts:12
+Defined in classes/child-pool.ts:84
getFree
@@ -113,7 +113,7 @@ Parameters
id: string
Returns Child[]
+Defined in classes/child-pool.ts:80
kill
@@ -128,7 +128,7 @@ child: signal: "SIGKILL" | "SIGTERM" = 'SIGKILL'
Returns Promise<void>
+Defined in classes/child-pool.ts:64
release
@@ -141,7 +141,7 @@ Parameters
child: Child
Returns void
+Defined in classes/child-pool.ts:48
remove
@@ -154,7 +154,7 @@ Parameters
child: Child
Returns void
+Defined in classes/child-pool.ts:53
retain
@@ -167,7 +167,7 @@ Parameters
processFile: string
Returns Promise<Child>
+Defined in classes/child-pool.ts:23
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in classes/child-processor.ts:19
@@ -75,24 +75,24 @@ msg: Returns Promise<void>
Returns ChildProcessor
+
Defined in classes/child-processor.ts:24
+
Defined in classes/child-processor.ts:21
Optional
status
status?: ChildStatus
+
Defined in classes/child-processor.ts:20
Methods
@@ -107,7 +107,7 @@ Parameters
processorFile: string
Returns Promise<void>
+Defined in classes/child-processor.ts:26
start
Returns Promise<void>
+Defined in classes/child-processor.ts:64
+Defined in classes/child-processor.ts:92
waitForCurrentJobAndExit
@@ -138,7 +138,7 @@ waitForCurrentJobAnd
Returns Promise<void>
+Defined in classes/child-processor.ts:94
@@ -32,7 +32,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:92
+
Defined in classes/flow-producer.ts:100
+
Defined in classes/flow-producer.ts:94
+
Defined in classes/flow-producer.ts:101
+
Defined in classes/flow-producer.ts:96
toKey
toKey: ((name, type) => string)
@@ -126,7 +126,7 @@ name: type: string
Returns string
+Defined in classes/flow-producer.ts:93
+Defined in classes/flow-producer.ts:172
+Defined in classes/flow-producer.ts:262
+Defined in classes/flow-producer.ts:477
+Defined in classes/flow-producer.ts:488
emit
@@ -237,7 +237,7 @@ Rest
Returns boolean
+Defined in classes/flow-producer.ts:138
+Defined in classes/flow-producer.ts:230
+Defined in classes/flow-producer.ts:145
+Defined in classes/flow-producer.ts:153
+Defined in classes/flow-producer.ts:161
+Defined in classes/flow-producer.ts:183
@@ -41,7 +41,7 @@
Implements
+
Defined in classes/job.ts:60
Returns Job<DataType, ReturnType, NameType>
+
Defined in classes/job.ts:148
Properties
@@ -169,7 +169,7 @@ Default Value
0
+Defined in classes/job.ts:105
data
data: DataType
@@ -178,7 +178,7 @@ data
+Defined in classes/job.ts:158
delay
delay: number
@@ -190,7 +190,7 @@ Default Value
0
+Defined in classes/job.ts:94
failedReason
failedReason: string
@@ -199,7 +199,7 @@ failedReason
+Defined in classes/job.ts:110
Optional
finishedOn
finishedOn?: number
@@ -208,13 +208,13 @@ Optional
+Defined in classes/job.ts:115
+Defined in classes/job.ts:164
name
name: NameType
@@ -223,7 +223,7 @@ name
+Defined in classes/job.ts:153
opts
@@ -232,7 +232,7 @@ opts
+Defined in classes/job.ts:163
Optional
parent
@@ -241,7 +241,7 @@ Optional
+Defined in classes/job.ts:130
Optional
parentKey
parentKey?: string
@@ -250,7 +250,7 @@ Optional
+Defined in classes/job.ts:125
Optional
processedOn
processedOn?: number
@@ -259,7 +259,7 @@ Optional
+Defined in classes/job.ts:120
progress
progress: number | object = 0
@@ -271,7 +271,7 @@ Default Value
0
+Defined in classes/job.ts:76
+Defined in classes/job.ts:70
Optional
repeatJobKey
repeatJobKey?: string
@@ -291,7 +291,7 @@ Optional
+Defined in classes/job.ts:135
returnvalue
returnvalue: ReturnType = null
@@ -303,7 +303,7 @@ Default Value
null
+Defined in classes/job.ts:82
stacktrace
stacktrace: string[] = null
@@ -315,7 +315,7 @@ Default Value
null
+Defined in classes/job.ts:88
timestamp
timestamp: number
@@ -324,7 +324,7 @@ timestamp
+Defined in classes/job.ts:99
Optional
token
token?: string
@@ -332,7 +332,7 @@ Optional
+Defined in classes/job.ts:140
queueName
@@ -356,7 +356,7 @@ Returns string
+Defined in classes/job.ts:741
asJSON
@@ -388,7 +388,7 @@ Returns
+Defined in classes/job.ts:423
asJSONSandbox
@@ -400,7 +400,7 @@ Returns
+Defined in classes/job.ts:465
changeDelay
@@ -420,7 +420,7 @@ Returns Promise<
+Defined in classes/job.ts:768
changePriority
@@ -442,7 +442,7 @@ Returns Promise<
+Defined in classes/job.ts:778
clearLogs
@@ -461,7 +461,7 @@ Optional
Returns Promise<void>
+Defined in classes/job.ts:510
+Defined in classes/job.ts:1083
extendLock
@@ -496,7 +496,7 @@ duration: Returns Promise<number>
+Defined in classes/job.ts:550
getChildrenValues
@@ -513,7 +513,7 @@ Returns Promise<
+Defined in classes/job.ts:790
+Defined in classes/job.ts:812
getDependenciesCount
@@ -559,7 +559,7 @@ Returns Promise<
+Defined in classes/job.ts:904
getState
@@ -572,7 +572,7 @@ Returns Promise<
+Defined in classes/job.ts:758
isActive
@@ -582,7 +582,7 @@ Returns Promise<
+Defined in classes/job.ts:727
isCompleted
@@ -592,7 +592,7 @@ Returns Promise<
+Defined in classes/job.ts:699
isDelayed
@@ -602,7 +602,7 @@ Returns Promise<
+Defined in classes/job.ts:713
isFailed
@@ -612,7 +612,7 @@ Returns Promise<
+Defined in classes/job.ts:706
isWaiting
@@ -622,7 +622,7 @@ Returns Promise<
+Defined in classes/job.ts:734
isWaitingChildren
@@ -632,7 +632,7 @@ Returns Promise<
+Defined in classes/job.ts:720
log
@@ -653,7 +653,7 @@ Returns Promise<
+Defined in classes/job.ts:501
moveToCompleted
@@ -684,7 +684,7 @@ Returns Promise<
+Defined in classes/job.ts:563
moveToDelayed
@@ -708,7 +708,7 @@ Optional
Returns Promise<void>
+Defined in classes/job.ts:1028
moveToFailed
@@ -743,7 +743,7 @@ Returns Promise<
+Defined in classes/job.ts:601
moveToWaitingChildren
@@ -768,7 +768,7 @@ Returns Promise<
+Defined in classes/job.ts:1045
+Defined in classes/job.ts:1055
remove
@@ -803,7 +803,7 @@ removeChildrenReturns Promise<void>
+Defined in classes/job.ts:528
retry
@@ -825,7 +825,7 @@ Returns Promise<
+Defined in classes/job.ts:1071
+Defined in classes/job.ts:414
updateData
@@ -853,7 +853,7 @@ Returns Promise<
+Defined in classes/job.ts:478
updateProgress
@@ -873,7 +873,7 @@ Returns Promise<
+Defined in classes/job.ts:489
waitUntilFinished
@@ -898,7 +898,7 @@ Optional
Returns Promise<ReturnType>
+Defined in classes/job.ts:956
Static
addJobLog
@@ -933,7 +933,7 @@ Returns Promise<
+Defined in classes/job.ts:389
Static
create
@@ -976,7 +976,7 @@ Optional
Returns Promise<Job<T, R, N>>
+Defined in classes/job.ts:205
Static
createBulk
@@ -1009,7 +1009,7 @@ jobs: Returns Promise<Job<T, R, N>[]>
+Defined in classes/job.ts:232
Static
fromId
@@ -1042,7 +1042,7 @@ jobId: Returns Promise<Job<T, R, N>>
+Defined in classes/job.ts:361
Static
fromJSON
@@ -1080,7 +1080,7 @@ Optional
Returns Job<T, R, N>
+Defined in classes/job.ts:279
@@ -38,7 +38,7 @@
Hierarchy
+
Defined in classes/queue.ts:92
@@ -148,7 +148,7 @@ Optional
Returns Queue<DataType, ResultType, NameType>
+
Defined in classes/queue.ts:101
+
Defined in classes/queue-base.ts:26
+
Defined in classes/queue.ts:98
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -176,7 +176,7 @@ Readonly
+Defined in classes/queue-base.ts:41
opts
@@ -185,13 +185,13 @@ opts
+Defined in classes/queue-base.ts:42
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -210,12 +210,12 @@ type: Returns string
+Defined in classes/queue-base.ts:24
token
token: string = ...
+Defined in classes/queue.ts:97
+Defined in classes/queue.ts:167
redisVersion
@@ -252,7 +252,7 @@ Returns string
+Defined in classes/queue-base.ts:97
+Defined in classes/queue.ts:171
Methods
@@ -291,7 +291,7 @@ Optional
Returns Promise<Job<DataType, ResultType, NameType>>
+Defined in classes/queue.ts:191
addBulk
@@ -312,7 +312,7 @@ jobs: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue.ts:231
addJobLog
@@ -342,7 +342,7 @@ Returns Promise<
+Defined in classes/queue.ts:388
clean
@@ -374,7 +374,7 @@ Returns Promise<
+Defined in classes/queue.ts:417
close
@@ -386,7 +386,7 @@ Returns Promise<
+Defined in classes/queue.ts:268
count
@@ -399,7 +399,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:96
disconnect
@@ -411,7 +411,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:158
drain
@@ -432,7 +432,7 @@ delayed: Returns Promise<void>
+Defined in classes/queue.ts:403
emit
@@ -459,7 +459,7 @@ Returns boolean
+Defined in classes/queue.ts:133
getActive
@@ -484,7 +484,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:241
getActiveCount
@@ -496,7 +496,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:186
getCompleted
@@ -521,7 +521,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:277
getCompletedCount
@@ -533,7 +533,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:165
getDelayed
@@ -558,7 +558,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:253
getDelayedCount
@@ -570,7 +570,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:179
getFailed
@@ -595,7 +595,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:289
getFailedCount
@@ -607,7 +607,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:172
getJob
@@ -621,7 +621,7 @@ jobId: Returns Promise<Job<DataType, ResultType, NameType>>
+Defined in classes/queue-getters.ts:26
getJobCountByTypes
@@ -642,7 +642,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:127
getJobCounts
@@ -660,7 +660,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:137
getJobLogs
@@ -695,7 +695,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:366
getJobState
@@ -714,7 +714,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:158
getJobs
@@ -749,7 +749,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:339
getMetrics
@@ -784,7 +784,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:454
getPrioritized
@@ -809,7 +809,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:265
getPrioritizedCount
@@ -821,7 +821,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:193
getQueueEvents
@@ -837,7 +837,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:432
getRanges
@@ -857,7 +857,7 @@ asc: Returns Promise<string[]>
+Defined in classes/queue-getters.ts:296
+Defined in classes/queue-getters.ts:114
+Defined in classes/queue.ts:304
getWaiting
@@ -928,7 +928,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:216
getWaitingChildren
@@ -954,7 +954,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:229
getWaitingChildrenCount
@@ -966,7 +966,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:207
getWaitingCount
@@ -978,7 +978,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:200
getWorkers
@@ -995,7 +995,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:418
+Defined in classes/queue.ts:290
obliterate
@@ -1030,7 +1030,7 @@ Optional
Returns Promise<void>
+Defined in classes/queue.ts:464
off
@@ -1051,7 +1051,7 @@ listener: Returns Queue<DataType, ResultType, NameType>
+Defined in classes/queue.ts:140
on
@@ -1072,7 +1072,7 @@ listener: Returns Queue<DataType, ResultType, NameType>
+Defined in classes/queue.ts:148
once
@@ -1093,7 +1093,7 @@ listener: Returns Queue<DataType, ResultType, NameType>
+Defined in classes/queue.ts:156
+Defined in classes/queue.ts:259
promoteJobs
@@ -1129,7 +1129,7 @@ Optional
Returns Promise<void>
+Defined in classes/queue.ts:508
remove
@@ -1159,7 +1159,7 @@ Returns Promise<
+Defined in classes/queue.ts:362
removeDeprecatedPriorityKey
@@ -1170,7 +1170,7 @@ removeDeprecatedPriorityKey<
Returns Promise<number>
+Defined in classes/queue.ts:528
removeRepeatable
@@ -1197,7 +1197,7 @@ Returns Promise<
See
removeRepeatableByKey
+Defined in classes/queue.ts:325
removeRepeatableByKey
@@ -1217,7 +1217,7 @@ Returns Promise<
See
getRepeatableJobs
+Defined in classes/queue.ts:346
+Defined in classes/queue.ts:282
retryJobs
@@ -1253,7 +1253,7 @@ Optional
Returns Promise<void>
+Defined in classes/queue.ts:487
trimEvents
@@ -1269,7 +1269,7 @@ maxLength: Returns Promise<number>
+Defined in classes/queue.ts:520
updateJobProgress
@@ -1293,7 +1293,7 @@ progress: Returns Promise<void>
+Defined in classes/queue.ts:372
+Defined in classes/queue-base.ts:129
@@ -37,7 +37,7 @@
Implements
+
Defined in classes/queue-base.ts:23
@@ -97,7 +97,7 @@ Connection: Returns QueueBase
+
Defined in classes/queue-base.ts:40
+
Defined in classes/queue-base.ts:26
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -120,7 +120,7 @@ Readonly
+Defined in classes/queue-base.ts:41
opts
@@ -129,13 +129,13 @@ opts
+Defined in classes/queue-base.ts:42
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -154,7 +154,7 @@ type: Returns string
+Defined in classes/queue-base.ts:24
redisVersion
@@ -180,7 +180,7 @@ Returns string
+Defined in classes/queue-base.ts:97
+Defined in classes/queue-base.ts:158
emit
@@ -227,7 +227,7 @@ Returns boolean
Implementation of MinimalQueue.emit
Overrides EventEmitter.emit
+Defined in classes/queue-base.ts:115
+Defined in classes/queue-base.ts:129
+
Defined in classes/queue-base.ts:26
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -106,7 +106,7 @@ Readonly
+Defined in classes/queue-base.ts:41
opts
@@ -115,13 +115,13 @@ opts
+Defined in classes/queue-base.ts:42
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -140,7 +140,7 @@ type: Returns string
+Defined in classes/queue-base.ts:24
redisVersion
@@ -166,7 +166,7 @@ Returns string
+Defined in classes/queue-base.ts:97
disconnect
@@ -192,7 +192,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:158
emit
@@ -219,7 +219,7 @@ Returns boolean
+Defined in classes/queue-events.ts:196
+Defined in classes/queue-events.ts:203
+Defined in classes/queue-events.ts:211
+Defined in classes/queue-events.ts:219
+Defined in classes/queue-events.ts:231
+Defined in classes/queue-base.ts:129
@@ -38,7 +38,7 @@
Hierarchy
+
Defined in classes/queue-getters.ts:21
@@ -133,7 +133,7 @@ Connection: Returns QueueGetters<DataType, ResultType, NameType>
+
Defined in classes/queue-base.ts:40
+
Defined in classes/queue-base.ts:26
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -156,7 +156,7 @@ Readonly
+Defined in classes/queue-base.ts:41
opts
@@ -165,13 +165,13 @@ opts
+Defined in classes/queue-base.ts:42
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -190,7 +190,7 @@ type: Returns string
+Defined in classes/queue-base.ts:24
redisVersion
@@ -216,7 +216,7 @@ Returns string
+Defined in classes/queue-base.ts:97
+Defined in classes/queue-getters.ts:96
disconnect
@@ -254,7 +254,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:158
emit
@@ -276,7 +276,7 @@ Returns boolean
+Defined in classes/queue-base.ts:115
getActive
@@ -300,7 +300,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:241
+Defined in classes/queue-getters.ts:186
getCompleted
@@ -335,7 +335,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:277
+Defined in classes/queue-getters.ts:165
getDelayed
@@ -370,7 +370,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:253
+Defined in classes/queue-getters.ts:179
getFailed
@@ -405,7 +405,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:289
+Defined in classes/queue-getters.ts:172
getJob
@@ -429,7 +429,7 @@ Parameters
jobId: string
Returns Promise<Job<DataType, ResultType, NameType>>
+Defined in classes/queue-getters.ts:26
getJobCountByTypes
@@ -449,7 +449,7 @@ Rest
Returns Promise<number>
+Defined in classes/queue-getters.ts:127
getJobCounts
@@ -466,7 +466,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:137
getJobLogs
@@ -500,7 +500,7 @@ asc: Returns Promise<{
    count: number;
    logs: string[];
}>
+Defined in classes/queue-getters.ts:366
getJobState
@@ -518,7 +518,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:158
getJobs
@@ -552,7 +552,7 @@ asc: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:339
getMetrics
@@ -586,7 +586,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:454
getPrioritized
@@ -610,7 +610,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:265
+Defined in classes/queue-getters.ts:193
getQueueEvents
@@ -636,7 +636,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:432
getRanges
@@ -655,7 +655,7 @@ end: asc: boolean = false
Returns Promise<string[]>
+Defined in classes/queue-getters.ts:296
+Defined in classes/queue-getters.ts:114
getWaiting
@@ -694,7 +694,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:216
getWaitingChildren
@@ -719,7 +719,7 @@ end: Returns Promise<Job<DataType, ResultType, NameType>[]>
+Defined in classes/queue-getters.ts:229
getWaitingChildrenCount
@@ -730,7 +730,7 @@ getWaitingChildrenCountReturns Promise<number>
+Defined in classes/queue-getters.ts:207
+Defined in classes/queue-getters.ts:200
getWorkers
@@ -757,7 +757,7 @@ Returns Promise<
+Defined in classes/queue-getters.ts:418
+Defined in classes/queue-base.ts:129
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/queue-keys.ts:3
@@ -55,14 +55,14 @@ Parameters
prefix: string = 'bull'
Returns QueueKeys
+
Defined in classes/queue-keys.ts:4
Properties
Readonly
prefix
prefix: string = 'bull'
+
Defined in classes/queue-keys.ts:4
Methods
@@ -77,7 +77,7 @@ Parameters
name: string
Returns KeysMap
+Defined in classes/queue-keys.ts:6
getQueueQualifiedName
@@ -90,7 +90,7 @@ Parameters
name: string
Returns string
+Defined in classes/queue-keys.ts:37
toKey
@@ -105,7 +105,7 @@ name: type: string
Returns string
+Defined in classes/queue-keys.ts:33
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in classes/redis-connection.ts:37
+
Defined in classes/redis-connection.ts:57
+
Defined in classes/redis-connection.ts:41
Static
minimumVersion
minimumVersion: string = '5.0.0'
+
Defined in classes/redis-connection.ts:38
Static
recommendedMinimumVersion
recommendedMinimumVersion: string = '6.2.0'
+
Defined in classes/redis-connection.ts:39
+
Defined in classes/redis-connection.ts:324
disconnect
@@ -136,7 +136,7 @@ Parameters
wait: boolean = true
Returns Promise<void>
+
Defined in classes/redis-connection.ts:239
+
Defined in classes/redis-connection.ts:270
+Defined in classes/redis-connection.ts:128
@@ -28,7 +28,7 @@
Hierarchy
+
Defined in classes/repeat.ts:9
@@ -83,7 +83,7 @@ Optional
Returns Repeat
+
Defined in classes/repeat.ts:13
+
Defined in classes/queue-base.ts:26
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -106,7 +106,7 @@ Readonly
+Defined in classes/queue-base.ts:41
opts
@@ -115,13 +115,13 @@ opts
+Defined in classes/queue-base.ts:42
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -140,7 +140,7 @@ type: Returns string
+Defined in classes/queue-base.ts:24
redisVersion
@@ -166,7 +166,7 @@ Returns string
+Defined in classes/queue-base.ts:97
close
@@ -208,7 +208,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:146
disconnect
@@ -220,7 +220,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:158
emit
@@ -242,7 +242,7 @@ Returns boolean
+Defined in classes/queue-base.ts:115
+Defined in classes/repeat.ts:206
getRepeatableJobs
@@ -267,7 +267,7 @@ end: asc: boolean = false
Returns Promise<RepeatableJob[]>
+Defined in classes/repeat.ts:187
removeRepeatable
Returns Promise<number>
+Defined in classes/repeat.ts:143
removeRepeatableByKey
@@ -297,7 +297,7 @@ Parameters
repeatJobKey: string
Returns Promise<number>
+Defined in classes/repeat.ts:159
+Defined in classes/queue-base.ts:129
@@ -25,7 +25,7 @@
Hierarchy
+
Defined in commands/script-loader.ts:84
+
Defined in commands/script-loader.ts:96
+
Defined in commands/script-loader.ts:463
interpolate
@@ -118,7 +118,7 @@ Optional
Returns string
+
Defined in commands/script-loader.ts:333
load
@@ -144,7 +144,7 @@ Optional
Returns Promise<void>
+
Defined in commands/script-loader.ts:435
loadCommand
@@ -159,7 +159,7 @@ filename: Optional cache: Map<string, ScriptMetadata>
Returns Promise<Command>
+
Defined in commands/script-loader.ts:356
loadScripts
@@ -182,7 +182,7 @@ Optional
Returns Promise<Command[]>
+
Defined in commands/script-loader.ts:390
+
Defined in commands/script-loader.ts:305
resolvePath
@@ -235,7 +235,7 @@ stack: Returns string
+Defined in commands/script-loader.ts:134
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in commands/script-loader.ts:52
+
Defined in commands/script-loader.ts:60
Readonly
line
line: number
+
Defined in commands/script-loader.ts:57
Readonly
position
position: number
+
Defined in commands/script-loader.ts:58
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/scripts.ts:40
Returns Scripts
+
Defined in classes/scripts.ts:43
Properties
moveToFinishedKeys
moveToFinishedKeys: string[]
+
Defined in classes/scripts.ts:41
Methods
@@ -116,7 +116,7 @@ jobId: parentOpts: ParentOpts = {}
Returns Promise<string>
+Defined in classes/scripts.ts:138
changeDelay
@@ -131,7 +131,7 @@ jobId: delay: number
Returns Promise<void>
+Defined in classes/scripts.ts:577
changePriority
@@ -148,7 +148,7 @@ priority: lifo: boolean = false
Returns Promise<void>
+Defined in classes/scripts.ts:609
cleanJobsInSet
@@ -169,7 +169,7 @@ Returns Promise<
+Defined in classes/scripts.ts:778
drain
@@ -182,7 +182,7 @@ Parameters
delayed: boolean
Returns Promise<void>
+Defined in classes/scripts.ts:443
extendLock
@@ -201,7 +201,7 @@ duration: Optional client: ChainableCommander | RedisClient
Returns Promise<number>
+Defined in classes/scripts.ts:263
finishedErrors
@@ -220,7 +220,7 @@ command: Optional state: string
Returns Error
+Defined in classes/scripts.ts:400
getCounts
@@ -233,7 +233,7 @@ Parameters
types: JobType[]
Returns Promise<number[]>
+Defined in classes/scripts.ts:493
getRanges
@@ -252,7 +252,7 @@ end: asc: boolean = false
Returns Promise<[string][]>
+Defined in classes/scripts.ts:468
getState
@@ -265,7 +265,7 @@ Parameters
jobId: string
Returns Promise<"unknown" | JobState>
+Defined in classes/scripts.ts:555
isFinished
@@ -280,7 +280,7 @@ jobId: returnValue: boolean = false
Returns Promise<number | [number, string]>
+Defined in classes/scripts.ts:540
isJobInList
@@ -295,7 +295,7 @@ listKey: jobId: string
Returns Promise<boolean>
+Defined in classes/scripts.ts:63
moveJobFromActiveToWait
@@ -318,7 +318,7 @@ token: Returns Promise<any>
+Defined in classes/scripts.ts:1009
moveStalledJobsToWait
@@ -334,7 +334,7 @@ moveStalledJobsToWait<
Returns Promise<[string[], string[]]>
+Defined in classes/scripts.ts:977
moveToActive
@@ -351,7 +351,7 @@ token: Optional jobId: string
Returns Promise<any[]>
+Defined in classes/scripts.ts:912
moveToCompletedArgs
@@ -381,7 +381,7 @@ token: fetchNext: boolean = false
Returns (string | number | boolean | Buffer)[]
+Defined in classes/scripts.ts:500
moveToDelayed
@@ -400,7 +400,7 @@ delay: token: string = '0'
Returns Promise<void>
+Defined in classes/scripts.ts:722
moveToDelayedArgs
@@ -419,7 +419,7 @@ token: delay: number
Returns (string | number)[]
+Defined in classes/scripts.ts:645
moveToFailedArgs
@@ -449,7 +449,7 @@ token: fetchNext: boolean = false
Returns (string | number | boolean | Buffer)[]
+Defined in classes/scripts.ts:520
moveToFinished
@@ -464,7 +464,7 @@ jobId: args: (string | number | boolean | Buffer)[]
Returns Promise<any[]>
+Defined in classes/scripts.ts:384
+Defined in classes/scripts.ts:748
moveToWaitingChildrenArgs
Returns string[]
+Defined in classes/scripts.ts:699
obliterate
@@ -529,7 +529,7 @@ countforce: boolean
Returns Promise<number>
+Defined in classes/scripts.ts:1032
pause
@@ -542,7 +542,7 @@ Parameters
pause: boolean
Returns Promise<void>
+Defined in classes/scripts.ts:212
promote
@@ -555,7 +555,7 @@ Parameters
jobId: string
Returns Promise<void>
+Defined in classes/scripts.ts:947
promoteJobs
@@ -568,7 +568,7 @@ Parameters
count: number = 1000
Returns Promise<number>
+Defined in classes/scripts.ts:859
remove
@@ -583,7 +583,7 @@ jobId: removeChildren: boolean
Returns Promise<number>
+Defined in classes/scripts.ts:254
removeRepeatable
@@ -598,7 +598,7 @@ repeatJobId: repeatJobKey: string
Returns Promise<number>
+Defined in classes/scripts.ts:244
reprocessJob
@@ -634,7 +634,7 @@ Returns Promise<
+Defined in classes/scripts.ts:880
retryJobArgs
@@ -651,7 +651,7 @@ lifo: token: string
Returns (string | number)[]
+Defined in classes/scripts.ts:795
retryJobs
@@ -668,7 +668,7 @@ count: timestamp: number = ...
Returns Promise<number>
+Defined in classes/scripts.ts:847
saveStacktraceArgs
@@ -685,7 +685,7 @@ stacktrace: failedReason: string
Returns string[]
+Defined in classes/scripts.ts:689
updateData
Returns Promise<void>
+Defined in classes/scripts.ts:280
updateProgress
@@ -733,7 +733,7 @@ jobId: progress: number | object
Returns Promise<void>
+Defined in classes/scripts.ts:296
@@ -38,7 +38,7 @@
Hierarchy
+
Defined in classes/worker.ts:161
@@ -116,7 +116,7 @@ Optional
Returns Worker<DataType, ResultType, NameType>
+
Defined in classes/worker.ts:194
+
Defined in classes/queue-base.ts:26
+
Defined in classes/worker.ts:167
+
Defined in classes/queue-base.ts:25
Readonly
name
name: string
@@ -144,7 +144,7 @@ Readonly
+Defined in classes/queue-base.ts:41
Readonly
opts
@@ -153,13 +153,13 @@ Readonly
+Defined in classes/worker.ts:166
Readonly
qualifiedName
qualifiedName: string
+Defined in classes/queue-base.ts:31
toKey
toKey: ((type) => string)
@@ -178,7 +178,7 @@ type: Returns string
+Defined in classes/queue-base.ts:24
concurrency
@@ -205,7 +205,7 @@ Parameters
concurrency: number
Returns void
+Defined in classes/worker.ts:353
redisVersion
@@ -217,7 +217,7 @@ Returns string
+Defined in classes/queue-base.ts:97
+Defined in classes/worker.ts:364
delay
@@ -268,7 +268,7 @@ Optional
Returns Promise<void>
+Defined in classes/worker.ts:638
disconnect
@@ -280,7 +280,7 @@ Returns Promise<
+Defined in classes/queue-base.ts:158
emit
@@ -307,7 +307,7 @@ Returns boolean
+Defined in classes/worker.ts:293
getNextJob
@@ -329,7 +329,7 @@ Returns Promise<
+Defined in classes/worker.ts:490
isPaused
@@ -341,7 +341,7 @@ Returns boolean
+Defined in classes/worker.ts:775
isRunning
@@ -353,7 +353,7 @@ Returns boolean
+Defined in classes/worker.ts:785
off
@@ -374,7 +374,7 @@ listener: Returns Worker<DataType, ResultType, NameType>
+Defined in classes/worker.ts:300
on
@@ -395,7 +395,7 @@ listener: Returns Worker<DataType, ResultType, NameType>
+Defined in classes/worker.ts:308
once
@@ -416,7 +416,7 @@ listener: Returns Worker<DataType, ResultType, NameType>
+Defined in classes/worker.ts:316
pause
@@ -432,7 +432,7 @@ Optional
Returns Promise<void>
+Defined in classes/worker.ts:744
processJob
@@ -457,7 +457,7 @@ Returns boolean
jobsInProgress: Set<{
    job: Job<any, any, string>;
    ts: number;
}>
Returns Promise<void | Job<DataType, ResultType, NameType>>
+Defined in classes/worker.ts:672
rateLimit
@@ -476,7 +476,7 @@ expireTimeMs: Returns Promise<void>
+Defined in classes/worker.ts:548
+Defined in classes/worker.ts:762
+Defined in classes/worker.ts:378
+Defined in classes/worker.ts:851
waitUntilReady
@@ -527,7 +527,7 @@ Returns Promise<
+Defined in classes/worker.ts:348
Static
RateLimitError
@@ -535,7 +535,7 @@ Static
Returns Error
+Defined in classes/worker.ts:190
@@ -66,7 +66,7 @@
Start
Stop
@@ -59,7 +59,7 @@
blocking
normal
@@ -80,7 +80,7 @@
JobPendingDependencies
ParentJobNotExist
@@ -101,7 +101,7 @@
THIRTY_MINUTES
TWO_WEEKS
@@ -101,7 +101,7 @@
Progress
Update
@@ -66,7 +66,7 @@
Start
Stop
@@ -59,7 +59,7 @@
blocking
normal
@@ -80,7 +80,7 @@
JobPendingDependencies
ParentJobNotExist
@@ -101,7 +101,7 @@
THIRTY_MINUTES
TWO_WEEKS
@@ -101,7 +101,7 @@
Progress
Update
@@ -66,7 +66,7 @@
Start
Stop
@@ -59,7 +59,7 @@
blocking
normal
@@ -87,7 +87,7 @@
JobPendingDependencies
ParentJobNotExist
@@ -101,7 +101,7 @@
THIRTY_MINUTES
TWO_WEEKS
@@ -101,7 +101,7 @@
Progress
Update
@@ -17,7 +17,7 @@
ChildCommand
Enumeration ChildCommand
+
Defined in enums/child-command.ts:1
+
Defined in enums/child-command.ts:3
+Defined in enums/child-command.ts:4
@@ -17,7 +17,7 @@
ClientType
Enumeration ClientType
+
Defined in interfaces/queue-options.ts:5
+Defined in interfaces/queue-options.ts:7
@@ -17,7 +17,7 @@
ErrorCode
Enumeration ErrorCode
+
Defined in enums/error-code.ts:1
@@ -38,32 +38,32 @@ Enumeration Members
JobLockMismatch
JobLockMismatch: -6
+Defined in enums/error-code.ts:7
JobLockNotExist
JobLockNotExist: -2
+
Defined in enums/error-code.ts:3
JobNotExist
JobNotExist: -1
+
Defined in enums/error-code.ts:2
JobNotInState
JobNotInState: -3
+
Defined in enums/error-code.ts:4
JobPendingDependencies
JobPendingDependencies: -4
+
Defined in enums/error-code.ts:5
ParentJobNotExist
ParentJobNotExist: -5
+Defined in enums/error-code.ts:6
@@ -17,7 +17,7 @@
MetricsTime
Enumeration MetricsTime
+
Defined in enums/metrics-time.ts:1
FIVE_MINUTES
FIVE_MINUTES: 5
+
Defined in enums/metrics-time.ts:3
+
Defined in enums/metrics-time.ts:6
+
Defined in enums/metrics-time.ts:2
ONE_MONTH
ONE_MONTH: 80640
+
Defined in enums/metrics-time.ts:9
+
Defined in enums/metrics-time.ts:7
THIRTY_MINUTES
THIRTY_MINUTES: 30
+
Defined in enums/metrics-time.ts:5
TWO_WEEKS
TWO_WEEKS: 20160
+Defined in enums/metrics-time.ts:8
+Defined in enums/parent-command.ts:10
@@ -41,7 +41,7 @@
Member Visibility
@@ -48,7 +48,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -45,7 +45,7 @@
Member Visibility
@@ -49,7 +49,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -45,7 +45,7 @@
Member Visibility
@@ -56,7 +56,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -48,7 +48,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -45,7 +45,7 @@
Member Visibility
@@ -49,7 +49,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -45,7 +45,7 @@
Member Visibility
@@ -56,7 +56,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -48,7 +48,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -43,7 +43,7 @@
Member Visibility
@@ -46,7 +46,7 @@
Member Visibility
@@ -44,7 +44,7 @@
Member Visibility
@@ -41,7 +41,7 @@
Member Visibility
@@ -45,7 +45,7 @@
Member Visibility
@@ -56,7 +56,7 @@
Member Visibility
@@ -27,7 +27,7 @@
Parameters
arr: string[]
Returns Record<string, string>
+Defined in utils.ts:46
@@ -34,7 +34,7 @@
proc: msg: any
Returns Promise<void>
+Defined in utils.ts:159
@@ -29,7 +29,7 @@
proc: msg: ChildMessage
Returns Promise<void>
+Defined in utils.ts:180
@@ -29,7 +29,7 @@
emitter: count: number
Returns void
+Defined in utils.ts:90
@@ -29,7 +29,7 @@
ms: Optional
abortController: AbortController
Returns Promise<void>
+Defined in utils.ts:54
@@ -27,7 +27,7 @@
Parameters
value: any
Returns Record<string, any>
+Defined in utils.ts:205
@@ -29,7 +29,7 @@
millis: opts: RepeatOptions
Returns number
+Defined in classes/repeat.ts:238
@@ -32,7 +32,7 @@
id
queue: string
Returns string | undefined
+Defined in utils.ts:130
@@ -29,7 +29,7 @@
emitter: count: number
Returns void
+Defined in utils.ts:82
@@ -27,7 +27,7 @@
Parameters
obj: object
Returns boolean
+Defined in utils.ts:37
@@ -27,7 +27,7 @@
Parameters
error: Error
Returns boolean
+Defined in utils.ts:146
@@ -27,7 +27,7 @@
Parameters
obj: unknown
Returns obj is Cluster
+Defined in utils.ts:78
@@ -27,7 +27,7 @@
Parameters
obj: any
Returns obj is Cluster | Redis
+Defined in utils.ts:70
@@ -29,7 +29,7 @@
currentVersion: minimumVersion: string
Returns boolean
+Defined in utils.ts:185
+Defined in utils.ts:33
@@ -30,7 +30,7 @@
obj: [key: string]: string
Returns Record<string, any>
+Defined in utils.ts:194
@@ -27,7 +27,7 @@
Parameters
raw: any[]
Returns any[]
+Defined in classes/scripts.ts:1054
@@ -31,7 +31,7 @@
queueName: prefix: string = ...
Returns Promise<void | boolean>
+Defined in utils.ts:97
@@ -42,7 +42,7 @@
ctx: args: any[]
Returns any
+Defined in utils.ts:15
-
bullmq - v4.15.3
+
bullmq - v4.15.4
@@ -375,7 +375,7 @@
Contributing
Thanks
@@ -89,7 +89,7 @@
parent
queuesOpts
@@ -92,7 +92,7 @@
parent
queuesOpts
@@ -75,7 +75,7 @@
backoffStrategies
repeatStrategy
@@ -61,7 +61,7 @@
repeatStrategy
@@ -75,7 +75,7 @@
delay
type
@@ -182,7 +182,7 @@
stackTraceLimit
timestamp
@@ -70,7 +70,7 @@
err
value
@@ -58,7 +58,7 @@
processFile
@@ -70,7 +70,7 @@
name
options
@@ -77,7 +77,7 @@
processed
unprocessed
@@ -91,7 +91,7 @@
prefix
queueName
@@ -59,7 +59,7 @@
queuesOptions
@@ -95,7 +95,7 @@
error
ioredis:close
@@ -73,7 +73,7 @@
client
waitUntilReady
@@ -74,7 +74,7 @@
ioredis:close
@@ -98,7 +98,7 @@
next
tz
@@ -154,7 +154,7 @@
stacktrace
timestamp
@@ -161,7 +161,7 @@
stacktrace
timestamp
@@ -63,7 +63,7 @@
children
job
@@ -251,7 +251,7 @@
stackTraceLimit
timestamp
@@ -76,7 +76,7 @@
age
count
@@ -79,7 +79,7 @@
data
meta
@@ -61,7 +61,7 @@
maxDataPoints
@@ -99,7 +99,7 @@
prefix
queueName
@@ -73,7 +73,7 @@
count
force
@@ -93,7 +93,7 @@
prefix
queue
@@ -63,7 +63,7 @@
id
queueKey
@@ -77,7 +77,7 @@
job
value
@@ -99,7 +99,7 @@
prefix
sharedConnection
@@ -555,7 +555,7 @@
waiting
waiting-children
@@ -131,7 +131,7 @@
prefix
sharedConnection
@@ -242,7 +242,7 @@
resumed
waiting
@@ -156,7 +156,7 @@
sharedConnection
streams
@@ -149,7 +149,7 @@
ioredis:close
stalled
@@ -136,7 +136,7 @@
sharedConnection
stalledInterval
@@ -101,7 +101,7 @@
max
workerDelay
@@ -106,7 +106,7 @@
settings
sharedConnection
@@ -141,7 +141,7 @@
pattern
prevMillis
@@ -267,7 +267,7 @@
update
updateProgress
@@ -111,7 +111,7 @@
path
token
@@ -38,7 +38,7 @@
Member Visibility
@@ -317,7 +317,7 @@
progress
resumed
@@ -188,7 +188,7 @@
sharedConnection
skipDelayCheck
@@ -89,7 +89,7 @@
parent
queuesOpts
@@ -92,7 +92,7 @@
parent
queuesOpts
@@ -75,7 +75,7 @@
backoffStrategies
repeatStrategy
@@ -61,7 +61,7 @@
repeatStrategy
@@ -75,7 +75,7 @@
delay
type
@@ -251,7 +251,7 @@
stackTraceLimit
timestamp
@@ -70,7 +70,7 @@
err
value
@@ -58,7 +58,7 @@
processFile
@@ -70,7 +70,7 @@
name
options
@@ -182,7 +182,7 @@
stackTraceLimit
timestamp
@@ -77,7 +77,7 @@
processed
unprocessed
@@ -59,7 +59,7 @@
queuesOptions
@@ -95,7 +95,7 @@
error
ioredis:close
@@ -73,7 +73,7 @@
client
waitUntilReady
@@ -73,7 +73,7 @@
ioredis:close
@@ -154,7 +154,7 @@
stacktrace
timestamp
@@ -161,7 +161,7 @@
stacktrace
timestamp
@@ -63,7 +63,7 @@
children
job
@@ -76,7 +76,7 @@
age
count
@@ -79,7 +79,7 @@
data
meta
@@ -61,7 +61,7 @@
maxDataPoints
@@ -99,7 +99,7 @@
prefix
queueName
@@ -73,7 +73,7 @@
count
force
@@ -93,7 +93,7 @@
prefix
queue
@@ -63,7 +63,7 @@
id
queueKey
@@ -77,7 +77,7 @@
job
value
@@ -98,7 +98,7 @@
prefix
sharedConnection
@@ -551,7 +551,7 @@
waiting
waiting-children
@@ -131,7 +131,7 @@
prefix
sharedConnection
@@ -242,7 +242,7 @@
resumed
waiting
@@ -156,7 +156,7 @@
sharedConnection
streams
@@ -101,7 +101,7 @@
max
workerDelay
@@ -70,7 +70,7 @@
keys
name
@@ -106,7 +106,7 @@
settings
sharedConnection
@@ -141,7 +141,7 @@
pattern
prevMillis
@@ -239,7 +239,7 @@
update
updateProgress
@@ -111,7 +111,7 @@
path
token
@@ -38,7 +38,7 @@
Member Visibility
@@ -344,7 +344,7 @@
resumed
stalled
@@ -210,7 +210,7 @@
skipDelayCheck
stalledInterval
@@ -89,7 +89,7 @@
parent
queuesOpts
@@ -92,7 +92,7 @@
parent
queuesOpts
@@ -72,7 +72,7 @@
backoffStrategy
repeatStrategy
@@ -61,7 +61,7 @@
repeatStrategy
@@ -75,7 +75,7 @@
delay
type
@@ -255,7 +255,7 @@
stackTraceLimit
timestamp
@@ -56,7 +56,7 @@
skipVersionCheck
@@ -49,7 +49,7 @@
Member Visibility
@@ -70,7 +70,7 @@
err
value
@@ -70,7 +70,7 @@
name
options
@@ -181,7 +181,7 @@
stackTraceLimit
timestamp
@@ -77,7 +77,7 @@
processed
unprocessed
@@ -96,7 +96,7 @@
prefix
queueName
@@ -59,7 +59,7 @@
queuesOptions
@@ -95,7 +95,7 @@
error
ioredis:close
@@ -73,7 +73,7 @@
client
waitUntilReady
@@ -73,7 +73,7 @@
ioredis:close
@@ -154,7 +154,7 @@
stacktrace
timestamp
@@ -161,7 +161,7 @@
stacktrace
timestamp
@@ -63,7 +63,7 @@
children
job
@@ -76,7 +76,7 @@
age
count
@@ -79,7 +79,7 @@
data
meta
@@ -61,7 +61,7 @@
maxDataPoints
@@ -368,7 +368,7 @@
update
updateProgress
@@ -99,7 +99,7 @@
prefix
queueName
@@ -73,7 +73,7 @@
count
force
@@ -93,7 +93,7 @@
prefix
queue
@@ -63,7 +63,7 @@
id
queueKey
@@ -77,7 +77,7 @@
job
value
@@ -98,7 +98,7 @@
prefix
sharedConnection
@@ -580,7 +580,7 @@
waiting
waiting-children
@@ -131,7 +131,7 @@
prefix
sharedConnection
@@ -242,7 +242,7 @@
resumed
waiting
@@ -137,7 +137,7 @@
sharedConnection
streams
@@ -71,7 +71,7 @@
duration
max
@@ -70,7 +70,7 @@
keys
name
@@ -106,7 +106,7 @@
settings
sharedConnection
@@ -130,7 +130,7 @@
pattern
prevMillis
@@ -239,7 +239,7 @@
update
updateProgress
@@ -111,7 +111,7 @@
path
token
@@ -365,7 +365,7 @@
resumed
stalled
@@ -313,7 +313,7 @@
stalledInterval
useWorkerThreads
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:34
+
Defined in classes/flow-producer.ts:36
parent
parent: {
    parentDependenciesKey: string;
    parentOpts: {
        id: string;
        queue: string;
    };
}
@@ -62,12 +62,12 @@ id
queue: string
+
Defined in classes/flow-producer.ts:37
+Defined in classes/flow-producer.ts:44
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:18
+
Defined in classes/flow-producer.ts:20
Optional
parent
parent?: {
    parentDependenciesKey: string;
    parentOpts: {
        id: string;
        queue: string;
    };
}
@@ -62,7 +62,7 @@ id
queue: string
+
Defined in classes/flow-producer.ts:21
Optional
queuesOpts
@@ -70,7 +70,7 @@ Optional
+Defined in classes/flow-producer.ts:31
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in interfaces/advanced-options.ts:16
Optional
repeatKeyHashAlgorithm
repeatKeyHashAlgorithm?: string
@@ -54,7 +54,7 @@ Optional
+
Defined in interfaces/advanced-options.ts:13
Optional
repeatStrategy
@@ -63,7 +63,7 @@ Optional
+Defined in interfaces/advanced-options.ts:7
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in interfaces/advanced-options.ts:3
Optional
repeatStrategy
@@ -52,7 +52,7 @@ Optional
+
Defined in interfaces/advanced-options.ts:7
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in interfaces/backoff-options.ts:6
type
type: "fixed" | "exponential" | string & {}
@@ -55,7 +55,7 @@ type
+Defined in interfaces/backoff-options.ts:10
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in interfaces/base-job-options.ts:77
@@ -61,7 +61,7 @@ Default Value
0
+
Defined in interfaces/base-job-options.ts:29
Optional
backoff
@@ -70,7 +70,7 @@ Optional
+Defined in interfaces/base-job-options.ts:34
Optional
delay
delay?: number
@@ -84,7 +84,7 @@ Default Value
0
+Defined in interfaces/base-job-options.ts:23
Optional
jobId
jobId?: string
@@ -96,7 +96,7 @@ Optional
+Defined in interfaces/base-job-options.ts:95
Optional
keepLogs
keepLogs?: number
@@ -105,7 +105,7 @@ Optional
+Defined in interfaces/base-job-options.ts:64
+Defined in interfaces/base-job-options.ts:41
Optional
parent
parent?: {
    id: string;
    queue: string;
}
@@ -133,7 +133,7 @@ queuehttps://www.gnu.org/software/gawk/manual/html_node/Qualified-Names.html
+Defined in interfaces/base-job-options.ts:100
Optional
prevMillis
prevMillis?: number
@@ -141,7 +141,7 @@ Optional
+Defined in interfaces/base-job-options.ts:113
Optional
priority
priority?: number
@@ -152,7 +152,7 @@ Optional
+Defined in interfaces/base-job-options.ts:15
Optional
removeOnComplete
removeOnComplete?: number | boolean | KeepJobs
@@ -165,7 +165,7 @@ Optional
+Defined in interfaces/base-job-options.ts:50
Optional
removeOnFail
removeOnFail?: number | boolean | KeepJobs
@@ -178,7 +178,7 @@ Optional
+Defined in interfaces/base-job-options.ts:59
Optional
repeat
@@ -186,7 +186,7 @@ Optional
+Defined in interfaces/base-job-options.ts:81
Optional
repeatJobKey
repeatJobKey?: string
@@ -194,7 +194,7 @@ Optional
+Defined in interfaces/base-job-options.ts:86
Optional
sizeLimit
sizeLimit?: number
@@ -203,7 +203,7 @@ Optional
+Defined in interfaces/base-job-options.ts:74
Optional
stackTraceLimit
stackTraceLimit?: number
@@ -212,7 +212,7 @@ Optional
+Defined in interfaces/base-job-options.ts:69
Optional
timestamp
timestamp?: number
@@ -224,7 +224,7 @@ Default Value
Date
+Defined in interfaces/base-job-options.ts:8
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/redis-options.ts:3
@@ -37,7 +37,7 @@ Properties
Optional
skipVersionCheck
skipVersionCheck?: boolean
+
Defined in interfaces/redis-options.ts:4
@@ -35,7 +35,7 @@
Parameters
delay: number
Returns BackoffStrategy
+Defined in classes/backoffs.ts:4
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/child-message.ts:3
Optional
err
err?: Record<string, any>
+
Defined in interfaces/child-message.ts:6
Optional
value
value?: any
+
Defined in interfaces/child-message.ts:5
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in commands/script-loader.ts:15
options
options: {
    lua: string;
    numberOfKeys: number;
}
@@ -50,7 +50,7 @@ lua
numberOfKeys: number
+Defined in commands/script-loader.ts:17
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in interfaces/base-job-options.ts:3
@@ -55,7 +55,7 @@ Default Value
0
+
Defined in interfaces/base-job-options.ts:29
Optional
backoff
@@ -63,7 +63,7 @@ Optional
+
Defined in interfaces/base-job-options.ts:34
Optional
delay
delay?: number
@@ -76,7 +76,7 @@ Default Value
0
+Defined in interfaces/base-job-options.ts:23
Optional
keepLogs
keepLogs?: number
@@ -84,7 +84,7 @@ Optional
+Defined in interfaces/base-job-options.ts:64
+Defined in interfaces/base-job-options.ts:41
Optional
priority
priority?: number
@@ -104,7 +104,7 @@ Optional
+Defined in interfaces/base-job-options.ts:15
Optional
removeOnComplete
removeOnComplete?: number | boolean | KeepJobs
@@ -116,7 +116,7 @@ Optional
+Defined in interfaces/base-job-options.ts:50
Optional
removeOnFail
removeOnFail?: number | boolean | KeepJobs
@@ -128,7 +128,7 @@ Optional
+Defined in interfaces/base-job-options.ts:59
Optional
sizeLimit
sizeLimit?: number
@@ -136,7 +136,7 @@ Optional
+Defined in interfaces/base-job-options.ts:74
Optional
stackTraceLimit
stackTraceLimit?: number
@@ -144,7 +144,7 @@ Optional
+Defined in interfaces/base-job-options.ts:69
Optional
timestamp
timestamp?: number
@@ -155,7 +155,7 @@ Default Value
Date
+Defined in interfaces/base-job-options.ts:8
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/minimal-job.ts:14
@@ -45,7 +45,7 @@ Optional
Optional
cursor?: number
+
Defined in interfaces/minimal-job.ts:15
Optional
unprocessed
unprocessed?: {
    count?: number;
    cursor?: number;
}
@@ -57,7 +57,7 @@ Optional
Optional
cursor?: number
+Defined in interfaces/minimal-job.ts:19
@@ -26,7 +26,7 @@
Hierarchy
+
Defined in interfaces/flow-job.ts:4
+
Defined in interfaces/flow-job.ts:7
+
Defined in interfaces/flow-job.ts:5
Optional
opts
opts?: Omit<T, "repeat">
+
Defined in interfaces/flow-job.ts:9
Optional
prefix
prefix?: string
+
Defined in interfaces/flow-job.ts:8
queueName
queueName: string
+
Defined in interfaces/flow-job.ts:6
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/flow-job.ts:22
@@ -40,7 +40,7 @@ queuesOptions
+Defined in interfaces/flow-job.ts:26
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:75
@@ -57,7 +57,7 @@ failedReason: Returns void
+
Defined in classes/flow-producer.ts:81
ioredis:close
ioredis:close: (() => void)
@@ -75,7 +75,7 @@ Returns void
+Defined in interfaces/ioredis-events.ts:7
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/worker-options.ts:142
@@ -37,7 +37,7 @@ Properties
Optional
block
block?: boolean
+
Defined in interfaces/worker-options.ts:143
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in interfaces/connection.ts:6
@@ -43,7 +43,7 @@ Properties
client
+
Defined in interfaces/connection.ts:8
+
Defined in interfaces/connection.ts:7
@@ -26,7 +26,7 @@
Hierarchy
QueueListener
WorkerListener
+
Defined in interfaces/ioredis-events.ts:1
@@ -54,7 +54,7 @@ Type declaration
Returns void
+Defined in interfaces/ioredis-events.ts:7
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/job-json.ts:4
+
Defined in interfaces/job-json.ts:7
failedReason
failedReason: string
+
Defined in interfaces/job-json.ts:14
Optional
finishedOn
finishedOn?: number
+
Defined in interfaces/job-json.ts:11
+
Defined in interfaces/job-json.ts:5
+
Defined in interfaces/job-json.ts:6
+
Defined in interfaces/job-json.ts:8
+
Defined in interfaces/job-json.ts:17
Optional
parentKey
parentKey?: string
+
Defined in interfaces/job-json.ts:18
Optional
processedOn
processedOn?: number
+
Defined in interfaces/job-json.ts:12
progress
progress: number | object
+
Defined in interfaces/job-json.ts:9
Optional
repeatJobKey
repeatJobKey?: string
+
Defined in interfaces/job-json.ts:19
returnvalue
returnvalue: string
+
Defined in interfaces/job-json.ts:16
stacktrace
stacktrace: string
+
Defined in interfaces/job-json.ts:15
timestamp
timestamp: number
+
Defined in interfaces/job-json.ts:13
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/job-json.ts:22
+
Defined in interfaces/job-json.ts:25
+
Defined in interfaces/job-json.ts:26
failedReason
failedReason: string
+
Defined in interfaces/job-json.ts:33
Optional
finishedOn
finishedOn?: string
+
Defined in interfaces/job-json.ts:30
+
Defined in interfaces/job-json.ts:23
+
Defined in interfaces/job-json.ts:24
+
Defined in interfaces/job-json.ts:27
Optional
parent
parent?: string
+
Defined in interfaces/job-json.ts:37
Optional
parentKey
parentKey?: string
+
Defined in interfaces/job-json.ts:36
Optional
processedOn
processedOn?: string
+
Defined in interfaces/job-json.ts:31
progress
progress: string
+
Defined in interfaces/job-json.ts:28
returnvalue
returnvalue: string
+
Defined in interfaces/job-json.ts:35
Optional
rjk
rjk?: string
+
Defined in interfaces/job-json.ts:38
stacktrace
stacktrace: string[]
+
Defined in interfaces/job-json.ts:34
timestamp
timestamp: string
+
Defined in interfaces/job-json.ts:32
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:70
job
job: Job<any, any, string>
+
Defined in classes/flow-producer.ts:71
@@ -28,7 +28,7 @@
Hierarchy
+
Defined in interfaces/keep-jobs.ts:8
Optional
count
count?: number
@@ -56,7 +56,7 @@ Optional
+
Defined in interfaces/keep-jobs.ts:17
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/metrics.ts:1
+
Defined in interfaces/metrics.ts:7
meta
meta: {
    count: number;
    prevCount: number;
    prevTS: number;
}
@@ -58,7 +58,7 @@ prevCount
prevTS: number
+Defined in interfaces/metrics.ts:2
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/metrics-options.ts:5
@@ -42,7 +42,7 @@ Optional
+
Defined in interfaces/metrics-options.ts:11
@@ -38,7 +38,7 @@
Implemented by
+
Defined in interfaces/minimal-job.ts:28
@@ -89,7 +89,7 @@ Default Value
0
+
Defined in interfaces/minimal-job.ts:74
data
data: DataType
@@ -97,7 +97,7 @@ data
+Defined in interfaces/minimal-job.ts:40
delay
delay: number
@@ -108,7 +108,7 @@ Default Value
0
+Defined in interfaces/minimal-job.ts:65
failedReason
failedReason: string
@@ -116,7 +116,7 @@ failedReason
+Defined in interfaces/minimal-job.ts:78
Optional
finishedOn
finishedOn?: number
@@ -124,12 +124,12 @@ Optional
+Defined in interfaces/minimal-job.ts:82
+Defined in interfaces/minimal-job.ts:45
name
name: NameType
@@ -137,7 +137,7 @@ name
+Defined in interfaces/minimal-job.ts:36
opts
@@ -145,7 +145,7 @@ opts
+Defined in interfaces/minimal-job.ts:44
Optional
parent
@@ -153,7 +153,7 @@ Optional
+Defined in interfaces/minimal-job.ts:94
Optional
parentKey
parentKey?: string
@@ -161,7 +161,7 @@ Optional
+Defined in interfaces/minimal-job.ts:90
Optional
processedOn
processedOn?: number
@@ -169,7 +169,7 @@ Optional
+Defined in interfaces/minimal-job.ts:86
progress
progress: number | object
@@ -180,7 +180,7 @@ Default Value
0
+Defined in interfaces/minimal-job.ts:50
Optional
repeatJobKey
repeatJobKey?: string
@@ -188,7 +188,7 @@ Optional
+Defined in interfaces/minimal-job.ts:98
returnvalue
returnvalue: ReturnType
@@ -199,7 +199,7 @@ Default Value
null
+Defined in interfaces/minimal-job.ts:55
stacktrace
stacktrace: string[]
@@ -210,7 +210,7 @@ Default Value
null
+Defined in interfaces/minimal-job.ts:60
timestamp
timestamp: number
@@ -218,7 +218,7 @@ timestamp
+Defined in interfaces/minimal-job.ts:69
+Defined in interfaces/minimal-job.ts:127
+Defined in interfaces/minimal-job.ts:136
+Defined in interfaces/minimal-job.ts:108
log
@@ -293,7 +293,7 @@ logRow: Returns Promise<number>
+Defined in interfaces/minimal-job.ts:126
updateData
@@ -312,7 +312,7 @@ data: Returns Promise<void>
+Defined in interfaces/minimal-job.ts:114
updateProgress
@@ -331,7 +331,7 @@ progress: Returns Promise<void>
+Defined in interfaces/minimal-job.ts:120
@@ -21,7 +21,7 @@
Hierarchy
- MoveToWaitingChildrenOpts
+
Defined in interfaces/minimal-job.ts:7
@@ -44,7 +44,7 @@ id
queue: string
+Defined in interfaces/minimal-job.ts:8
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/flow-producer.ts:47
id
id: string
@@ -52,7 +52,7 @@ id
+
Defined in classes/flow-producer.ts:59
Optional
maxChildren
maxChildren?: number
@@ -60,7 +60,7 @@ Optional
+
Defined in classes/flow-producer.ts:67
Optional
prefix
prefix?: string
@@ -68,7 +68,7 @@ Optional
+
Defined in classes/flow-producer.ts:55
queueName
queueName: string
@@ -76,7 +76,7 @@ queueName
+
Defined in classes/flow-producer.ts:51
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in classes/queue.ts:17
@@ -44,7 +44,7 @@ Default Value
1000
+
Defined in classes/queue.ts:27
Optional
force
force?: boolean
@@ -55,7 +55,7 @@ Default Value
false
+Defined in classes/queue.ts:22
@@ -30,7 +30,7 @@
Hierarchy
+
Defined in interfaces/parent.ts:5
+
Defined in interfaces/parent.ts:6
+
Defined in interfaces/parent.ts:10
Optional
prefix
prefix?: string
+
Defined in interfaces/parent.ts:7
Optional
queue
queue?: string
+
Defined in interfaces/parent.ts:8
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/parent.ts:13
queueKey
queueKey: string
+
Defined in interfaces/parent.ts:15
@@ -30,7 +30,7 @@
Hierarchy
QueueEventsOptions
WorkerOptions
+
Defined in interfaces/queue-options.ts:13
Optional
connection
@@ -60,7 +60,7 @@ Optional
+
Defined in interfaces/queue-options.ts:17
Optional
prefix
prefix?: string
@@ -68,7 +68,7 @@ Optional
+
Defined in interfaces/queue-options.ts:27
Optional
skipVersionCheck
skipVersionCheck?: boolean
@@ -79,7 +79,7 @@ Default Value
false
+Defined in interfaces/queue-options.ts:33
@@ -23,7 +23,7 @@
Hierarchy
+
Defined in classes/queue-events.ts:16
@@ -80,7 +80,7 @@ id: Returns void
+
Defined in classes/queue-events.ts:22
added
added: ((args, id) => void)
@@ -109,7 +109,7 @@ id: Returns void
+Defined in classes/queue-events.ts:29
cleaned
cleaned: ((args, id) => void)
@@ -136,7 +136,7 @@ id: Returns void
+Defined in classes/queue-events.ts:36
completed
completed: ((args, id) => void)
@@ -167,7 +167,7 @@ id: Returns void
+Defined in classes/queue-events.ts:43
delayed
delayed: ((args, id) => void)
@@ -196,7 +196,7 @@ id: Returns void
+Defined in classes/queue-events.ts:53
drained
drained: ((id) => void)
@@ -220,7 +220,7 @@ id: Returns void
+Defined in classes/queue-events.ts:62
duplicated
duplicated: ((args, id) => void)
@@ -247,7 +247,7 @@ id: Returns void
+Defined in classes/queue-events.ts:69
error
error: ((args) => void)
@@ -269,7 +269,7 @@ args: Returns void
+Defined in classes/queue-events.ts:76
failed
failed: ((args, id) => void)
@@ -300,7 +300,7 @@ id: Returns void
+Defined in classes/queue-events.ts:83
ioredis:close
ioredis:close: (() => void)
@@ -318,7 +318,7 @@ Returns void
+Defined in interfaces/ioredis-events.ts:7
paused
paused: ((args, id) => void)
@@ -343,7 +343,7 @@ id: Returns void
+Defined in classes/queue-events.ts:93
progress
progress: ((args, id) => void)
@@ -375,7 +375,7 @@ id: Returns void
+Defined in classes/queue-events.ts:103
removed
removed: ((args, id) => void)
@@ -405,7 +405,7 @@ id: Returns void
+Defined in classes/queue-events.ts:114
resumed
resumed: ((args, id) => void)
@@ -430,7 +430,7 @@ id: Returns void
+Defined in classes/queue-events.ts:121
retries-exhausted
retries-exhausted: ((args, id) => void)
@@ -459,7 +459,7 @@ id: Returns void
+Defined in classes/queue-events.ts:128
stalled
stalled: ((args, id) => void)
@@ -488,7 +488,7 @@ id: Returns void
+Defined in classes/queue-events.ts:140
waiting
waiting: ((args, id) => void)
@@ -517,7 +517,7 @@ id: Returns void
+Defined in classes/queue-events.ts:147
waiting-children
waiting-children: ((args, id) => void)
@@ -544,7 +544,7 @@ id: Returns void
+Defined in classes/queue-events.ts:154
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in interfaces/queue-options.ts:70
Optional
blockingConnection
blockingConnection?: boolean
@@ -61,7 +61,7 @@ Optional
+
Defined in interfaces/queue-options.ts:22
Optional
blockingTimeout
blockingTimeout?: number
@@ -69,7 +69,7 @@ Optional
+
Defined in interfaces/queue-options.ts:85
Optional
connection
@@ -78,7 +78,7 @@ Optional
+Defined in interfaces/queue-options.ts:17
Optional
lastEventId
lastEventId?: string
@@ -88,7 +88,7 @@ Optional
+Defined in interfaces/queue-options.ts:80
Optional
prefix
prefix?: string
@@ -97,7 +97,7 @@ Optional
+Defined in interfaces/queue-options.ts:27
Optional
skipVersionCheck
skipVersionCheck?: boolean
@@ -109,7 +109,7 @@ Default Value
false
+Defined in interfaces/queue-options.ts:33
@@ -32,7 +32,7 @@
Hierarchy
+
Defined in classes/queue.ts:30
@@ -74,7 +74,7 @@ type: Returns void
+
Defined in classes/queue.ts:37
error
error: ((err) => void)
@@ -96,7 +96,7 @@ err: Returns void
+Defined in classes/queue.ts:44
ioredis:close
ioredis:close: (() => void)
@@ -114,7 +114,7 @@ Returns void
+Defined in interfaces/ioredis-events.ts:7
paused
paused: (() => void)
@@ -131,7 +131,7 @@ Type declaration
Returns void
+Defined in classes/queue.ts:51
progress
progress: ((job, progress) => void)
@@ -155,7 +155,7 @@ progress: Returns void
+Defined in classes/queue.ts:58
removed
removed: ((job) => void)
@@ -177,7 +177,7 @@ job: Returns void
+Defined in classes/queue.ts:68
resumed
resumed: (() => void)
@@ -194,7 +194,7 @@ Type declaration
Returns void
+Defined in classes/queue.ts:75
waiting
waiting: ((job) => void)
@@ -216,7 +216,7 @@ job: Returns void
+Defined in classes/queue.ts:82
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in interfaces/queue-options.ts:39
@@ -53,7 +53,7 @@ Optional
+
Defined in interfaces/queue-options.ts:22
Optional
connection
@@ -62,12 +62,12 @@ Optional
+Defined in interfaces/queue-options.ts:17
Optional
defaultJobOptions
+Defined in interfaces/queue-options.ts:40
Optional
prefix
prefix?: string
@@ -76,12 +76,12 @@ Optional
+Defined in interfaces/queue-options.ts:27
+Defined in interfaces/queue-options.ts:57
Optional
skipVersionCheck
skipVersionCheck?: boolean
@@ -93,7 +93,7 @@ Default Value
false
+Defined in interfaces/queue-options.ts:33
Optional
streams
streams?: {
    events: {
        maxLen: number;
    };
}
@@ -115,7 +115,7 @@ maxLen
+Defined in interfaces/queue-options.ts:45
@@ -21,7 +21,7 @@
Hierarchy
+
Defined in interfaces/rate-limiter-options.ts:1
max
max: number
@@ -51,7 +51,7 @@ max
+Defined in interfaces/rate-limiter-options.ts:6
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in interfaces/queue-options.ts:63
@@ -51,7 +51,7 @@ Optional
+
Defined in interfaces/queue-options.ts:22
Optional
connection
@@ -60,7 +60,7 @@ Optional
+Defined in interfaces/queue-options.ts:17
Optional
prefix
prefix?: string
@@ -69,12 +69,12 @@ Optional
+Defined in interfaces/queue-options.ts:27
+Defined in interfaces/queue-options.ts:64
Optional
skipVersionCheck
skipVersionCheck?: boolean
@@ -86,7 +86,7 @@ Default Value
false
+Defined in interfaces/queue-options.ts:33
@@ -29,7 +29,7 @@
Hierarchy
+
Defined in interfaces/repeat-options.ts:8
Optional
every
every?: number
@@ -64,7 +64,7 @@ Optional
+
Defined in interfaces/repeat-options.ts:21
Optional
immediately
immediately?: boolean
@@ -73,12 +73,12 @@ Optional
+
Defined in interfaces/repeat-options.ts:26
Optional
jobId
jobId?: string
+
Defined in interfaces/repeat-options.ts:33
Optional
limit
limit?: number
@@ -86,12 +86,12 @@ Optional
+
Defined in interfaces/repeat-options.ts:16
Optional
offset
offset?: number
+
Defined in interfaces/repeat-options.ts:32
Optional
pattern
pattern?: string
@@ -99,12 +99,12 @@ Optional
+
Defined in interfaces/repeat-options.ts:12
Optional
prevMillis
prevMillis?: number
+
Defined in interfaces/repeat-options.ts:31
@@ -34,7 +34,7 @@
Hierarchy
+
Defined in interfaces/sandboxed-job.ts:7
+
Defined in interfaces/job-json.ts:10
+
Defined in interfaces/sandboxed-job.ts:9
failedReason
failedReason: string
+
Defined in interfaces/job-json.ts:14
Optional
finishedOn
finishedOn?: number
+
Defined in interfaces/job-json.ts:11
+
Defined in interfaces/job-json.ts:5
log
log: ((row) => void)
@@ -111,7 +111,7 @@ Parameters
row: any
Returns void
+Defined in interfaces/sandboxed-job.ts:12
moveToDelayed
moveToDelayed: ((timestamp, token?) => Promise<void>)
@@ -131,71 +131,71 @@ timestamp: Optional token: string
Returns Promise<void>
+Defined in interfaces/sandboxed-job.ts:11
+Defined in interfaces/job-json.ts:6
+Defined in interfaces/sandboxed-job.ts:10
+Defined in interfaces/job-json.ts:17
Optional
parentKey
parentKey?: string
+Defined in interfaces/job-json.ts:18
Optional
processedOn
processedOn?: number
+Defined in interfaces/job-json.ts:12
progress
progress: number | object
+Defined in interfaces/job-json.ts:9
Optional
repeatJobKey
repeatJobKey?: string
+Defined in interfaces/job-json.ts:19
returnValue
returnValue: R
+Defined in interfaces/sandboxed-job.ts:15
returnvalue
returnvalue: string
+Defined in interfaces/job-json.ts:16
stacktrace
stacktrace: string
+Defined in interfaces/job-json.ts:15
timestamp
timestamp: number
+Defined in interfaces/job-json.ts:13
updateData
updateData: ((data) => Promise<void>)
@@ -213,7 +213,7 @@ Parameters
data: any
Returns Promise<void>
+Defined in interfaces/sandboxed-job.ts:13
updateProgress
updateProgress: ((value) => Promise<void>)
@@ -231,7 +231,7 @@ Parameters
value: number | object
Returns Promise<void>
+Defined in interfaces/sandboxed-job.ts:14
@@ -25,7 +25,7 @@
Hierarchy
+
Defined in commands/script-loader.ts:26
@@ -49,7 +49,7 @@ content
+
Defined in commands/script-loader.ts:41
includes
@@ -57,7 +57,7 @@ includes
+
Defined in commands/script-loader.ts:49
name
name: string
@@ -65,12 +65,12 @@ name
+Defined in commands/script-loader.ts:30
Optional
numberOfKeys
numberOfKeys?: number
+Defined in commands/script-loader.ts:32
path
path: string
@@ -79,7 +79,7 @@ path
+Defined in commands/script-loader.ts:37
token
token: string
@@ -87,7 +87,7 @@ token
+Defined in commands/script-loader.ts:45
@@ -32,7 +32,7 @@
Hierarchy
+
Defined in classes/worker.ts:45
@@ -79,7 +79,7 @@ prev: Returns void
+
Defined in classes/worker.ts:55
closed
closed: (() => void)
@@ -96,7 +96,7 @@ Type declaration
Returns void
+Defined in classes/worker.ts:62
closing
closing: ((msg) => void)
@@ -118,7 +118,7 @@ msg: Returns void
+Defined in classes/worker.ts:69
completed
completed: ((job, result, prev) => void)
@@ -144,7 +144,7 @@ prev: Returns void
+Defined in classes/worker.ts:76
drained
drained: (() => void)
@@ -163,7 +163,7 @@ Type declaration
Returns void
+Defined in classes/worker.ts:89
error
error: ((failedReason) => void)
@@ -185,7 +185,7 @@ failedReason: Returns void
+Defined in classes/worker.ts:96
failed
failed: ((job, error, prev) => void)
@@ -213,7 +213,7 @@ prev: Returns void
+Defined in classes/worker.ts:105
ioredis:close
ioredis:close: (() => void)
@@ -231,7 +231,7 @@ Returns void
+Defined in interfaces/ioredis-events.ts:7
paused
paused: (() => void)
@@ -248,7 +248,7 @@ Type declaration
Returns void
+Defined in classes/worker.ts:116
progress
progress: ((job, progress) => void)
@@ -275,7 +275,7 @@ progress: Returns void
+Defined in classes/worker.ts:126
ready
ready: (() => void)
@@ -292,7 +292,7 @@ Type declaration
Returns void
+Defined in classes/worker.ts:136
resumed
resumed: (() => void)
@@ -309,7 +309,7 @@ Type declaration
Returns void
+Defined in classes/worker.ts:143
stalled
stalled: ((jobId, prev) => void)
@@ -334,7 +334,7 @@ prev: Returns void
+Defined in classes/worker.ts:151
@@ -27,7 +27,7 @@
Hierarchy
+
Defined in interfaces/worker-options.ts:16
@@ -68,7 +68,7 @@ Default
true
+
Defined in interfaces/worker-options.ts:22
Optional
blockingConnection
blockingConnection?: boolean
@@ -77,7 +77,7 @@ Optional
+Defined in interfaces/queue-options.ts:22
+Defined in interfaces/worker-options.ts:31
Optional
connection
@@ -100,7 +100,7 @@ Optional
+Defined in interfaces/queue-options.ts:17
Optional
drainDelay
drainDelay?: number
@@ -111,7 +111,7 @@ Default
5
+Defined in interfaces/worker-options.ts:99
+Defined in interfaces/worker-options.ts:37
Optional
lockDuration
lockDuration?: number
@@ -135,7 +135,7 @@ Default
30000
+Defined in interfaces/worker-options.ts:110
Optional
lockRenewTime
lockRenewTime?: number
@@ -145,7 +145,7 @@ Optional
+Defined in interfaces/worker-options.ts:118
Optional
maxStalledCount
maxStalledCount?: number
@@ -158,7 +158,7 @@ Default
1
+Defined in interfaces/worker-options.ts:52
+Defined in interfaces/worker-options.ts:43
Optional
prefix
prefix?: string
@@ -177,7 +177,7 @@ Optional
+Defined in interfaces/queue-options.ts:27
Optional
removeOnComplete
@@ -187,7 +187,7 @@ Optional
+Defined in interfaces/worker-options.ts:66
Optional
removeOnFail
@@ -197,7 +197,7 @@ Optional
+Defined in interfaces/worker-options.ts:73
Optional
runRetryDelay
runRetryDelay?: number
@@ -208,7 +208,7 @@ Default
15000
+Defined in interfaces/worker-options.ts:125
Optional
settings
@@ -216,7 +216,7 @@ Optional
+Defined in interfaces/worker-options.ts:130
Optional
skipLockRenewal
skipLockRenewal?: boolean
@@ -229,7 +229,7 @@ Default
false
+Defined in interfaces/worker-options.ts:91
Optional
skipStalledCheck
skipStalledCheck?: boolean
@@ -242,7 +242,7 @@ Default
false
+Defined in interfaces/worker-options.ts:82
Optional
skipVersionCheck
skipVersionCheck?: boolean
@@ -254,7 +254,7 @@ Default Value
false
+Defined in interfaces/queue-options.ts:33
Optional
stalledInterval
stalledInterval?: number
@@ -265,7 +265,7 @@ Default
30000
+Defined in interfaces/worker-options.ts:59
Optional
useWorkerThreads
useWorkerThreads?: boolean
@@ -278,7 +278,7 @@ Default
false
+Defined in interfaces/worker-options.ts:139
@@ -690,7 +690,7 @@
StreamReadRaw
WaitingEventCallback3
@@ -484,7 +484,7 @@
StreamName
StreamReadRaw
@@ -493,7 +493,7 @@
StreamName
StreamReadRaw
@@ -175,7 +175,7 @@
Member Visibility
@@ -37,7 +37,7 @@
Optional
Optional job: MinimalJob
Returns Promise<number> | number
+Defined in types/backoff-strategy.ts:3
@@ -18,7 +18,7 @@
Type alias BulkJobOptions
+Defined in interfaces/minimal-job.ts:5
@@ -18,7 +18,7 @@
Type alias ClusterOptions
+Defined in interfaces/redis-options.ts:9
@@ -18,7 +18,7 @@
Type alias ConnectionOptions
+Defined in interfaces/redis-options.ts:11
@@ -18,7 +18,7 @@
Type alias EntryId
EntryId: string
+Defined in interfaces/redis-streams.ts:6
@@ -18,7 +18,7 @@
Type alias EntryRaw
+Defined in interfaces/redis-streams.ts:7
@@ -18,7 +18,7 @@
Type alias FinishedPropValAttribute
FinishedPropValAttribute: "returnvalue" | "failedReason"
+Defined in types/finished-status.ts:3
@@ -18,7 +18,7 @@
Type alias FinishedStatus
FinishedStatus: "completed" | "failed"
+Defined in types/finished-status.ts:1
@@ -18,7 +18,7 @@
Type alias FlowChildJob
+Defined in interfaces/flow-job.ts:13
@@ -18,7 +18,7 @@
Type alias FlowJob
+Defined in interfaces/flow-job.ts:15
@@ -18,7 +18,7 @@
Type alias FlowQueuesOpts
FlowQueuesOpts: Record<string, Omit<QueueOptions, "connection" | "prefix">>
+Defined in interfaces/flow-job.ts:17
@@ -18,7 +18,7 @@
Type alias JobData
+Defined in classes/scripts.ts:38
@@ -25,7 +25,7 @@
prefix
queueName: string
+Defined in types/job-json-sandbox.ts:3
@@ -18,7 +18,7 @@
Type alias JobState
JobState: FinishedStatus | "active" | "delayed" | "prioritized" | "waiting" | "waiting-children"
+Defined in types/job-type.ts:3
@@ -18,7 +18,7 @@
Type alias JobType
JobType: JobState | "paused" | "repeat" | "wait"
+Defined in types/job-type.ts:11
@@ -31,7 +31,7 @@
Optional
+Defined in types/job-options.ts:3
@@ -18,7 +18,7 @@
Type alias KeysMap
KeysMap: {
    [index in string]: string
}
+Defined in classes/queue-keys.ts:1
@@ -18,7 +18,7 @@
Type alias MinimalQueue
MinimalQueue: Pick<QueueBase, "name" | "client" | "toKey" | "keys" | "opts" | "qualifiedName" | "closing" | "waitUntilReady" | "removeListener" | "emit" | "on" | "redisVersion">
+Defined in types/minimal-queue.ts:3
@@ -27,7 +27,7 @@
Optional
Optional
waitChildrenKey?: string
+Defined in interfaces/parent.ts:18
@@ -45,7 +45,7 @@
Optional
Returns Promise<R>
+Defined in interfaces/worker-options.ts:11
@@ -18,7 +18,7 @@
Type alias RedisClient
RedisClient: Redis | Cluster
+Defined in interfaces/connection.ts:4
@@ -39,7 +39,7 @@
Optional
+Defined in types/job-options.ts:18
@@ -18,7 +18,7 @@
Type alias RedisOptions
+Defined in interfaces/redis-options.ts:7
@@ -35,7 +35,7 @@
opts: Optional name: string
Returns number | undefined | Promise<number | undefined>
+Defined in types/repeat-strategy.ts:3
@@ -35,7 +35,7 @@
pattern
tz: string | null
+Defined in interfaces/repeatable-job.ts:1
+Defined in interfaces/sandboxed-job-processor.ts:6
@@ -18,7 +18,7 @@
Type alias StreamName
StreamName: string
+Defined in interfaces/redis-streams.ts:5
@@ -18,7 +18,7 @@
Type alias StreamReadRaw
+Defined in interfaces/redis-streams.ts:8
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -37,7 +37,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -37,7 +37,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -37,7 +37,7 @@
Member Visibility
@@ -32,7 +32,7 @@
Member Visibility
@@ -18,7 +18,7 @@
Variable DELAY_TIME_1Const
DELAY_TIME_1: 100 = 100
+Defined in utils.ts:144
@@ -18,7 +18,7 @@
Variable DELAY_TIME_5Const
DELAY_TIME_5: 5000 = 5000
+Defined in utils.ts:142
@@ -18,7 +18,7 @@
Variable PRIORITY_LIMITConst
PRIORITY_LIMIT: number = ...
+Defined in classes/job.ts:48
@@ -18,7 +18,7 @@
Variable QUEUE_EVENT_SUFFIXConst
QUEUE_EVENT_SUFFIX: ":qe" = ':qe'
+Defined in utils.ts:217
@@ -18,7 +18,7 @@
Variable RATE_LIMIT_ERRORConst
RATE_LIMIT_ERROR: "bullmq:rateLimitExceeded" = 'bullmq:rateLimitExceeded'
+Defined in classes/errors/rate-limit-error.ts:1
@@ -18,7 +18,7 @@
Variable WORKER_SUFFIXConst
WORKER_SUFFIX: "" = ''
+Defined in utils.ts:215
@@ -18,7 +18,7 @@
Variable clientCommandMessageRegConst
clientCommandMessageReg: RegExp = ...
+Defined in utils.ts:139
@@ -23,7 +23,7 @@
Type declaration
[index: string]: any
+Defined in utils.ts:13
@@ -18,7 +18,7 @@
Variable scriptLoaderConst
+Defined in commands/index.ts:4