Struct SqlServerJournalStore 

pub struct SqlServerJournalStore {
    pub pool: Pool<ConnectionManager>,
}

Fields

pool: Pool<ConnectionManager>

Trait Implementations

impl Clone for SqlServerJournalStore

fn clone(&self) -> SqlServerJournalStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl JournalStore for SqlServerJournalStore

fn get_initial_offset<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

fn get_events_from_journal<'life0, 'async_trait>( &'life0 self, offset: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<(u64, Vec<u8>)>>> + Send + 'async_trait>>

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

fn load_entity_events<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, entity_type_name: &'life1 str, persistence_id: &'life2 str, offset: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn persist_event_to_journal<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, entity_type_name: &'life1 str, event_type: &'life2 str, event_date: &'life3 DateTime<Utc>, bytes: &'life4 [u8], persistence_id: &'life5 str, offset: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,