Struct SqliteRunJournal 

pub struct SqliteRunJournal { /* private fields */ }

SQLite-backed run journal adapter.

Implementations

impl SqliteRunJournal

pub fn open(path: impl AsRef<Path>) -> Result<Self, AgentError>

Opens or creates a SQLite run journal.

pub fn path(&self) -> &Path

Returns the backing SQLite database path.

Trait Implementations

impl Clone for SqliteRunJournal

fn clone(&self) -> SqliteRunJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteRunJournal

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RunJournal for SqliteRunJournal

fn append(&self, record: JournalRecord) -> Result<JournalCursor, AgentError>

Appends one durable journal record and returns its cursor. Implementations append one durable journal record and return its cursor; they must not execute the effect described by the record.

impl RunJournalReader for SqliteRunJournal

fn records_for_run( &self, run_id: &RunId, ) -> Result<Vec<JournalRecord>, AgentError>

Returns records for one run ordered by journal sequence.

fn records_after( &self, run_id: &RunId, after_journal_seq: u64, ) -> Result<Vec<JournalRecord>, AgentError>

Returns records for one run after a journal sequence.