测事件推送所用事件

panlei

2019-11-04 11082e25407ea22361c54787f84d1c1a88a93301

 main.go

@@ -103,12 +103,16 @@
               ruleserver.Judge(&arg, &m) // 把sdkMessage传进去，方便缓存数据时拼出一个resultMag
               // 把arg里的打的标签拿出来给m再封装一层
               resultMsg := structure.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult}
               logger.Debug("规则判断完所用时间：", time.Since(start))
               ruleEnd := time.Since(start)
               logger.Debug("规则判断完所用时间：", ruleEnd)
               // 将打完标签的数据插入到ES
               insertdata.InsertToEs(resultMsg)
               logger.Debug("插入完Es所用时间：", time.Since(start))
               esEnd := time.Since(start)
               logger.Debug("插入完Es所用时间：", esEnd)
               //事件推送
               // labelFilter.PushSomthing(resultMsg)
               labelFilter.PushSomthing(resultMsg)
               pushEnd := time.Since(start)
               logger.Info("事件推送完所用时间：",ruleEnd,esEnd,pushEnd)
            }(msg)
         }
      }