logstash_kafka

May 6, 2020

Changes in this version

type FrontKafka

+ func (f *FrontKafka) Log(entry *logrus.Entry)

Mar 13, 2020

Changes in this version

+ func EnableLogrusLogstashKafka(appName, logFile, tracePrefix string, zhHosts []string)

+ type FrontKafka struct

+ func NewLogstashFrontKafka(config *LogstashFrontKafkaConfig) *FrontKafka

+ func (l *FrontKafka) GetLogrusHook() Hook

+ type FrontStatus int

+ const FrontStatusKafkaConnected

+ const FrontStatusKafkaConnecting

+ const FrontStatusKafkaDisconnected

+ const FrontStatusKafkaReconnecting

+ const FrontStatusStopped

+ const FrontStatusStopping

+ type Hook struct

+ func (h Hook) Fire(entry *logrus.Entry) error

+ func (h Hook) Levels() []logrus.Level

+ type LogstashFrontKafkaConfig struct

+ AppName string

+ FileLogPath string

+ TracePrefix string

+ ZKHosts []string

+ func NewLogstashFrontKafkaConfig() *LogstashFrontKafkaConfig