Class BullAnalyzeQueue

Bull analyze queue implementation

Hierarchy (View Summary)

BullBaseQueue
- BullAnalyzeQueue

Implements

AnalyzeQueue

Constructors

constructor

new BullAnalyzeQueue(
    config: Config<BullProduceConfig>,
    logger: Logger,
    connector: ProduceConnector,
): BullAnalyzeQueue
Parameters
- config: Config<BullProduceConfig>
- logger: Logger
- connector: ProduceConnector
Returns BullAnalyzeQueue
Overrides BullBaseQueue.constructor
- Defined in packages/produce/src/modules/analyze/bull-analyze.queue.ts:26

Methods

addJob

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

close

close(): Promise<void>
Close queue

Returns Promise<void>
Implementation of AnalyzeQueue.close
Inherited from BullBaseQueue.close
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:47

getJobCount

getJobCount(): Promise<number>
Get job cound

Returns Promise<number>
Implementation of AnalyzeQueue.getJobCount
Inherited from BullBaseQueue.getJobCount
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:53

getJobCounts

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

Returns Promise<Record<string, number>>
Implementation of AnalyzeQueue.getJobCounts
Inherited from BullBaseQueue.getJobCounts
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:61

`Static`register

register(container: DIContainer): void
Register dependency
Parameters
- container: DIContainer
Returns void
- Defined in packages/produce/src/modules/analyze/bull-analyze.queue.ts:18