Code

PGMQ driver implementation#38

Code

Open

sundbry wants to merge 18 commits intopoundifdef:mainpoundifdef/smoothmq:mainfrom

sundbry:pgmqsundbry/smoothmq:pgmqCopy head branch name to clipboard

Commits

Commits on Apr 12, 2025

• pgmq: New backend implementation

  Show description for 3875e79
  sundbry

  committed
  3875e79

  Copy full SHA for 3875e79

• go.mod: Install github.com/craigpastro/pgmq-go

  sundbry

  committed
  d705204

  Copy full SHA for d705204

• pgmq: Postgres connection initialization & shutdown

  sundbry

  committed
  650721b

  Copy full SHA for 650721b

• cmd/smoothmq/tester: Create a new queue for each test run

  sundbry

  committed
  78e68a7

  Copy full SHA for 78e68a7

• pgmq: Implement CreateQueue, DeleteQueue, Enqueue and Dequeue

  sundbry

  committed
  eae9e3b

  Copy full SHA for eae9e3b

• go.mod: Install gorm for postgres + pgtype

  sundbry

  committed
  9e7701c

  Copy full SHA for 9e7701c

• pgmq: Implement Peek

  sundbry

  committed
  fa3f5cc

  Copy full SHA for fa3f5cc

• pgmq: Implement Delete

  sundbry

  committed
  5dbafca

  Copy full SHA for 5dbafca

• pgmq: Implement ListQueues

  sundbry

  committed
  908d1cd

  Copy full SHA for 908d1cd

• pgmq: Implement Stats()

  sundbry

  committed
  2ff1c38

  Copy full SHA for 2ff1c38

• pgmq: Implement Filter()

  sundbry

  committed
  1aa5824

  Copy full SHA for 1aa5824

• pgmq: Provide message metadata (Tries, DeliverAt, MaxTries)

  sundbry

  committed
  37620ed

  Copy full SHA for 37620ed

• go.mod: upgrade pgmq-go

  sundbry

  committed
  d1a901c

  Copy full SHA for d1a901c

• pgmq: Update to pgmq-go 0.6.0

  Show description for d22b616
  sundbry

  committed
  d22b616

  Copy full SHA for d22b616

• pgmq: Support Enqueue with delay

  sundbry

  committed
  db1f00d

  Copy full SHA for db1f00d

• pgmq: Implement UpdateMessage to change visibility timeout

  sundbry

  committed
  1178cb7

  Copy full SHA for 1178cb7

• tester.go: Add coverage on ChangeMessageVisibility

  sundbry

  committed
  73eea17

  Copy full SHA for 73eea17

• Dockerfile: Upgrade to 1.23

  sundbry

  committed
  b071e90

  Copy full SHA for b071e90