Class Queue<DataType, ResultType, NameType>

Queue

This class provides methods to add jobs to a queue and some othe high-level administration such as pausing or deleting queues.

Type Parameters

  • DataType = any

  • ResultType = any

  • NameType extends string = string

Hierarchy

Constructors

constructor

Properties

closing jobsOpts keys name opts qualifiedName toKey token

Accessors

client defaultJobOptions redisVersion repeat

Methods

add addBulk clean close count disconnect drain emit getActive getActiveCount getCompleted getCompletedCount getDelayed getDelayedCount getFailed getFailedCount getJob getJobCountByTypes getJobCounts getJobLogs getJobState getJobs getMetrics getPrioritized getPrioritizedCount getQueueEvents getRanges getRateLimitTtl getRepeatableJobs getWaiting getWaitingChildren getWaitingChildrenCount getWaitingCount getWorkers isPaused obliterate off on once pause promoteJobs remove removeDeprecatedPriorityKey removeRepeatable removeRepeatableByKey resume retryJobs trimEvents waitUntilReady

Constructors

constructor

  • Type Parameters

    • DataType = any

    • ResultType = any

    • NameType extends string = string

    Parameters

    Returns Queue<DataType, ResultType, NameType>

Properties

closing

closing: Promise<void>

jobsOpts

jobsOpts: BaseJobOptions

keys

keys: KeysMap

Readonly name

name: string

The name of the queue.

opts

opts: QueueBaseOptions = {}

Options for the queue.

Readonly qualifiedName

qualifiedName: string

toKey

toKey: ((type) => string)

Type declaration

    • (type): string

    • Parameters

      • type: string

      Returns string

token

token: string = ...

Accessors

client

defaultJobOptions

redisVersion

  • get redisVersion(): string

  • Returns the version of the Redis instance the client is connected to,

    Returns string

repeat

Methods

add

  • Adds a new job to the queue.

    Parameters

    • name: NameType

      Name of the job to be added to the queue,.

    • data: DataType

      Arbitrary data to append to the job.

    • Optional opts: JobsOptions

      Job options that affects how the job is going to be processed.

      Optional

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

addBulk

  • Adds an array of jobs to the queue. This method may be faster than adding one job at a time in a sequence.

    Parameters

    • jobs: {
          data: DataType;
          name: NameType;
          opts?: BulkJobOptions;
      }[]

      The array of jobs to add to the queue. Each job is defined by 3 properties, 'name', 'data' and 'opts'. They follow the same signature as 'Queue.add'.

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

clean

  • Cleans jobs from a queue. Similar to drain but keeps jobs within a certain grace period.

    Parameters

    • grace: number

      The grace period

    • limit: number

      Max number of jobs to clean

    • type: "failed" | "active" | "paused" | "completed" | "wait" | "prioritized" | "delayed" = 'completed'

      The type of job to clean Possible values are completed, wait, active, paused, delayed, failed. Defaults to completed.

    Returns Promise<string[]>

    Id jobs from the deleted records

close

count

  • Returns the number of jobs waiting to be processed. This includes jobs that are "waiting" or "delayed" or "prioritized" or "waiting-children".

    Returns Promise<number>

disconnect

drain

  • Drains the queue, i.e., removes all jobs that are waiting or delayed, but not active, completed or failed.

    Parameters

    • delayed: boolean = false

      Pass true if it should also clean the delayed jobs.

    Returns Promise<void>

emit

  • Emits an event. Normally used by subclasses to emit events.

    Type Parameters

    Parameters

    • event: U

      The emitted event.

    • Rest ...args: Parameters<QueueListener<DataType, ResultType, NameType>[U]>
      Rest

    Returns boolean

getActive

  • Returns the jobs that are in the "active" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getActiveCount

getCompleted

  • Returns the jobs that are in the "completed" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getCompletedCount

getDelayed

  • Returns the jobs that are in the "delayed" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getDelayedCount

getFailed

  • Returns the jobs that are in the "failed" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getFailedCount

getJob

getJobCountByTypes

  • Job counts by type

    Queue#getJobCountByTypes('completed') => completed count Queue#getJobCountByTypes('completed,failed') => completed + failed count Queue#getJobCountByTypes('completed', 'failed') => completed + failed count Queue#getJobCountByTypes('completed', 'waiting', 'failed') => completed + waiting + failed count

    Parameters

    Returns Promise<number>

getJobCounts

  • Returns the job counts for each type specified or every list/set in the queue by default.

    Parameters

    Returns Promise<{
        [index: string]: number;
    }>

    An object, key (type) and value (count)

getJobLogs

  • Returns the logs for a given Job.

    Parameters

    • jobId: string

      the id of the job to get the logs for.

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

    • asc: boolean = true

      if true, the jobs will be returned in ascending order.

    Returns Promise<{
        count: number;
        logs: string[];
    }>

getJobState

getJobs

  • Returns the jobs that are on the given statuses (note that JobType is synonym for job status)

    Parameters

    • Optional types: JobType | JobType[]

      the statuses of the jobs to return.

      Optional
    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

    • asc: boolean = false

      if true, the jobs will be returned in ascending order.

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

getMetrics

  • Get queue metrics related to the queue.

    This method returns the gathered metrics for the queue. The metrics are represented as an array of job counts per unit of time (1 minute).

    Parameters

    • type: "failed" | "completed"
    • start: number = 0

      Start point of the metrics, where 0 is the newest point to be returned.

    • end: number = -1

      End point of the metrics, where -1 is the oldest point to be returned.

    Returns Promise<Metrics>

    • Returns an object with queue metrics.

getPrioritized

  • Returns the jobs that are in the "prioritized" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getPrioritizedCount

getQueueEvents

  • Get queue events list related to the queue. Note: GCP does not support SETNAME, so this call will not work

    Returns Promise<{
        [index: string]: string;
    }[]>

    • Returns an array with queue events info.

getRanges

getRateLimitTtl

getRepeatableJobs

  • Get all repeatable meta jobs.

    Parameters

    • Optional start: number

      Offset of first job to return.

      Optional
    • Optional end: number

      Offset of last job to return.

      Optional
    • Optional asc: boolean

      Determine the order in which jobs are returned based on their next execution time.

      Optional

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

getWaiting

  • Returns the jobs that are in the "waiting" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getWaitingChildren

  • Returns the jobs that are in the "waiting" status.

    Parameters

    • start: number = 0

      zero based index from where to start returning jobs.

    • end: number = -1

      zero based index where to stop returning jobs.

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

getWaitingChildrenCount

getWaitingCount

getWorkers

  • Get the worker list related to the queue. i.e. all the known workers that are available to process jobs for this queue. Note: GCP does not support SETNAME, so this call will not work

    Returns Promise<{
        [index: string]: string;
    }[]>

    • Returns an array with workers info.

isPaused

  • Returns true if the queue is currently paused.

    Returns Promise<boolean>

obliterate

  • Completely destroys the queue and all of its contents irreversibly. This method will the pause the queue and requires that there are no active jobs. It is possible to bypass this requirement, i.e. not having active jobs using the "force" option.

    Note: This operation requires to iterate on all the jobs stored in the queue and can be slow for very large queues.

    Parameters

    Returns Promise<void>

off

  • Type Parameters

    Parameters

    • eventName: U
    • listener: QueueListener<DataType, ResultType, NameType>[U]

    Returns Queue<DataType, ResultType, NameType>

on

  • Type Parameters

    Parameters

    • event: U
    • listener: QueueListener<DataType, ResultType, NameType>[U]

    Returns Queue<DataType, ResultType, NameType>

once

  • Type Parameters

    Parameters

    • event: U
    • listener: QueueListener<DataType, ResultType, NameType>[U]

    Returns Queue<DataType, ResultType, NameType>

pause

  • Pauses the processing of this queue globally.

    We use an atomic RENAME operation on the wait queue. Since we have blocking calls with BRPOPLPUSH on the wait queue, as long as the queue is renamed to 'paused', no new jobs will be processed (the current ones will run until finalized).

    Adding jobs requires a LUA script to check first if the paused list exist and in that case it will add it there instead of the wait list.

    Returns Promise<void>

promoteJobs

  • Promote all the delayed jobs.

    Parameters

    • opts: {
          count?: number;
      } = {}
      • Optional count?: number

    Returns Promise<void>

remove

  • Removes the given job from the queue as well as all its dependencies.

    Parameters

    • jobId: string

      The id of the job to remove

    • opts: {
          removeChildren: boolean;
      } = {}

      Options to remove a job

      • removeChildren: boolean

    Returns Promise<number>

    1 if it managed to remove the job or 0 if the job or any of its dependencies were locked.

removeDeprecatedPriorityKey

  • Delete old priority helper key.

    Returns Promise<number>

removeRepeatable

  • Removes a repeatable job.

    Note: you need to use the exact same repeatOpts when deleting a repeatable job than when adding it.

    Parameters

    • name: NameType
    • repeatOpts: RepeatOptions
    • Optional jobId: string
      Optional

    Returns Promise<boolean>

    See

    removeRepeatableByKey

removeRepeatableByKey

  • Removes a repeatable job by its key. Note that the key is the one used to store the repeatable job metadata and not one of the job iterations themselves. You can use "getRepeatableJobs" in order to get the keys.

    Parameters

    • key: string

      to the repeatable job.

    Returns Promise<boolean>

    See

    getRepeatableJobs

resume

  • Resumes the processing of this queue globally.

    The method reverses the pause operation by resuming the processing of the queue.

    Returns Promise<void>

retryJobs

  • Retry all the failed jobs.

    Parameters

    • opts: {
          count?: number;
          state?: FinishedStatus;
          timestamp?: number;
      } = {}
      • Optional count?: number
      • Optional state?: FinishedStatus
      • Optional timestamp?: number

    Returns Promise<void>

trimEvents

  • Trim the event stream to an approximately maxLength.

    Parameters

    • maxLength: number

    Returns Promise<number>

waitUntilReady

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc