go-zero/core/logx/durationlogger.go

package logx

import (
	"context"
	"fmt"
	"time"

	"github.com/zeromicro/go-zero/core/timex"
)

// WithDuration returns a Logger which logs the given duration.
func WithDuration(d time.Duration) Logger {
	return &durationLogger{
		Duration: timex.ReprOfDuration(d),
	}
}

type durationLogger logEntry

func (l *durationLogger) Error(v ...interface{}) {
	l.err(fmt.Sprint(v...))
}

func (l *durationLogger) Errorf(format string, v ...interface{}) {
	l.err(fmt.Sprintf(format, v...))
}

func (l *durationLogger) Errorv(v interface{}) {
	l.err(v)
}

func (l *durationLogger) Errorw(msg string, fields ...LogField) {
	l.err(msg, fields...)
}

func (l *durationLogger) Info(v ...interface{}) {
	l.info(fmt.Sprint(v...))
}

func (l *durationLogger) Infof(format string, v ...interface{}) {
	l.info(fmt.Sprintf(format, v...))
}

func (l *durationLogger) Infov(v interface{}) {
	l.info(v)
}

func (l *durationLogger) Infow(msg string, fields ...LogField) {
	l.info(msg, fields...)
}

func (l *durationLogger) Slow(v ...interface{}) {
	l.slow(fmt.Sprint(v...))
}

func (l *durationLogger) Slowf(format string, v ...interface{}) {
	l.slow(fmt.Sprintf(format, v...))
}

func (l *durationLogger) Slowv(v interface{}) {
	l.slow(v)
}

func (l *durationLogger) Sloww(msg string, fields ...LogField) {
	l.slow(msg, fields...)
}

func (l *durationLogger) WithContext(ctx context.Context) Logger {
	return &contextLogger{
		ctx: ctx,
		logEntry: logEntry{
			Duration: l.Duration,
		},
	}
}

func (l *durationLogger) WithDuration(duration time.Duration) Logger {
	l.Duration = timex.ReprOfDuration(duration)
	return l
}

func (l *durationLogger) err(v interface{}, fields ...LogField) {
	if shallLog(ErrorLevel) {
		fields = append(fields, Field(durationKey, l.Duration))
		getWriter().Error(v, fields...)
	}
}

func (l *durationLogger) info(v interface{}, fields ...LogField) {
	if shallLog(InfoLevel) {
		fields = append(fields, Field(durationKey, l.Duration))
		getWriter().Info(v, fields...)
	}
}

func (l *durationLogger) slow(v interface{}, fields ...LogField) {
	if shallLog(ErrorLevel) {
		fields = append(fields, Field(durationKey, l.Duration))
		getWriter().Slow(v, fields...)
	}
}