consumers 2.2.0.3 → 2.2.0.4

raw patch · 3 files changed

+9/−6 lines, 3 filesdep ~log-basePVP: major bump suggested

API removals or changes: PVP suggests a major version bump

Dependency ranges changed: log-base

API changes (from Hackage documentation)

- Database.PostgreSQL.Consumers: runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> m (m ())

+ Database.PostgreSQL.Consumers: runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> m (m ())

- Database.PostgreSQL.Consumers: runConsumerWithIdleSignal :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> TMVar Bool -> m (m ())

+ Database.PostgreSQL.Consumers: runConsumerWithIdleSignal :: (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> TMVar Bool -> m (m ())

- Database.PostgreSQL.Consumers.Components: runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> m (m ())

+ Database.PostgreSQL.Consumers.Components: runConsumer :: (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> m (m ())

- Database.PostgreSQL.Consumers.Components: runConsumerWithIdleSignal :: (MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> TMVar Bool -> m (m ())

+ Database.PostgreSQL.Consumers.Components: runConsumerWithIdleSignal :: (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx, FromSQL idx, ToSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> TMVar Bool -> m (m ())

- Database.PostgreSQL.Consumers.Components: spawnMonitor :: forall m idx job. (MonadBaseControl IO m, MonadLog m, MonadMask m, Show idx, FromSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> ConsumerID -> m ThreadId

+ Database.PostgreSQL.Consumers.Components: spawnMonitor :: forall m idx job. (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Show idx, FromSQL idx) => ConsumerConfig m idx job -> ConnectionSourceM m -> ConsumerID -> m ThreadId

Files

CHANGELOG.md +3/−0
consumers.cabal +2/−2
src/Database/PostgreSQL/Consumers/Components.hs +4/−4

CHANGELOG.md view

@@ -1,3 +1,6 @@+# consumers-2.2.0.4 (2021-06-09)+* Adjust to changes in log-base-0.10.+ # consumers-2.2.0.3 (2021-05-28) * Support GHC 9.0.

consumers.cabal view

@@ -1,5 +1,5 @@ name:               consumers-version:            2.2.0.3+version:            2.2.0.4 synopsis:           Concurrent PostgreSQL data consumers  description:        Library for setting up concurrent consumers of data@@ -39,7 +39,7 @@                   , hpqtypes          >= 1.7    && < 2.0                   , lifted-base       >= 0.2    && < 0.3                   , lifted-threads    >= 1.0    && < 1.1-                  , log-base          >= 0.7    && < 0.10+                  , log-base          >= 0.7    && < 0.11                   , monad-control     >= 1.0    && < 1.1                   , monad-time        >= 0.3    && < 0.4                   , mtl               >= 2.2    && < 2.3

src/Database/PostgreSQL/Consumers/Components.hs view

@@ -38,7 +38,7 @@ -- This function is best used in conjunction with 'finalize' to -- seamlessly handle the finalization. runConsumer-  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx+  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx      , FromSQL idx, ToSQL idx )   => ConsumerConfig m idx job   -> ConnectionSourceM m@@ -46,7 +46,7 @@ runConsumer cc cs = runConsumerWithMaybeIdleSignal cc cs Nothing  runConsumerWithIdleSignal-  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx+  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx      , FromSQL idx, ToSQL idx )   => ConsumerConfig m idx job   -> ConnectionSourceM m@@ -57,7 +57,7 @@ -- | Run the consumer and also signal whenever the consumer is waiting for -- getNotification or threadDelay. runConsumerWithMaybeIdleSignal-  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, Eq idx, Show idx+  :: ( MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m, Eq idx, Show idx      , FromSQL idx, ToSQL idx )   => ConsumerConfig m idx job   -> ConnectionSourceM m@@ -147,7 +147,7 @@ -- | Spawn a thread that monitors working consumers -- for activity and periodically updates its own. spawnMonitor-  :: forall m idx job. (MonadBaseControl IO m, MonadLog m, MonadMask m,+  :: forall m idx job. (MonadBaseControl IO m, MonadLog m, MonadMask m, MonadTime m,                         Show idx, FromSQL idx)   => ConsumerConfig m idx job   -> ConnectionSourceM m