IceRpc.Deadline 0.6.1

Deadline interceptor and middleware for IceRPC

IceRpc.Deadline provides an IceRPC interceptor and the corresponding middleware.

The deadline interceptor adds deadline fields to outgoing requests, while the deadline middleware decodes deadline fields received with incoming requests.

Source code | Package | Example | API reference | Interceptor documentation | Middleware documentation

Sample code

// Client application

using IceRpc;
using System.Security.Cryptography.X509Certificates;

// Load the test root CA certificate in order to connect to the server that uses a test
// server certificate.
using var rootCA = X509CertificateLoader.LoadCertificateFromFile("certs/cacert.der");

await using var connection = new ClientConnection(
    new Uri("icerpc://localhost"),
    // examples/common/Program.Authentication.cs in the icerpc-csharp repo provides the
    // CreateClientAuthenticationOptions helper method
    clientAuthenticationOptions: CreateClientAuthenticationOptions(rootCA));

// Add the deadline interceptor to the invocation pipeline.
Pipeline pipeline = new Pipeline()
    .UseDeadline(TimeSpan.FromSeconds(20))
    .Into(connection);

// Server application

using IceRpc;
using System.Security.Cryptography.X509Certificates;

// Add the deadline middleware to the dispatch pipeline.
Router router = new Router()
    .UseDeadline()
    .Map(...);

// The default transport (QUIC) requires a server certificate.
// We use a test certificate here.
using var serverCertificate = X509CertificateLoader.LoadPkcs12FromFile(
    "certs/server.p12",
    password: null,
    keyStorageFlags: X509KeyStorageFlags.Exportable);

await using var server = new Server(
    router,
    // examples/common/Program.Authentication.cs in the icerpc-csharp repo provides the
    // CreateServerAuthenticationOptions helper method
    serverAuthenticationOptions: CreateServerAuthenticationOptions(serverCertificate));
server.Listen();

Sample code with DI

This sample stays focused on the deadline registration. For a complete Generic Host setup with certificates and configuration, see the GenericHost example.

// Client application

using IceRpc;
using IceRpc.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

HostApplicationBuilder hostBuilder = Host.CreateApplicationBuilder(args);

hostBuilder.Services
    .AddIceRpcClientConnection(new Uri("icerpc://localhost"))
    .AddIceRpcInvoker(builder =>
        builder
            // Add the deadline interceptor to the invocation pipeline.
            .UseDeadline(TimeSpan.FromSeconds(20))
            .Into<ClientConnection>());

using IHost host = hostBuilder.Build();
host.Run();

// Server application

using IceRpc;
using IceRpc.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

HostApplicationBuilder hostBuilder = Host.CreateApplicationBuilder(args);

hostBuilder.Services
    .AddIceRpcServer(builder =>
        builder
            // Add the deadline middleware to the dispatch pipeline.
            .UseDeadline()
            .Map<...>());

using IHost host = hostBuilder.Build();
host.Run();