Skip to main content

Module repository

Module repository 

Source

Structs§

AsyncCommitBatch
A structured async write batch that must commit under one backend transaction.
AsyncStreamWrite
One aggregate event stream staged for an async transactional commit.
CommitBatch
A structured set of writes that must commit under one transaction boundary.
InboxReceipt
A single consumer/message processing receipt.
PreparedEventAppend
Owned append data prepared from a borrowed stream write before async I/O.
StreamIdentity
Stable event-stream identity used by persistence backends.

Enums§

AsyncSnapshotWrite
Snapshot writes staged in an async transactional commit.
InboxOutcome
Outcome of committing an InboxReceipt.
RepositoryError
SnapshotWrite
A snapshot write staged as part of a transactional commit.

Traits§

AsyncGetStream
Async stream-aware aggregate loading.
AsyncInboxStore
Consumer inbox read capability: check whether a (consumer, message_id) receipt has already been recorded.
AsyncReadModelWritePlanStore
Async adapter contract for committing read-model write plans.
AsyncRelationalReadModelQueryStore
Async primary-key relational read-model query contract.
AsyncRepository
Repository trait for types that implement async stream reads and commits.
AsyncSnapshotStore
Async snapshot persistence keyed by full stream identity.
AsyncTransactionalCommit
Async transactional commit capability for durable persistence backends.