diff --git a/loki.go b/loki.go index 27c7bce..f6a9b8b 100644 --- a/loki.go +++ b/loki.go @@ -75,7 +75,6 @@ func (c lokiWriter) Write(p []byte) (int, error) { label["level"] = model.LabelValue(li.Level) label["caller"] = model.LabelValue(li.Caller) - // 异步推送消息到服务器 _ = ants.Submit(func() { t, e := time.ParseInLocation("2006-01-02 15:04:05.000", li.Ts, time.Local) if e != nil { @@ -86,8 +85,6 @@ func (c lokiWriter) Write(p []byte) (int, error) { } }) - defer ants.Release() - return 0, nil }