packages feed

consumers 1.0 → 1.1

raw patch · 2 files changed

+2/−3 lines, 2 filesdep ~logPVP ok

version bump matches the API change (PVP)

Dependency ranges changed: log

API changes (from Hackage documentation)

- Database.PostgreSQL.Consumers.Config: ccConsumersTable :: ConsumerConfig m idx job -> !(RawSQL ())
- Database.PostgreSQL.Consumers.Config: ccJobFetcher :: ConsumerConfig m idx job -> !(row -> job)
- Database.PostgreSQL.Consumers.Config: ccJobIndex :: ConsumerConfig m idx job -> !(job -> idx)
- Database.PostgreSQL.Consumers.Config: ccJobSelectors :: ConsumerConfig m idx job -> ![SQL]
- Database.PostgreSQL.Consumers.Config: ccJobsTable :: ConsumerConfig m idx job -> !(RawSQL ())
- Database.PostgreSQL.Consumers.Config: ccMaxRunningJobs :: ConsumerConfig m idx job -> !Int
- Database.PostgreSQL.Consumers.Config: ccNotificationChannel :: ConsumerConfig m idx job -> !(Maybe Channel)
- Database.PostgreSQL.Consumers.Config: ccNotificationTimeout :: ConsumerConfig m idx job -> !Int
- Database.PostgreSQL.Consumers.Config: ccOnException :: ConsumerConfig m idx job -> !(SomeException -> job -> m Action)
- Database.PostgreSQL.Consumers.Config: ccProcessJob :: ConsumerConfig m idx job -> !(job -> m Result)
- Database.PostgreSQL.Consumers.Config: instance Eq Action
- Database.PostgreSQL.Consumers.Config: instance Eq Result
- Database.PostgreSQL.Consumers.Config: instance Ord Action
- Database.PostgreSQL.Consumers.Config: instance Ord Result
- Database.PostgreSQL.Consumers.Config: instance Show Action
- Database.PostgreSQL.Consumers.Config: instance Show Result
- Database.PostgreSQL.Consumers.Consumer: instance Eq ConsumerID
- Database.PostgreSQL.Consumers.Consumer: instance FromSQL ConsumerID
- Database.PostgreSQL.Consumers.Consumer: instance Ord ConsumerID
- Database.PostgreSQL.Consumers.Consumer: instance PQFormat ConsumerID
- Database.PostgreSQL.Consumers.Consumer: instance Show ConsumerID
- Database.PostgreSQL.Consumers.Consumer: instance ToSQL ConsumerID
- Database.PostgreSQL.Consumers.Utils: instance Exception StopExecution
- Database.PostgreSQL.Consumers.Utils: instance Exception ThrownFrom
- Database.PostgreSQL.Consumers.Utils: instance Show StopExecution
- Database.PostgreSQL.Consumers.Utils: instance Show ThrownFrom
- Database.PostgreSQL.Consumers.Utils: instance Typeable StopExecution
- Database.PostgreSQL.Consumers.Utils: instance Typeable ThrownFrom
+ Database.PostgreSQL.Consumers.Config: [ccConsumersTable] :: ConsumerConfig m idx job -> !(RawSQL ())
+ Database.PostgreSQL.Consumers.Config: [ccJobFetcher] :: ConsumerConfig m idx job -> !(row -> job)
+ Database.PostgreSQL.Consumers.Config: [ccJobIndex] :: ConsumerConfig m idx job -> !(job -> idx)
+ Database.PostgreSQL.Consumers.Config: [ccJobSelectors] :: ConsumerConfig m idx job -> ![SQL]
+ Database.PostgreSQL.Consumers.Config: [ccJobsTable] :: ConsumerConfig m idx job -> !(RawSQL ())
+ Database.PostgreSQL.Consumers.Config: [ccMaxRunningJobs] :: ConsumerConfig m idx job -> !Int
+ Database.PostgreSQL.Consumers.Config: [ccNotificationChannel] :: ConsumerConfig m idx job -> !(Maybe Channel)
+ Database.PostgreSQL.Consumers.Config: [ccNotificationTimeout] :: ConsumerConfig m idx job -> !Int
+ Database.PostgreSQL.Consumers.Config: [ccOnException] :: ConsumerConfig m idx job -> !(SomeException -> job -> m Action)
+ Database.PostgreSQL.Consumers.Config: [ccProcessJob] :: ConsumerConfig m idx job -> !(job -> m Result)
+ Database.PostgreSQL.Consumers.Config: instance GHC.Classes.Eq Database.PostgreSQL.Consumers.Config.Action
+ Database.PostgreSQL.Consumers.Config: instance GHC.Classes.Eq Database.PostgreSQL.Consumers.Config.Result
+ Database.PostgreSQL.Consumers.Config: instance GHC.Classes.Ord Database.PostgreSQL.Consumers.Config.Action
+ Database.PostgreSQL.Consumers.Config: instance GHC.Classes.Ord Database.PostgreSQL.Consumers.Config.Result
+ Database.PostgreSQL.Consumers.Config: instance GHC.Show.Show Database.PostgreSQL.Consumers.Config.Action
+ Database.PostgreSQL.Consumers.Config: instance GHC.Show.Show Database.PostgreSQL.Consumers.Config.Result
+ Database.PostgreSQL.Consumers.Consumer: instance Database.PostgreSQL.PQTypes.Format.PQFormat Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Consumer: instance Database.PostgreSQL.PQTypes.FromSQL.FromSQL Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Consumer: instance Database.PostgreSQL.PQTypes.ToSQL.ToSQL Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Consumer: instance GHC.Classes.Eq Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Consumer: instance GHC.Classes.Ord Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Consumer: instance GHC.Show.Show Database.PostgreSQL.Consumers.Consumer.ConsumerID
+ Database.PostgreSQL.Consumers.Utils: instance GHC.Exception.Exception Database.PostgreSQL.Consumers.Utils.StopExecution
+ Database.PostgreSQL.Consumers.Utils: instance GHC.Exception.Exception Database.PostgreSQL.Consumers.Utils.ThrownFrom
+ Database.PostgreSQL.Consumers.Utils: instance GHC.Show.Show Database.PostgreSQL.Consumers.Utils.StopExecution
+ Database.PostgreSQL.Consumers.Utils: instance GHC.Show.Show Database.PostgreSQL.Consumers.Utils.ThrownFrom

Files

consumers.cabal view
@@ -1,5 +1,5 @@ name:               consumers-version:            1.0+version:            1.1 synopsis:           Concurrent PostgreSQL data consumers description:        Library for setting up concurrent consumers of data stored inside PostgreSQL database in a simple, declarative manner. homepage:           https://github.com/scrive/consumers@@ -28,7 +28,7 @@                     hpqtypes >=1.4,                     lifted-base,                     lifted-threads,-                    log,+                    log >= 0.4,                     monad-control,                     mtl,                     stm,
src/Database/PostgreSQL/Consumers/Components.hs view
@@ -20,7 +20,6 @@ import Data.Monoid.Utils import Database.PostgreSQL.PQTypes import Log-import Log.Class.Instances () import qualified Control.Concurrent.STM as STM import qualified Control.Concurrent.Thread.Lifted as T import qualified Data.Foldable as F