Versions in this module Expand all Collapse all v1 v1.0.0 Dec 3, 2017 Changes in this version + type Coordinator struct + App *protocol.ApplicationContext + Log *zap.Logger + func (bc *Coordinator) Configure() + func (bc *Coordinator) Start() error + func (bc *Coordinator) Stop() error + type KafkaCluster struct + App *protocol.ApplicationContext + Log *zap.Logger + func (module *KafkaCluster) Configure(name string, configRoot string) + func (module *KafkaCluster) Start() error + func (module *KafkaCluster) Stop() error
Go to main page