测事件推送所用事件

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)
            }
        }