consumers-2.2.0.0: Concurrent PostgreSQL data consumers

Safe HaskellNone
LanguageHaskell2010

Database.PostgreSQL.Consumers.Consumer

Synopsis

Documentation

data ConsumerID Source #

ID of a consumer.

Instances
Eq ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

Ord ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

Show ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

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 #

PQFormat ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

type PQDest ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

type PQBase ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

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.