Skip to content

Commit ea8b1bb

Browse files
committed
mod: update cb policy
1 parent 40b3c15 commit ea8b1bb

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

internal/config/config.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ var (
2222
defaultPhishingDb = "https://cfg.rpchub.io/agg/scam-addresses.json"
2323

2424
_Config = &Config{
25-
RequestTimeout: 90,
25+
RequestTimeout: 120,
2626
MaxRetries: 3,
2727
PhishingDb: []string{defaultPhishingDb},
2828
PhishingDbUpdateInterval: 3600,

internal/middleware/plugins/http_proxy.go

+2-5
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import (
1010

1111
"github.com/failsafe-go/failsafe-go"
1212
"github.com/failsafe-go/failsafe-go/circuitbreaker"
13-
"github.com/failsafe-go/failsafe-go/timeout"
1413
cmap "github.com/orcaman/concurrent-map/v2"
1514
"github.com/valyala/fasthttp"
1615
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"
@@ -111,13 +110,11 @@ func (m *HttpProxyMiddleware) OnProcess(session *rpc.Session) error {
111110
policies = make([]failsafe.Policy[any], 0)
112111
// circuit breaker opens after 3 failures, half-opens after 1 minute, closes after 2 successes
113112
circuitBreaker := circuitbreaker.Builder[any]().
114-
WithFailureThreshold(3).
113+
WithFailureThreshold(5).
115114
WithDelay(time.Minute).
116115
WithSuccessThreshold(2).
117116
Build()
118-
// timeout after 90 seconds
119-
timeoutPolicy := timeout.With[any](90 * time.Second)
120-
policies = append(policies, timeoutPolicy, circuitBreaker)
117+
policies = append(policies, circuitBreaker)
121118
m.policiesMap.Set(session.NodeName, policies)
122119
}
123120

0 commit comments

Comments
 (0)