关闭事件推送和更新依赖

panlei

2019-10-25 867be315d615ad2a702d717ead1f11f809fe66bb

关闭事件推送和更新依赖

 go.mod

@@ -3,14 +3,6 @@
go 1.12

require (
    basic.com/dbapi.git v0.0.0-20190822081128-ce924b8a905f
    basic.com/pubsub/cache.git v0.0.0-20190718093725-6a413e1d7d48
    basic.com/pubsub/protomsg.git v0.0.0-20190905061607-7b96dafe8f99
    basic.com/pubsub/sdkcompare.git v0.0.0-20190715013640-f536a4647d00
    basic.com/valib/deliver.git v0.0.0-20190531095353-25d8c3b20051
    basic.com/valib/gopherdiscovery.git v0.0.0-20190605034340-15d89d8b4e28
    basic.com/valib/gosdk.git v0.0.0-20190531034110-0062fdaaa05a // indirect
    basic.com/valib/logger.git v0.0.0-20190927065828-cb651da7c223
    github.com/Microsoft/go-winio v0.4.12 // indirect
    github.com/ajg/form v1.5.1 // indirect
    github.com/go-yaml/yaml v2.1.0+incompatible

 labelFilter/req.go

@@ -65,7 +65,7 @@
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        return
    }
    errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 3000)
    errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 2000)
    if errTimeOut != nil {
        fmt.Errorf("Failed set MaxRecvDeadline: %v", err)
        return

 main.go

@@ -7,7 +7,6 @@
    "net/http"
    _ "net/http/pprof"
    "ruleprocess/insertdata"
    "ruleprocess/labelFilter"
    "ruleprocess/structure"
    "ruleprocess/util"
    "time"
@@ -107,7 +106,7 @@
                    insertdata.InsertToEs(resultMsg)
                    logger.Debug("插入完Es所用时间：", time.Since(start))
                    //事件推送
                    go labelFilter.Judge(resultMsg)
                    //go labelFilter.Judge(resultMsg)
                //}(msg)
            }
        }