Yoga.Kafka.OmLayer

type KafkaConfig = { brokers :: Array BrokerAddress, clientId :: ClientId }

type KafkaL :: Row Type -> Row Typetype KafkaL r = (kafka :: Kafka | r)

type KafkaProducerL :: Row Type -> Row Typetype KafkaProducerL r = (kafkaProducer :: Producer | r)

type KafkaConsumerL :: Row Type -> Row Typetype KafkaConsumerL r = (kafkaConsumer :: Consumer | r)

kafkaLayer :: forall r. OmLayer (kafkaConfig :: KafkaConfig | r) () { kafka :: Kafka }

producerLayer :: forall r. OmLayer (kafka :: Kafka | r) () { kafkaProducer :: Producer }

consumerLayer :: forall r. OmLayer (consumerGroupId :: ConsumerGroupId, kafka :: Kafka | r) () { kafkaConsumer :: Consumer }