consumers-2.1.1.0: Concurrent PostgreSQL data consumers

Safe HaskellNone
LanguageHaskell2010

Database.PostgreSQL.Consumers.Consumer

Synopsis

Documentation

registerConsumer :: (MonadBase IO m, MonadMask m, MonadTime m) => ConsumerConfig n idx job -> ConnectionSourceM m -> 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 -> ConnectionSourceM m -> ConsumerID -> m () Source #

Unregister consumer with a given ID.