Hoogle Search

Within LTS Haskell 24.34 (ghc-9.10.3)

Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.

Exact lookup

1. asum :: (Foldable t, Alternative f) => t (f a) -> f a

   configuration-tools	Configuration.Utils.CommandLine

   The sum of a collection of actions using (<|>), generalizing concat. asum is just like msum, but generalised to Alternative.

   Examples

   Basic usage:

   >>> asum [Just "Hello", Nothing, Just "World"]
   Just "Hello"
   

2. package consumers

   Concurrent PostgreSQL data consumers Library for setting up concurrent consumers of data stored inside PostgreSQL database in a simple, declarative manner.

3. module Database.PostgreSQL.Consumers

   No documentation available.

4. 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 ())

   consumers	Database.PostgreSQL.Consumers

   Run the consumer. The purpose of the returned monadic action is to wait for currently processed jobs and clean up. This function is best used in conjunction with finalize to seamlessly handle the finalization. If you want to add metrics, see the consumers-metrics-prometheus package to seamlessly instrument your consumer.

5. 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 ())

   consumers	Database.PostgreSQL.Consumers

   No documentation available.

6. 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 ())

   consumers	Database.PostgreSQL.Consumers.Components

   Run the consumer. The purpose of the returned monadic action is to wait for currently processed jobs and clean up. This function is best used in conjunction with finalize to seamlessly handle the finalization. If you want to add metrics, see the consumers-metrics-prometheus package to seamlessly instrument your consumer.

7. 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 ())

   consumers	Database.PostgreSQL.Consumers.Components

   No documentation available.

8. data ConsumerConfig (m :: Type -> Type) idx job

   consumers	Database.PostgreSQL.Consumers.Config

   Config of a consumer.

9. ConsumerConfig :: !RawSQL () -> !RawSQL () -> [SQL] -> row -> job -> job -> idx -> !Maybe Channel -> Int -> Int -> job -> m Result -> SomeException -> job -> m Action -> job -> [Pair] -> ConsumerConfig (m :: Type -> Type) idx job

   consumers	Database.PostgreSQL.Consumers.Config

   No documentation available.

10. ccConsumersTable :: ConsumerConfig (m :: Type -> Type) idx job -> !RawSQL ()

    consumers	Database.PostgreSQL.Consumers.Config

    Name of a database table where registered consumers are stored. The table itself needs to have the following columns:

    • id - represents ID of a consumer. Needs to be a primary key of the type SERIAL or BIGSERIAL (recommended).
    • name - represents jobs table of the consumer. Needs to be not nullable, of type TEXT. Allows for tracking consumers of multiple queues with one table. Set to ccJobsTable.
    • last_activity - represents the last registered activity of the consumer. It's updated periodically by all currently running consumers every 30 seconds to prove that they are indeed running. They also check for the registered consumers that didn't update their status for a minute. If any such consumers are found, they are presumed to be not working and all the jobs reserved by them are released. This prevents the situation where a consumer with reserved jobs silently fails (e.g. because of a hard crash) and these jobs stay locked forever, yet are never processed.

Page 205 of many | Previous | Next