Aaron.Akka.Discovery.Redis 0.2.0

Akka.NET Aspire Plugin

Automated Akka.NET cluster formation for .NET Aspire. Configure your cluster topology in the AppHost, and each service replica will automatically discover peers, form a cluster, and report health status.

Packages

Usage

AppHost

using Aaron.Akka.Aspire.Hosting;

var builder = DistributedApplication.CreateBuilder(args);

var redis = builder.AddRedis("akka-discovery");

var akka = builder.AddAkka("my-cluster")
    .WithClustering(redis);

builder.AddProject<Projects.MyService>("service")
    .WithHttpEndpoint(name: "http")
    .WithReplicas(3)
    .WithReference(akka);

builder.Build().Run();

Service (Redis Discovery)

using Aaron.Akka.Aspire;
using Aaron.Akka.Discovery.Redis;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddAkka("MySystem", (akkaBuilder, sp) =>
{
    akkaBuilder.WithAspireClusterBootstrap(sp,
        configureDiscovery: (b, config) =>
        {
            var redisConn = config.GetConnectionString("akka-discovery");
            if (!string.IsNullOrEmpty(redisConn))
                b.WithRedisDiscovery(redisConn, config["Akka:Cluster:ServiceName"]);
        },
        clusterConfigure: c => c.Roles = ["my-service"]);
});

builder.Services.AddHealthChecks();
var app = builder.Build();

app.MapHealthChecks("/healthz");
app.MapGet("/", () => "Hello from Akka.NET!");
app.Run();

WithAspireClusterBootstrap configures Akka.Remote, Akka.Cluster, Akka.Management, Cluster Bootstrap, and health checks from the environment variables that the hosting package injects. The configureDiscovery callback wires up the discovery plugin using the same IConfiguration that Aspire populates. No manual HOCON needed.

How It Works

The hosting package (WithReference(akka)) injects environment variables into each service replica:

• Akka__Cluster__Enabled - enables clustering
• Akka__Cluster__RemotePort / Akka__Cluster__ManagementPort - unique ports per replica
• Akka__Cluster__PublicHostName / Akka__Cluster__ServiceName - discovery identity
• Akka__Cluster__RequiredContactPointsNr - derived from replica count
• Akka__Cluster__Clustering__ProviderType - auto-detected from the resource type (e.g. Redis, AzureTableStorage)
• Akka__Cluster__Clustering__ConnectionStringName - the Aspire resource name for the discovery backend
• Connection string for the discovery backend (e.g. ConnectionStrings__akka-discovery)

The service-side bootstrap reads these via IConfiguration, configures the full Akka.NET cluster stack, and uses the discovery plugin to find other replicas. Cluster Bootstrap's SelfAwareJoinDecider handles initial seed node election.

Supported Discovery Providers

• Redis (Aaron.Akka.Discovery.Redis) - each node registers in Redis with a heartbeat
• Azure Table Storage (Akka.Discovery.Azure) - uses Azure Table Storage for node registration
• Kubernetes (Akka.Discovery.KubernetesApi) - queries the Kubernetes API for pod endpoints
• Config - static seed nodes (default fallback)

Production Deployment

The configureDiscovery callback makes it straightforward to swap discovery providers between environments. Only the AppHost and the callback change -- the rest of the service code stays identical.

Azure Table Storage (local dev with Azurite, production with real Azure)

AppHost:

var storage = builder.AddAzureStorage("azure-storage").RunAsEmulator();
var tables = storage.AddTables("akka-discovery");

var akka = builder.AddAkka("my-cluster")
    .WithClustering(tables);

Service:

akkaBuilder.WithAspireClusterBootstrap(sp,
    configureDiscovery: (b, config) =>
    {
        var azureConn = config.GetConnectionString("akka-discovery");
        if (!string.IsNullOrEmpty(azureConn))
            b.WithAzureDiscovery(azureConn, config["Akka:Cluster:ServiceName"]);
    },
    clusterConfigure: c => c.Roles = ["my-service"]);

Kubernetes (no connection string needed)

Service:

akkaBuilder.WithAspireClusterBootstrap(sp,
    configureDiscovery: (b, config) =>
    {
        b.WithKubernetesDiscovery();
    },
    clusterConfigure: c => c.Roles = ["my-service"]);

See the samples/ directory for complete working examples with Redis and Azure Table Storage.

Learn More

• Akka.NET Clustering - how Akka.NET clusters work, membership lifecycle, and seed node discovery
• Akka.Management - HTTP management endpoint and Cluster Bootstrap for automated cluster formation
• Akka.Hosting - IServiceCollection integration for configuring Akka.NET without raw HOCON
• .NET Aspire - orchestration, service discovery, and telemetry for distributed .NET apps

Building

dotnet tool restore
dotnet build -c Release
dotnet test -c Release
dotnet pack -c Release -o ./bin/nuget

Integration tests require Docker (they spin up a Redis container via Aspire).

License

Apache-2.0

Pinning Actions to SHAs