167 lines
3.8 KiB
Go
167 lines
3.8 KiB
Go
package logger // import "go.unistack.org/micro/v3/logger/wrapper"
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
|
|
rutil "go.unistack.org/micro/v3/util/reflect"
|
|
)
|
|
|
|
// LogFunc function used for Log method
|
|
type LogFunc func(ctx context.Context, level Level, args ...interface{})
|
|
|
|
// LogfFunc function used for Logf method
|
|
type LogfFunc func(ctx context.Context, level Level, msg string, args ...interface{})
|
|
|
|
type Wrapper interface {
|
|
// Log logs message with needed level
|
|
Log(LogFunc) LogFunc
|
|
// Logf logs message with needed level
|
|
Logf(LogfFunc) LogfFunc
|
|
}
|
|
|
|
var _ Logger = &omitLogger{}
|
|
|
|
type omitLogger struct {
|
|
l Logger
|
|
}
|
|
|
|
func NewOmitLogger(l Logger) Logger {
|
|
return &omitLogger{l: l}
|
|
}
|
|
|
|
func (w *omitLogger) Init(opts ...Option) error {
|
|
return w.l.Init(append(opts, WrapLogger(NewOmitWrapper()))...)
|
|
}
|
|
|
|
func (w *omitLogger) V(level Level) bool {
|
|
return w.l.V(level)
|
|
}
|
|
|
|
func (w *omitLogger) Level(level Level) {
|
|
w.l.Level(level)
|
|
}
|
|
|
|
func (w *omitLogger) Clone(opts ...Option) Logger {
|
|
return w.l.Clone(opts...)
|
|
}
|
|
|
|
func (w *omitLogger) Options() Options {
|
|
return w.l.Options()
|
|
}
|
|
|
|
func (w *omitLogger) Fields(fields ...interface{}) Logger {
|
|
return w.l.Fields(fields...)
|
|
}
|
|
|
|
func (w *omitLogger) Info(ctx context.Context, args ...interface{}) {
|
|
w.l.Info(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Trace(ctx context.Context, args ...interface{}) {
|
|
w.l.Trace(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Debug(ctx context.Context, args ...interface{}) {
|
|
w.l.Debug(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Warn(ctx context.Context, args ...interface{}) {
|
|
w.l.Warn(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Error(ctx context.Context, args ...interface{}) {
|
|
w.l.Error(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Fatal(ctx context.Context, args ...interface{}) {
|
|
w.l.Fatal(ctx, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Infof(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Infof(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Tracef(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Tracef(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Debugf(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Debugf(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Warnf(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Warnf(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Errorf(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Errorf(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Fatalf(ctx context.Context, msg string, args ...interface{}) {
|
|
w.l.Fatalf(ctx, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Log(ctx context.Context, level Level, args ...interface{}) {
|
|
w.l.Log(ctx, level, args...)
|
|
}
|
|
|
|
func (w *omitLogger) Logf(ctx context.Context, level Level, msg string, args ...interface{}) {
|
|
w.l.Logf(ctx, level, msg, args...)
|
|
}
|
|
|
|
func (w *omitLogger) String() string {
|
|
return w.l.String()
|
|
}
|
|
|
|
type omitWrapper struct{}
|
|
|
|
func NewOmitWrapper() Wrapper {
|
|
return &omitWrapper{}
|
|
}
|
|
|
|
func getArgs(args []interface{}) []interface{} {
|
|
nargs := make([]interface{}, 0, len(args))
|
|
var err error
|
|
for _, arg := range args {
|
|
val := reflect.ValueOf(arg)
|
|
if val.Kind() == reflect.Ptr {
|
|
val = val.Elem()
|
|
}
|
|
narg := arg
|
|
if val.Kind() != reflect.Struct {
|
|
nargs = append(nargs, narg)
|
|
continue
|
|
}
|
|
|
|
if narg, err = rutil.Zero(arg); err != nil {
|
|
nargs = append(nargs, narg)
|
|
continue
|
|
}
|
|
|
|
rutil.CopyDefaults(narg, arg)
|
|
if flds, ferr := rutil.StructFields(narg); ferr == nil {
|
|
for _, fld := range flds {
|
|
if tv, ok := fld.Field.Tag.Lookup("logger"); ok && tv == "omit" {
|
|
fld.Value.Set(reflect.Zero(fld.Value.Type()))
|
|
}
|
|
}
|
|
}
|
|
|
|
nargs = append(nargs, narg)
|
|
}
|
|
return nargs
|
|
}
|
|
|
|
func (w *omitWrapper) Log(fn LogFunc) LogFunc {
|
|
return func(ctx context.Context, level Level, args ...interface{}) {
|
|
fn(ctx, level, getArgs(args)...)
|
|
}
|
|
}
|
|
|
|
func (w *omitWrapper) Logf(fn LogfFunc) LogfFunc {
|
|
return func(ctx context.Context, level Level, msg string, args ...interface{}) {
|
|
fn(ctx, level, msg, getArgs(args)...)
|
|
}
|
|
}
|