Skip to content
/ pgq-ext Public
forked from pgq/pgq-ext

Remote queue position tracking for PgQ consumers

Notifications You must be signed in to change notification settings

furmur/pgq-ext

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

14 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Track processed batches and events in target DB

Batch tracking is OK.

Event tracking is OK if consumer does not use retry queue.

Batch tracking

is_batch_done(consumer, batch)

returns:

true - batch is done already false - batch is not done yet

set_batch_done(consumer, batch)

returns:

true - tagging successful, batch was not done yet false - batch was done already

Event tracking

is_batch_done(consumer, batch, event)

returns:

true - event is done false - event is not done yet

set_batch_done(consumer, batch, event)

returns:

true - tagging was successful, event was not done false - event is done already

About

Remote queue position tracking for PgQ consumers

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • PLpgSQL 55.1%
  • Python 34.8%
  • Makefile 10.1%