Redis Hook for Logrus
Useful for centralized logging, using a RELK stack (Redis, Elasticsearch, Logstash and Kibana). When the hook is installed, all log messages are sent to a Redis server, in Logstash message V0 or V1 format, ready to be parsed/processed by Logstash.
$ go get github.com/rogierlommers/logrus-redis-hook
package main
import (
log "github.com/sirupsen/logrus"
"github.com/rogierlommers/logrus-redis-hook"
)
func init() {
hook, err := logredis.NewHook("localhost", 6379, "my_redis_key")
if err == nil {
log.AddHook(hook)
}
}
func main() {
// when hook is injected succesfully, logs will be send to redis server
log.Info("just some logging...")
}
type LogstashMessageV0 struct {
Type string `json:"@type,omitempty"`
Timestamp string `json:"@timestamp"`
Sourcehost string `json:"@source_host"`
Message string `json:"@message"`
Level string `json:"@level"`
Fields struct {
Exception struct {
ExceptionClass string `json:"exception_class"`
ExceptionMessage string `json:"exception_message"`
Stacktrace string `json:"stacktrace"`
} `json:"exception"`
File string `json:"file"`
Level string `json:"level"`
Timestamp string `json:"timestamp"`
} `json:"@fields"`
}
work in progresss...
Please see the docker-compose
directory for information about how to test. There is a readme inside.
MIT