mirror/go-pattern-examples
1
0
Fork 0
mirror of https://github.com/crazybber/go-pattern-examples.git synced 2024-11-25 21:26:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix logic flow and test

Browse Source
This commit is contained in:
eamon 2020-06-04 17:39:45 +08:00
parent 4ba68f1cbd
commit baae348eb8
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
resiliency/06_circuit_breaker/circuit_breaker_adv.go
View File

@ -96,15 +96,15 @@ func (rb *RequestBreaker) beforeRequest() error {
rb.options.Expiry = time.Now().Add(rb.options.Timeout) rb.options.Expiry = time.Now().Add(rb.options.Timeout)
return nil return nil
} }
return ErrTooManyRequests
case StateClosed: case StateClosed:
if rb.options.Expiry.Before(time.Now()) { if rb.options.Expiry.Before(time.Now()) {
rb.cnter.Reset() rb.cnter.Reset()
rb.options.Expiry = time.Now().Add(rb.options.Interval) rb.options.Expiry = time.Now().Add(rb.options.Interval)
} }
} }
return ErrTooManyRequests return nil
} }

2
resiliency/06_circuit_breaker/circuit_breaker_test.go
View File

@ -71,6 +71,8 @@ func TestObjectBreaker(t *testing.T) {
} }
fmt.Println(string(body.([]byte))) fmt.Println(string(body.([]byte)))
log.Print("\nresult:", body.([]byte))
} }
func TestFunctionalBreaker(t *testing.T) { func TestFunctionalBreaker(t *testing.T) {