vendor/github.com/go-kit/kit/circuitbreaker/handy_breaker_test.go

   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 }