Class QueueGetters<DataType, ResultType, NameType>

QueueGetters

Description

Provides different getters for different aspects of a queue.

Type Parameters

DataType
ResultType
NameType extends string

Hierarchy (View Summary)

QueueBase
- QueueGetters
  - Queue

Constructors

constructor

new QueueGetters<DataType, ResultType, NameType extends string>(
    name: string,
    opts?: QueueBaseOptions,
    Connection?: typeof RedisConnection,
): QueueGetters<DataType, ResultType, NameType>
Type Parameters
- DataType
- ResultType
- NameType extends string
Parameters
- name: string
  The name of the queue.
- opts: QueueBaseOptions = {}
  Options for the queue.
- Connection: typeof RedisConnection = RedisConnection
  An optional "Connection" class used to instantiate a Connection. This is useful for testing with mockups and/or extending the Connection class and passing an alternate implementation.
Returns QueueGetters<DataType, ResultType, NameType>
Inherited from QueueBase.constructor
- Defined in classes/queue-base.ts:32

Properties

closing

closing: Promise<void>

keys

keys: KeysMap

`Readonly`name

name: string

The name of the queue.

opts

opts: QueueBaseOptions = {}

Options for the queue.

toKey

toKey: (type: string) => string

Accessors

client

get client(): Promise<RedisClient>
Returns a promise that resolves to a redis client. Normally used only by subclasses.

Returns Promise<RedisClient>
Inherited from QueueBase.client
- Defined in classes/queue-base.ts:76

redisVersion

get redisVersion(): string
Returns the version of the Redis instance the client is connected to,

Returns string
Inherited from QueueBase.redisVersion
- Defined in classes/queue-base.ts:83

Methods

close

close(): Promise<void>
Returns Promise<void>
Closes the connection and returns a promise that resolves when the connection is closed.
Inherited from QueueBase.close
- Defined in classes/queue-base.ts:131

count

count(): Promise<number>
Returns the number of jobs waiting to be processed. This includes jobs that are "waiting" or "delayed".

Returns Promise<number>
- Defined in classes/queue-getters.ts:94

disconnect

disconnect(): Promise<void>
Force disconnects a connection.

Returns Promise<void>
Inherited from QueueBase.disconnect
- Defined in classes/queue-base.ts:142

emit

emit(event: string | symbol, ...args: any[]): boolean
Emits an event. Normally used by subclasses to emit events.
Parameters
- event: string | symbol
  The emitted event.
- ...args: any[]
Returns boolean
Inherited from QueueBase.emit
- Defined in classes/queue-base.ts:101

getActive

getActive(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:249

getActiveCount

getActiveCount(): Promise<number>
Returns the number of jobs in active status.

Returns Promise<number>
- Defined in classes/queue-getters.ts:201

getCompleted

getCompleted(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:273

getCompletedCount

getCompletedCount(): Promise<number>
Returns the number of jobs in completed status.

Returns Promise<number>
- Defined in classes/queue-getters.ts:180

getDelayed

getDelayed(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:261

getDelayedCount

getDelayedCount(): Promise<number>
Returns the number of jobs in delayed status.

Returns Promise<number>
- Defined in classes/queue-getters.ts:194

getFailed

getFailed(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:285

getFailedCount

getFailedCount(): Promise<number>
Returns the number of jobs in failed status.

Returns Promise<number>
- Defined in classes/queue-getters.ts:187

getJob

getJob(jobId: string): Promise<Job<DataType, ResultType, NameType>>
Parameters
- jobId: string
Returns Promise<Job<DataType, ResultType, NameType>>
- Defined in classes/queue-getters.ts:27

getJobCountByTypes

getJobCountByTypes(...types: JobType[]): Promise<number>
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
- ...types: JobType[]
Returns Promise<number>
- Defined in classes/queue-getters.ts:134

getJobCounts

getJobCounts(...types: JobType[]): Promise<{ [index: string]: number }>
Returns the job counts for each type specified or every list/set in the queue by default.
Parameters
- ...types: JobType[]
Returns Promise<{ [index: string]: number }>
An object, key (type) and value (count)
- Defined in classes/queue-getters.ts:144

getJobLogs

getJobLogs(
    jobId: string,
    start?: number,
    end?: number,
    asc?: boolean,
): Promise<{ count: number; logs: string[] }>
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
  zeroo 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[] }>
- Defined in classes/queue-getters.ts:373

getJobs

getJobs(
    types?: JobType | JobType[],
    start?: number,
    end?: number,
    asc?: boolean,
): Promise<Job<DataType, ResultType, NameType>[]>
Returns the jobs that are on the given statuses (note that JobType is synonym for job status)
Parameters
- Optionaltypes: JobType | JobType[]
  the statuses of the jobs to return.
- start: number = 0
  zero based index from where to start returning jobs.
- end: number = -1
  zeroo 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>[]>
- Defined in classes/queue-getters.ts:346

getMetrics

getMetrics(
    type: "completed" | "failed",
    start?: number,
    end?: number,
): Promise<Metrics>
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: "completed" | "failed"
- 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.
- Defined in classes/queue-getters.ts:470

getQueueEvents

getQueueEvents(): Promise<{ [index: string]: string }[]>
Get queue events list related to the queue.

Returns Promise<{ [index: string]: string }[]>
- Returns an array with queue events info.
- Defined in classes/queue-getters.ts:448

getQueueSchedulers

getQueueSchedulers(): Promise<{ [index: string]: string }[]>
Get queue schedulers list related to the queue.

Returns Promise<{ [index: string]: string }[]>
- Returns an array with queue schedulers info.
- Defined in classes/queue-getters.ts:435

getRanges

getRanges(
    types: JobType[],
    start?: number,
    end?: number,
    asc?: boolean,
): Promise<string[]>
Parameters
- types: JobType[]
- start: number = 0
- end: number = 1
- asc: boolean = false
Returns Promise<string[]>
- Defined in classes/queue-getters.ts:292

getWaiting

getWaiting(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:225

getWaitingChildren

getWaitingChildren(
start?: number,
end?: number,
): Promise<Job<DataType, ResultType, NameType>[]>
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
  zeroo based index where to stop returning jobs.
Returns Promise<Job<DataType, ResultType, NameType>[]>
- Defined in classes/queue-getters.ts:237

getWaitingChildrenCount

getWaitingChildrenCount(): Promise<number>
Returns the number of jobs in waiting-children status.

Returns Promise<number>
- Defined in classes/queue-getters.ts:215

getWaitingCount

getWaitingCount(): Promise<number>
Returns the number of jobs in waiting or paused statuses.

Returns Promise<number>
- Defined in classes/queue-getters.ts:208

getWorkers

getWorkers(): Promise<{ [index: string]: string }[]>
Get the worker list related to the queue. i.e. all the known workers that are available to process jobs for this queue.

Returns Promise<{ [index: string]: string }[]>
- Returns an array with workers info.
- Defined in classes/queue-getters.ts:422

waitUntilReady

waitUntilReady(): Promise<RedisClient>
Returns Promise<RedisClient>
Inherited from QueueBase.waitUntilReady
- Defined in classes/queue-base.ts:114

Class QueueGetters<DataType, ResultType, NameType>

Description

Type Parameters

Hierarchy (View Summary)

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

Parameters

Returns QueueGetters<DataType, ResultType, NameType>

Properties

closing

keys

Readonlyname

opts

toKey

Accessors

client

Returns Promise<RedisClient>

redisVersion

Returns string

Methods

close

Returns Promise<void>

count

Returns Promise<number>

disconnect

Returns Promise<void>

emit

Parameters

Returns boolean

getActive

Parameters

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

getActiveCount

Returns Promise<number>

getCompleted

Parameters

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

getCompletedCount

Returns Promise<number>

getDelayed

Parameters

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

getDelayedCount

Returns Promise<number>

getFailed

Parameters

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

getFailedCount

Returns Promise<number>

getJob

Parameters

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

getJobCountByTypes

Parameters

Returns Promise<number>

getJobCounts

Parameters

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

getJobLogs

Parameters

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

getJobs

Parameters

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

getMetrics

Parameters

Returns Promise<Metrics>

getQueueEvents

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

getQueueSchedulers

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

getRanges

Parameters

Returns Promise<string[]>

`Readonly`name