terraskye/eventsourcing Documentation¶

A Go library for building event-sourced systems with CQRS support.

go get github.com/terraskye/eventsourcing

Tutorials¶

Step-by-step guides to learn event sourcing by building a real application.

Practical recipes for specific tasks.

Commands - Handle concurrency conflicts with optimistic locking - Add metadata to events - Customise stream names (multi-tenancy) - Retry commands on conflict - The aggregate variant — when to use it and when not to

Events - Register events for serialization - Subscribe to events with the event bus - Version events when the schema changes

Queries - Build a live read model - Build a cached projection

Infrastructure - Use KurrentDB as the event store - Add OpenTelemetry tracing - Add structured logging - Test event-sourced code

Complete API documentation.

Core interfaces — Event, Command, Query, EventStore, EventBus
CommandHandler — NewCommandHandler, options
EventHandler & EventGroupProcessor — OnEvent, NewEventGroupProcessor
QueryBus & QueryGateway — NewQueryBus, RegisterQueryHandler, NewQueryGateway
CommandBus — NewCommandBus, Register, Dispatch
Stream states — Any, NoStream, StreamExists, Revision
Event registry — RegisterEvent, NewEventByName
Iterator — Iterator[T], NewIteratorFunc
Context helpers — envelope propagation through context
Errors — error types and sentinel values
Implementations
memory.EventStore
memory.EventBus
postgres.EventStore
postgres.EventBus
file.EventStore
kurrentdb.EventStore
kurrentdb.EventBus

Background reading to understand the design and concepts.