postq

AsyncHandler converts the given user defined handler into a async event handler.

NewPGConsumer returns a new EventConsumer.

SyncHandlers converts the given user defined handlers into sync event handlers.

Event represents the event queue table.

PGConsumer manages concurrent consumers to handle PostgreSQL NOTIFY events from a specific channel.

AsyncEventHandlerFunc processes multiple events and returns the failed ones.

SyncEventHandlerFunc processes a single event and ONLY makes db changes.