Class WorkerPro<DataType, ResultType, NameType>

constructor

• WorkerPro(name, processor?, opts?): WorkerPro<DataType, ResultType, NameType>

• Parameters

  • name: string
  • Optional processor: string | ProcessorPro<DataType, ResultType, NameType>
  • Optional opts: WorkerProOptions

  Returns WorkerPro<DataType, ResultType, NameType>

opts

Static RateLimitError

rateLimitGroup

• rateLimitGroup(job, expireTimeMs): Promise<void>

• Overrides the rate limit so that it becomes active for the given group.

  Parameters

  • job: JobPro

    Job currently being processed, and whose group we want to rate limit.
  • expireTimeMs: number

    Expire time in ms of this rate limit.

  Returns Promise<void>