LinKit.Sagas 1.0.0

LinKit.Sagas

LinKit.Sagas delivers high-performance, Zero-Reflection, and Native AOT compatible Distributed Saga Orchestration with automated compensation workflows for LinKit.

🚀 Key Features

• Zero Reflection & Native AOT Ready: 100% Native AOT & Trimming safe with compile-time type dispatch and zero runtime reflection.
• Automated Compensation: Automatic backward compensation execution (CompensateAsync) if any forward saga step (ExecuteAsync) throws an exception.
• State Persistence: Supports state transitions and correlation tracking via ISagaRepository<TData>. Comes with high-performance InMemorySagaRepository<TData> with easy hooks for EF Core / MongoDB / Redis.
• Correlation Tracking: End-to-end distributed tracking using CorrelationId and CurrentState.

📦 Installation

dotnet add package LinKit.Sagas

🛠️ Usage Guide

1. Define Saga State Data

using LinKit.Sagas;

public class OrderSagaData : SagaData
{
    public Guid OrderId { get; set; }
    public decimal Amount { get; set; }
}

2. Define Saga Steps with Forward & Compensation Logic

using LinKit.Sagas;

public class ProcessPaymentSagaStep : ISagaStep<OrderSagaData, ProcessPaymentEvent>
{
    private readonly IPaymentService _paymentService;

    public ProcessPaymentSagaStep(IPaymentService paymentService)
    {
        _paymentService = paymentService;
    }

    public async Task ExecuteAsync(OrderSagaData data, ProcessPaymentEvent @event, CancellationToken ct)
    {
        // 1. Forward action
        await _paymentService.ChargeAsync(data.OrderId, data.Amount, ct);
    }

    public async Task CompensateAsync(OrderSagaData data, ProcessPaymentEvent @event, CancellationToken ct)
    {
        // 2. Backward compensation action if subsequent steps fail
        await _paymentService.RefundAsync(data.OrderId, data.Amount, ct);
    }
}

3. Register Sagas & Coordinate Execution

using LinKit.Sagas;

var builder = WebApplication.CreateBuilder(args);

// Register Saga infrastructure
builder.Services.AddLinKitSagas<OrderSagaData>();
builder.Services.AddScoped<ProcessPaymentSagaStep>();

var app = builder.Build();

// Execute a step via SagaCoordinator
var coordinator = app.Services.GetRequiredService<SagaCoordinator<OrderSagaData>>();
var step = app.Services.GetRequiredService<ProcessPaymentSagaStep>();

await coordinator.ExecuteStepAsync(
    correlationId: Guid.NewGuid(),
    @event: new ProcessPaymentEvent(),
    step: step,
    nextState: "PaymentProcessed"
);

📄 License

Licensed under the MIT License.