Backplane.
Copy Markdown
Per-aggregate ordered event projection and bounded cursor replay.
Duplicate or out-of-order aggregate sequences are rejected. Cursor expiry returns an explicit snapshot requirement instead of silently replaying retained events. Each stream is bound to its first event's aggregate so it does not imply a global ordering across aggregates.
Summary
Types
@type t() :: map()
Functions
@spec append(t(), map()) :: {:ok, t()} | {:error, Backplane.AgentRuntime.Error.t()}
@spec new(non_neg_integer()) :: {:ok, t()} | {:error, Backplane.AgentRuntime.Error.t()}
@spec replay(t(), non_neg_integer()) :: {:ok, list(), keyword()} | {:error, Backplane.AgentRuntime.Error.t()}