Distributed Redis Discovery Package

ModularPipelines.Distributed.Discovery.Redis advertises and discovers a distributed master's endpoint through Redis. It implements the transport-neutral IMasterDiscovery contract, whose MasterEndpoint carries the master's URL and access token; SignalR uses it so workers can locate and authenticate to the current master.

Installation

dotnet add package ModularPipelines.Distributed.Discovery.Redis

Configuration

using ModularPipelines.Distributed;
using ModularPipelines.Distributed.Discovery.Redis;
using ModularPipelines.Distributed.SignalR;

var builder = Pipeline.CreateBuilder(args);

builder.AddDistributedMode(options => options with { TotalInstances = 2 });
builder.AddSignalRDistributedCoordinator(options => options with { Tunnel = options.Tunnel with { Enabled = true } });
builder.AddRedisMasterDiscovery(options => options with
{
    ConnectionString = "localhost:6379",
});

Discovery has no default connection. Set ConnectionString explicitly, including localhost:6379 for local Redis, or supply endpoints through ConfigureConnection. Missing connection configuration fails during pipeline construction. TCP options validation runs ConfigureConnection and requires at least one endpoint afterward. The resulting configuration is cached per options instance; finish configuring options before building the pipeline. Discovery opens its own Redis connection on first use. REST discovery does not invoke the TCP callback. RestUrl is an absolute HTTPS Uri (HTTP is allowed only on loopback), for example options => options with { RestUrl = new Uri("https://redis.example") }. It may include a path prefix, but query strings and fragments are rejected because Redis commands are appended to that path. For REST-backed Redis services, configure both RestUrl and RestToken; no TCP connection string is needed:

builder.AddRedisMasterDiscovery(options => options with
{
    RestUrl = new Uri(builder.Configuration["RedisRestUrl"]!),
    RestToken = builder.Configuration["RedisRestToken"],
});

For callback-only TCP configuration, supply endpoints explicitly:

builder.AddRedisMasterDiscovery(options => options with
{
    ConfigureConnection = connection => connection with
    {
        Endpoints = [new RespireEndpoint("redis.internal", 6380)],
        UseTls = true,
        Password = builder.Configuration["RedisPassword"],
    },
});

Because the stored endpoint includes the access token, only the run's processes should be able to read the discovery database. See Configuration for all options.

An empty or whitespace RestUrl is treated as omitted and retains TCP discovery. Remote REST endpoints require HTTPS to protect RestToken in transit.