labelFilter/req.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
main.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
labelFilter/req.go
@@ -111,7 +111,7 @@ logger.Info("序列化数据") for v := range urlPool[url]{ logger.Info(v) logger.Info("无限循环",v) } //for { main.go
@@ -108,7 +108,7 @@ insertdata.InsertToEs(resultMsg) logger.Debug("插入完Es所用时间:", time.Since(start)) //事件推送 go labelFilter.PushSomthing(resultMsg) labelFilter.PushSomthing(resultMsg) //}(msg) } }