Safe Haskell	Safe-Inferred
Language	Haskell2010

Database.PostgreSQL.Consumers.Consumer

Synopsis

data ConsumerID
registerConsumer :: (MonadBase IO m, MonadMask m, MonadTime m) => ConsumerConfig n idx job -> ConnectionSourceM m -> m ConsumerID
unregisterConsumer :: (MonadBase IO m, MonadMask m) => ConsumerConfig n idx job -> ConnectionSourceM m -> ConsumerID -> m ()

Documentation

data ConsumerID Source #

ID of a consumer.

Instances

Instances details

Show ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods showsPrec :: Int -> ConsumerID -> ShowS # show :: ConsumerID -> String # showList :: [ConsumerID] -> ShowS #
Eq ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods (==) :: ConsumerID -> ConsumerID -> Bool # (/=) :: ConsumerID -> ConsumerID -> Bool #
Ord ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods compare :: ConsumerID -> ConsumerID -> Ordering # (<) :: ConsumerID -> ConsumerID -> Bool # (<=) :: ConsumerID -> ConsumerID -> Bool # (>) :: ConsumerID -> ConsumerID -> Bool # (>=) :: ConsumerID -> ConsumerID -> Bool # max :: ConsumerID -> ConsumerID -> ConsumerID # min :: ConsumerID -> ConsumerID -> ConsumerID #
PQFormat ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods pqFormat :: ByteString # pqFormat0 :: ByteString # pqVariables :: Int #
FromSQL ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Associated Types type PQBase ConsumerID # Methods fromSQL :: Maybe (PQBase ConsumerID) -> IO ConsumerID #
ToSQL ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Associated Types type PQDest ConsumerID # Methods toSQL :: ConsumerID -> ParamAllocator -> (Ptr (PQDest ConsumerID) -> IO r) -> IO r #
type PQBase ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer type PQBase ConsumerID = PQBase Int64
type PQDest ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer type PQDest ConsumerID = PQDest Int64

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.