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 full)

QueueBase
- QueueGetters
  - Queue

Constructors

constructor

new QueueGetters<DataType, ResultType, NameType>(name, opts?, Connection?): 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:40

Properties

closing

closing: Promise<void>

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

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:80

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:91

Methods

close

close(): Promise<void>
Closes the connection and returns a promise that resolves when the connection is closed.

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

count

count(): Promise<number>
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>
- Defined in classes/queue-getters.ts:92

disconnect

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

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

emit

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

getActive

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

getActiveCount

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

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

getCompleted

getCompleted(start?, end?): 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
  zero 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:161

getDelayed

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

getDelayedCount

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

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

getDependencies

getDependencies(parentId, type, start, end): Promise<{
    items: {
        err?: string;
        id: string;
        v?: any;
    }[];
    jobs: JobJsonRaw[];
    total: number;
}>
Returns the qualified job ids and the raw job data (if available) of the children jobs of the given parent job. It is possible to get either the already processed children, in this case an array of qualified job ids and their result values will be returned, or the pending children, in this case an array of qualified job ids will be returned. A qualified job id is a string representing the job id in a given queue, for example: "bull:myqueue:jobid".
Parameters
- parentId: string
  The id of the parent job
- type: "pending" | "processed"
  "processed" | "pending"
- start: number
- end: number
Returns Promise<{
    items: {
        err?: string;
        id: string;
        v?: any;
    }[];
    jobs: JobJsonRaw[];
    total: number;
}>
- Defined in classes/queue-getters.ts:308

getFailed

getFailed(start?, end?): 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
  zero 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:168

getJob

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

getJobCountByTypes

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

getJobCounts

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

getJobLogs

getJobLogs(jobId, start?, end?, asc?): 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
  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[];
}>
- Defined in classes/queue-getters.ts:405

getJobState

getJobState(jobId): Promise<"unknown" | JobState>
Get current job state.
Parameters
- jobId: string
Returns Promise<"unknown" | JobState>
Returns one of these values: 'completed', 'failed', 'delayed', 'active', 'waiting', 'waiting-children', 'unknown'.
- Defined in classes/queue-getters.ts:154

getJobs

getJobs(types?, start?, end?, asc?): Promise<Job<DataType, ResultType, NameType>[]>
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.
- 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>[]>
- Defined in classes/queue-getters.ts:378

getMetrics

getMetrics(type, start?, end?): 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: "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.
- Defined in classes/queue-getters.ts:515

getPrioritized

getPrioritized(start?, end?): Promise<Job<DataType, ResultType, NameType>[]>
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>[]>
- Defined in classes/queue-getters.ts:261

getPrioritizedCount

getPrioritizedCount(): Promise<number>
Returns the number of jobs in prioritized status.

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

getQueueEvents

getQueueEvents(): Promise<{
[index: string]: string;
}[]>
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.
Deprecated
do not use this method, it will be removed in the future.
- Defined in classes/queue-getters.ts:492

getRanges

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

getRateLimitTtl

getRateLimitTtl(): Promise<number>
Returns the time to live for a rate limited key in milliseconds.

Returns Promise<number>
-2 if the key does not exist. -1 if the key exists but has no associated expire.

See
https://redis.io/commands/pttl/
- Defined in classes/queue-getters.ts:110

getWaiting

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

getWaitingChildren

getWaitingChildren(start?, end?): Promise<Job<DataType, ResultType, NameType>[]>
Returns the jobs that are in the "waiting-children" status. I.E. parent jobs that have at least one child that has not completed yet.
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>[]>
- Defined in classes/queue-getters.ts:225

getWaitingChildrenCount

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

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

getWaitingCount

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

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

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. Note: GCP does not support SETNAME, so this call will not work

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

getWorkersCount

getWorkersCount(): Promise<number>
Returns the current count of workers for the queue.

getWorkersCount(): Promise

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

waitUntilReady

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

Class QueueGetters<DataType, ResultType, NameType>

Description

Type Parameters

Hierarchy (view full)

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

Parameters

Returns QueueGetters<DataType, ResultType, NameType>

Properties

closing

keys

Readonly name

opts

Readonly qualifiedName

toKey

Type declaration

Parameters

Returns string

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>

getDependencies

Parameters

Returns Promise<{ items: { err?: string; id: string; v?: any; }[]; jobs: JobJsonRaw[]; total: 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[]; }>

getJobState

Parameters

Returns Promise<"unknown" | JobState>

getJobs

Parameters

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

`Readonly` name

`Readonly` qualifiedName

Returns Promise<{
items: {
err?: string;
id: string;
v?: any;
}[];
jobs: JobJsonRaw[];
total: number;
}>

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

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

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

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