Struct SharedEventStore 

pub struct SharedEventStore(pub Arc<InMemoryEventStore>);

Shared event store: wraps Arc<InMemoryEventStore> so graph and Kernel can share the same log.

Tuple Fields

0: Arc<InMemoryEventStore>

Implementations

impl SharedEventStore

pub fn new() -> Self

Trait Implementations

impl Default for SharedEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for SharedEventStore

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).