Ruvio.Client.AspNetCore 0.2.6

Ruvio.Client.AspNetCore

Registers Ruvio.Client in an ASP.NET Core service collection. The client speaks RESP2 and does not send CLIENT SETINFO. The TCP connection opens when dependency injection creates RuvioClient, which is a singleton.

builder.Services.AddRuvioClient("127.0.0.1", 6379, database: 2);

With options:

builder.Services.AddRuvioClient(options =>
{
    options.Host = "127.0.0.1";
    options.Port = 6379;
    options.Database = 2;
    options.Reconnect = true;
    options.MaxReconnectAttempts = 8;
    options.ReconnectBaseDelay = TimeSpan.FromMilliseconds(100);
    options.ReconnectMaxDelay = TimeSpan.FromSeconds(2);
}, client =>
{
    client.ConnectionLost += (_, notice) =>
        Console.WriteLine($"lost {notice.Host}:{notice.Port} subscriber={notice.Subscriber}");
    client.ConnectionRestored += (_, notice) =>
        Console.WriteLine($"restored {notice.Host}:{notice.Port}");
});

Configuration section:

builder.Services.AddRuvioClient(builder.Configuration.GetSection("Ruvio"));

{
  "Ruvio": {
    "Host": "127.0.0.1",
    "Port": 6379,
    "Database": 2,
    "Reconnect": true,
    "MaxReconnectAttempts": 8,
    "ReconnectBaseDelay": "00:00:00.100",
    "ReconnectMaxDelay": "00:00:02"
  }
}

Reconnect defaults to true. A broken command or shard socket is opened again before the next command. The command that discovers the drop fails, so a write is not sent twice. Pub/Sub channels are subscribed again on the new socket. Set Reconnect to false and call ReconnectAsync when the application should own the timing. ReconnectDelay is a Func<int, TimeSpan?> and is not read from configuration; return null to stop. When it is set, MaxReconnectAttempts is not applied. The configureClient callback runs once, after the socket opens, so ConnectionLost, ConnectionRestored, and ConnectionFailed are attached before the singleton is handed out. RuvioConnectionNotice carries host, port, whether the socket is the Pub/Sub connection, and the error on a drop.

Connect sends CLUSTER SLOTS and, on a sharded server, routes by hash slot. Database 0 sends nothing after that; any other index sends SELECT on a standalone server. Cluster mode has only database 0. The registered client stays on that database unless code calls SelectAsync, which changes it for every consumer of the singleton.

Inject RuvioClient. Resolve it once at startup if the process should fail before it accepts traffic:

app.Services.GetRequiredService<RuvioClient>();