Class Queue<DataType, ReturnType, NameType>

Type Parameters

DataType = any
ReturnType = any
NameType extends string = string

Hierarchy

Queue<DataType, ReturnType, NameType>
- Queue

Index

Constructors

Methods

add addBulk deleteGroup deleteGroups getGroupJobs getGroupJobsCount getGroupStatus getGroups getGroupsByStatus getGroupsCount getGroupsCountByStatus getGroupsJobsCount getVersion obliterate pauseGroup repairMaxedGroup resumeGroup

Constructors

constructor

new Queue<DataType, ReturnType, NameType>(name: string, opts?: QueueProOptions): Queue<DataType, ReturnType, NameType>
Type Parameters
- DataType = any
- ReturnType = any
- NameType extends string = string
Parameters
- name: string
- Optional opts: QueueProOptions
Returns Queue<DataType, ReturnType, NameType>
Overrides Queue<DataType, ReturnType, NameType>.constructor
- Defined in src/classes/queue-pro.ts:17

Methods

add

add(name: NameType, data: DataType, opts?: JobsProOptions): Promise<Job<DataType, ReturnType, NameType>>
Adds a Job to the queue.
Parameters
- name: NameType
- data: DataType
- Optional opts: JobsProOptions
Returns Promise<Job<DataType, ReturnType, NameType>>
Overrides Queue.add
- Defined in src/classes/queue-pro.ts:50

addBulk

addBulk(jobs: {
    data: DataType;
    name: NameType;
    opts?: BulkJobProOptions;
}[]): Promise<Job<DataType, ReturnType, NameType>[]>
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?: BulkJobProOptions;
  }[]
  
  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, ReturnType, NameType>[]>
Overrides Queue.addBulk
- Defined in src/classes/queue-pro.ts:63

deleteGroup

deleteGroup(groupId: string | number): Promise<void>
Cleans all the jobs that are part of a group.
Parameters
- groupId: string | number
Returns Promise<void>
- Defined in src/classes/queue-pro.ts:308

deleteGroups

deleteGroups(): Promise<void>
Cleans all the groups in this queue

Returns Promise<void>
- Defined in src/classes/queue-pro.ts:329

getGroupJobs

getGroupJobs(groupId: string | number, start?: number, end?: number): Promise<Job<DataType, ReturnType, NameType>[]>
Get jobs that are part of a given group.
Parameters
- groupId: string | number
- start: number = 0
- end: number = -1
Returns Promise<Job<DataType, ReturnType, NameType>[]>
- Defined in src/classes/queue-pro.ts:263

getGroupJobsCount

getGroupJobsCount(groupId: string | number): Promise<number>
Gets the count of jobs inside a given group id.
Parameters
- groupId: string | number
Returns Promise<number>
- Defined in src/classes/queue-pro.ts:291

getGroupStatus

getGroupStatus(groupId: string): Promise<GroupStatus>
Get the given group status.

Returns
GroupStatus - The status of the group or null if the group does not exist.
Parameters
- groupId: string
  
  The group id to get the status for.
Returns Promise<GroupStatus>
- Defined in src/classes/queue-pro.ts:231

getGroups

getGroups(start?: number, end?: number): Promise<{
id: string;
status: GroupStatus;
}[]>
Get the group ids with jobs current jobs in them.

TODO: Support group id filtering.
Parameters
- start: number = 0
- end: number = -1
Returns Promise<{
id: string;
status: GroupStatus;
}[]>
- Defined in src/classes/queue-pro.ts:80

getGroupsByStatus

getGroupsByStatus(status: GroupStatus, start?: number, end?: number): Promise<{
count: number;
id: string;
}[]>
Gets all the groups that are in a particular status.

Returns
an array of objects with the group id and status.
Parameters
- status: GroupStatus
  
  GroupStatus so we can filter by status
- start: number = 0
  
  start index, used for pagination.
- end: number = -1
  
  end index, used for pagination.
Returns Promise<{
count: number;
id: string;
}[]>
- Defined in src/classes/queue-pro.ts:125

getGroupsCount

getGroupsCount(): Promise<number>
Get the total number of groups with jobs in them.

Returns Promise<number>
- Defined in src/classes/queue-pro.ts:154

getGroupsCountByStatus

getGroupsCountByStatus(): Promise<{
    limited: number;
    maxed: number;
    paused: number;
    waiting: number;
}>
Get the total number of groups with jobs in them, in their different statuses.

Returns

Returns Promise<{
    limited: number;
    maxed: number;
    paused: number;
    waiting: number;
}>
- Defined in src/classes/queue-pro.ts:173

getGroupsJobsCount

getGroupsJobsCount(): Promise<number>
Gets the count of all the jobs belonging to any group.

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

getVersion

getVersion(): Promise<string>
Get library version.

Returns
the content of the meta.library field.

Returns Promise<string>
- Defined in src/classes/queue-pro.ts:38

obliterate

obliterate(opts?: {
count?: number;
force?: boolean;
}): Promise<void>
Parameters
- Optional opts: {
  count?: number;
  force?: boolean;
  }
  - Optional count?: number
  - Optional force?: boolean
Returns Promise<void>
Overrides Queue.obliterate
- Defined in src/classes/queue-pro.ts:343

pauseGroup

pauseGroup(groupId: string | number): Promise<boolean>
Pauses the processing of a specific group globally.

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 or group list.
Parameters
- groupId: string | number
Returns Promise<boolean>
- Defined in src/classes/queue-pro.ts:354

repairMaxedGroup

repairMaxedGroup(groupId: string): Promise<any>
Repairs a maxed group.

It seems that in some unknown situations a group can become maxed although there are no active jobs in the group. This function will try to repair this situation.
Parameters
- groupId: string
  
  the group to repair
Returns Promise<any>
- Defined in src/classes/queue-pro.ts:379

resumeGroup

resumeGroup(groupId: string | number): Promise<boolean>
Resumes the processing of a specific group globally.

The method reverses the pause operation by resuming the processing of the group.
Parameters
- groupId: string | number
  
  the group to resume
Returns Promise<boolean>
- Defined in src/classes/queue-pro.ts:366

Class Queue<DataType, ReturnType, NameType>

Type Parameters

DataType = any

ReturnType = any

NameType extends string = string

Hierarchy

Index

Constructors

Methods

Constructors

constructor

Type Parameters

DataType = any

ReturnType = any

NameType extends string = string

Parameters

name: string

Optional opts: QueueProOptions

Returns Queue<DataType, ReturnType, NameType>

Methods

add

Parameters

name: NameType

data: DataType

Optional opts: JobsProOptions

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

addBulk

Parameters

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

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

deleteGroup

Parameters

groupId: string | number

Returns Promise<void>

deleteGroups

Returns Promise<void>

getGroupJobs

Parameters

groupId: string | number

start: number = 0

end: number = -1

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

getGroupJobsCount

Parameters

groupId: string | number

Returns Promise<number>

getGroupStatus

Returns

Parameters

groupId: string

Returns Promise<GroupStatus>

getGroups

Parameters

start: number = 0

end: number = -1

Returns Promise<{ id: string; status: GroupStatus; }[]>

getGroupsByStatus

Returns

Parameters

status: GroupStatus

start: number = 0

end: number = -1

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

getGroupsCount

Returns Promise<number>

getGroupsCountByStatus

Returns

Returns Promise<{ limited: number; maxed: number; paused: number; waiting: number; }>

getGroupsJobsCount

Returns Promise<number>

getVersion

Returns

Returns Promise<string>

obliterate

Parameters

Optional opts: { count?: number; force?: boolean; }

Optional count?: number

Optional force?: boolean

Returns Promise<void>

pauseGroup

`Optional` opts: QueueProOptions

`Optional` opts: JobsProOptions

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

Returns Promise<{
id: string;
status: GroupStatus;
}[]>

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

Returns Promise<{
limited: number;
maxed: number;
paused: number;
waiting: number;
}>

`Optional` opts: {
count?: number;
force?: boolean;
}

`Optional` count?: number

`Optional` force?: boolean