consumers-2.3.2.0: Concurrent PostgreSQL data consumers
Safe HaskellSafe-Inferred
LanguageHaskell2010

Database.PostgreSQL.Consumers.Consumer

Synopsis

Documentation

data ConsumerID Source #

ID of a consumer.

Instances

Instances details
Show ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

Eq ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

Ord ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

PQFormat ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

FromSQL ConsumerID Source # 
Instance details

Defined in Database.PostgreSQL.Consumers.Consumer

Associated Types

type PQBase 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 PQDest 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.