Struct SqliteEventStore 

pub struct SqliteEventStore<E> { /* private fields */ }

SQLite-backed EventStorePort with BEGIN IMMEDIATE sequence allocation.

Implementations

impl<E> SqliteEventStore<E>

where E: Serialize + DeserializeOwned + Clone + Send + Sync,

pub fn open(path: &str) -> Result<Self, StoreError>

Open (or create) an event store at the given file path.

pub fn open_in_memory() -> Result<Self, StoreError>

Open a transient in-memory store (useful in tests).

pub fn load_all_global(&self) -> Result<Vec<EventEnvelope<E>>, StoreError>

Return all events across aggregates ordered by global_seq (for tests).

Trait Implementations

impl<E> EventStorePort for SqliteEventStore<E>

where E: Serialize + DeserializeOwned + Clone + Send + Sync,

type Error = StoreError

Error type returned by event-store operations.

type Event = E

Serde-serializable domain event type stored by this port.

fn append( &self, aggregate_id: Uuid, expected_seq: u64, event: &Self::Event, ) -> Result<EventEnvelope<Self::Event>, Self::Error>

Append event to the log for aggregate_id.

fn load( &self, aggregate_id: Uuid, ) -> Result<Vec<EventEnvelope<Self::Event>>, Self::Error>

Load all events for aggregate_id in aggregate_seq order.