Struct AzureJournal 

pub struct AzureJournal { /* private fields */ }

Implementations

impl AzureJournal

pub async fn connect(cfg: AzureConfig) -> Result<Arc<Self>, JournalError>

pub fn config(&self) -> &AzureConfig

Trait Implementations

impl Journal for AzureJournal

fn write_messages<'life0, 'async_trait>( &'life0 self, messages: Vec<PersistentRepr>, ) -> Pin<Box<dyn Future<Output = Result<(), JournalError>> + Send + 'async_trait>>

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

fn delete_messages_to<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, to_sequence_nr: u64, ) -> Pin<Box<dyn Future<Output = Result<(), JournalError>> + Send + 'async_trait>>

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

fn replay_messages<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, from: u64, to: u64, max: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<PersistentRepr>, JournalError>> + Send + 'async_trait>>

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

fn highest_sequence_nr<'life0, 'life1, 'async_trait>( &'life0 self, persistence_id: &'life1 str, _from: u64, ) -> Pin<Box<dyn Future<Output = Result<u64, JournalError>> + Send + 'async_trait>>

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

fn events_by_tag<'life0, 'life1, 'async_trait>( &'life0 self, _tag: &'life1 str, _from_offset: u64, _max: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<PersistentRepr>, JournalError>> + Send + 'async_trait>>

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

fn all_persistence_ids<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, JournalError>> + Send + 'async_trait>>

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

Distinct persistence ids known to the backend. Default impl returns empty so backends without an id index opt in.