Struct FileRuntimeEventJournal 

pub struct FileRuntimeEventJournal { /* private fields */ }

Implementations

impl FileRuntimeEventJournal

pub fn new(path: impl Into<PathBuf>) -> Result<Self, CamelError>

Trait Implementations

impl Clone for FileRuntimeEventJournal

fn clone(&self) -> FileRuntimeEventJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RuntimeEventJournalPort for FileRuntimeEventJournal

fn append_batch<'life0, 'life1, 'async_trait>( &'life0 self, events: &'life1 [RuntimeEvent], ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Append a batch of runtime events to a durable journal.

fn load_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<RuntimeEvent>, CamelError>> + Send + 'async_trait>>

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

Load the complete journal stream (append order).

fn append_command_id<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Append a “command seen” marker to durable dedup journal.

fn remove_command_id<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

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

Append a “command forgotten” marker to durable dedup journal.

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

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

Load all accepted command IDs from durable dedup journal.