Class WorkerManager

constructor

• new WorkerManager(options: WorkerManagerOptions): WorkerManager

  Parameters

  • options: WorkerManagerOptions

  Returns WorkerManager

name

enqueue

• enqueue<T = unknown, R = unknown>(
      name: string,
      data: T,
      opts?: JobOptions,
  ): Promise<JobDescriptor<T, R>>

  Encola un job para ser procesado. Devuelve un descriptor que, además de los datos del job, expone result() para esperar el valor de retorno del handler.

  Type Parameters

  • T = unknown
  • R = unknown

  Parameters

  • name: string
  • data: T
  • Optionalopts: JobOptions

  Returns Promise<JobDescriptor<T, R>>

init

• init(app: App): Promise<void>

  Parameters

  • app: App

  Returns Promise<void>

register

• register<T = unknown, R = void>(
      jobName: string,
      handler: JobHandler<T, R>,
  ): WorkerManager

  Registra un handler para un tipo de job. El handler puede devolver un valor R que queda disponible como resultado del job.

  Type Parameters

  • T = unknown
  • R = void

  Parameters

  • jobName: string
  • handler: JobHandler<T, R>

  Returns WorkerManager

schedule

• schedule<T = unknown, R = unknown>(
      name: string,
      data: T,
      repeat: RepeatSpec,
      opts?: JobOptions,
  ): Promise<JobDescriptor<T, R>>

  Programa un job repetible (cron o intervalo). Conveniencia sobre enqueue con la opción repeat ya configurada.

  Type Parameters

  • T = unknown
  • R = unknown

  Parameters

  • name: string
  • data: T
  • repeat: RepeatSpec

    patrón cron (string) o { every: ms }/{ pattern: cron }.

  • Optionalopts: JobOptions

  Returns Promise<JobDescriptor<T, R>>

start

• start(): Promise<void>

  Returns Promise<void>

stop

• stop(): Promise<void>

  Returns Promise<void>