Skip to main content Module repository Copy item path Source CommitBatch A structured async write batch that must commit under one backend transaction. InboxReceipt A single consumer/message processing receipt. PreparedEventAppend Append data prepared from a borrowed stream write before async I/O. Events
are borrowed from the staged entity — backends bind them by reference, so
preparing a batch never clones event payloads. StreamIdentity Stable event-stream identity used by persistence backends. StreamWrite One aggregate event stream staged for an async transactional commit. InboxOutcome Outcome of committing an InboxReceipt RepositoryError SnapshotWrite Snapshot writes staged in an async transactional commit. GetStream Stream-aware aggregate loading. InboxStore Consumer inbox read capability: check whether a (consumer, message_id)
receipt has already been recorded. ReadModelWritePlanStore Adapter contract for committing read-model write plans. RelationalReadModelQueryStore Primary-key relational read-model query contract. Repository Repository trait for types that implement stream reads and commits. SnapshotStore Snapshot persistence keyed by full stream identity. TransactionalCommit Transactional commit capability for durable persistence backends.