Versions in this module Expand all Collapse all v0 v0.1.0 May 9, 2017 Changes in this version + func CreateFileReaderProps(context actor.Context, bootstrapServers string) *actor.PID + type CoordinatorActor struct + BootStrapServers string + func (parent *CoordinatorActor) Receive(context actor.Context) + type Producer struct + func NewProducer(brokerList string) Producer + func (p Producer) Produce(value string)
Go to main page