From 344426390332f00e263cbcc5fde60d470cbe7e57 Mon Sep 17 00:00:00 2001 From: qydysky Date: Sun, 10 Mar 2024 13:55:26 +0800 Subject: [PATCH] 1 --- config.go | 2 +- http.go | 2 +- ws.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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 { -- 2.39.2