Source file src/github.com/go-kit/kit/circuitbreaker/gobreaker_test.go

Documentation: github.com/go-kit/kit/circuitbreaker

     1  package circuitbreaker_test
     2  
     3  import (
     4  	"testing"
     5  
     6  	"github.com/sony/gobreaker"
     7  
     8  	"github.com/go-kit/kit/circuitbreaker"
     9  )
    10  
    11  func TestGobreaker(t *testing.T) {
    12  	var (
    13  		breaker          = circuitbreaker.Gobreaker(gobreaker.NewCircuitBreaker(gobreaker.Settings{}))
    14  		primeWith        = 100
    15  		shouldPass       = func(n int) bool { return n <= 5 } // https://github.com/sony/gobreaker/blob/bfa846d/gobreaker.go#L76
    16  		circuitOpenError = "circuit breaker is open"
    17  	)
    18  	testFailingEndpoint(t, breaker, primeWith, shouldPass, 0, circuitOpenError)
    19  }
    20  

View as plain text