Class WorkerPro<DataType, ResultType, NameType>

constructor

• new WorkerPro<
      DataType = any,
      ResultType = any,
      NameType extends string = string,
  >(
      name: string,
      processor?: string | ProcessorPro<DataType, ResultType, NameType>,
      opts?: WorkerProOptions,
  ): WorkerPro<DataType, ResultType, NameType>

  Type Parameters

  • DataType = any
  • ResultType = any
  • NameType extends string = string

  Parameters

  • name: string
  • Optionalprocessor: string | ProcessorPro<DataType, ResultType, NameType>
  • Optionalopts: WorkerProOptions

  Returns WorkerPro<DataType, ResultType, NameType>

opts

StaticRateLimitError

rateLimitGroup

• rateLimitGroup(job: JobPro, expireTimeMs: number): 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>