PollyRedis 1.0.0

PollyRedis

Polly v8 resilience for StackExchange.Redis.
Automatic retry with exponential back-off on RedisConnectionException and RedisTimeoutException, circuit breaker to stop hammering a degraded cluster, and per-command timeout — wired up in one line via IServiceCollection or IConnectionMultiplexer.

Why PollyRedis?

Redis is often the first thing that fails under load, and StackExchange.Redis's built-in retry is limited. Production Redis clusters experience:

Installation

dotnet add package PollyRedis

Quick Start

With dependency injection

// Program.cs
builder.Services.AddSingleton<IConnectionMultiplexer>(
    ConnectionMultiplexer.Connect("localhost:6379"));

builder.Services.AddPollyRedis();

// Inject IResilientRedisDatabase wherever you need Redis
public class CacheService(IResilientRedisDatabase db)
{
    public Task<RedisValue> GetAsync(string key) => db.StringGetAsync(key);
    public Task SetAsync(string key, string value, TimeSpan ttl)
        => db.StringSetAsync(key, value, ttl);
}

Direct extension on IConnectionMultiplexer

var multiplexer = ConnectionMultiplexer.Connect("localhost:6379");
IResilientRedisDatabase db = multiplexer.GetResilientDatabase(options =>
{
    options.MaxRetries = 4;
    options.CommandTimeout = TimeSpan.FromSeconds(3);
});

var value = await db.StringGetAsync("my-key");

Configuration

builder.Services.AddPollyRedis(options =>
{
    // Retry
    options.MaxRetries = 3;                                  // default: 3
    options.BaseDelay = TimeSpan.FromMilliseconds(200);      // default: 200 ms
    options.MaxDelay = TimeSpan.FromSeconds(10);             // default: 10 s

    // Circuit breaker
    options.CircuitBreakerMinimumThroughput = 5;             // default: 5
    options.CircuitBreakerFailureRatio = 0.5;                // default: 0.5 (50%)
    options.CircuitBreakerSamplingDuration = TimeSpan.FromSeconds(30);
    options.CircuitBreakerBreakDuration = TimeSpan.FromSeconds(30);

    // Timeout (per command)
    options.CommandTimeout = TimeSpan.FromSeconds(5);        // default: 5 s

    // Add extra exception types to treat as transient
    options.AdditionalTransientExceptions.Add(typeof(SocketException));
});

Supported Operations

IResilientRedisDatabase covers the most common Redis commands:

Custom command (escape hatch)

// Any IDatabase operation wrapped in the Polly pipeline
var result = await db.ExecuteAsync(d => d.StringGetRangeAsync("key", 0, -1));

Pipeline order

Command
  └─► Retry (exponential back-off on connection/timeout errors)
        └─► Circuit Breaker (opens on sustained failures)
              └─► Timeout (per-command deadline)
                    └─► IDatabase → Redis

Comparison

Related Packages

Package	Downloads	Description
PollyChaos		Chaos engineering / fault injection for Polly v8
PollyMediatR		Polly v8 pipelines for MediatR request handlers
PollyEFCore		Polly v8 resilience for EF Core queries and SaveChanges
PollyHealthChecks		ASP.NET Core health checks for Polly v8 circuit breakers
PollyOpenAI		Polly v8 resilience for OpenAI and Azure OpenAI API calls
PollyBackoff		Custom back-off strategies for Polly v8

License

MIT