Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

In-memory event store: one log per run, seq assigned on append.

Implementations

impl InMemoryEventStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

fn append(&self, run_id: &RunId, events: &[Event]) -> Result<Seq, KernelError>

Appends events for the given run. Returns the seq of the last written event (or an error). Implementations must assign seqs if not present and guarantee atomicity.

fn scan( &self, run_id: &RunId, from: Seq, ) -> Result<Vec<SequencedEvent>, KernelError>

Scans events for the run starting at from (inclusive), in ascending seq order.

fn head(&self, run_id: &RunId) -> Result<Seq, KernelError>

Returns the highest seq for the run (0 if no events).