freckle-app-1.15.2.0: Haskell application toolkit used at Freckle
Safe HaskellSafe-Inferred
LanguageHaskell2010

Freckle.App.Kafka.Producer

Documentation

data KafkaProducerPoolConfig Source #

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.

class HasKafkaProducerPool env where Source #

Instances

Instances details
HasKafkaProducerPool site => HasKafkaProducerPool (HandlerData child site) Source # 
Instance details

Defined in Freckle.App.Kafka.Producer

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 #