Add queries for jobs, including adding dead letter queue.

migrations/20240112_01_Njk7j-create-initial-tables.sql

@@ -46,7 +46,16 @@ CREATE TABLE job (
  job_id SERIAL PRIMARY KEY,
  job_type TEXT NOT NULL,
  job_object TEXT NOT NULL,
+ attempts INTEGER NOT NULL DEFAULT 0,
  data JSON NOT NULL,
 
  UNIQUE (job_type, job_object)
 );
+
+CREATE TABLE job_dead (
+ job_id INTEGER PRIMARY KEY,
+ buried_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(),
+ job_type TEXT NOT NULL,
+ job_object TEXT NOT NULL
+ data JSON NOT NULL
+);

queries/add_dead_job.sql

@@ -0,0 +1,3 @@
+-- :name add_dead_job :insert
+INSERT INTO job_dead (job_id, job_type, job_object, data)
+ VALUES (:job_id, :job_type, :job_object, :data)

queries/add_job.sql

@@ -0,0 +1,2 @@
+-- :name add_job :insert
+INSERT INTO job (job_type, job_object, data) VALUES (:job_type, :job_object, :data)

queries/delete_job.sql

@@ -0,0 +1,2 @@
+-- :name delete_job :affected
+DELETE FROM job WHERE job_id = :job_id

queries/fail_job.sql

@@ -0,0 +1,2 @@
+-- :name fail_job :affected
+UPDATE job SET attempts = attempts + 1 WHERE job_id = :job_id

queries/get_jobs.sql

@@ -0,0 +1,3 @@
+-- :name get_job :many
+-- Select jobs randomly to avoid bias or potential loops
+SELECT * FROM job TABLESAMPLE SYSTEM (2);