| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you under the Apache License, Version 2.0 (the |
| // "License"); you may not use this file except in compliance |
| // with the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, |
| // software distributed under the License is distributed on an |
| // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| // KIND, either express or implied. See the License for the |
| // specific language governing permissions and limitations |
| // under the License. |
| |
| /* |
| Package logger - configurable logging middleware |
| */ |
| package logger |
| |
| import ( |
| "errors" |
| "fmt" |
| "os" |
| "time" |
| |
| "github.com/go-kit/kit/log" |
| ) |
| |
| const ( |
| timeFormat = "2006-01-02T15:04:05.000" |
| |
| logLevelNone = iota |
| logLevelError |
| logLevelInfo |
| logLevelDebug |
| ) |
| |
| // Logger implements go-kit logger interface |
| // Adding additional functionality |
| type Logger struct { |
| logger log.Logger |
| logLevel int |
| } |
| |
| // NewLogger initializes a new Logger instance |
| // Supported log types are: text, json, none |
| func NewLogger(logType, logLevel string, options ...Option) (*Logger, error) { |
| logger := logTypeFromString(logType) |
| if logger == nil { |
| return nil, errors.New("unuspported log format") |
| } |
| |
| l := &Logger{ |
| logger: logger, |
| logLevel: logLevelFromString(logLevel), |
| } |
| |
| for _, o := range options { |
| if err := o(l); err != nil { |
| return nil, err |
| } |
| } |
| |
| return l, nil |
| } |
| |
| func logTypeFromString(logType string) log.Logger { |
| var logger log.Logger |
| switch logType { |
| case "text": |
| logger = NewLogTextLogger(os.Stdout) |
| case "fmt": |
| logger = log.NewLogfmtLogger(os.Stdout) |
| case "json": |
| logger = log.NewJSONLogger(os.Stdout) |
| case "none": |
| logger = log.NewNopLogger() |
| default: |
| return nil |
| } |
| |
| timestampFormat := log.TimestampFormat( |
| func() time.Time { return time.Now().UTC() }, |
| timeFormat, |
| ) |
| |
| logger = log.With(logger, "ts", timestampFormat) |
| |
| return logger |
| } |
| |
| func logLevelFromString(logLevel string) int { |
| switch logLevel { |
| case "error": |
| return logLevelError |
| case "info": |
| return logLevelInfo |
| case "debug": |
| return logLevelDebug |
| } |
| |
| return logLevelNone |
| } |
| |
| // Option for adding additional configurations of Logger instance |
| type Option func(l *Logger) error |
| |
| // With adds additional values to the logger |
| func With(k, v interface{}) Option { |
| return func(l *Logger) error { |
| l.logger = log.With(l.logger, k, v) |
| return nil |
| } |
| } |
| |
| // Log satisfies Logger interface |
| func (l *Logger) Log(kvals ...interface{}) error { |
| return l.logger.Log(kvals...) |
| } |
| |
| // Error log |
| func (l *Logger) Error(msg string, vals ...interface{}) { |
| if l.logLevel < logLevelError { |
| return |
| } |
| |
| _ = l.Log("t", "err", "msg", fmt.Sprintf(msg, vals...)) |
| } |
| |
| // Info log |
| func (l *Logger) Info(msg string, vals ...interface{}) { |
| if l.logLevel < logLevelInfo { |
| return |
| } |
| _ = l.Log("t", "inf", "msg", fmt.Sprintf(msg, vals...)) |
| } |
| |
| // Request log |
| func (l *Logger) Request(reqID, method, path string) { |
| if l.logLevel < logLevelInfo { |
| return |
| } |
| _ = l.Log("t", "req", "reqID", reqID, "method", method, "path", path) |
| } |
| |
| // Response log |
| func (l *Logger) Response(reqID, method, path string, statusCode int, statusText string, reqTime time.Duration) { |
| if l.logLevel < logLevelInfo { |
| return |
| } |
| |
| _ = l.Log("t", "res", "reqID", reqID, "method", method, "path", path, "statusCode", statusCode, "statusText", statusText, "time", reqTime.String()) |
| } |
| |
| // Debug log |
| func (l *Logger) Debug(msg string, vals ...interface{}) { |
| if l.logLevel < logLevelDebug { |
| return |
| } |
| _ = l.Log("t", "dbg", "msg", fmt.Sprintf(msg, vals...)) |
| } |