Struct RedbRuntimeEventJournal 

pub struct RedbRuntimeEventJournal { /* private fields */ }

Redb-backed implementation of RuntimeEventJournalPort.

Arc<Database> allows cheap cloning — all clones share the same underlying redb file handle. redb::Database is Send + Sync.

Implementations

impl RedbRuntimeEventJournal

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

Open (or create) the redb database at path.

Parent directories are created if they do not exist. Both tables are initialised on first open. Uses tokio::task::spawn_blocking because Database::open is blocking.

pub async fn inspect( path: impl Into<PathBuf>, filter: JournalInspectFilter, ) -> Result<Vec<JournalEntry>, CamelError>

Open an existing database at path and return entries (newest-first, up to filter.limit).

Uses Database::open + begin_read — concurrent with a live writer on the same file. inspect is an offline utility: it does NOT require a live RedbRuntimeEventJournal instance.

Trait Implementations

impl Clone for RedbRuntimeEventJournal

fn clone(&self) -> RedbRuntimeEventJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RuntimeEventJournalPort for RedbRuntimeEventJournal

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

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

Load all accepted command IDs from durable dedup journal.