Codebase list golang-github-go-kit-kit / d2f2902b-79c4-43cd-8c09-341e33fc6017/v0.11.0 circuitbreaker / gobreaker.go
d2f2902b-79c4-43cd-8c09-341e33fc6017/v0.11.0

Tree @d2f2902b-79c4-43cd-8c09-341e33fc6017/v0.11.0 (Download .tar.gz)

gobreaker.go @d2f2902b-79c4-43cd-8c09-341e33fc6017/v0.11.0raw · history · blame

package circuitbreaker

import (
	"context"

	"github.com/sony/gobreaker"

	"github.com/go-kit/kit/endpoint"
)

// Gobreaker returns an endpoint.Middleware that implements the circuit
// breaker pattern using the sony/gobreaker package. Only errors returned by
// the wrapped endpoint count against the circuit breaker's error count.
//
// See http://godoc.org/github.com/sony/gobreaker for more information.
func Gobreaker(cb *gobreaker.CircuitBreaker) endpoint.Middleware {
	return func(next endpoint.Endpoint) endpoint.Endpoint {
		return func(ctx context.Context, request interface{}) (interface{}, error) {
			return cb.Execute(func() (interface{}, error) { return next(ctx, request) })
		}
	}
}