Safe Haskell	None
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

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 #
Show ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods showsPrec :: Int -> ConsumerID -> ShowS # show :: ConsumerID -> String # showList :: [ConsumerID] -> ShowS #
ToSQL ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Associated Types type PQDest ConsumerID :: Type # Methods toSQL :: ConsumerID -> ParamAllocator -> (Ptr (PQDest ConsumerID) -> IO r) -> IO r #
FromSQL ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Associated Types type PQBase ConsumerID :: Type # Methods fromSQL :: Maybe (PQBase ConsumerID) -> IO ConsumerID #
PQFormat ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer Methods pqFormat :: ByteString # pqFormat0 :: ByteString # pqVariables :: Int #
type PQDest ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer type PQDest ConsumerID = PQDest Int64
type PQBase ConsumerID Source #
Instance details Defined in Database.PostgreSQL.Consumers.Consumer type PQBase ConsumerID = PQBase 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.