Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Synopsis
- data Action
- data Result
- data ConsumerConfig m idx job = forall row.FromRow row => ConsumerConfig {
- 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)
Documentation
Action to take after a job was processed.
data ConsumerConfig m idx job Source #
Config of a consumer.
forall row.FromRow row => ConsumerConfig | |
|