WorkflowForge.Extensions.Resilience.Polly 2.1.1

WorkflowForge.Extensions.Resilience.Polly

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;
using WorkflowForge.Extensions.Resilience.Polly;

// Option 1: Foundry-level middleware (applies to all operations)
using var foundry = WorkflowForge.CreateFoundry("ResilientWorkflow");
foundry.UsePollyRetry(maxRetryAttempts: 3, baseDelay: TimeSpan.FromSeconds(1));

// Option 2: Wrap individual operations
var resilientOp = PollyRetryOperation.WithRetryPolicy(
    new ActionWorkflowOperation("CallApi", async (input, foundry, ct) => { /* call external API */ }),
    maxRetryAttempts: 3,
    baseDelay: TimeSpan.FromSeconds(1));

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

// Option 3: Comprehensive policies (retry + circuit breaker + timeout)
foundry.UsePollyComprehensive(
    maxRetryAttempts: 3,
    circuitBreakerThreshold: 5,
    timeoutDuration: TimeSpan.FromSeconds(30));

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>();

See Configuration Guide for complete options.

Usage Examples

Retry with Exponential Backoff

// Foundry-level: applies retry to all operations
foundry.UsePollyRetry(maxRetryAttempts: 3, baseDelay: TimeSpan.FromSeconds(1));

Comprehensive Policies (Retry + Circuit Breaker + Timeout)

foundry.UsePollyComprehensive(
    maxRetryAttempts: 3,
    circuitBreakerThreshold: 5,
    timeoutDuration: TimeSpan.FromSeconds(30));

Code-Configured Options

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

foundry.UsePollyFromSettings(options);

Documentation

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