Yoga.Kafka.Admin

data Admin

createAdminImpl :: EffectFn1 Kafka Admin

createAdmin :: Kafka -> Effect Admin

connectAdminImpl :: EffectFn1 Admin (Promise Unit)

connect :: Admin -> Aff Unit

type TopicConfig = { numPartitions :: PartitionCount, replicationFactor :: ReplicationFactor, topic :: TopicName }

createTopicsImpl :: EffectFn2 Admin { topics :: Array TopicConfig } (Promise Boolean)

createTopics :: { topics :: Array TopicConfig } -> Admin -> Aff Boolean

deleteTopicsImpl :: EffectFn2 Admin { topics :: Array TopicName } (Promise Unit)

deleteTopics :: { topics :: Array TopicName } -> Admin -> Aff Unit

listTopicsImpl :: EffectFn1 Admin (Promise (Array TopicName))

listTopics :: Admin -> Aff (Array TopicName)

disconnectAdminImpl :: EffectFn1 Admin (Promise Unit)

disconnect :: Admin -> Aff Unit