Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Documentation
data KafkaProducerPoolConfig Source #
KafkaProducerPoolConfig | |
|
Instances
Show KafkaProducerPoolConfig Source # | |
Defined in Freckle.App.Kafka.Producer showsPrec :: Int -> KafkaProducerPoolConfig -> ShowS # show :: KafkaProducerPoolConfig -> String # showList :: [KafkaProducerPoolConfig] -> ShowS # |
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, MonadTracer m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m () Source #
produceKeyedOnAsync :: (MonadMask m, MonadUnliftIO m, MonadLogger m, MonadTracer m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m () Source #