Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Documentation
data KafkaProducerPoolConfig Source #
KafkaProducerPoolConfig | |
|
Instances
Show KafkaProducerPoolConfig Source # | |
Defined in Freckle.App.Kafka.Producer |
class HasKafkaProducerPool env where Source #
Instances
HasKafkaProducerPool site => HasKafkaProducerPool (HandlerData child site) Source # | |
Defined in Freckle.App.Kafka.Producer kafkaProducerPoolL :: Lens' (HandlerData child site) KafkaProducerPool Source # |
createKafkaProducerPool :: NonEmpty BrokerAddress -> KafkaProducerPoolConfig -> IO (Pool KafkaProducer) Source #
produceKeyedOn :: (MonadUnliftIO m, MonadLogger m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m () Source #
produceKeyedOnAsync :: (MonadMask m, MonadUnliftIO m, MonadLogger m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m () Source #