Database.PostgreSQL.Consumers.Consumer

Documentation

data ConsumerID

ID of a consumer.

Instances

Eq ConsumerID

Ord ConsumerID

Show ConsumerID

ToSQL ConsumerID

FromSQL ConsumerID

PQFormat ConsumerID

type PQDest ConsumerID = PQDest Int64

type PQBase ConsumerID = PQBase Int64

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

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 ()

Unregister consumer with a given ID.