Cosmos.EventDriven.Abstractions 0.0.5-RC.2

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
• 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.PublishEventAsync(@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);
    }
}

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.