logstash_kafka

Documentation

Overview

@Time : 2019-11-04 9:31 @Author : zr

Index

• func EnableLogrusLogstashKafka(appName, logFile, tracePrefix string, zhHosts []string)
• type FrontKafka
  • func NewLogstashFrontKafka(config *LogstashFrontKafkaConfig) *FrontKafka
  • func (f *FrontKafka) GetLogrusHook() Hook
  • func (f *FrontKafka) Log(entry *logrus.Entry)
• type FrontStatus
• type Hook
  • func (h Hook) Fire(entry *logrus.Entry) error
  • func (h Hook) Levels() []logrus.Level
• type LogstashFrontKafkaConfig
  • func NewLogstashFrontKafkaConfig() *LogstashFrontKafkaConfig

Functions

func EnableLogrusLogstashKafka

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

Types

type FrontKafka

type FrontKafka struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLogstashFrontKafka

func NewLogstashFrontKafka(config *LogstashFrontKafkaConfig) *FrontKafka

func (*FrontKafka) GetLogrusHook

func (f *FrontKafka) GetLogrusHook() Hook

func (*FrontKafka) Log

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

type FrontStatus

type FrontStatus int

const (
	FrontStatusKafkaConnecting FrontStatus
	FrontStatusKafkaConnected
	FrontStatusKafkaReconnecting
	FrontStatusKafkaDisconnected
	FrontStatusStopping
	FrontStatusStopped
)

type Hook

type Hook struct {
	// contains filtered or unexported fields
}

func (Hook) Fire

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

func (Hook) Levels

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

type LogstashFrontKafkaConfig

type LogstashFrontKafkaConfig struct {
	//应用名,用于创建ES索引
	AppName string
	//连接Kafka失败时信息储存位置
	FileLogPath string
	//trace字段预设值
	TracePrefix string
	ZKHosts     []string
}

func NewLogstashFrontKafkaConfig

func NewLogstashFrontKafkaConfig() *LogstashFrontKafkaConfig