package log import ( "fmt" "io" kitlog "github.com/go-kit/kit/log" "github.com/go-kit/kit/log/level" "github.com/go-kit/kit/log/term" ) const ( msgKey = "_msg" // "_" prefixed to avoid collisions ) type tmLogger struct { srcLogger kitlog.Logger } // NewTMTermLogger returns a logger that encodes msg and keyvals to the Writer // using go-kit's log as an underlying logger and our custom formatter. Note // that underlying logger could be swapped with something else. func NewTMLogger(w io.Writer) Logger { // Color by level value colorFn := func(keyvals ...interface{}) term.FgBgColor { if keyvals[0] != level.Key() { panic(fmt.Sprintf("expected level key to be first, got %v", keyvals[0])) } switch keyvals[1].(level.Value).String() { case "debug": return term.FgBgColor{Fg: term.DarkGray} case "error": return term.FgBgColor{Fg: term.Red} default: return term.FgBgColor{} } } srcLogger := term.NewLogger(w, NewTMFmtLogger, colorFn) srcLogger = level.NewFilter(srcLogger, level.AllowInfo()) return &tmLogger{srcLogger} } // Info logs a message at level Info. func (l *tmLogger) Info(msg string, keyvals ...interface{}) error { lWithLevel := level.Info(l.srcLogger) return kitlog.With(lWithLevel, msgKey, msg).Log(keyvals...) } // Debug logs a message at level Debug. func (l *tmLogger) Debug(msg string, keyvals ...interface{}) error { lWithLevel := level.Debug(l.srcLogger) return kitlog.With(lWithLevel, msgKey, msg).Log(keyvals...) } // Error logs a message at level Error. func (l *tmLogger) Error(msg string, keyvals ...interface{}) error { lWithLevel := level.Error(l.srcLogger) return kitlog.With(lWithLevel, msgKey, msg).Log(keyvals...) }