Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Documentation
class HasKafkaConsumer env where Source #
kafkaConsumerL :: Lens' env KafkaConsumer Source #
withKafkaConsumer :: MonadUnliftIO m => KafkaConsumerConfig -> (KafkaConsumer -> m a) -> m a Source #
data KafkaConsumerConfig Source #
KafkaConsumerConfig | |
|
Instances
Show KafkaConsumerConfig Source # | |
Defined in Freckle.App.Kafka.Consumer |
runConsumer :: (MonadMask m, MonadUnliftIO m, MonadReader env m, MonadLogger m, HasKafkaConsumer env, FromJSON a) => Timeout -> (a -> m ()) -> m () Source #