Freckle.App.Kafka.Producer

Documentation

envKafkaBrokerAddresses :: Parser Error (NonEmpty BrokerAddress)

data KafkaProducerPoolConfig

Constructors

KafkaProducerPoolConfig

Fields

• kafkaProducerPoolConfigStripes :: Int

  The number of stripes (distinct sub-pools) to maintain. The smallest acceptable value is 1.

• kafkaProducerPoolConfigIdleTimeout :: NominalDiffTime

  Amount of time for which an unused resource is kept open. The smallest acceptable value is 0.5 seconds.

  The elapsed time before destroying a resource may be a little longer than requested, as the reaper thread wakes at 1-second intervals.

• kafkaProducerPoolConfigSize :: Int

  Maximum number of resources to keep open per stripe. The smallest acceptable value is 1.

  Requests for resources will block if this limit is reached on a single stripe, even if other stripes have idle resources available.

Instances

Show KafkaProducerPoolConfig

Defined in Freckle.App.Kafka.Producer

Methods

showsPrec :: Int -> KafkaProducerPoolConfig -> ShowS

show :: KafkaProducerPoolConfig -> String

showList :: [KafkaProducerPoolConfig] -> ShowS

envKafkaProducerPoolConfig :: Parser Error KafkaProducerPoolConfig

data KafkaProducerPool

Constructors

NullKafkaProducerPool

KafkaProducerPool (Pool KafkaProducer)

class HasKafkaProducerPool env where

Methods

kafkaProducerPoolL :: Lens' env KafkaProducerPool

Instances

HasKafkaProducerPool site => HasKafkaProducerPool (HandlerData child site)

Defined in Freckle.App.Kafka.Producer

Methods

kafkaProducerPoolL :: Lens' (HandlerData child site) KafkaProducerPool

createKafkaProducerPool :: NonEmpty BrokerAddress -> KafkaProducerPoolConfig -> IO (Pool KafkaProducer)

produceKeyedOn :: (MonadUnliftIO m, MonadLogger m, MonadTracer m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m ()

produceKeyedOnAsync :: (MonadMask m, MonadUnliftIO m, MonadLogger m, MonadTracer m, MonadReader env m, HasKafkaProducerPool env, ToJSON key, ToJSON value) => TopicName -> NonEmpty value -> (value -> key) -> m ()