consumers-0.1: Concurrent PostgreSQL data consumers

Safe HaskellNone
LanguageHaskell2010

Database.PostgreSQL.Consumers.Consumer

Synopsis

Documentation

registerConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> m ConsumerID Source

Register consumer in the consumers table, so that it can reserve jobs using acquired ID.

unregisterConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSource -> ConsumerID -> m () Source

Unregister consumer with a given ID.