logmania/input/syslog/internal.go

package syslog

import (
	"github.com/bdlm/log"
	logstd "github.com/bdlm/std/logger"

	libSyslog "dev.sum7.eu/sum7/logmania/lib/syslog"
)

var SyslogPriorityMap = map[int]logstd.Level{
	0: log.PanicLevel,
	1: log.PanicLevel,
	2: log.PanicLevel,
	3: log.ErrorLevel,
	4: log.WarnLevel,
	5: log.InfoLevel,
	6: log.InfoLevel,
	7: log.DebugLevel,
}

func toLogEntry(msg []byte, from string) *log.Entry {
	syslogMsg := libSyslog.Parse(msg)

	entry := log.NewEntry(nil)
	entry = entry.WithField("hostname", from)
	entry.Time = syslogMsg.Timestemp
	entry.Level = SyslogPriorityMap[syslogMsg.Severity]
	entry.Message = syslogMsg.Content
	return entry
}