panlei
2019-07-30 44441d5439df4e81d641b115c94b079ace31a5c6
labelFilter/ruleForLabel.go
@@ -19,6 +19,7 @@
   }
   //遍历所有的规则组,看看符合哪个规则组,就把数据插入到哪个规则组的目标机器上
   for _,ruleGroup := range allRules {
      if ruleGroup.Enable {  // 大规则开关开启状态
      // 先过时间规则
      timeJudge(label,ruleGroup)
      result := ""
@@ -57,12 +58,14 @@
         if err1 != nil {
            logger.Error("带入参数有误")
         }
            logger.Warn("规则判断结果是:",)
         if result.(bool) {
            logger.Info("通过规则,表达式为:",result)
            // 推送服务器
            pushData(ruleGroup.IpPorts,result.(ruleserver.ResultMsg))
               pushData(ruleGroup.Urls,result.(ruleserver.ResultMsg))
         } else {
            logger.Info("没通过规则,表达式为:",result)
            }
         }
      }
   }
@@ -187,6 +190,6 @@
   return "false"
}
// 调用目标服务器的插入接口
func pushData (urls []*protomsg.PushIpPort, data ruleserver.ResultMsg){
func pushData (urls []*protomsg.PushUrl, data ruleserver.ResultMsg){
}