remove handlers
This commit is contained in:
andrey
@@ -1,47 +0,0 @@
|
||||
package logrus
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/sirupsen/logrus"
|
||||
"gitoa.ru/go-4devs/log"
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
"gitoa.ru/go-4devs/log/field"
|
||||
"gitoa.ru/go-4devs/log/level"
|
||||
)
|
||||
|
||||
// Standard create new standart logrus handler.
|
||||
func Standard() log.Logger {
|
||||
return New(logrus.StandardLogger())
|
||||
}
|
||||
|
||||
// New create new logrus handler.
|
||||
func New(log *logrus.Logger) log.Logger {
|
||||
return func(ctx context.Context, data *entry.Entry) (int, error) {
|
||||
lrgFields := make(logrus.Fields, data.Fields().Len())
|
||||
data.Fields().Fields(func(f field.Field) bool {
|
||||
lrgFields[f.Key] = f.Value.Any()
|
||||
|
||||
return true
|
||||
})
|
||||
|
||||
entry := log.WithContext(ctx).WithFields(lrgFields)
|
||||
|
||||
switch data.Level() {
|
||||
case level.Emergency:
|
||||
entry.Panic(data.Message())
|
||||
case level.Alert:
|
||||
entry.Fatal(data.Message())
|
||||
case level.Critical, level.Error:
|
||||
entry.Error(data.Message())
|
||||
case level.Warning:
|
||||
entry.Warn(data.Message())
|
||||
case level.Notice, level.Info:
|
||||
entry.Info(data.Message())
|
||||
case level.Debug:
|
||||
entry.Debug(data.Message())
|
||||
}
|
||||
|
||||
return 0, nil
|
||||
}
|
||||
}
|
||||
@@ -1,38 +0,0 @@
|
||||
package logrus_test
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"strings"
|
||||
"testing"
|
||||
|
||||
lgr "github.com/sirupsen/logrus"
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
"gitoa.ru/go-4devs/log/handler/logrus"
|
||||
"gitoa.ru/go-4devs/log/level"
|
||||
)
|
||||
|
||||
func TestNew(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
ctx := context.Background()
|
||||
buf := &bytes.Buffer{}
|
||||
|
||||
lgrus := lgr.New()
|
||||
lgrus.SetLevel(lgr.DebugLevel)
|
||||
lgrus.SetOutput(buf)
|
||||
lgrus.SetFormatter(&lgr.TextFormatter{
|
||||
DisableTimestamp: true,
|
||||
})
|
||||
|
||||
handler := logrus.New(lgrus)
|
||||
expect := "level=info msg=\"handle logrus message\"\n"
|
||||
|
||||
if _, err := handler(ctx, entry.New(entry.WithLevel(level.Info), entry.WithMessage("handle logrus message"))); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
|
||||
if !strings.HasSuffix(buf.String(), expect) {
|
||||
t.Errorf("invalid suffix\n got: %s\nexpect:%s\n", buf.String(), expect)
|
||||
}
|
||||
}
|
||||
@@ -1,59 +0,0 @@
|
||||
package otel
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
"gitoa.ru/go-4devs/log/field"
|
||||
"gitoa.ru/go-4devs/log/level"
|
||||
"go.opentelemetry.io/otel/attribute"
|
||||
"go.opentelemetry.io/otel/trace"
|
||||
)
|
||||
|
||||
const (
|
||||
fieldSeverityNumber = "SeverityNumber"
|
||||
fieldSeverityText = "SeverityText"
|
||||
levelFields = 2
|
||||
)
|
||||
|
||||
func levels(lvl level.Level) Level {
|
||||
switch lvl {
|
||||
case level.Emergency:
|
||||
return levelError3
|
||||
case level.Alert:
|
||||
return levelFatal
|
||||
case level.Critical:
|
||||
return levelError2
|
||||
case level.Error:
|
||||
return levelError
|
||||
case level.Warning:
|
||||
return levelWarn
|
||||
case level.Notice:
|
||||
return levelInfo2
|
||||
case level.Info:
|
||||
return levelInfo
|
||||
case level.Debug:
|
||||
return levelDebug
|
||||
}
|
||||
|
||||
return 0
|
||||
}
|
||||
|
||||
func addEvent(ctx context.Context, data *entry.Entry) {
|
||||
span := trace.SpanFromContext(ctx)
|
||||
attrs := make([]attribute.KeyValue, 0, data.Fields().Len()+levelFields)
|
||||
|
||||
lvl := levels(data.Level())
|
||||
attrs = append(attrs,
|
||||
attribute.String(fieldSeverityText, lvl.String()),
|
||||
attribute.Int(fieldSeverityNumber, int(lvl)),
|
||||
)
|
||||
|
||||
data.Fields().Fields(func(f field.Field) bool {
|
||||
attrs = append(attrs, attribute.String(f.Key, f.Value.String()))
|
||||
|
||||
return true
|
||||
})
|
||||
|
||||
span.AddEvent(data.Message(), trace.WithAttributes(attrs...))
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package otel
|
||||
|
||||
//go:generate stringer -type=Level -linecomment -output=level_string.go
|
||||
|
||||
type Level int
|
||||
|
||||
const (
|
||||
levelDebug Level = 5 // DEBUG
|
||||
levelInfo Level = 9 // INFO
|
||||
levelInfo2 Level = 10 // INFO2
|
||||
levelWarn Level = 13 // WARN
|
||||
levelError Level = 17 // ERROR
|
||||
levelError2 Level = 18 // ERROR2
|
||||
levelError3 Level = 19 // ERROR3
|
||||
levelFatal Level = 21 // FATAL
|
||||
)
|
||||
@@ -1,51 +0,0 @@
|
||||
// Code generated by "stringer -type=Level -linecomment -output=level_string.go"; DO NOT EDIT.
|
||||
|
||||
package otel
|
||||
|
||||
import "strconv"
|
||||
|
||||
func _() {
|
||||
// An "invalid array index" compiler error signifies that the constant values have changed.
|
||||
// Re-run the stringer command to generate them again.
|
||||
var x [1]struct{}
|
||||
_ = x[levelDebug-5]
|
||||
_ = x[levelInfo-9]
|
||||
_ = x[levelInfo2-10]
|
||||
_ = x[levelWarn-13]
|
||||
_ = x[levelError-17]
|
||||
_ = x[levelError2-18]
|
||||
_ = x[levelError3-19]
|
||||
_ = x[levelFatal-21]
|
||||
}
|
||||
|
||||
const (
|
||||
_Level_name_0 = "DEBUG"
|
||||
_Level_name_1 = "INFOINFO2"
|
||||
_Level_name_2 = "WARN"
|
||||
_Level_name_3 = "ERRORERROR2ERROR3"
|
||||
_Level_name_4 = "FATAL"
|
||||
)
|
||||
|
||||
var (
|
||||
_Level_index_1 = [...]uint8{0, 4, 9}
|
||||
_Level_index_3 = [...]uint8{0, 5, 11, 17}
|
||||
)
|
||||
|
||||
func (i Level) String() string {
|
||||
switch {
|
||||
case i == 5:
|
||||
return _Level_name_0
|
||||
case 9 <= i && i <= 10:
|
||||
i -= 9
|
||||
return _Level_name_1[_Level_index_1[i]:_Level_index_1[i+1]]
|
||||
case i == 13:
|
||||
return _Level_name_2
|
||||
case 17 <= i && i <= 19:
|
||||
i -= 17
|
||||
return _Level_name_3[_Level_index_3[i]:_Level_index_3[i+1]]
|
||||
case i == 21:
|
||||
return _Level_name_4
|
||||
default:
|
||||
return "Level(" + strconv.FormatInt(int64(i), 10) + ")"
|
||||
}
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package otel
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"gitoa.ru/go-4devs/log"
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
)
|
||||
|
||||
func New() log.Logger {
|
||||
return func(ctx context.Context, e *entry.Entry) (int, error) {
|
||||
addEvent(ctx, e)
|
||||
|
||||
return 0, nil
|
||||
}
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package otel
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"gitoa.ru/go-4devs/log"
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
)
|
||||
|
||||
func Middleware() log.Middleware {
|
||||
return func(ctx context.Context, e *entry.Entry, handler log.Logger) (int, error) {
|
||||
addEvent(ctx, e)
|
||||
|
||||
return handler(ctx, e)
|
||||
}
|
||||
}
|
||||
@@ -1,66 +0,0 @@
|
||||
package zap
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"gitoa.ru/go-4devs/log"
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
"gitoa.ru/go-4devs/log/field"
|
||||
"gitoa.ru/go-4devs/log/level"
|
||||
"go.uber.org/zap"
|
||||
)
|
||||
|
||||
func Nop() log.Logger {
|
||||
return New(zap.NewNop())
|
||||
}
|
||||
|
||||
func Example(options ...zap.Option) log.Logger {
|
||||
return New(zap.NewExample(options...))
|
||||
}
|
||||
|
||||
func Production(options ...zap.Option) log.Logger {
|
||||
z, err := zap.NewProduction(options...)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
return New(z)
|
||||
}
|
||||
|
||||
func Development(options ...zap.Option) log.Logger {
|
||||
z, err := zap.NewDevelopment(options...)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
return New(z)
|
||||
}
|
||||
|
||||
// New create handler by zap logger.
|
||||
func New(logger *zap.Logger) log.Logger {
|
||||
return func(ctx context.Context, data *entry.Entry) (int, error) {
|
||||
zf := make([]zap.Field, 0, data.Fields().Len())
|
||||
data.Fields().Fields(func(f field.Field) bool {
|
||||
zf = append(zf, zap.Any(f.Key, f.Value.Any()))
|
||||
|
||||
return true
|
||||
})
|
||||
|
||||
switch data.Level() {
|
||||
case level.Emergency:
|
||||
logger.Fatal(data.Message(), zf...)
|
||||
case level.Alert:
|
||||
logger.Panic(data.Message(), zf...)
|
||||
case level.Critical, level.Error:
|
||||
logger.Error(data.Message(), zf...)
|
||||
case level.Warning:
|
||||
logger.Warn(data.Message(), zf...)
|
||||
case level.Notice, level.Info:
|
||||
logger.Info(data.Message(), zf...)
|
||||
case level.Debug:
|
||||
logger.Debug(data.Message(), zf...)
|
||||
}
|
||||
|
||||
return 0, nil
|
||||
}
|
||||
}
|
||||
@@ -1,43 +0,0 @@
|
||||
package zap_test
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"testing"
|
||||
|
||||
"gitoa.ru/go-4devs/log/entry"
|
||||
"gitoa.ru/go-4devs/log/field"
|
||||
zlog "gitoa.ru/go-4devs/log/handler/zap"
|
||||
"gitoa.ru/go-4devs/log/level"
|
||||
"go.uber.org/zap"
|
||||
"go.uber.org/zap/zapcore"
|
||||
)
|
||||
|
||||
func TestNew(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
ctx := context.Background()
|
||||
buf := &bytes.Buffer{}
|
||||
core := zapcore.NewCore(zapcore.NewJSONEncoder(zapcore.EncoderConfig{
|
||||
MessageKey: "msg",
|
||||
LevelKey: "level",
|
||||
NameKey: "logger",
|
||||
EncodeLevel: zapcore.LowercaseLevelEncoder,
|
||||
EncodeTime: zapcore.ISO8601TimeEncoder,
|
||||
EncodeDuration: zapcore.StringDurationEncoder,
|
||||
}), zapcore.AddSync(buf), zapcore.DebugLevel)
|
||||
logger := zlog.New(zap.New(core))
|
||||
expect := `{"level":"info","msg":"handle zap message","env":"test"}` + "\n"
|
||||
|
||||
if _, err := logger(ctx, entry.New(
|
||||
entry.WithFields(field.String("env", "test")),
|
||||
entry.WithLevel(level.Notice),
|
||||
entry.WithMessage("handle zap message"),
|
||||
)); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
|
||||
if buf.String() != expect {
|
||||
t.Errorf("invalid message\n got: %s\nexpect:%s\n", buf.String(), expect)
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user