Trait coerce::persistent::journal::storage::JournalStorage

pub trait JournalStorage: Send + Sync {
    // Required methods
    fn write_snapshot<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        entry: JournalEntry
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn write_message<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        entry: JournalEntry
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn write_message_batch<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        entries: Vec<JournalEntry>
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_latest_snapshot<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<Option<JournalEntry>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_latest_messages<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        from_sequence: i64
    ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<JournalEntry>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_message<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        sequence_id: i64
    ) -> Pin<Box<dyn Future<Output = Result<Option<JournalEntry>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_messages<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        from_sequence: i64,
        to_sequence: i64
    ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<JournalEntry>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn delete_messages_to<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str,
        to_sequence: i64
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn delete_all<'life0, 'life1, 'async_trait>(
        &'life0 self,
        persistence_id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods

fn write_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, entry: JournalEntry ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn write_message<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, entry: JournalEntry ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn write_message_batch<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, entries: Vec<JournalEntry> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn read_latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<Option<JournalEntry>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn read_latest_messages<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, from_sequence: i64 ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<JournalEntry>>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn read_message<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, sequence_id: i64 ) -> Pin<Box<dyn Future<Output = Result<Option<JournalEntry>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn read_messages<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, from_sequence: i64, to_sequence: i64 ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<JournalEntry>>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_messages_to<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, to_sequence: i64 ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_all<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors

impl JournalStorage for InMemoryJournalStorage