logrus_udp2es

README

Logrus-udp2es-hook

用于写入udp地址走后续自动入ES流程

Usage

import (
    "github.com/sirupsen/logrus"
    "github.com/360SO/logrus-udp2es-hook"
)

func main() {

    // logrus 必须设置为json输出
    logrus.SetFormatter(&logrus.JSONFormatter{})

    // 初始化hook
    hook, err := logrus_udp2es.NewUdp2EsHook(&logrus_udp2es.Hook{
        Host: "127.0.0.1", // your udp server host
        Port: 12345, // your udp server port
        ESIndex: "test-index", // your es index
    })

    // 只记录指定Level的日志
    hook.SetLevels([]logrus.Level{logrus.ErrorLevel, logrus.WarnLevel})

    if err == nil {
    	logrus.AddHook(hook)
    } else {
    	logrus.Error("add hook error:", err)
    }

    logrus.Warning("Here is your message")
}

ChangeLog

Documentation

Index

• type Hook
  • func NewUdp2EsHook(hook *Hook) (*Hook, error)
  • func (hook *Hook) Fire(entry *logrus.Entry) error
  • func (hook *Hook) Levels() []logrus.Level
  • func (hook *Hook) SetLevels(lvs []logrus.Level)

Types

type Hook

type Hook struct {
	// Connection Details
	Host string
	Port int

	// es index
	ESIndex string
	// contains filtered or unexported fields
}

func NewUdp2EsHook

func NewUdp2EsHook(hook *Hook) (*Hook, error)

NewPapertrailHook creates a UDP hook to be added to an instance of logger.

func (*Hook) Fire

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

Fire is called when a log envent is fired.

func (*Hook) Levels

func (hook *Hook) Levels() []logrus.Level

Levels returns the available logging levels.

func (*Hook) SetLevels

func (hook *Hook) SetLevels(lvs []logrus.Level)

SetLevels specify nessesary levels for this hook.