labelFilter/ruleForLabel.go
@@ -4,6 +4,7 @@ "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" "github.com/golang/protobuf/proto" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" @@ -320,7 +321,12 @@ func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) { for _, url := range urls { logger.Debug("看看推送地址:",url.Url) urlPool[url.Url] <- data bytes,err1 := proto.Marshal(data) if err1 != nil { logger.Info("序列化失败:",err1) } urlPool[url.Url] <- bytes logger.Info("urlPool大小: ", urlPool[url.Url]) } }