diff --git a/classes/v4.AsyncFifoQueue.html b/classes/v4.AsyncFifoQueue.html index 52968ed9f9..2bec3a916a 100644 --- a/classes/v4.AsyncFifoQueue.html +++ b/classes/v4.AsyncFifoQueue.html @@ -37,7 +37,7 @@

Hierarchy

+
  • Defined in classes/async-fifo-queue.ts:13
  • @@ -75,7 +75,7 @@

    Parameters

    ignoreErrors: boolean = false

    Returns AsyncFifoQueue<T>

    +
  • Defined in classes/async-fifo-queue.ts:21
  • Methods

    @@ -90,7 +90,7 @@

    Parameters

    promise: Promise<T>

    Returns void

    +
  • Defined in classes/async-fifo-queue.ts:25
  • +
  • Defined in classes/async-fifo-queue.ts:84
  • +
  • Defined in classes/async-fifo-queue.ts:55
  • +
  • Defined in classes/async-fifo-queue.ts:59
  • +
  • Defined in classes/async-fifo-queue.ts:51
  • +
  • Defined in classes/async-fifo-queue.ts:47
  • Returns BackoffOptions

    +
  • Defined in classes/backoffs.ts:23
  • +
  • Defined in classes/child-pool.ts:13
  • retained: {
        [key: number]: Child;
    } = {}
    @@ -82,7 +82,7 @@

    Type declaration

  • [key: number]: Child
  • +
  • Defined in classes/child-pool.ts:12
  • Methods

    @@ -92,7 +92,7 @@
    +
  • Defined in classes/child-pool.ts:72
  • +
  • Defined in classes/child-pool.ts:84
  • Returns Child[]

    +
  • Defined in classes/child-pool.ts:80
  • Returns Promise<void>

    +
  • Defined in classes/child-pool.ts:64
  • Returns void

    +
  • Defined in classes/child-pool.ts:48
  • Returns void

    +
  • Defined in classes/child-pool.ts:53
  • Returns Promise<Child>

    +
  • Defined in classes/child-pool.ts:23
  • Returns Promise<void>

    +
  • Defined in classes/child-processor.ts:26
  • Returns Promise<void>

    +
  • Defined in classes/child-processor.ts:63
  • +
  • Defined in classes/child-processor.ts:91
  • +
  • Defined in classes/child-processor.ts:93
  • +
  • Defined in classes/flow-producer.ts:93
  • Accessors

    @@ -135,7 +135,7 @@
    +
  • Defined in classes/flow-producer.ts:210
  • Methods

    @@ -162,7 +162,7 @@
    Optional Returns Promise<JobNode>
    +
  • Defined in classes/flow-producer.ts:159
  • +
  • Defined in classes/flow-producer.ts:235
  • +
  • Defined in classes/flow-producer.ts:446
  • +
  • Defined in classes/flow-producer.ts:453
  • +
  • Defined in classes/flow-producer.ts:118
  • +
  • Defined in classes/flow-producer.ts:192
  • +
  • Defined in classes/flow-producer.ts:125
  • +
  • Defined in classes/flow-producer.ts:133
  • +
  • Defined in classes/flow-producer.ts:141
  • +
  • Defined in classes/job.ts:105
  • data: DataType
    @@ -175,7 +175,7 @@
    +
  • Defined in classes/job.ts:158
  • delay: number
    @@ -187,7 +187,7 @@

    Default Value

    0
     
    +
  • Defined in classes/job.ts:94
  • failedReason: string
    @@ -196,7 +196,7 @@
    +
  • Defined in classes/job.ts:110
  • finishedOn?: number
    @@ -205,13 +205,13 @@
    +
  • Defined in classes/job.ts:115
  • id?: string
    +
  • Defined in classes/job.ts:164
  • name: NameType
    @@ -220,7 +220,7 @@
    +
  • Defined in classes/job.ts:153
  • opts: JobsOptions = {}
    @@ -229,7 +229,7 @@
    +
  • Defined in classes/job.ts:163
  • parent?: ParentKeys
    @@ -238,7 +238,7 @@
    +
  • Defined in classes/job.ts:130
  • parentKey?: string
    @@ -247,7 +247,7 @@
    +
  • Defined in classes/job.ts:125
  • processedOn?: number
    @@ -256,7 +256,7 @@
    +
  • Defined in classes/job.ts:120
  • progress: number | object = 0
    @@ -268,7 +268,7 @@

    Default Value

    0
     
    +
  • Defined in classes/job.ts:76
  • queueQualifiedName: string
    @@ -279,7 +279,7 @@

    See

    Implementation of MinimalJob.queueQualifiedName

    +
  • Defined in classes/job.ts:70
  • repeatJobKey?: string
    @@ -288,7 +288,7 @@
    +
  • Defined in classes/job.ts:135
  • returnvalue: ReturnType = null
    @@ -300,7 +300,7 @@

    Default Value

    null
    +
  • Defined in classes/job.ts:82
  • stacktrace: string[] = null
    @@ -312,7 +312,7 @@

    Default Value

    null
    +
  • Defined in classes/job.ts:88
  • timestamp: number
    @@ -321,7 +321,7 @@
    +
  • Defined in classes/job.ts:99
  • token?: string
    @@ -329,7 +329,7 @@
    +
  • Defined in classes/job.ts:140
  • Accessors

    @@ -342,7 +342,7 @@

    Returns string

    +
  • Defined in classes/job.ts:743
    • @@ -353,7 +353,7 @@

      Returns string

    +
  • Defined in classes/job.ts:736
  • Methods

    @@ -373,7 +373,7 @@
    Optional Returns Promise<string>
    +
  • Defined in classes/job.ts:1095
  • +
  • Defined in classes/job.ts:423
  • +
  • Defined in classes/job.ts:465
  • +
  • Defined in classes/job.ts:763
  • +
  • Defined in classes/job.ts:773
  • +
  • Defined in classes/job.ts:510
  • +
  • Defined in classes/job.ts:1073
  • +
  • Defined in classes/job.ts:550
  • +
  • Defined in classes/job.ts:785
  • +
  • Defined in classes/job.ts:807
  • +
  • Defined in classes/job.ts:899
  • +
  • Defined in classes/job.ts:753
  • +
  • Defined in classes/job.ts:722
  • +
  • Defined in classes/job.ts:694
  • +
  • Defined in classes/job.ts:708
  • +
  • Defined in classes/job.ts:701
  • +
  • Defined in classes/job.ts:729
  • +
  • Defined in classes/job.ts:715
  • +
  • Defined in classes/job.ts:501
  • +
  • Defined in classes/job.ts:563
  • +
  • Defined in classes/job.ts:1023
  • +
  • Defined in classes/job.ts:601
  • +
  • Defined in classes/job.ts:1034
  • +
  • Defined in classes/job.ts:1044
  • +
  • Defined in classes/job.ts:528
  • +
  • Defined in classes/job.ts:1061
    • @@ -813,7 +813,7 @@
    +
  • Defined in classes/job.ts:414
  • +
  • Defined in classes/job.ts:478
  • +
  • Defined in classes/job.ts:489
  • +
  • Defined in classes/job.ts:951
  • +
  • Defined in classes/job.ts:389
  • +
  • Defined in classes/job.ts:205
  • +
  • Defined in classes/job.ts:232
  • +
  • Defined in classes/job.ts:361
  • +
  • Defined in classes/job.ts:279
  • +
  • Defined in classes/queue-base.ts:35
  • opts: QueueBaseOptions = {}
    @@ -185,13 +185,13 @@
    +
  • Defined in classes/queue-base.ts:36
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -210,12 +210,12 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • token: string = ...
    +
  • Defined in classes/queue.ts:97
  • Accessors

    @@ -229,7 +229,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue.ts:168
  • +
  • Defined in classes/queue-base.ts:91
  • +
  • Defined in classes/queue.ts:172
  • Methods

    @@ -288,7 +288,7 @@
    Optional Returns Promise<Job<DataType, ResultType, NameType>>
    +
  • Defined in classes/queue.ts:192
  • +
  • Defined in classes/queue.ts:232
  • +
  • Defined in classes/queue.ts:385
  • +
  • Defined in classes/queue.ts:414
  • +
  • Defined in classes/queue.ts:269
  • +
  • Defined in classes/queue-getters.ts:96
  • +
  • Defined in classes/queue-base.ts:151
  • +
  • Defined in classes/queue.ts:400
  • +
  • Defined in classes/queue.ts:134
  • +
  • Defined in classes/queue-getters.ts:240
  • +
  • Defined in classes/queue-getters.ts:186
  • +
  • Defined in classes/queue-getters.ts:276
  • +
  • Defined in classes/queue-getters.ts:165
  • +
  • Defined in classes/queue-getters.ts:252
  • +
  • Defined in classes/queue-getters.ts:179
  • +
  • Defined in classes/queue-getters.ts:288
  • +
  • Defined in classes/queue-getters.ts:172
  • +
  • Defined in classes/queue-getters.ts:26
  • +
  • Defined in classes/queue-getters.ts:127
  • +
  • Defined in classes/queue-getters.ts:137
  • +
  • Defined in classes/queue-getters.ts:365
  • +
  • Defined in classes/queue-getters.ts:158
  • +
  • Defined in classes/queue-getters.ts:338
  • +
  • Defined in classes/queue-getters.ts:453
  • +
  • Defined in classes/queue-getters.ts:264
  • +
  • Defined in classes/queue-getters.ts:193
  • +
  • Defined in classes/queue-getters.ts:431
  • +
  • Defined in classes/queue-getters.ts:295
  • +
  • Defined in classes/queue-getters.ts:114
    • @@ -868,7 +868,7 @@
      Optional Returns Promise<{
          endDate: number;
          id: string;
          key: string;
          name: string;
          next: number;
          pattern: string;
          tz: string;
      }[]>
    +
  • Defined in classes/queue.ts:305
  • +
  • Defined in classes/queue-getters.ts:216
  • +
  • Defined in classes/queue-getters.ts:228
  • +
  • Defined in classes/queue-getters.ts:207
  • +
  • Defined in classes/queue-getters.ts:200
  • +
  • Defined in classes/queue-getters.ts:417
  • +
  • Defined in classes/queue.ts:291
  • +
  • Defined in classes/queue.ts:447
  • +
  • Defined in classes/queue.ts:141
  • +
  • Defined in classes/queue.ts:149
  • +
  • Defined in classes/queue.ts:157
  • +
  • Defined in classes/queue.ts:260
  • +
  • Defined in classes/queue.ts:491
  • +
  • Defined in classes/queue.ts:359
    • @@ -1127,7 +1127,7 @@
    +
  • Defined in classes/queue.ts:511
  • +
  • Defined in classes/queue.ts:322
  • +
  • Defined in classes/queue.ts:343
  • +
  • Defined in classes/queue.ts:283
  • +
  • Defined in classes/queue.ts:470
  • +
  • Defined in classes/queue.ts:503
  • +
  • Defined in classes/queue.ts:369
  • +
  • Defined in classes/queue-base.ts:123
  • +
  • Defined in classes/queue-base.ts:35
  • opts: QueueBaseOptions = {}
    @@ -126,13 +126,13 @@
    +
  • Defined in classes/queue-base.ts:36
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -151,7 +151,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -165,7 +165,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue-base.ts:91
  • Methods

    @@ -189,7 +189,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:140
  • +
  • Defined in classes/queue-base.ts:151
    • @@ -222,7 +222,7 @@

      Returns booleanImplementation of MinimalQueue.emit

      Overrides EventEmitter.emit

    +
  • Defined in classes/queue-base.ts:109
  • +
  • Defined in classes/queue-base.ts:123
  • +
  • Defined in classes/queue-base.ts:35
  • opts: QueueBaseOptions = {}
    @@ -115,13 +115,13 @@
    +
  • Defined in classes/queue-base.ts:36
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -140,7 +140,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -154,7 +154,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue-base.ts:91
  • Methods

    @@ -180,7 +180,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-events.ts:304
  • +
  • Defined in classes/queue-base.ts:151
  • +
  • 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:123
  • +
  • Defined in classes/queue-base.ts:35
  • opts: QueueBaseOptions = {}
    @@ -162,13 +162,13 @@
    +
  • Defined in classes/queue-base.ts:36
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -187,7 +187,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -201,7 +201,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue-base.ts:91
  • Methods

    @@ -226,7 +226,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:140
  • +
  • Defined in classes/queue-getters.ts:96
  • +
  • Defined in classes/queue-base.ts:151
  • +
  • Defined in classes/queue-base.ts:109
  • +
  • Defined in classes/queue-getters.ts:240
  • +
  • Defined in classes/queue-getters.ts:186
  • +
  • Defined in classes/queue-getters.ts:276
  • +
  • Defined in classes/queue-getters.ts:165
  • +
  • Defined in classes/queue-getters.ts:252
  • +
  • Defined in classes/queue-getters.ts:179
  • +
  • Defined in classes/queue-getters.ts:288
  • +
  • Defined in classes/queue-getters.ts:172
    • @@ -416,7 +416,7 @@

      Parameters

      jobId: string

    Returns Promise<Job<DataType, ResultType, NameType>>

    +
  • Defined in classes/queue-getters.ts:26
  • +
  • Defined in classes/queue-getters.ts:127
  • +
  • Defined in classes/queue-getters.ts:137
  • +
  • Defined in classes/queue-getters.ts:365
  • +
  • Defined in classes/queue-getters.ts:158
  • +
  • Defined in classes/queue-getters.ts:338
  • +
  • Defined in classes/queue-getters.ts:453
  • +
  • Defined in classes/queue-getters.ts:264
  • +
  • Defined in classes/queue-getters.ts:193
  • +
  • Defined in classes/queue-getters.ts:431
    • @@ -630,7 +630,7 @@
      end: asc: boolean = false

    Returns Promise<string[]>

    +
  • Defined in classes/queue-getters.ts:295
  • +
  • Defined in classes/queue-getters.ts:114
  • +
  • Defined in classes/queue-getters.ts:216
  • +
  • Defined in classes/queue-getters.ts:228
  • +
  • Defined in classes/queue-getters.ts:207
  • +
  • Defined in classes/queue-getters.ts:200
  • +
  • Defined in classes/queue-getters.ts:417
  • +
  • Defined in classes/queue-base.ts:123
  • Returns KeysMap

    +
  • Defined in classes/queue-keys.ts:6
    • @@ -90,7 +90,7 @@

      Parameters

      name: string

    Returns string

    +
  • Defined in classes/queue-keys.ts:37
    • @@ -105,7 +105,7 @@
      name: type: string

    Returns string

    +
  • Defined in classes/queue-keys.ts:33
  • +
  • Defined in classes/queue-base.ts:35
  • opts: QueueBaseOptions = {}
    @@ -115,13 +115,13 @@
    +
  • Defined in classes/queue-base.ts:36
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -140,7 +140,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -154,7 +154,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue-base.ts:91
  • Methods

    @@ -196,7 +196,7 @@
    opts: Optional skipCheckExists: boolean
    Optional

    Returns Promise<Job<T, R, N>>

    +
  • Defined in classes/repeat.ts:27
  • +
  • Defined in classes/queue-base.ts:140
  • +
  • Defined in classes/queue-base.ts:151
  • +
  • Defined in classes/queue-base.ts:109
  • +
  • Defined in classes/repeat.ts:202
    • @@ -265,7 +265,7 @@
      end: asc: boolean = false

    Returns Promise<{
        endDate: number;
        id: string;
        key: string;
        name: string;
        next: number;
        pattern: string;
        tz: string;
    }[]>

    +
  • Defined in classes/repeat.ts:187
  • Returns Promise<number>

    +
  • Defined in classes/repeat.ts:143
    • @@ -295,7 +295,7 @@

      Parameters

      repeatJobKey: string

    Returns Promise<number>

    +
  • Defined in classes/repeat.ts:159
  • +
  • Defined in classes/queue-base.ts:123
  • +
  • Defined in commands/script-loader.ts:134
  • Returns Promise<string>

    +
  • Defined in classes/scripts.ts:74
    • @@ -131,7 +131,7 @@
      jobId: delay: number

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:503
    • @@ -148,7 +148,7 @@
      priority: lifo: boolean = false

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:535
  • +
  • Defined in classes/scripts.ts:701
    • @@ -182,7 +182,7 @@

      Parameters

      delayed: boolean

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:369
    • @@ -201,7 +201,7 @@
      duration: Optional client: ChainableCommander | RedisClient
      Optional

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:193
    • @@ -220,7 +220,7 @@
      command: Optional state: string
      Optional

    Returns Error

    +
  • Defined in classes/scripts.ts:326
    • @@ -233,7 +233,7 @@

      Parameters

      types: JobType[]

    Returns Promise<number[]>

    +
  • Defined in classes/scripts.ts:419
    • @@ -252,7 +252,7 @@
      end: asc: boolean = false

    Returns Promise<[string][]>

    +
  • Defined in classes/scripts.ts:394
    • @@ -265,7 +265,7 @@

      Parameters

      jobId: string

    Returns Promise<"unknown" | JobState>

    +
  • Defined in classes/scripts.ts:481
    • @@ -280,7 +280,7 @@
      jobId: returnValue: boolean = false

    Returns Promise<number | [number, string]>

    +
  • Defined in classes/scripts.ts:466
    • @@ -295,7 +295,7 @@
      listKey: jobId: string

    Returns Promise<boolean>

    +
  • Defined in classes/scripts.ts:63
  • +
  • Defined in classes/scripts.ts:930
    • @@ -333,7 +333,7 @@
    +
  • Defined in classes/scripts.ts:898
    • @@ -348,7 +348,7 @@
      token: Optional jobId: string
      Optional

    Returns Promise<any[]>

    +
  • Defined in classes/scripts.ts:835
    • @@ -378,7 +378,7 @@
      token: fetchNext: boolean = false

    Returns (string | number | boolean | Buffer)[]

    +
  • Defined in classes/scripts.ts:426
    • @@ -395,7 +395,7 @@
      timestamp: token: string = '0'

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:646
    • @@ -412,7 +412,7 @@
      timestamp: token: string

    Returns (string | number)[]

    +
  • Defined in classes/scripts.ts:571
    • @@ -442,7 +442,7 @@
      token: fetchNext: boolean = false

    Returns (string | number | boolean | Buffer)[]

    +
  • Defined in classes/scripts.ts:446
    • @@ -457,7 +457,7 @@
      jobId: args: (string | number | boolean | Buffer)[]

    Returns Promise<any[]>

    +
  • Defined in classes/scripts.ts:310
    • @@ -487,7 +487,7 @@

      Throws

      JobNotInState This exception is thrown if job is not in active state.

    +
  • Defined in classes/scripts.ts:671
  • Returns string[]

    +
  • Defined in classes/scripts.ts:623
    • @@ -522,7 +522,7 @@
      countforce: boolean

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:953
    • @@ -535,7 +535,7 @@

      Parameters

      pause: boolean

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:142
    • @@ -548,7 +548,7 @@

      Parameters

      jobId: string

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:871
    • @@ -561,7 +561,7 @@

      Parameters

      count: number = 1000

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:782
    • @@ -576,7 +576,7 @@
      jobId: removeChildren: boolean

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:184
    • @@ -591,7 +591,7 @@
      repeatJobId: repeatJobKey: string

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:174
  • +
  • Defined in classes/scripts.ts:803
    • @@ -643,7 +643,7 @@
      lifo: token: string

    Returns (string | number)[]

    +
  • Defined in classes/scripts.ts:718
    • @@ -660,7 +660,7 @@
      count: timestamp: number = ...

    Returns Promise<number>

    +
  • Defined in classes/scripts.ts:770
    • @@ -677,7 +677,7 @@
      stacktrace: failedReason: string

    Returns string[]

    +
  • Defined in classes/scripts.ts:613
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:210
    • @@ -725,7 +725,7 @@
      jobId: progress: number | object

    Returns Promise<void>

    +
  • Defined in classes/scripts.ts:226
  • +
  • Defined in classes/queue-base.ts:35
  • @@ -153,13 +153,13 @@
    +
  • Defined in classes/worker.ts:165
  • qualifiedName: string
    +
  • Defined in classes/queue-base.ts:25
  • toKey: ((type) => string)
    @@ -178,7 +178,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -192,7 +192,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:84
    • @@ -205,7 +205,7 @@

      Parameters

      concurrency: number

    Returns void

    +
  • Defined in classes/worker.ts:350
  • +
  • Defined in classes/queue-base.ts:91
  • +
  • Defined in classes/worker.ts:361
  • Methods

    @@ -249,7 +249,7 @@

    Returns Promise<

    +
  • Defined in classes/worker.ts:751
  • +
  • Defined in classes/worker.ts:578
  • +
  • Defined in classes/queue-base.ts:151
  • +
  • Defined in classes/worker.ts:290
  • +
  • Defined in classes/worker.ts:448
  • +
  • Defined in classes/worker.ts:726
  • +
  • Defined in classes/worker.ts:736
  • +
  • Defined in classes/worker.ts:297
  • +
  • Defined in classes/worker.ts:305
  • +
  • Defined in classes/worker.ts:313
  • +
  • Defined in classes/worker.ts:695
    • @@ -454,7 +454,7 @@

      Returns booleanjobsInProgress: Set<{
          job: Job<any, any, string>;
          ts: number;
      }>

    Returns Promise<void | Job<DataType, ResultType, NameType>>

    +
  • Defined in classes/worker.ts:619
  • +
  • Defined in classes/worker.ts:497
  • +
  • Defined in classes/worker.ts:713
  • +
  • Defined in classes/worker.ts:375
  • +
  • Defined in classes/worker.ts:801
  • +
  • Defined in classes/worker.ts:345
  • +
  • Defined in classes/worker.ts:189
  • +
  • Defined in enums/child-command.ts:4
  • +
  • Defined in interfaces/queue-options.ts:7
  • +
  • Defined in enums/error-code.ts:6
  • +
  • Defined in enums/metrics-time.ts:8
  • +
  • Defined in enums/parent-command.ts:10
  • +
  • Defined in utils.ts:45
  • +
  • Defined in utils.ts:141
  • +
  • Defined in utils.ts:162
  • +
  • Defined in utils.ts:53
  • +
  • Defined in utils.ts:187
  • +
  • Defined in classes/repeat.ts:234
  • +
  • Defined in utils.ts:112
  • +
  • Defined in utils.ts:36
  • +
  • Defined in utils.ts:128
  • +
  • Defined in utils.ts:77
  • +
  • Defined in utils.ts:69
  • +
  • Defined in utils.ts:167
  • +
  • Defined in utils.ts:32
  • +
  • Defined in utils.ts:176
  • +
  • Defined in classes/scripts.ts:975
  • +
  • Defined in utils.ts:81
  • +
  • Defined in utils.ts:14
  • +
  • Defined in classes/flow-producer.ts:44
  • +
  • Defined in classes/flow-producer.ts:31
  • +
  • Defined in interfaces/advanced-options.ts:7
  • +
  • Defined in interfaces/backoff-options.ts:10
  • +
  • Defined in interfaces/base-job-options.ts:34
  • delay?: number
    @@ -84,7 +84,7 @@

    Default Value

    0
     
    +
  • Defined in interfaces/base-job-options.ts:23
  • jobId?: string
    @@ -96,7 +96,7 @@
    +
  • Defined in interfaces/base-job-options.ts:95
  • keepLogs?: number
    @@ -105,7 +105,7 @@
    +
  • Defined in interfaces/base-job-options.ts:64
  • lifo?: boolean
    @@ -116,7 +116,7 @@

    See

    https://docs.bul

    +
  • Defined in interfaces/base-job-options.ts:41
  • 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
  • prevMillis?: number
    @@ -141,7 +141,7 @@
    +
  • Defined in interfaces/base-job-options.ts:113
  • priority?: number
    @@ -152,7 +152,7 @@
    +
  • Defined in interfaces/base-job-options.ts:15
  • removeOnComplete?: number | boolean | KeepJobs
    @@ -165,7 +165,7 @@
    +
  • Defined in interfaces/base-job-options.ts:50
  • removeOnFail?: number | boolean | KeepJobs
    @@ -178,7 +178,7 @@
    +
  • Defined in interfaces/base-job-options.ts:59
  • repeat?: RepeatOptions
    @@ -186,7 +186,7 @@
    +
  • Defined in interfaces/base-job-options.ts:81
  • repeatJobKey?: string
    @@ -194,7 +194,7 @@
    +
  • Defined in interfaces/base-job-options.ts:86
  • sizeLimit?: number
    @@ -203,7 +203,7 @@
    +
  • Defined in interfaces/base-job-options.ts:74
  • stackTraceLimit?: number
    @@ -212,7 +212,7 @@
    +
  • Defined in interfaces/base-job-options.ts:69
  • timestamp?: number
    @@ -224,7 +224,7 @@

    Default Value

    Date
    +
  • Defined in interfaces/base-job-options.ts:8
  • +
  • Defined in classes/backoffs.ts:4
  • +
  • Defined in commands/script-loader.ts:17
  • +
  • Defined in interfaces/base-job-options.ts:23
  • keepLogs?: number
    @@ -84,7 +84,7 @@
    +
  • Defined in interfaces/base-job-options.ts:64
  • lifo?: boolean
    @@ -94,7 +94,7 @@

    https://docs.bullmq.io/guide/jobs/lifo

    +
  • Defined in interfaces/base-job-options.ts:41
  • priority?: number
    @@ -104,7 +104,7 @@
    +
  • Defined in interfaces/base-job-options.ts:15
  • removeOnComplete?: number | boolean | KeepJobs
    @@ -116,7 +116,7 @@
    +
  • Defined in interfaces/base-job-options.ts:50
  • removeOnFail?: number | boolean | KeepJobs
    @@ -128,7 +128,7 @@
    +
  • Defined in interfaces/base-job-options.ts:59
  • sizeLimit?: number
    @@ -136,7 +136,7 @@
    +
  • Defined in interfaces/base-job-options.ts:74
  • stackTraceLimit?: number
    @@ -144,7 +144,7 @@
    +
  • Defined in interfaces/base-job-options.ts:69
  • timestamp?: number
    @@ -155,7 +155,7 @@

    Default Value

    Date
    +
  • Defined in interfaces/base-job-options.ts:8
  • +
  • Defined in interfaces/minimal-job.ts:19
  • +
  • Defined in interfaces/flow-job.ts:26
  • +
  • Defined in interfaces/ioredis-events.ts:7
  • +
  • Defined in interfaces/ioredis-events.ts:7
  • +
  • Defined in interfaces/metrics.ts:2
  • +
  • Defined in interfaces/minimal-job.ts:40
  • delay: number
    @@ -108,7 +108,7 @@

    Default Value

    0
     
    +
  • Defined in interfaces/minimal-job.ts:65
  • failedReason: string
    @@ -116,7 +116,7 @@
    +
  • Defined in interfaces/minimal-job.ts:78
  • finishedOn?: number
    @@ -124,12 +124,12 @@
    +
  • Defined in interfaces/minimal-job.ts:82
  • id?: string
    +
  • Defined in interfaces/minimal-job.ts:45
  • name: NameType
    @@ -137,7 +137,7 @@
    +
  • Defined in interfaces/minimal-job.ts:36
  • @@ -145,7 +145,7 @@
    +
  • Defined in interfaces/minimal-job.ts:44
  • parent?: ParentKeys
    @@ -153,7 +153,7 @@
    +
  • Defined in interfaces/minimal-job.ts:94
  • parentKey?: string
    @@ -161,7 +161,7 @@
    +
  • Defined in interfaces/minimal-job.ts:90
  • processedOn?: number
    @@ -169,7 +169,7 @@
    +
  • Defined in interfaces/minimal-job.ts:86
  • progress: number | object
    @@ -180,7 +180,7 @@

    Default Value

    0
     
    +
  • Defined in interfaces/minimal-job.ts:50
  • repeatJobKey?: string
    @@ -188,7 +188,7 @@
    +
  • Defined in interfaces/minimal-job.ts:98
  • returnvalue: ReturnType
    @@ -199,7 +199,7 @@

    Default Value

    null
    +
  • Defined in interfaces/minimal-job.ts:55
  • stacktrace: string[]
    @@ -210,7 +210,7 @@

    Default Value

    null
    +
  • Defined in interfaces/minimal-job.ts:60
  • timestamp: number
    @@ -218,7 +218,7 @@
    +
  • Defined in interfaces/minimal-job.ts:69
  • Accessors

    @@ -230,7 +230,7 @@

    Returns string

    +
  • Defined in interfaces/minimal-job.ts:131
  • +
  • Defined in interfaces/minimal-job.ts:127
  • +
  • Defined in interfaces/minimal-job.ts:136
  • Methods

    @@ -263,7 +263,7 @@
    +
  • Defined in interfaces/minimal-job.ts:103
  • +
  • Defined in interfaces/minimal-job.ts:108
  • +
  • Defined in interfaces/minimal-job.ts:126
  • +
  • Defined in interfaces/minimal-job.ts:114
  • +
  • Defined in interfaces/minimal-job.ts:120
  • +
  • Defined in interfaces/minimal-job.ts:8
  • +
  • Defined in classes/queue.ts:22
  • +
  • Defined in interfaces/queue-options.ts:38
  • +
  • Defined in classes/queue-events.ts:29
  • cleaned: ((args, id) => void)
    @@ -136,7 +136,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:36
  • completed: ((args, id) => void)
    @@ -167,7 +167,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:43
  • delayed: ((args, id) => void)
    @@ -196,7 +196,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:53
  • drained: ((id) => void)
    @@ -220,7 +220,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:62
  • duplicated: ((args, id) => void)
    @@ -247,7 +247,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:69
  • error: ((args) => void)
    @@ -269,7 +269,7 @@
    args: Returns void
    +
  • Defined in classes/queue-events.ts:76
  • failed: ((args, id) => void)
    @@ -300,7 +300,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:83
  • ioredis:close: (() => void)
    @@ -318,7 +318,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: ((args, id) => void)
    @@ -343,7 +343,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:93
  • progress: ((args, id) => void)
    @@ -375,7 +375,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:103
  • removed: ((args, id) => void)
    @@ -405,7 +405,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:114
  • resumed: ((args, id) => void)
    @@ -430,7 +430,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:121
  • retries-exhausted: ((args, id) => void)
    @@ -459,7 +459,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:128
  • stalled: ((args, id) => void)
    @@ -488,7 +488,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:140
  • waiting: ((args, id) => void)
    @@ -517,7 +517,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:147
  • waiting-children: ((args, id) => void)
    @@ -544,7 +544,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:154
  • +
  • Defined in interfaces/queue-options.ts:17
  • lastEventId?: string
    @@ -89,7 +89,7 @@
    +
  • Defined in interfaces/queue-options.ts:85
  • prefix?: string
    @@ -98,7 +98,7 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • sharedConnection?: boolean
    @@ -107,7 +107,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • skipVersionCheck?: boolean
    @@ -119,7 +119,7 @@

    Default Value

    false
    +
  • Defined in interfaces/queue-options.ts:38
  • +
  • Defined in classes/queue.ts:44
  • ioredis:close: (() => void)
    @@ -114,7 +114,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: (() => void)
    @@ -131,7 +131,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/queue.ts:51
  • progress: ((job, progress) => void)
    @@ -155,7 +155,7 @@
    progress: Returns void
    +
  • Defined in classes/queue.ts:58
  • removed: ((job) => void)
    @@ -177,7 +177,7 @@
    job: Returns void
    +
  • Defined in classes/queue.ts:68
  • resumed: (() => void)
    @@ -194,7 +194,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/queue.ts:75
  • waiting: ((job) => void)
    @@ -216,7 +216,7 @@
    job: Returns void
    +
  • Defined in classes/queue.ts:82
  • +
  • Defined in interfaces/queue-options.ts:17
  • defaultJobOptions?: DefaultJobOptions
    +
  • Defined in interfaces/queue-options.ts:45
  • prefix?: string
    @@ -77,12 +77,12 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • +
  • Defined in interfaces/queue-options.ts:62
  • sharedConnection?: boolean
    @@ -91,7 +91,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • skipVersionCheck?: boolean
    @@ -103,7 +103,7 @@

    Default Value

    false
    +
  • Defined in interfaces/queue-options.ts:38
  • streams?: {
        events: {
            maxLen: number;
        };
    }
    @@ -125,7 +125,7 @@
    maxLen
    +
  • Defined in interfaces/queue-options.ts:50
  • +
  • Defined in interfaces/rate-limiter-options.ts:6
  • +
  • Defined in interfaces/queue-options.ts:17
  • prefix?: string
    @@ -70,12 +70,12 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • +
  • Defined in interfaces/queue-options.ts:69
  • sharedConnection?: boolean
    @@ -84,7 +84,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • skipVersionCheck?: boolean
    @@ -96,7 +96,7 @@

    Default Value

    false
    +
  • Defined in interfaces/queue-options.ts:38
  • Returns void

    +
  • Defined in interfaces/sandboxed-job.ts:12
  • moveToDelayed: ((timestamp, token?) => Promise<void>)
    @@ -131,71 +131,71 @@
    timestamp: Optional token: string
    Optional

    Returns Promise<void>

    +
  • Defined in interfaces/sandboxed-job.ts:11
  • name: string
    +
  • Defined in interfaces/job-json.ts:6
  • +
  • Defined in interfaces/sandboxed-job.ts:10
  • parent?: ParentKeys
    +
  • Defined in interfaces/job-json.ts:17
  • parentKey?: string
    +
  • Defined in interfaces/job-json.ts:18
  • processedOn?: number
    +
  • Defined in interfaces/job-json.ts:12
  • progress: number | object
    +
  • Defined in interfaces/job-json.ts:9
  • repeatJobKey?: string
    +
  • Defined in interfaces/job-json.ts:19
  • returnValue: R
    +
  • Defined in interfaces/sandboxed-job.ts:15
  • returnvalue: string
    +
  • Defined in interfaces/job-json.ts:16
  • stacktrace: string
    +
  • Defined in interfaces/job-json.ts:15
  • timestamp: number
    +
  • Defined in interfaces/job-json.ts:13
  • updateData: ((data) => Promise<void>)
    @@ -213,7 +213,7 @@

    Parameters

    data: any

    Returns Promise<void>

    +
  • Defined in interfaces/sandboxed-job.ts:13
  • updateProgress: ((value) => Promise<void>)
    @@ -231,7 +231,7 @@

    Parameters

    value: number | object

    Returns Promise<void>

    +
  • Defined in interfaces/sandboxed-job.ts:14
  • +
  • Defined in commands/script-loader.ts:30
  • numberOfKeys?: number
    +
  • Defined in commands/script-loader.ts:32
  • path: string
    @@ -79,7 +79,7 @@
    +
  • Defined in commands/script-loader.ts:37
  • token: string
    @@ -87,7 +87,7 @@
    +
  • Defined in commands/script-loader.ts:45
  • +
  • Defined in classes/worker.ts:59
  • closing: ((msg) => void)
    @@ -118,7 +118,7 @@
    msg: Returns void
    +
  • Defined in classes/worker.ts:66
  • completed: ((job, result, prev) => void)
    @@ -144,7 +144,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:73
  • drained: (() => void)
    @@ -163,7 +163,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:86
  • error: ((failedReason) => void)
    @@ -185,7 +185,7 @@
    failedReason: Returns void
    +
  • Defined in classes/worker.ts:93
  • failed: ((job, error, prev) => void)
    @@ -213,7 +213,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:102
  • ioredis:close: (() => void)
    @@ -231,7 +231,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: (() => void)
    @@ -248,7 +248,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:113
  • progress: ((job, progress) => void)
    @@ -275,7 +275,7 @@
    progress: Returns void
    +
  • Defined in classes/worker.ts:123
  • ready: (() => void)
    @@ -292,7 +292,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:133
  • resumed: (() => void)
    @@ -309,7 +309,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:140
  • stalled: ((jobId, prev) => void)
    @@ -334,7 +334,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:148
  • +
  • Defined in interfaces/queue-options.ts:27
  • concurrency?: number
    @@ -92,7 +92,7 @@

    Default

    1
     

    See

    https://docs.bullmq.io/guide/workers/concurrency

    +
  • Defined in interfaces/worker-options.ts:31
  • connection?: ConnectionOptions
    @@ -101,7 +101,7 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • drainDelay?: number
    @@ -112,7 +112,7 @@

    Default

    5
     
    +
  • Defined in interfaces/worker-options.ts:99
  • @@ -122,7 +122,7 @@

    https://docs.bullmq.io/guide/rate-limiting

    +
  • Defined in interfaces/worker-options.ts:37
  • lockDuration?: number
    @@ -136,7 +136,7 @@

    Default

    30000
     
    +
  • Defined in interfaces/worker-options.ts:110
  • lockRenewTime?: number
    @@ -146,7 +146,7 @@
    +
  • Defined in interfaces/worker-options.ts:118
  • maxStalledCount?: number
    @@ -159,7 +159,7 @@

    Default

    1
     
    +
  • Defined in interfaces/worker-options.ts:52
  • metrics?: MetricsOptions
    @@ -169,7 +169,7 @@

    https://docs.bullmq.io/guide/metrics

    +
  • Defined in interfaces/worker-options.ts:43
  • prefix?: string
    @@ -178,7 +178,7 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • removeOnComplete?: KeepJobs
    @@ -188,7 +188,7 @@
    +
  • Defined in interfaces/worker-options.ts:66
  • removeOnFail?: KeepJobs
    @@ -198,7 +198,7 @@
    +
  • Defined in interfaces/worker-options.ts:73
  • runRetryDelay?: number
    @@ -209,7 +209,7 @@

    Default

    15000
     
    +
  • Defined in interfaces/worker-options.ts:125
  • settings?: AdvancedOptions
    @@ -217,7 +217,7 @@
    +
  • Defined in interfaces/worker-options.ts:130
  • sharedConnection?: boolean
    @@ -226,7 +226,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • skipLockRenewal?: boolean
    @@ -239,7 +239,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:91
  • skipStalledCheck?: boolean
    @@ -252,7 +252,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:82
  • skipVersionCheck?: boolean
    @@ -264,7 +264,7 @@

    Default Value

    false
    +
  • Defined in interfaces/queue-options.ts:38
  • stalledInterval?: number
    @@ -275,7 +275,7 @@

    Default

    30000
     
    +
  • Defined in interfaces/worker-options.ts:59
  • useWorkerThreads?: boolean
    @@ -288,7 +288,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:139
  • +
  • Defined in types/backoff-strategy.ts:3
  • +
  • Defined in interfaces/minimal-job.ts:5
  • +
  • Defined in interfaces/redis-options.ts:9
  • +
  • Defined in interfaces/redis-options.ts:11
  • +
  • Defined in interfaces/redis-streams.ts:6
  • +
  • Defined in interfaces/redis-streams.ts:7
  • +
  • Defined in types/finished-status.ts:3
  • +
  • Defined in types/finished-status.ts:1
  • +
  • Defined in interfaces/flow-job.ts:13
  • +
  • Defined in interfaces/flow-job.ts:15
  • +
  • Defined in interfaces/flow-job.ts:17
  • +
  • Defined in classes/scripts.ts:38
  • +
  • Defined in types/job-json-sandbox.ts:3
  • +
  • Defined in types/job-type.ts:3
  • +
  • Defined in types/job-type.ts:11
  • +
  • Defined in types/job-options.ts:3
  • +
  • Defined in classes/queue-keys.ts:1
  • +
  • Defined in types/minimal-queue.ts:3
  • +
  • Defined in interfaces/parent.ts:18
  • +
  • Defined in interfaces/worker-options.ts:11
  • +
  • Defined in interfaces/connection.ts:4
  • +
  • Defined in types/job-options.ts:18
  • +
  • Defined in interfaces/redis-options.ts:7
  • +
  • Defined in types/repeat-strategy.ts:3
  • +
  • Defined in interfaces/sandboxed-job-processor.ts:6
  • +
  • Defined in interfaces/redis-streams.ts:5
  • +
  • Defined in interfaces/redis-streams.ts:8
  • +
  • Defined in utils.ts:126
  • +
  • Defined in utils.ts:124
  • +
  • Defined in classes/job.ts:48
  • +
  • Defined in utils.ts:199
  • +
  • Defined in utils.ts:197
  • +
  • Defined in utils.ts:121
  • +
  • Defined in utils.ts:12
  • +
  • Defined in commands/index.ts:4