W4k.AspNetCore.Correlator 3.3.0

W4k.AspNetCore.Correlator

Correlator helps you with handling correlation ID (also "request ID"): reading, generating new one and forwarding to subsequent requests.

Correlation ID is sent within HTTP headers. If header is not set, Correlator will happily generate new one for you.

Apart from accepting or generating correlation ID, it is also possible to return correlation ID back to caller, so in case when correlation ID is generated, caller is aware of that value.

To forward correlation ID to subsequent request, it is necessary to use designated HTTP message handler, see examples below.

W3 Trace Context and .NET

Be aware that Trace Context is not supported, Correlator helps you with simple non-standard headers.

Distributed tracing and trace context is built in .NET, You can get more insights from article: .NET distributed tracing.

Basic usage

Startup class

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddDefaultCorrelator();

var app = builder.Build();

// register as first middleware
// (or as soon as possible to benefit from having correlation ID)
app.UseCorrelator();

// ...
app.Run();

Accessing correlation ID

Correlation ID of current request is available via ICorrelationContextAccessor.CorrelationContext:

using W4k.AspNetCore.Correlator;
using W4k.AspNetCore.Correlator.Context;

public class MyLittleService
{
    private readonly ICorrelationContextAccessor _contextAccessor;

    public MyLittleService(ICorrelationContextAccessor contextAccessor)
    {
        _contextAccessor = contextAccessor;
    }

    public async Task DoMagicalStuff()
    {
        CorrelationId correlationId = _contextAccessor.CorrelationContext.CorrelationId;

        // ...
    }
}

Forwarding correlation ID

In order to pass correlation ID to subsequent requests, additional HTTP message handler has to be registered.

Add CorrelatorHttpMessageHandler to HTTP client's message handler pipeline like this:

// named HTTP client
builder.Services
    .AddHttpClient("DummyClient")
    .WithCorrelation();

// typed HTTP client
builder.Services
    .AddHttpClient<FooClient>()
    .WithCorrelation();

// registering HTTP message handler manually
builder.Services
    .AddHttpClient("FizzClient")
    .AddHttpMessageHandler<CorrelatorHttpMessageHandler>();

// registering HTTP client with custom settings
// (global options - CorrelatorOptions.Forward - won't be used)
builder.Services
    .AddHttpClient<LegacyClient>()
    .WithCorrelation(PropagationSettings.PropagateAs("X-Legacy-Correlation-Id"));

// ...

See "Configure the HttpMessageHandler" for more details about usage of HTTP message handler.

Validation of correlation ID

It is possible to validate correlation ID value and prevent invalid value to spread. By default, validation is turned off. In order to turn validation on, implementation of ICorrelationValidator has to be registered.

Correlator is shipped with lightweight validator, CorrelationValueLengthValidator, which decides whether received value is valid simply based on its length.

builder.Services
    .AddDefaultCorrelator()
    .WithValidator(new CorrelationValueLengthValidator(64));

Documentation

• Detailed configuration description
• Dependency injection registration
• Components description
• Alternative packages and further reading

Icon made by Kiranshastry from Flaticon, www.flaticon.com