Struct 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 Clone for SqliteBackend

fn clone(&self) -> SqliteBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteBackend

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

Formats the value using the given formatter.