labelFilter/req.go
@@ -145,11 +145,12 @@ if err = sock.Send(data); err != nil { Die("groutine"+url+"推送socket发送数据失败: ", err.Error()) } pushTime := time.Since(start) msg, err = sock.Recv(); if err != nil { Die("groutine"+url+"接收响应失败: ", err.Error(),time.Since(start)) Die("groutine"+url+"接收响应失败: ", err.Error(),pushTime,time.Since(start)) } else { logger.Debug("事件推送成功!groutine"+url+"收到响应",string(msg),time.Since(start)) logger.Debug("事件推送成功!groutine"+url+"收到响应",string(msg),pushTime,time.Since(start)) } default: