Class TakaroQueue<T>

constructor

• new TakaroQueue<T extends Record<string, unknown>>(name: string): TakaroQueue<T>

• Type Parameters

  • T extends Record<string, unknown>

  Parameters

  • name: string

  Returns TakaroQueue<T>

bullQueue

name

add

• add(data: T, extra?: JobsOptions, name?: string): Promise<Job<T>>

• Parameters

  • data: T
  • extra: JobsOptions = {}
  • name: string = ...

  Returns Promise<Job<T>>

getRepeatableJobs

• getRepeatableJobs(): Promise<RepeatableJob[]>

• Returns Promise<RepeatableJob[]>

removeRepeatableByKey

• removeRepeatableByKey(id: string): Promise<boolean>

• Parameters

  • id: string

  Returns Promise<boolean>