Polly Circuitbreaker

ICircuitBreaker.cs

public interface ICircuitBreaker
{
    TResult Execute(Func action);
    void Execute(Action action);
}

ICircuitBreakerSettings.cs

public interface ICircuitBreakerSettings
{
    int BreakOnNumberOfExceptions { get; }
    int BreakCircuitForSeconds { get; }
}

PollyCircuitBreaker.cs

public class PollyCircuitBreaker : ICircuitBreaker
{
    private readonly Policy _policy;
    public PollyCircuitBreaker(ICircuitBreakerSettings settings)
    {
        try
        {
            _policy = Policy
                .Handle<Exception>()
                .CircuitBreaker(settings.BreakOnNumberOfExceptions,
                    TimeSpan.FromSeconds(settings.BreakCircuitForSeconds));
        }
        catch (Exception ex)
        {
            _policy = null;
            //Log policy configuration issue
        }
   }

public TResult Execute<TResult>(Func<TResult> action)
{
    if (_policy == null)
    {
        return action.Invoke();
    }
    else
    {
        try
        {
            return _policy.Execute(action);
        }
        catch (BrokenCircuitException ex)
        {
            throw new CircuitBrokenException("Broken circuit", ex);
        }
    }
 }

public void Execute(Action action)
{
    if (_policy == null)
    {
        action.Invoke();
    }
    else
    {
        try
        {
            _policy.Execute(action);
        }
        catch (BrokenCircuitException ex)
        {
            throw new CircuitBrokenException("Broken circuit", ex);
        }
    }
}