Interface AnalyzeQueue

Represents an analyze queue

interface AnalyzeQueue {
    addJob(name: string, data: AnalyzeJobData): Promise<void>;
    close(): Promise<void>;
    getJobCount(): Promise<number>;
    getJobCounts(): Promise<Record<string, number>>;
}

Implemented by

BullAnalyzeQueue

Methods

addJob

addJob(name: string, data: AnalyzeJobData): Promise<void>
Add job to queue
Parameters
- name: string
- data: AnalyzeJobData
Returns Promise<void>
- Defined in packages/produce/src/modules/analyze/analyze.ts:39

close

close(): Promise<void>
Close queue

Returns Promise<void>
- Defined in packages/produce/src/modules/analyze/analyze.ts:24

getJobCount

getJobCount(): Promise<number>
Get job cound

Returns Promise<number>
- Defined in packages/produce/src/modules/analyze/analyze.ts:29

getJobCounts

getJobCounts(): Promise<Record<string, number>>
Get job counts

Returns Promise<Record<string, number>>
- Defined in packages/produce/src/modules/analyze/analyze.ts:34