Code

feat: Support for SQLite backend#130

Code

Open

pranavmodx wants to merge 49 commits intoacaloiaro:mainacaloiaro/neoq:mainfrom pranavmodx:sqlite-backendpranavmodx/neoq-sqlite:sqlite-backendCopy head branch name to clipboard

+1,681-30

Commits

Commits on May 5, 2024

• change mod init name

  pranavmodx

  committed
  3fc305a

• sqlite backend work so far

  pranavmodx

  committed
  c3df22a

• migration works

  pranavmodx

  committed
  4375dbb

• init db

  pranavmodx

  committed
  9bff228

• enqueuing works

  pranavmodx

  committed
  a1ba274

• notification - related work

  pranavmodx

  committed
  7cfd550

• job executes but db gets locked so not commited

  pranavmodx

  committed
  ab982c6

• pending jobs works

  pranavmodx

  committed
  ed54b2a

• db lock issue fixed, enqueuing works

  pranavmodx

  committed
  3800287

• comment few logs

  pranavmodx

  committed
  5042ed4

• fix enqueue locking indefinitely issue

  pranavmodx

  committed
  66f6154

• retrying works

  pranavmodx

  committed
  5e0dcb0

• fix job chaining sync issue

  pranavmodx

  committed
  e2d5d04

• code cleanup

  pranavmodx

  committed
  3be1f0d

• remove queue monitor and related fields

  pranavmodx

  committed
  8b2be88

• use ctx versions of sql apis

  pranavmodx

  committed
  9fdb1cb

• code cleanup

  pranavmodx

  committed
  59201dd

• update and fix max_retries entries in db

  pranavmodx

  committed
  e56993a

• fix sqlite3 db path

  pranavmodx

  committed
  a35e870

• make queueListenerChan buffer size configurable

  pranavmodx

  committed
  82a13d9

• fix order of scanned columns in query

  pranavmodx

  committed
  00b8429

• remove deadline from query

  pranavmodx

  committed
  4dea09d

• add in progress job status

  pranavmodx

  committed
  a575976

• add dbgs

  pranavmodx

  committed
  fd7e5cc

• add dbgs

  pranavmodx

  committed
  330893c

• add dbgs

  pranavmodx

  committed
  ddbc6b1

• close db when calling shutdown

  pranavmodx

  committed
  4859e6e

• implement initFutureJobs

  pranavmodx

  committed
  66a7f1e

• remove dbgs

  pranavmodx

  committed
  0ac8178

• create neoq_dead_jobs table; implement moveToDeadQueue

  pranavmodx

  committed
  faaa11d

• implement StartCron

  pranavmodx

  committed
  aeebbf2

• add basic test layout

  pranavmodx

  committed
  31de8d5

• add tests for multiple queues, cron

  pranavmodx

  committed
  9e7265d

• add tests job errors, future job scheduling

  pranavmodx

  committed
  b710137

• change author back to original

  pranavmodx

  committed
  85e7409

• cleanup postgres backend logs

  pranavmodx

  committed
  f2e60ba

• code cleanup; carve out updateJobToInProgress

  pranavmodx

  committed
  a159d2b

Commits on May 11, 2024

• fix futureJobs concurrency issue

  pranavmodx

  committed
  b1c10a3

• extract queueListenerChan for a given queue beforehand

  pranavmodx

  committed
  7857380

Commits on May 12, 2024

• add support for deadline, insert deadline and max_retries in enqueueJob; multiple tests

  pranavmodx

  committed
  bf6680e

• add tests - TestMultipleProcessors, TestMultipleCronNodes

  pranavmodx

  committed
  f29e7b3

• populate id and deadline to dead queue

  pranavmodx

  committed
  d59a5f4

• support json payload; remove payload2

  pranavmodx

  committed
  a4fe135

Commits on May 30, 2024

• add test for duplicate job rejection

  pranavmodx

  committed
  e2b4608

Commits on May 31, 2024

• code cleanup

  pranavmodx

  committed
  1ce892a

Commits on Jun 8, 2024

• extract db path by trimming prefix

  pranavmodx

  committed
  0691d74

• remove id in query for moveToDeadQueue

  pranavmodx

  committed
  91e3609

• edit comment for initializeDB

  pranavmodx

  committed
  b818224

• replace TrimLeft with TrimPrefix

  pranavmodx

  committed
  e4da1db