Safe Haskell	Safe-Inferred
Language	Haskell2010

Database.PostgreSQL.Consumers.Config

Synopsis

Documentation

Action to take after a job was processed.

Constructors

Instances details

Show Action Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods showsPrec :: Int -> Action -> ShowS # show :: Action -> String # showList :: [Action] -> ShowS #
Eq Action Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods (==) :: Action -> Action -> Bool # (/=) :: Action -> Action -> Bool #
Ord Action Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods compare :: Action -> Action -> Ordering # (<) :: Action -> Action -> Bool # (<=) :: Action -> Action -> Bool # (>) :: Action -> Action -> Bool # (>=) :: Action -> Action -> Bool # max :: Action -> Action -> Action # min :: Action -> Action -> Action #

Result of processing a job.

Constructors

Ok Action
Failed Action

Instances details

Show Result Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods showsPrec :: Int -> Result -> ShowS # show :: Result -> String # showList :: [Result] -> ShowS #
Eq Result Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods (==) :: Result -> Result -> Bool # (/=) :: Result -> Result -> Bool #
Ord Result Source #
Instance details Defined in Database.PostgreSQL.Consumers.Config Methods compare :: Result -> Result -> Ordering # (<) :: Result -> Result -> Bool # (<=) :: Result -> Result -> Bool # (>) :: Result -> Result -> Bool # (>=) :: Result -> Result -> Bool # max :: Result -> Result -> Result # min :: Result -> Result -> Result #

Config of a consumer.

Constructors

forall row.FromRow row => ConsumerConfig
Fields ccJobsTable :: !(RawSQL ()) ccConsumersTable :: !(RawSQL ()) ccJobSelectors :: ![SQL] ccJobFetcher :: !(row -> job) ccJobIndex :: !(job -> idx) ccNotificationChannel :: !(Maybe Channel) ccNotificationTimeout :: !Int ccMaxRunningJobs :: !Int ccProcessJob :: !(job -> m Result) ccOnException :: !(SomeException -> job -> m Action)