LockFree.EventStore

Event store em memória, genérico, de baixa latência e lock-free para .NET. Ideal para cenários de monitoramento, métricas e eventos de domínio.

Principais Recursos

• Escrita MPMC lock-free com descarte FIFO
• Particionamento por chave para alta concorrência
• Snapshots consistentes sem bloquear produtores
• Agregações funcionais e consultas por janela temporal
• Zero dependências externas, pronto para AOT/Trimming
• API fluente para configuração avançada
• Métricas e observabilidade integradas
• Agregações especializadas (Sum, Average, Min, Max)

Exemplo de Uso Básico

var store = new EventStore<Order>();
store.TryAppend(new Order { Id = 1, Amount = 10m, Timestamp = DateTime.UtcNow });

var total = store.Aggregate(() => 0m, (acc, e) => acc + e.Amount,
    from: DateTime.UtcNow.AddMinutes(-10));

Novos Construtores

// Capacidade explícita
var store = new EventStore<Order>(capacity: 100_000);

// Capacidade e partições
var store = new EventStore<Order>(capacity: 50_000, partitions: 8);

// Configuração avançada
var store = new EventStore<Order>(new EventStoreOptions<Order>
{
    Capacity = 100_000,
    Partitions = 16,
    OnEventDiscarded = evt => Logger.LogTrace("Event discarded: {Event}", evt),
    OnCapacityReached = () => Metrics.IncrementCounter("eventstore.capacity_reached"),
    TimestampSelector = new OrderTimestampSelector()
});

// API fluente
var store = EventStore.For<Order>()
    .WithCapacity(100_000)
    .WithPartitions(8)
    .OnDiscarded(evt => Log(evt))
    .OnCapacityReached(() => NotifyAdmin())
    .WithTimestampSelector(new OrderTimestampSelector())
    .Create();

Propriedades de Estado

store.Count          // Número atual de eventos
store.Capacity       // Capacidade máxima configurada
store.IsEmpty        // Se está vazio
store.IsFull         // Se atingiu capacidade máxima
store.Partitions     // Número de partições

Agregações Especializadas

// Contagem por janela temporal
var count = store.Count(from: start, to: end);

// Soma de valores
var sum = store.Sum(evt => evt.Amount, from: start, to: end);

// Média
var avg = store.Average(evt => evt.Value, from: start, to: end);

// Mínimo e máximo
var min = store.Min(evt => evt.Score, from: start, to: end);
var max = store.Max(evt => evt.Score, from: start, to: end);

// Com filtros
var filteredSum = store.Sum(
    evt => evt.Amount, 
    filter: evt => evt.Type == "Payment",
    from: start, 
    to: end
);

Snapshots com Filtros

// Snapshot filtrado
var recentEvents = store.Snapshot(
    filter: evt => evt.Timestamp > DateTime.UtcNow.AddMinutes(-5)
);

// Snapshot por janela temporal
var snapshot = store.Snapshot(from: start, to: end);

// Snapshot com filtro e janela temporal
var filtered = store.Snapshot(
    filter: evt => evt.Amount > 100,
    from: start,
    to: end
);