From: qydysky Date: Sun, 10 Mar 2024 05:55:26 +0000 (+0800) Subject: 1 X-Git-Tag: v0.1.20240310055543 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=344426390332f00e263cbcc5fde60d470cbe7e57;p=front%2F.git 1 --- diff --git a/config.go b/config.go index 5c3c1af..226df50 100755 --- a/config.go +++ b/config.go @@ -292,7 +292,7 @@ func (t *Back) Disable() { } type Dealer struct { - ErrToSec int `json:"errToSec"` + ErrToSec float64 `json:"errToSec"` ErrBanSec int `json:"errBanSec"` ReqHeader []Header `json:"reqHeader"` ResHeader []Header `json:"resHeader"` diff --git a/http.go b/http.go index 0953217..237bbae 100644 --- a/http.go +++ b/http.go @@ -66,7 +66,7 @@ func httpDealer(ctx context.Context, w http.ResponseWriter, r *http.Request, rou return errors.New("后端故障") } - if chosenBack.ErrToSec != 0 && time.Since(opT).Seconds() > float64(chosenBack.ErrToSec) { + if chosenBack.ErrToSec != 0 && time.Since(opT).Seconds() > chosenBack.ErrToSec { logger.Warn(`W:`, fmt.Sprintf("%v > %v > %v http 超时响应 %v", chosenBack.route.config.Addr, routePath, chosenBack.Name, time.Since(opT))) chosenBack.Disable() } else { diff --git a/ws.go b/ws.go index 68ffb91..3a19c4b 100644 --- a/ws.go +++ b/ws.go @@ -67,7 +67,7 @@ func wsDealer(ctx context.Context, w http.ResponseWriter, r *http.Request, route return errors.New("后端故障") } - if chosenBack.ErrToSec != 0 && time.Since(opT).Seconds() > float64(chosenBack.ErrToSec) { + if chosenBack.ErrToSec != 0 && time.Since(opT).Seconds() > chosenBack.ErrToSec { logger.Warn(`W:`, fmt.Sprintf("%v > %v > %v ws 超时响应 %v", chosenBack.route.config.Addr, routePath, chosenBack.Name, time.Since(opT))) chosenBack.Disable() } else {