| | |
| | | package labelFilter |
| | | |
| | | import ( |
| | | "basic.com/valib/logger.git" |
| | | "fmt" |
| | | "github.com/golang/protobuf/proto" |
| | | "nanomsg.org/go-mangos" |
| | | "nanomsg.org/go-mangos/protocol/rep" |
| | | "nanomsg.org/go-mangos/protocol/req" |
| | | "nanomsg.org/go-mangos/transport/ipc" |
| | | "nanomsg.org/go-mangos/transport/tcp" |
| | | "os" |
| | | "github.com/golang/protobuf/proto" |
| | | "ruleprocess/logger" |
| | | "ruleprocess/ruleserver" |
| | | "ruleprocess/structure" |
| | | "time" |
| | | ) |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | func Push(url string,data ruleserver.ResultMsg) { |
| | | func Push(url string,data structure.ResultMsg) { |
| | | var sock mangos.Socket |
| | | var err error |
| | | var msg []byte |