Struct EventStore 

pub struct EventStore { /* private fields */ }

Append-only event store with per-stream indexing.

Internally uses a flat sequence (no nested streams), filtered at query time.

Implementations

impl EventStore

pub fn new(config: EventStoreConfig) -> Self

Create a new event store with the given configuration.

pub fn append( &self, stream_id: impl Into<String>, event_type: impl Into<String>, payload: Value, ) -> u64

Append an event to a stream. Returns the assigned sequence number.

pub fn query(&self, query: EventQuery) -> Vec<StoredEvent>

Query events matching the filter.

pub fn replay(&self, stream_id: &str) -> Vec<StoredEvent>

Replay all events for a particular stream, in order.

pub fn subscribe(&self) -> Receiver<StoredEvent>

Subscribe to new events.

Trait Implementations

impl Default for EventStore

fn default() -> Self

Returns the “default value” for a type.