Struct InMemoryJournal 

pub struct InMemoryJournal { /* private fields */ }

Implementations

impl InMemoryJournal

pub fn new() -> Arc<Self>

impl InMemoryJournal

pub fn list_persistence_ids(&self) -> Vec<String>

List all persistence ids currently stored. Used by the telemetry JournalAdmin impl.

pub fn event_count(&self, persistence_id: &str) -> u64

Number of non-deleted events stored for persistence_id.

Trait Implementations

impl Default for InMemoryJournal

fn default() -> InMemoryJournal

Returns the “default value” for a type.

impl Journal for InMemoryJournal

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, pid: &'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 all_persistence_ids<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, JournalError>> + Send + 'async_trait>>

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

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

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,