Timebox#

Timebox is a small, opinionated event sourcing library for Go with append-only event storage, optimistic concurrency, snapshotting, and durable message scheduling. It supports Redis, PostgreSQL, or Raft as its persistence backend.

What It Provides#

• Typed aggregate state and event appliers
• Automatic retries on optimistic concurrency conflicts
• Atomic multi-aggregate transactions
• Durable deferred messages delivered by a scheduler
• Snapshots and optional event trimming
• Status and tag indexes updated with the event append
• Memory, PostgreSQL, Redis/Valkey, and Raft backends
• One-way archive storage in memory, Redis, and Raft

Quick Start#

go get github.com/kode4food/timebox@latest

Start with the in-memory backend, define a state constructor and appliers, then execute a command:

backend := memory.Open()
defer backend.Close()

store, err := backend.NewStore()
if err != nil {
    return err
}

orders := store.Executor(newOrder, orderAppliers.Reduce)
orderID := timebox.NewAggregateID("order", "ORD-123")

order, err := orders.Exec(orderID,
    func(_ Order, ag *timebox.Aggregator[Order]) error {
        return ag.Raise(OrderCreated, OrderCreatedData{
            CustomerName: "Ada",
        })
    },
)

The complete runnable order example shows an aggregate lifecycle using Redis.

→ Build the order tutorial

→ Schedule a deferred message

Status#

Timebox is 0.x software. Its persistence contract is tested across every backend, but public APIs and durable formats may still change between minor releases.