main.go
@@ -16,10 +16,11 @@ "flag" "fmt" "github.com/golang/protobuf/proto" "github.com/spf13/viper" "ruleprocess/cache" "ruleprocess/ruleserver" "sync" "github.com/spf13/viper" ) var dbIp = flag.String("dbIp", "127.0.0.1", "dbserver ip") @@ -105,7 +106,7 @@ esEnd := time.Since(start) logger.Debug("插入完Es所用时间:", esEnd) //事件推送 //labelFilter.PushSomthing(resultMsg) labelFilter.PushSomthing(resultMsg) //}(msg) } }