Struct OfflineBuffer 

pub struct OfflineBuffer<S: BufferStore> { /* private fields */ }

A store-and-forward buffer that accumulates signed AuditRecords during connectivity loss and replays them in order when the link recovers.

Implementations

impl<S: BufferStore> OfflineBuffer<S>

pub fn new(store: S) -> Self

Create a new buffer backed by store.

pub fn push( &mut self, record: AuditRecord, raw_payload: Vec<u8>, ) -> Result<(), S::Error>

Push a signed record into the buffer.

pub fn len(&self) -> Result<usize, S::Error>

Return the number of records currently buffered.

pub fn is_empty(&self) -> Result<bool, S::Error>

Return true when the buffer is empty.

pub fn flush<R, L, O>( &mut self, service: &mut IngestService<R, L, O>, ) -> Result<FlushReport, FlushError<S::Error>>

where R: RawDataStore, L: AuditLedger, O: OperationLogStore,

Replay buffered records through service and return a FlushReport.

Records are submitted oldest-first. A record that is accepted or already a duplicate is removed from the buffer. The first non-duplicate error stops the replay; any remaining records are preserved for the next flush attempt.