p25734189
/
wheat-cache
forked from p93542168/wheat-cache
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat(logx): update send msg mode

This commit is contained in:
bandl 2021-10-19 16:05:24 +08:00
parent 74a85e518d
commit 4a887b0e58
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/logx/logx.go
View File

@ -3,12 +3,13 @@ package logx
import ( import (
"context" "context"
"fmt" "fmt"
"gitee.com/timedb/wheatCache/pkg/event"
middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg"
"os" "os"
"runtime" "runtime"
"strings" "strings"
"time" "time"
"gitee.com/timedb/wheatCache/pkg/event"
middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg"
) )
func With(ctx context.Context, p event.ProduceInterface) *upLogger { func With(ctx context.Context, p event.ProduceInterface) *upLogger {
@ -41,15 +42,13 @@ func (l *upLogger) Panic(format string, msg ...interface{}) {
func (l *upLogger) Print(level string, format string, msg ...interface{}) { func (l *upLogger) Print(level string, format string, msg ...interface{}) {
logPrint(4, level, format, msg...) logPrint(4, level, format, msg...)
sendMsg := &middleMsg.LogContext{
eventMiddle := event.NewEvent(middleMsg.EventNameLog)
eventMiddle.SetValue(middleMsg.MiddleMsgKey, middleMsg.LogContext{
Level: level, Level: level,
Data: time.Now(), Data: time.Now(),
Msg: fmt.Sprintf(format, msg...), Msg: fmt.Sprintf(format, msg...),
Route: findPlace(4), Route: findPlace(4),
}) }
l.produce.Call(l.ctx, eventMiddle) middleMsg.SendMiddleMsg(l.ctx, l.produce, sendMsg)
} }
func (l *upLogger) Debugln(msg ...interface{}) { func (l *upLogger) Debugln(msg ...interface{}) {