Interface QueueOptions

Concurrency, retention, ID prefix, and lifecycle callbacks for the in-memory queue.

interface QueueOptions {
    concurrency?: number;
    keep?: number;
    onChange?: (record: JobRecord) => void;
    onDrop?: (record: JobRecord) => void;
    prefix?: string;
}

Properties

concurrency?: number

Jobs run at the same time (default: the number of CPUs).

keep?: number

Finished jobs kept for lookup (default 1000, oldest dropped first).

onChange?: (record: JobRecord) => void

Called on every change, e.g. to persist records.

onDrop?: (record: JobRecord) => void

Called when a finished job is dropped (beyond keep), e.g. to remove its files.

prefix?: string

Prefix for job ids (default 'job').