Struct SqliteEventStore 

pub struct SqliteEventStore { /* private fields */ }

Implementations

impl SqliteEventStore

pub async fn setup(url: impl AsRef<str>) -> Result<Self, ProtocolError>

Nitinol sets up a Journal Database for storing Events.

Note: Since run our own migration, we must avoid integrating databases.

Trait Implementations

impl Clone for SqliteEventStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Reader for SqliteEventStore

fn read<'life0, 'async_trait>( &'life0 self, id: EntityId, seq: i64, ) -> Pin<Box<dyn Future<Output = Result<Payload, ProtocolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn read_to<'life0, 'async_trait>( &'life0 self, id: EntityId, from: i64, to: i64, ) -> Pin<Box<dyn Future<Output = Result<BTreeSet<Payload>, ProtocolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn read_to_latest<'life0, 'async_trait>( &'life0 self, id: EntityId, from: i64, ) -> Pin<Box<dyn Future<Output = Result<BTreeSet<Payload>, ProtocolError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

impl Writer for SqliteEventStore

fn write<'life0, 'async_trait>( &'life0 self, aggregate_id: EntityId, payload: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), ProtocolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,