...
1 package circuitbreaker_test
2
3 import (
4 "testing"
5
6 handybreaker "github.com/streadway/handy/breaker"
7
8 "github.com/go-kit/kit/circuitbreaker"
9 )
10
11 func TestHandyBreaker(t *testing.T) {
12 var (
13 failureRatio = 0.05
14 breaker = circuitbreaker.HandyBreaker(handybreaker.NewBreaker(failureRatio))
15 primeWith = handybreaker.DefaultMinObservations * 10
16 shouldPass = func(n int) bool { return (float64(n) / float64(primeWith+n)) <= failureRatio }
17 openCircuitError = handybreaker.ErrCircuitOpen.Error()
18 )
19 testFailingEndpoint(t, breaker, primeWith, shouldPass, 0, openCircuitError)
20 }
21
View as plain text