WorkflowForge.Extensions.Resilience.Polly 2.0.0

WorkflowForge.Extensions.Resilience.Polly

<p align="center"> <img src="https://raw.githubusercontent.com/animatlabs/workflow-forge/main/icon.png" alt="WorkflowForge" width="120" height="120"> </p>

Advanced resilience extension for WorkflowForge with Polly integration for retry, circuit breaker, timeout, and rate limiting policies.

Dependency Isolation

This extension internalizes Polly with ILRepack. This means:

• Reduced dependency conflicts for Polly
• Public APIs stay WorkflowForge/BCL only
• Microsoft/System assemblies remain external

Installation

dotnet add package WorkflowForge.Extensions.Resilience.Polly

Requires: .NET Standard 2.0 or later

Quick Start

using WorkflowForge.Extensions.Resilience.Polly;
using Polly;

// Configure retry policy
var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetryAsync(
        retryCount: 3,
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)),
        onRetry: (exception, timeSpan, retryCount, context) =>
        {
            logger.LogWarning("Retry {RetryCount} after {Delay}ms", 
                retryCount, timeSpan.TotalMilliseconds);
        });

// Wrap operation with policy
var operation = new PollyWrappedOperation<HttpResponseMessage>(
    new CallExternalApiOperation(),
    retryPolicy);

var workflow = WorkflowForge.CreateWorkflow("ResilientWorkflow")
    .AddOperation(operation)
    .Build();

Key Features

• Retry Policies: Exponential backoff, fixed intervals, jitter
• Circuit Breaker: Prevent cascading failures
• Timeout: Operation-level timeouts
• Rate Limiting: Control operation throughput
• Policy Composition: Combine multiple policies
• Full Polly Integration: Access entire Polly ecosystem

Configuration

Via appsettings.json

{
  "WorkflowForge": {
    "Extensions": {
      "Polly": {
        "Enabled": true,
        "EnableComprehensivePolicies": false,
        "EnableDetailedLogging": true,
        "DefaultTags": {
          "environment": "production",
          "application": "my-app"
        },
        "Retry": {
          "IsEnabled": true,
          "MaxRetryAttempts": 3,
          "BaseDelay": "00:00:01",
          "BackoffType": "Exponential",
          "UseJitter": true
        },
        "CircuitBreaker": {
          "IsEnabled": true,
          "FailureThreshold": 5,
          "BreakDuration": "00:00:30",
          "SamplingDuration": "00:00:30",
          "MinimumThroughput": 10
        },
        "Timeout": {
          "IsEnabled": true,
          "DefaultTimeout": "00:00:30",
          "UseOptimisticTimeout": true
        },
        "RateLimiter": {
          "IsEnabled": false,
          "PermitLimit": 100,
          "Window": "00:01:00",
          "QueueLimit": 0
        }
      }
    }
  }
}

Via Code

using WorkflowForge.Extensions.Resilience.Polly.Options;

var options = new PollyMiddlewareOptions
{
    Enabled = true,
    Retry = { IsEnabled = true, MaxRetryAttempts = 3, BaseDelay = TimeSpan.FromSeconds(1) },
    CircuitBreaker = { IsEnabled = true, FailureThreshold = 5 },
    Timeout = { IsEnabled = true, DefaultTimeout = TimeSpan.FromSeconds(30) }
};

foundry.UsePollyFromSettings(options);

Via Dependency Injection

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using WorkflowForge.Extensions.Resilience.Polly;

services.AddWorkflowForgePolly(configuration, PollyMiddlewareOptions.DefaultSectionName);
var options = serviceProvider.GetRequiredService<PollyMiddlewareOptions>();

Preset Configurations

// Development settings (minimal retry)
var devOptions = PollyMiddlewareOptions.ForDevelopment();

// Production settings (retry + circuit breaker)
var prodOptions = PollyMiddlewareOptions.ForProduction();

// Enterprise settings (all policies enabled)
var enterpriseOptions = PollyMiddlewareOptions.ForEnterprise();

// Minimal settings (basic retry only)
var minimalOptions = PollyMiddlewareOptions.Minimal();

See Configuration Guide for complete options.

Policy Examples

Retry with Exponential Backoff

var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetryAsync(3, 
        attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)));

Circuit Breaker

var circuitBreakerPolicy = Policy
    .Handle<HttpRequestException>()
    .CircuitBreakerAsync(5, TimeSpan.FromSeconds(30));

Timeout

var timeoutPolicy = Policy
    .TimeoutAsync(TimeSpan.FromSeconds(30));

Combined Policies

var combinedPolicy = Policy.WrapAsync(
    retryPolicy,
    circuitBreakerPolicy,
    timeoutPolicy);

Documentation

• Getting Started
• Configuration Guide
• Extensions Overview
• Sample 14: Polly Resilience