import { Job } from '../classes'; import { AdvancedOptions, QueueBaseOptions, RateLimiterOptions } from './'; /** * An async function that receives `Job`s and handles them. */ export declare type Processor = (job: Job, token?: string) => Promise; export interface WorkerOptions extends QueueBaseOptions { /** * Amount of jobs that a single worker is allowed to work on * in parallel. * * @see {@link https://docs.bullmq.io/guide/workers/concurrency} */ concurrency?: number; /** * @see {@link https://docs.bullmq.io/guide/rate-limiting} */ limiter?: RateLimiterOptions; skipDelayCheck?: boolean; drainDelay?: number; lockDuration?: number; lockRenewTime?: number; runRetryDelay?: number; settings?: AdvancedOptions; } export interface GetNextJobOptions { block?: boolean; }