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