@gomani/jobs

createJobRunner gives enqueue/drain/work with retry + backoff → dead-letter, idempotency dedupe, and delayed jobs. cronMatches + createCronScheduler ride the same retry pipeline. The same app code runs single / multi / split topology — where it runs is config, not code.

API

createJobRunner

function

createJobRunner(config: JobRunnerConfig): JobRunner

A durable runner: enqueue/runNext/drain/work with retry, dead-letter, idempotency, and delayed jobs.

runWorker

function

runWorker(app: WorkerApp, options: { signal: AbortSignal }): Promise<void>

Run a standalone worker: a drain loop plus the cron scheduler.