| | |
| | | } |
| | | //遍历所有的规则组,看看符合哪个规则组,就把数据插入到哪个规则组的目标机器上 |
| | | for _,ruleGroup := range allRules { |
| | | if ruleGroup.Enable { // 大规则开关开启状态 |
| | | // 先过时间规则 |
| | | timeJudge(label,ruleGroup) |
| | | result := "" |
| | |
| | | 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) |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | return "false" |
| | | } |
| | | // 调用目标服务器的插入接口 |
| | | func pushData (urls []*protomsg.PushIpPort, data ruleserver.ResultMsg){ |
| | | func pushData (urls []*protomsg.PushUrl, data ruleserver.ResultMsg){ |
| | | |
| | | } |