CircuitBreakerPolicy<TResult>
public class CircuitBreakerPolicy<TResult> : Policy<TResult>, ICircuitBreakerPolicy<TResult>, ICircuitBreakerPolicy, IsPolicy
A circuit-breaker policy that can be applied to delegates returning a value of type TResult.
using System;
using System.Diagnostics;
using System.Threading;
namespace Polly.CircuitBreaker
{
public class CircuitBreakerPolicy<TResult> : Policy<TResult>, ICircuitBreakerPolicy<TResult>, ICircuitBreakerPolicy, IsPolicy
{
internal readonly ICircuitController<TResult> BreakerController;
public CircuitState CircuitState => BreakerController.CircuitState;
public Exception LastException => BreakerController.LastException;
public TResult LastHandledResult => BreakerController.LastHandledResult;
internal CircuitBreakerPolicy(PolicyBuilder<TResult> policyBuilder, ICircuitController<TResult> breakerController)
: base(policyBuilder)
{
BreakerController = breakerController;
}
public void Isolate()
{
BreakerController.Isolate();
}
public void Reset()
{
BreakerController.Reset();
}
[DebuggerStepThrough]
protected override TResult Implementation(Func<Context, CancellationToken, TResult> action, Context context, CancellationToken cancellationToken)
{
return CircuitBreakerEngine.Implementation<TResult>(action, context, cancellationToken, base.ExceptionPredicates, base.ResultPredicates, BreakerController);
}
}
}