diff options
Diffstat (limited to 'packages/queue/options.ts')
| -rw-r--r-- | packages/queue/options.ts | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/packages/queue/options.ts b/packages/queue/options.ts new file mode 100644 index 00000000..18f8e52d --- /dev/null +++ b/packages/queue/options.ts @@ -0,0 +1,22 @@ +import { ZodType } from "zod"; + +import { DequeuedJob, DequeuedJobError } from "./types"; + +export interface SqliteQueueOptions { + defaultJobArgs: { + numRetries: number; + }; +} + +export interface RunnerFuncs<T> { + run: (job: DequeuedJob<T>) => Promise<void>; + onComplete?: (job: DequeuedJob<T>) => Promise<void>; + onError?: (job: DequeuedJobError<T>) => Promise<void>; +} + +export interface RunnerOptions<T> { + pollIntervalMs: number; + timeoutSecs: number; + concurrency: number; + validator?: ZodType<T>; +} |
