AdvancedCircuitBreakerTResultSyntax
Fluent API for defining a Circuit Breaker Policy<T>.
using Polly.CircuitBreaker;
using Polly.Utilities;
using System;
using System.Runtime.CompilerServices;
namespace Polly
{
public static class AdvancedCircuitBreakerTResultSyntax
{
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak)
{
Action<DelegateResult<TResult>, TimeSpan> onBreak = delegate {
};
Action onReset = delegate {
};
return policyBuilder.AdvancedCircuitBreaker(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, onBreak, onReset);
}
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan> onBreak, Action onReset)
{
return policyBuilder.AdvancedCircuitBreaker(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, delegate(DelegateResult<TResult> outcome, TimeSpan timespan, Context _) {
onBreak(outcome, timespan);
}, delegate {
onReset();
});
}
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan, Context> onBreak, Action<Context> onReset)
{
Action onHalfOpen = delegate {
};
return policyBuilder.AdvancedCircuitBreaker(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, onBreak, onReset, onHalfOpen);
}
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan> onBreak, Action onReset, Action onHalfOpen)
{
return policyBuilder.AdvancedCircuitBreaker(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, delegate(DelegateResult<TResult> outcome, TimeSpan timespan, Context _) {
onBreak(outcome, timespan);
}, delegate {
onReset();
}, onHalfOpen);
}
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, TimeSpan, Context> onBreak, Action<Context> onReset, Action onHalfOpen)
{
return policyBuilder.AdvancedCircuitBreaker(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, delegate(DelegateResult<TResult> outcome, CircuitState _, TimeSpan timespan, Context context) {
onBreak(outcome, timespan, context);
}, onReset, onHalfOpen);
}
public static CircuitBreakerPolicy<TResult> AdvancedCircuitBreaker<TResult>(this PolicyBuilder<TResult> policyBuilder, double failureThreshold, TimeSpan samplingDuration, int minimumThroughput, TimeSpan durationOfBreak, Action<DelegateResult<TResult>, CircuitState, TimeSpan, Context> onBreak, Action<Context> onReset, Action onHalfOpen)
{
TimeSpan t = TimeSpan.FromTicks(AdvancedCircuitController<EmptyStruct>.ResolutionOfCircuitTimer);
if (failureThreshold <= 0)
throw new ArgumentOutOfRangeException("failureThreshold", "Value must be greater than zero.");
if (failureThreshold > 1)
throw new ArgumentOutOfRangeException("failureThreshold", "Value must be less than or equal to one.");
if (samplingDuration < t) {
DefaultInterpolatedStringHandler defaultInterpolatedStringHandler = new DefaultInterpolatedStringHandler(113, 1);
defaultInterpolatedStringHandler.AppendLiteral("Value must be equal to or greater than ");
defaultInterpolatedStringHandler.AppendFormatted(t.TotalMilliseconds);
defaultInterpolatedStringHandler.AppendLiteral(" milliseconds. This is the minimum resolution of the CircuitBreaker timer.");
throw new ArgumentOutOfRangeException("samplingDuration", defaultInterpolatedStringHandler.ToStringAndClear());
}
if (minimumThroughput <= 1)
throw new ArgumentOutOfRangeException("minimumThroughput", "Value must be greater than one.");
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");
AdvancedCircuitController<TResult> breakerController = new AdvancedCircuitController<TResult>(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak, onBreak, onReset, onHalfOpen);
return new CircuitBreakerPolicy<TResult>(policyBuilder, (ICircuitController<TResult>)breakerController);
}
}
}