We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4ba68f1 commit baae348Copy full SHA for baae348
resiliency/06_circuit_breaker/circuit_breaker_adv.go
@@ -96,15 +96,15 @@ func (rb *RequestBreaker) beforeRequest() error {
96
rb.options.Expiry = time.Now().Add(rb.options.Timeout)
97
return nil
98
}
99
+ return ErrTooManyRequests
100
case StateClosed:
101
if rb.options.Expiry.Before(time.Now()) {
102
rb.cnter.Reset()
103
rb.options.Expiry = time.Now().Add(rb.options.Interval)
104
-
105
106
107
- return ErrTooManyRequests
+ return nil
108
109
110
resiliency/06_circuit_breaker/circuit_breaker_test.go
@@ -71,6 +71,8 @@ func TestObjectBreaker(t *testing.T) {
71
72
73
fmt.Println(string(body.([]byte)))
74
+
75
+ log.Print("\nresult:", body.([]byte))
76
77
78
func TestFunctionalBreaker(t *testing.T) {
0 commit comments