Struct EventJournal 

pub struct EventJournal { /* private fields */ }

Append-only writer for the change-feed journal.

Implementations

impl EventJournal

pub fn open(dir: PathBuf) -> Result<(EventJournal, u64), Error>

Open (or create) the journal directory and recover the max seq seen.

Returns the writer plus the recovered max seq (0 for a fresh journal), which the caller uses to seed the sequence counter.

pub fn open_with_threshold( dir: PathBuf, rotate_threshold: u64, ) -> Result<(EventJournal, u64), Error>

Like Self::open but with a custom rotation threshold (bytes). A small threshold forces one file per event, which retention/resume tests use to build a multi-file journal deterministically.

pub fn append(&mut self, ce: &ChangeEvent) -> Result<(), Error>

Append one change event as a JSON line, rotating first if needed.

The line is flushed immediately: change events are low-volume, and flushing keeps concurrent /stream replays able to read the latest line without waiting on a timer.