CircuitBreakerTResultSyntaxAsync
Fluent API for defining a Circuit Breaker Policy.
using Polly.CircuitBreaker;
using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace Polly
{
public static class CircuitBreakerTResultSyntaxAsync
{
public static CircuitBreakerPolicy<TResult> CircuitBreakerAsync<TResult>(this PolicyBuilder<TResult> policyBuilder, int handledEventsAllowedBeforeBreaking, TimeSpan durationOfBreak)
{
Action<DelegateResult<TResult>, TimeSpan> onBreak = delegate {
};
Action onReset = delegate {
};
return policyBuilder.CircuitBreakerAsync(handledEventsAllowedBeforeBreaking, durationOfBreak, onBreak, onReset);
}
public static CircuitBreakerPolicy<TResult> CircuitBreakerAsync<TResult>(this PolicyBuilder<TResult> policyBuilder, int handledEventsAllowedBeforeBreaking, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan> onBreak, Action onReset)
{
return policyBuilder.CircuitBreakerAsync(handledEventsAllowedBeforeBreaking, durationOfBreak, delegate(DelegateResult<TResult> outcome, TimeSpan timespan, Context context) {
onBreak(outcome, timespan);
}, delegate {
onReset();
});
}
public static CircuitBreakerPolicy<TResult> CircuitBreakerAsync<TResult>(this PolicyBuilder<TResult> policyBuilder, int handledEventsAllowedBeforeBreaking, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan, Context> onBreak, Action<Context> onReset)
{
Action onHalfOpen = delegate {
};
return policyBuilder.CircuitBreakerAsync(handledEventsAllowedBeforeBreaking, durationOfBreak, onBreak, onReset, onHalfOpen);
}
public static CircuitBreakerPolicy<TResult> CircuitBreakerAsync<TResult>(this PolicyBuilder<TResult> policyBuilder, int handledEventsAllowedBeforeBreaking, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan> onBreak, Action onReset, Action onHalfOpen)
{
return policyBuilder.CircuitBreakerAsync(handledEventsAllowedBeforeBreaking, durationOfBreak, delegate(DelegateResult<TResult> outcome, TimeSpan timespan, Context context) {
onBreak(outcome, timespan);
}, delegate {
onReset();
}, onHalfOpen);
}
public static CircuitBreakerPolicy<TResult> CircuitBreakerAsync<TResult>(this PolicyBuilder<TResult> policyBuilder, int handledEventsAllowedBeforeBreaking, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan, Context> onBreak, Action<Context> onReset, Action onHalfOpen)
{
if (handledEventsAllowedBeforeBreaking <= 0)
throw new ArgumentOutOfRangeException("handledEventsAllowedBeforeBreaking", "Value must be greater than zero.");
if (durationOfBreak < TimeSpan.Zero)
throw new ArgumentOutOfRangeException("durationOfBreak", "Value must be greater than zero.");
if (onBreak == null)
throw new ArgumentNullException("onBreak");
if (onReset == null)
throw new ArgumentNullException("onReset");
if (onHalfOpen == null)
throw new ArgumentNullException("onHalfOpen");
ConsecutiveCountCircuitController<TResult> breakerController = (ConsecutiveCountCircuitController<TResult>)new ConsecutiveCountCircuitController<TResult>(handledEventsAllowedBeforeBreaking, durationOfBreak, onBreak, onReset, onHalfOpen);
return new CircuitBreakerPolicy<TResult>((Func<Func<Context, CancellationToken, Task<TResult>>, Context, CancellationToken, bool, Task<TResult>>)((Func<Context, CancellationToken, Task<TResult>> action, Context context, CancellationToken cancellationToken, bool continueOnCapturedContext) => CircuitBreakerEngine.ImplementationAsync<TResult>(action, context, (IEnumerable<ExceptionPredicate>)policyBuilder.ExceptionPredicates, (IEnumerable<ResultPredicate<TResult>>)policyBuilder.ResultPredicates, (ICircuitController<TResult>)breakerController, cancellationToken, continueOnCapturedContext)), (IEnumerable<ExceptionPredicate>)policyBuilder.ExceptionPredicates, (IEnumerable<ResultPredicate<TResult>>)policyBuilder.ResultPredicates, (ICircuitController<TResult>)breakerController);
}
}
}