Struct eventstore::backend::sqlite::SqliteBackend

pub struct SqliteBackend { /* private fields */ }

Implementations

impl SqliteBackend

pub fn new(manager: SqliteConnectionManager) -> Self

pub fn get_agg_max_version( &self, tx: &Transaction<'_>, agg_id_str: &str ) -> Result<u32, Error>

pub fn save_snapshot(&self, event: &Event) -> Result<(), Error>

Save an snapshot to the eventstore. Will overwrite existing snapshots.

Errors

This function will return an error if .

pub fn append_event(&self, event: &Event) -> Result<(), Error>

pub fn get_aggretate(&self, aggregate_id: Uuid) -> Result<Vec<Event>, Error>

pub fn get_snapshots(&self, aggregate_id: Uuid) -> Result<Vec<Event>, Error>

pub fn get_snapshot_by_version( &self, aggregate_id: Uuid, version: u32 ) -> Result<Event, Error>

pub fn get_aggretate_with_opts( &self, aggregate_id: Uuid, opts: &GetAggOpts ) -> Result<Vec<Event>, Error>

Trait Implementations

impl Debug for SqliteBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.