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, any, string>>

  Parameters

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

  Returns Promise<Job<T, any, string>>

getRepeatableJobs

• getRepeatableJobs(): Promise<RepeatableJob[]>

  Returns Promise<RepeatableJob[]>

removeRepeatableByKey

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

  Parameters

  • id: string

  Returns Promise<boolean>