From f77a41a75237b8c816e0c9ca7217dfacc32cc7d0 Mon Sep 17 00:00:00 2001
From: MohamedBassem <me@mbassem.com>
Date: Sun, 14 Jul 2024 20:42:06 +0000
Subject: chore: Add a new sqlite based queue package

---
 packages/queue/options.ts | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)
 create mode 100644 packages/queue/options.ts

(limited to 'packages/queue/options.ts')

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>;
+}
-- 
cgit v1.2.3-70-g09d2