chore: Add a new sqlite based queue package

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>;
+}