mirror of https://github.com/status-im/consul.git
528 lines
12 KiB
Go
528 lines
12 KiB
Go
package hclog
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"log"
|
|
"reflect"
|
|
"runtime"
|
|
"sort"
|
|
"strconv"
|
|
"strings"
|
|
"sync"
|
|
"sync/atomic"
|
|
"time"
|
|
)
|
|
|
|
// TimeFormat to use for logging. This is a version of RFC3339 that contains
|
|
// contains millisecond precision
|
|
const TimeFormat = "2006-01-02T15:04:05.000Z0700"
|
|
|
|
// errJsonUnsupportedTypeMsg is included in log json entries, if an arg cannot be serialized to json
|
|
const errJsonUnsupportedTypeMsg = "logging contained values that don't serialize to json"
|
|
|
|
var (
|
|
_levelToBracket = map[Level]string{
|
|
Debug: "[DEBUG]",
|
|
Trace: "[TRACE]",
|
|
Info: "[INFO] ",
|
|
Warn: "[WARN] ",
|
|
Error: "[ERROR]",
|
|
}
|
|
)
|
|
|
|
// Make sure that intLogger is a Logger
|
|
var _ Logger = &intLogger{}
|
|
|
|
// intLogger is an internal logger implementation. Internal in that it is
|
|
// defined entirely by this package.
|
|
type intLogger struct {
|
|
json bool
|
|
caller bool
|
|
name string
|
|
timeFormat string
|
|
|
|
// This is a pointer so that it's shared by any derived loggers, since
|
|
// those derived loggers share the bufio.Writer as well.
|
|
mutex *sync.Mutex
|
|
writer *writer
|
|
level *int32
|
|
|
|
implied []interface{}
|
|
}
|
|
|
|
// New returns a configured logger.
|
|
func New(opts *LoggerOptions) Logger {
|
|
if opts == nil {
|
|
opts = &LoggerOptions{}
|
|
}
|
|
|
|
output := opts.Output
|
|
if output == nil {
|
|
output = DefaultOutput
|
|
}
|
|
|
|
level := opts.Level
|
|
if level == NoLevel {
|
|
level = DefaultLevel
|
|
}
|
|
|
|
mutex := opts.Mutex
|
|
if mutex == nil {
|
|
mutex = new(sync.Mutex)
|
|
}
|
|
|
|
l := &intLogger{
|
|
json: opts.JSONFormat,
|
|
caller: opts.IncludeLocation,
|
|
name: opts.Name,
|
|
timeFormat: TimeFormat,
|
|
mutex: mutex,
|
|
writer: newWriter(output),
|
|
level: new(int32),
|
|
}
|
|
|
|
if opts.TimeFormat != "" {
|
|
l.timeFormat = opts.TimeFormat
|
|
}
|
|
|
|
atomic.StoreInt32(l.level, int32(level))
|
|
|
|
return l
|
|
}
|
|
|
|
// Log a message and a set of key/value pairs if the given level is at
|
|
// or more severe that the threshold configured in the Logger.
|
|
func (l *intLogger) Log(level Level, msg string, args ...interface{}) {
|
|
if level < Level(atomic.LoadInt32(l.level)) {
|
|
return
|
|
}
|
|
|
|
t := time.Now()
|
|
|
|
l.mutex.Lock()
|
|
defer l.mutex.Unlock()
|
|
|
|
if l.json {
|
|
l.logJSON(t, level, msg, args...)
|
|
} else {
|
|
l.log(t, level, msg, args...)
|
|
}
|
|
|
|
l.writer.Flush(level)
|
|
}
|
|
|
|
// Cleanup a path by returning the last 2 segments of the path only.
|
|
func trimCallerPath(path string) string {
|
|
// lovely borrowed from zap
|
|
// nb. To make sure we trim the path correctly on Windows too, we
|
|
// counter-intuitively need to use '/' and *not* os.PathSeparator here,
|
|
// because the path given originates from Go stdlib, specifically
|
|
// runtime.Caller() which (as of Mar/17) returns forward slashes even on
|
|
// Windows.
|
|
//
|
|
// See https://github.com/golang/go/issues/3335
|
|
// and https://github.com/golang/go/issues/18151
|
|
//
|
|
// for discussion on the issue on Go side.
|
|
|
|
// Find the last separator.
|
|
idx := strings.LastIndexByte(path, '/')
|
|
if idx == -1 {
|
|
return path
|
|
}
|
|
|
|
// Find the penultimate separator.
|
|
idx = strings.LastIndexByte(path[:idx], '/')
|
|
if idx == -1 {
|
|
return path
|
|
}
|
|
|
|
return path[idx+1:]
|
|
}
|
|
|
|
// Non-JSON logging format function
|
|
func (l *intLogger) log(t time.Time, level Level, msg string, args ...interface{}) {
|
|
l.writer.WriteString(t.Format(l.timeFormat))
|
|
l.writer.WriteByte(' ')
|
|
|
|
s, ok := _levelToBracket[level]
|
|
if ok {
|
|
l.writer.WriteString(s)
|
|
} else {
|
|
l.writer.WriteString("[?????]")
|
|
}
|
|
|
|
if l.caller {
|
|
if _, file, line, ok := runtime.Caller(3); ok {
|
|
l.writer.WriteByte(' ')
|
|
l.writer.WriteString(trimCallerPath(file))
|
|
l.writer.WriteByte(':')
|
|
l.writer.WriteString(strconv.Itoa(line))
|
|
l.writer.WriteByte(':')
|
|
}
|
|
}
|
|
|
|
l.writer.WriteByte(' ')
|
|
|
|
if l.name != "" {
|
|
l.writer.WriteString(l.name)
|
|
l.writer.WriteString(": ")
|
|
}
|
|
|
|
l.writer.WriteString(msg)
|
|
|
|
args = append(l.implied, args...)
|
|
|
|
var stacktrace CapturedStacktrace
|
|
|
|
if args != nil && len(args) > 0 {
|
|
if len(args)%2 != 0 {
|
|
cs, ok := args[len(args)-1].(CapturedStacktrace)
|
|
if ok {
|
|
args = args[:len(args)-1]
|
|
stacktrace = cs
|
|
} else {
|
|
args = append(args, "<unknown>")
|
|
}
|
|
}
|
|
|
|
l.writer.WriteByte(':')
|
|
|
|
FOR:
|
|
for i := 0; i < len(args); i = i + 2 {
|
|
var (
|
|
val string
|
|
raw bool
|
|
)
|
|
|
|
switch st := args[i+1].(type) {
|
|
case string:
|
|
val = st
|
|
case int:
|
|
val = strconv.FormatInt(int64(st), 10)
|
|
case int64:
|
|
val = strconv.FormatInt(int64(st), 10)
|
|
case int32:
|
|
val = strconv.FormatInt(int64(st), 10)
|
|
case int16:
|
|
val = strconv.FormatInt(int64(st), 10)
|
|
case int8:
|
|
val = strconv.FormatInt(int64(st), 10)
|
|
case uint:
|
|
val = strconv.FormatUint(uint64(st), 10)
|
|
case uint64:
|
|
val = strconv.FormatUint(uint64(st), 10)
|
|
case uint32:
|
|
val = strconv.FormatUint(uint64(st), 10)
|
|
case uint16:
|
|
val = strconv.FormatUint(uint64(st), 10)
|
|
case uint8:
|
|
val = strconv.FormatUint(uint64(st), 10)
|
|
case CapturedStacktrace:
|
|
stacktrace = st
|
|
continue FOR
|
|
case Format:
|
|
val = fmt.Sprintf(st[0].(string), st[1:]...)
|
|
default:
|
|
v := reflect.ValueOf(st)
|
|
if v.Kind() == reflect.Slice {
|
|
val = l.renderSlice(v)
|
|
raw = true
|
|
} else {
|
|
val = fmt.Sprintf("%v", st)
|
|
}
|
|
}
|
|
|
|
l.writer.WriteByte(' ')
|
|
l.writer.WriteString(args[i].(string))
|
|
l.writer.WriteByte('=')
|
|
|
|
if !raw && strings.ContainsAny(val, " \t\n\r") {
|
|
l.writer.WriteByte('"')
|
|
l.writer.WriteString(val)
|
|
l.writer.WriteByte('"')
|
|
} else {
|
|
l.writer.WriteString(val)
|
|
}
|
|
}
|
|
}
|
|
|
|
l.writer.WriteString("\n")
|
|
|
|
if stacktrace != "" {
|
|
l.writer.WriteString(string(stacktrace))
|
|
}
|
|
}
|
|
|
|
func (l *intLogger) renderSlice(v reflect.Value) string {
|
|
var buf bytes.Buffer
|
|
|
|
buf.WriteRune('[')
|
|
|
|
for i := 0; i < v.Len(); i++ {
|
|
if i > 0 {
|
|
buf.WriteString(", ")
|
|
}
|
|
|
|
sv := v.Index(i)
|
|
|
|
var val string
|
|
|
|
switch sv.Kind() {
|
|
case reflect.String:
|
|
val = sv.String()
|
|
case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
|
|
val = strconv.FormatInt(sv.Int(), 10)
|
|
case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
|
|
val = strconv.FormatUint(sv.Uint(), 10)
|
|
default:
|
|
val = fmt.Sprintf("%v", sv.Interface())
|
|
}
|
|
|
|
if strings.ContainsAny(val, " \t\n\r") {
|
|
buf.WriteByte('"')
|
|
buf.WriteString(val)
|
|
buf.WriteByte('"')
|
|
} else {
|
|
buf.WriteString(val)
|
|
}
|
|
}
|
|
|
|
buf.WriteRune(']')
|
|
|
|
return buf.String()
|
|
}
|
|
|
|
// JSON logging function
|
|
func (l *intLogger) logJSON(t time.Time, level Level, msg string, args ...interface{}) {
|
|
vals := l.jsonMapEntry(t, level, msg)
|
|
args = append(l.implied, args...)
|
|
|
|
if args != nil && len(args) > 0 {
|
|
if len(args)%2 != 0 {
|
|
cs, ok := args[len(args)-1].(CapturedStacktrace)
|
|
if ok {
|
|
args = args[:len(args)-1]
|
|
vals["stacktrace"] = cs
|
|
} else {
|
|
args = append(args, "<unknown>")
|
|
}
|
|
}
|
|
|
|
for i := 0; i < len(args); i = i + 2 {
|
|
if _, ok := args[i].(string); !ok {
|
|
// As this is the logging function not much we can do here
|
|
// without injecting into logs...
|
|
continue
|
|
}
|
|
val := args[i+1]
|
|
switch sv := val.(type) {
|
|
case error:
|
|
// Check if val is of type error. If error type doesn't
|
|
// implement json.Marshaler or encoding.TextMarshaler
|
|
// then set val to err.Error() so that it gets marshaled
|
|
switch sv.(type) {
|
|
case json.Marshaler, encoding.TextMarshaler:
|
|
default:
|
|
val = sv.Error()
|
|
}
|
|
case Format:
|
|
val = fmt.Sprintf(sv[0].(string), sv[1:]...)
|
|
}
|
|
|
|
vals[args[i].(string)] = val
|
|
}
|
|
}
|
|
|
|
err := json.NewEncoder(l.writer).Encode(vals)
|
|
if err != nil {
|
|
if _, ok := err.(*json.UnsupportedTypeError); ok {
|
|
plainVal := l.jsonMapEntry(t, level, msg)
|
|
plainVal["@warn"] = errJsonUnsupportedTypeMsg
|
|
|
|
json.NewEncoder(l.writer).Encode(plainVal)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (l intLogger) jsonMapEntry(t time.Time, level Level, msg string) map[string]interface{} {
|
|
vals := map[string]interface{}{
|
|
"@message": msg,
|
|
"@timestamp": t.Format("2006-01-02T15:04:05.000000Z07:00"),
|
|
}
|
|
|
|
var levelStr string
|
|
switch level {
|
|
case Error:
|
|
levelStr = "error"
|
|
case Warn:
|
|
levelStr = "warn"
|
|
case Info:
|
|
levelStr = "info"
|
|
case Debug:
|
|
levelStr = "debug"
|
|
case Trace:
|
|
levelStr = "trace"
|
|
default:
|
|
levelStr = "all"
|
|
}
|
|
|
|
vals["@level"] = levelStr
|
|
|
|
if l.name != "" {
|
|
vals["@module"] = l.name
|
|
}
|
|
|
|
if l.caller {
|
|
if _, file, line, ok := runtime.Caller(4); ok {
|
|
vals["@caller"] = fmt.Sprintf("%s:%d", file, line)
|
|
}
|
|
}
|
|
return vals
|
|
}
|
|
|
|
// Emit the message and args at DEBUG level
|
|
func (l *intLogger) Debug(msg string, args ...interface{}) {
|
|
l.Log(Debug, msg, args...)
|
|
}
|
|
|
|
// Emit the message and args at TRACE level
|
|
func (l *intLogger) Trace(msg string, args ...interface{}) {
|
|
l.Log(Trace, msg, args...)
|
|
}
|
|
|
|
// Emit the message and args at INFO level
|
|
func (l *intLogger) Info(msg string, args ...interface{}) {
|
|
l.Log(Info, msg, args...)
|
|
}
|
|
|
|
// Emit the message and args at WARN level
|
|
func (l *intLogger) Warn(msg string, args ...interface{}) {
|
|
l.Log(Warn, msg, args...)
|
|
}
|
|
|
|
// Emit the message and args at ERROR level
|
|
func (l *intLogger) Error(msg string, args ...interface{}) {
|
|
l.Log(Error, msg, args...)
|
|
}
|
|
|
|
// Indicate that the logger would emit TRACE level logs
|
|
func (l *intLogger) IsTrace() bool {
|
|
return Level(atomic.LoadInt32(l.level)) == Trace
|
|
}
|
|
|
|
// Indicate that the logger would emit DEBUG level logs
|
|
func (l *intLogger) IsDebug() bool {
|
|
return Level(atomic.LoadInt32(l.level)) <= Debug
|
|
}
|
|
|
|
// Indicate that the logger would emit INFO level logs
|
|
func (l *intLogger) IsInfo() bool {
|
|
return Level(atomic.LoadInt32(l.level)) <= Info
|
|
}
|
|
|
|
// Indicate that the logger would emit WARN level logs
|
|
func (l *intLogger) IsWarn() bool {
|
|
return Level(atomic.LoadInt32(l.level)) <= Warn
|
|
}
|
|
|
|
// Indicate that the logger would emit ERROR level logs
|
|
func (l *intLogger) IsError() bool {
|
|
return Level(atomic.LoadInt32(l.level)) <= Error
|
|
}
|
|
|
|
// Return a sub-Logger for which every emitted log message will contain
|
|
// the given key/value pairs. This is used to create a context specific
|
|
// Logger.
|
|
func (l *intLogger) With(args ...interface{}) Logger {
|
|
if len(args)%2 != 0 {
|
|
panic("With() call requires paired arguments")
|
|
}
|
|
|
|
sl := *l
|
|
|
|
result := make(map[string]interface{}, len(l.implied)+len(args))
|
|
keys := make([]string, 0, len(l.implied)+len(args))
|
|
|
|
// Read existing args, store map and key for consistent sorting
|
|
for i := 0; i < len(l.implied); i += 2 {
|
|
key := l.implied[i].(string)
|
|
keys = append(keys, key)
|
|
result[key] = l.implied[i+1]
|
|
}
|
|
// Read new args, store map and key for consistent sorting
|
|
for i := 0; i < len(args); i += 2 {
|
|
key := args[i].(string)
|
|
_, exists := result[key]
|
|
if !exists {
|
|
keys = append(keys, key)
|
|
}
|
|
result[key] = args[i+1]
|
|
}
|
|
|
|
// Sort keys to be consistent
|
|
sort.Strings(keys)
|
|
|
|
sl.implied = make([]interface{}, 0, len(l.implied)+len(args))
|
|
for _, k := range keys {
|
|
sl.implied = append(sl.implied, k)
|
|
sl.implied = append(sl.implied, result[k])
|
|
}
|
|
|
|
return &sl
|
|
}
|
|
|
|
// Create a new sub-Logger that a name decending from the current name.
|
|
// This is used to create a subsystem specific Logger.
|
|
func (l *intLogger) Named(name string) Logger {
|
|
sl := *l
|
|
|
|
if sl.name != "" {
|
|
sl.name = sl.name + "." + name
|
|
} else {
|
|
sl.name = name
|
|
}
|
|
|
|
return &sl
|
|
}
|
|
|
|
// Create a new sub-Logger with an explicit name. This ignores the current
|
|
// name. This is used to create a standalone logger that doesn't fall
|
|
// within the normal hierarchy.
|
|
func (l *intLogger) ResetNamed(name string) Logger {
|
|
sl := *l
|
|
|
|
sl.name = name
|
|
|
|
return &sl
|
|
}
|
|
|
|
// Update the logging level on-the-fly. This will affect all subloggers as
|
|
// well.
|
|
func (l *intLogger) SetLevel(level Level) {
|
|
atomic.StoreInt32(l.level, int32(level))
|
|
}
|
|
|
|
// Create a *log.Logger that will send it's data through this Logger. This
|
|
// allows packages that expect to be using the standard library log to actually
|
|
// use this logger.
|
|
func (l *intLogger) StandardLogger(opts *StandardLoggerOptions) *log.Logger {
|
|
if opts == nil {
|
|
opts = &StandardLoggerOptions{}
|
|
}
|
|
|
|
return log.New(l.StandardWriter(opts), "", 0)
|
|
}
|
|
|
|
func (l *intLogger) StandardWriter(opts *StandardLoggerOptions) io.Writer {
|
|
return &stdlogAdapter{
|
|
log: l,
|
|
inferLevels: opts.InferLevels,
|
|
forceLevel: opts.ForceLevel,
|
|
}
|
|
}
|