Event Sourcing

Em vez de gravar o estado atual, cada mudança da conta é gravada como um evento imutável, em ordem, num log append-only. O saldo é sempre derivado, dobrando os eventos com uma função pura. Use quando o histórico tem valor de negócio: auditoria regulatória, “como chegamos neste saldo”, saldo em qualquer data passada.

passos: 6
arquivos: 7
testes: 2
tecnologias: 4

Infraestrutura realTypeScriptBunPostgreSQLDocker

Cenário Relações Comparar

Baixar cartão

Cenário

Conta corrente de banco digital: abertura, depósitos e saques por PIX, TED e boleto viram eventos EventAccountOpened, EventAccountMoneyDeposited e EventAccountMoneyWithdrawn. O saldo não existe em coluna nenhuma — sai do replay. Dois saques simultâneos que juntos passam do saldo não podem passar os dois.

Planta

Sequência

8/8

8 passos — reproduza para seguir o fluxo

chamada
resposta ou assíncrono
falha
passo
toque num participante para focar
Outras plantas de sequência

Como funciona

6 passos

Log de eventos é a fonte da verdade.

Esconde cada passo: lembre antes de tocar para revelar.

Vocabulário compartilhado

correlationId+7

INSERT+3

accountEventApply+1

Event Sourcing

(aggregate_id, version)+1

Snapshot Pattern

created_at+1

Partition Table

channel+1

Event Sourcing

01
decide valida a regra sobre o estado atual e devolve eventos; accountEventApply só dobra eventos, sem I/O e sem rejeitar fato passado
02
O append grava na versão esperada + 1; a chave única (aggregate_id, version) faz o segundo escritor falhar com 23505
03
No conflito o comando recarrega o estado e decide de novo — nunca repete o mesmo INSERT
04
A cada 50 eventos o estado vira snapshot; a carga parte dele e aplica só a cauda
05
Payload antigo nunca é reescritoO upcaster converte a versão 1 (reais em texto) para centavos na leitura
06
Time travelReplay só dos eventos com created_at até o instante pedido; todo evento leva correlationId, causationId, userId e channel

Trade-offs

O que se ganha, o que se paga

3 vantagenscada ganho tem um preço3 custos

Vantagens

Auditoria completa e imutável por construção
Saldo em qualquer data passada
Concorrência otimista sem lock explícito

Custos

Leitura exige replay ou projeção
Log cresce sem fim: retenção e arquivamento a definir
Mudança de schema pede upcaster permanente

apps/data-patterns/event-sourcing

7 arquivos

sql/

01_schema.sqlschemaevent_store append-only com trigger, event_snapshot

src/

event_account.tsEventos, fold puro, decisões e upcaster
store_account.tsAppend com concorrência otimista, carga com snapshot, time travel
demo.tsdemoStream, recusa, time travel, corrida, snapshot e log imutável
event_account.test.tstesteFold, snapshot, limite do saque e upcaster sem banco
store_account.test.tstesteImutabilidade, conflito de versão, snapshot e time travel contra PostgreSQL real