Cosmos.EventDriven.Abstractions 2.0.0

Cosmos.EventDriven.Abstractions

Abstracciones fundamentales para implementar Event Driven Architecture (EDA) en .NET 10.

Descripción

Este paquete proporciona las interfaces base necesarias para construir aplicaciones basadas en arquitecturas orientadas a eventos. Define contratos claros para la publicación de eventos públicos (inter-servicio) y eventos privados (intra-servicio).

Características

• IPublicEvent: Marcador para eventos publicados a servicios externos vía broker (RabbitMQ, Azure Service Bus, etc.)
• IPrivateEvent: Marcador para eventos publicados dentro del mismo bounded context
• IPublicEventSender: Interfaz para publicar IPublicEvent de forma asíncrona
• IPrivateEventSender: Interfaz para publicar IPrivateEvent de forma asíncrona
• PublishOptions: Opciones del sobre (GroupId para orden FIFO y Headers arbitrarios) para publicar sin explotar la matriz de sobrecargas
• Sin dependencias de implementación concreta

Instalación

dotnet add package Cosmos.EventDriven.Abstractions

Uso

Definir un Evento Público (inter-servicio)

using Cosmos.EventDriven.Abstractions;

public record UserRegistered(
    string UserId,
    string Email,
    DateTime RegisteredAt
) : IPublicEvent;

Definir un Evento Privado (intra-servicio)

using Cosmos.EventDriven.Abstractions;

public record UserProfileUpdated(
    string UserId,
    string NewEmail
) : IPrivateEvent;

Publicar un Evento Público

public class UserService
{
    private readonly IPublicEventSender _publicEventSender;

    public UserService(IPublicEventSender publicEventSender)
    {
        _publicEventSender = publicEventSender;
    }

    public async Task RegisterUser(string userId, string email)
    {
        // Lógica de negocio...

        var @event = new UserRegistered(userId, email, DateTime.UtcNow);
        await _publicEventSender.PublishAsync(@event);
    }
}

Publicar Eventos Privados

public class UserService
{
    private readonly IPrivateEventSender _privateEventSender;

    public UserService(IPrivateEventSender privateEventSender)
    {
        _privateEventSender = privateEventSender;
    }

    public async Task UpdateProfile(string userId, string newEmail)
    {
        // Lógica de negocio...

        var @event = new UserProfileUpdated(userId, newEmail);
        await _privateEventSender.PublishAsync(@event);
    }
}

Publicar con opciones del sobre (headers / clave de enrutamiento)

Cuando el destinatario debe enrutarse por una clave de enrutamiento (por ejemplo, un correlation filter de Azure Service Bus que solo evalúa las application properties del mensaje, no su body), estampa esa clave como un header arbitrario del sobre vía PublishOptions.Headers:

using Cosmos.EventDriven.Abstractions;

var options = new PublishOptions
{
    Headers = new Dictionary<string, string> { ["applicationBundleId"] = applicationBundleId },
};

await _publicEventSender.PublishAsync(options, @event);

GroupId (orden FIFO / SessionId) y Headers (clave de enrutamiento) son ortogonales: pueden usarse por separado o juntos en el mismo PublishOptions, sin conflacionarse.

var options = new PublishOptions { GroupId = "cuenta-123", Headers = headers };

En Azure Service Bus, los Headers se materializan como application properties del mensaje (matcheables por un CorrelationFilter de igualdad); en RabbitMQ, como headers.

Distinción IPublicEvent vs IPrivateEvent

Implementaciones Concretas

Para implementaciones listas para usar con Wolverine, consulta:

• Cosmos.EventDriven.CritterStack — implementaciones base con Wolverine
• Cosmos.EventDriven.CritterStack.RabbitMQ — extensiones para RabbitMQ
• Cosmos.EventDriven.CritterStack.AzureServiceBus — extensiones para Azure Service Bus

Requisitos

• .NET 10.0 o superior

Licencia

Copyright © Cosmos. Todos los derechos reservados.