kafka

Jul 3, 2019

Changes in this version

type GologAdapterLogger

+ func (GologAdapterLogger) Print(v ...interface{})

+ func (GologAdapterLogger) Printf(format string, args ...interface{})

+ func (GologAdapterLogger) Println(v ...interface{})

Dec 11, 2017

Changes in this version

+ type GologAdapterLogger struct

+ func (GologAdapterLogger) Debug(msg string, args ...interface{})

+ func (GologAdapterLogger) Error(msg string, args ...interface{})

+ func (GologAdapterLogger) Info(msg string, args ...interface{})

+ func (GologAdapterLogger) Warn(msg string, args ...interface{})

Mar 17, 2017

Changes in this version

+ const EventsTopic

+ const TimeSeriesTopic

+ type KafkaClient interface

+ Name func() string

+ ProduceKafkaMessage func(msgData interface{}) error

+ Stop func()

+ func NewKafkaClient(uri *url.URL, topicType string) (KafkaClient, error)