Struct WritebackJournal 

pub struct WritebackJournal { /* private fields */ }

In-memory, per-session writeback journal.

Writes go into Self::entries; a future flush_to_disk(path) helper will stream them to <session-id>.journal.jsonl. Keeping disk I/O out of this type makes every phase fast to unit-test.

Implementations

impl WritebackJournal

pub fn new(session_id: impl Into<String>) -> Self

Create a fresh journal for session_id.

pub fn session_id(&self) -> &str

The session this journal belongs to.

pub fn entries(&self) -> &[JournalEntry]

Every entry in the order it was appended.

pub fn stage(&mut self, op: Op) -> TxnId

Stage an op and return its TxnId. Writes a Staged entry.

Examples

use codetether_agent::session::journal::{Op, WritebackJournal};

let mut journal = WritebackJournal::new("s");
let txn = journal.stage(Op::Save);
assert_eq!(journal.entries().len(), 1);
journal.commit(txn).unwrap();
assert_eq!(journal.entries().len(), 2);

pub fn reject(&mut self, txn: TxnId, reason: RejectReason)

Mark a staged transaction as rejected with reason. The transaction is dropped from the pending set — a subsequent Self::commit on the same id returns Err(RejectReason).

pub fn commit(&mut self, txn: TxnId) -> Result<(), RejectReason>

Commit a staged transaction that passed validation. Returns Err(RejectReason::SchemaMismatch) when the transaction is unknown (never staged, or already rejected / committed).

Errors

See above — returns Err when the TxnId is not pending.

pub fn pending_count(&self) -> usize

Number of currently staged (neither committed nor rejected) transactions.

Trait Implementations

impl Clone for WritebackJournal

fn clone(&self) -> WritebackJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WritebackJournal

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

Formats the value using the given formatter.