diff --git a/pkg/logx/logx.go b/pkg/logx/logx.go index 3814ebe..17c5b62 100644 --- a/pkg/logx/logx.go +++ b/pkg/logx/logx.go @@ -3,12 +3,13 @@ package logx import ( "context" "fmt" - "gitee.com/timedb/wheatCache/pkg/event" - middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg" "os" "runtime" "strings" "time" + + "gitee.com/timedb/wheatCache/pkg/event" + middleMsg "gitee.com/timedb/wheatCache/pkg/middle-msg" ) 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{}) { logPrint(4, level, format, msg...) - - eventMiddle := event.NewEvent(middleMsg.EventNameLog) - eventMiddle.SetValue(middleMsg.MiddleMsgKey, middleMsg.LogContext{ + sendMsg := &middleMsg.LogContext{ Level: level, Data: time.Now(), Msg: fmt.Sprintf(format, msg...), Route: findPlace(4), - }) - l.produce.Call(l.ctx, eventMiddle) + } + middleMsg.SendMiddleMsg(l.ctx, l.produce, sendMsg) } func (l *upLogger) Debugln(msg ...interface{}) {