Struct FileJournal 

pub struct FileJournal { /* private fields */ }

On-disk journal format (per node, one file per channel or a single multiplexed file).

Record: u32 channel_id ‖ u64 seq ‖ u32 len ‖ [len] payload (little-endian). Append-only; readers scan from the start (or from a cached offset index).

Implementations

impl FileJournal

pub fn open(path: impl Into<PathBuf>) -> Result<Self, JournalError>

pub fn path(&self) -> &Path

pub fn append( &self, channel_id: u32, payload: &[u8], ) -> Result<u64, JournalError>

Append a payload; returns the assigned seq.

pub fn replay_after( &self, channel_id: u32, after: u64, limit: usize, ) -> Result<Vec<JournalEntry>, JournalError>

pub fn reply_body( &self, channel_id: u32, after: u64, limit: usize, ) -> Result<JournalReplyBody, JournalError>

Build a wire reply body for an uplink JournalReq.

Trait Implementations

impl Clone for FileJournal

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.