Struct Store 

pub struct Store { /* private fields */ }

Implementations

impl Store

pub fn new<E: Engine + 'static>(engine: E) -> Self

pub async fn load<A: Aggregate + Applier>( &self, aggregate_id: impl Into<String>, ) -> Result<Option<(A, u16)>>

pub async fn load_with<A: Aggregate + Applier>( &self, aggregate_id: impl Into<String>, first: u16, ) -> Result<Option<(A, u16)>>

pub async fn write<A: Aggregate>( &self, aggregate_id: impl Into<String>, event: WriteEvent, original_version: u16, ) -> Result<Event>

pub async fn write_all<A: Aggregate>( &self, aggregate_id: impl Into<String>, events: Vec<WriteEvent>, original_version: u16, ) -> Result<Vec<Event>>

pub async fn insert(&self, events: Vec<Event>) -> Result<()>

pub async fn read( &self, first: u16, after: Option<CursorType>, filters: Option<Vec<Value>>, ) -> Result<QueryResult<Event>>

pub async fn read_of<A: Aggregate>( &self, aggregate_id: impl Into<String>, first: u16, after: Option<CursorType>, ) -> Result<QueryResult<Event>>

pub async fn first_of<A: Aggregate>( &self, aggregate_id: impl Into<String>, ) -> Result<Option<Event>>

pub async fn last(&self) -> Result<Option<Event>>

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.