Module

Yoga.Kafka.Producer

Package: purescript-yoga-kafka
Repository: rowtype-yoga/purescript-yoga-kafka

#Producer Source

data Producer

#ProducerOptionsImpl Source

type ProducerOptionsImpl :: Row Typetype ProducerOptionsImpl = (allowAutoTopicCreation :: Boolean, transactionTimeout :: Milliseconds)

#createProducerImpl Source

createProducerImpl :: forall opts. EffectFn2 Kafka (Record opts) Producer

#createProducer Source

createProducer :: forall opts opts_. Union opts opts_ ProducerOptionsImpl => Record opts -> Kafka -> Effect Producer

#connectProducerImpl Source

connectProducerImpl :: EffectFn1 Producer (Promise Unit)

#connect Source

connect :: Producer -> Aff Unit

#ProducerMessageOptionsImpl Source

type ProducerMessageOptionsImpl :: Row Typetype ProducerMessageOptionsImpl = (headers :: Object HeaderValue, key :: Key, partition :: PartitionId, timestamp :: Timestamp)

#RecordMetadata Source

type RecordMetadata = { errorCode :: ErrorCode, offset :: Nullable Offset, partition :: PartitionId, timestamp :: Nullable Timestamp, topicName :: TopicName }

#SendRecordImpl Source

type SendRecordImpl :: Row Typetype SendRecordImpl = (messages :: Array (Record ProducerMessageOptionsImpl), topic :: TopicName)

#sendImpl Source

sendImpl :: forall opts msg. EffectFn2 Producer { messages :: Array { value :: Value | msg }, topic :: TopicName | opts } (Promise (Array RecordMetadata))

#send Source

send :: forall opts opts_ msg msgOpts_. Union opts opts_ SendRecordImpl => Union msg msgOpts_ ProducerMessageOptionsImpl => { messages :: Array { value :: Value | msg }, topic :: TopicName | opts } -> Producer -> Aff (Array RecordMetadata)

#disconnectProducerImpl Source

disconnectProducerImpl :: EffectFn1 Producer (Promise Unit)

#disconnect Source

disconnect :: Producer -> Aff Unit

Modules: Yoga.Kafka.Admin; Yoga.Kafka.Consumer; Yoga.Kafka.Kafka; Yoga.Kafka.Producer