Struct FileSyncOutbox 

pub struct FileSyncOutbox { /* private fields */ }

Crash-consistent file-backed synchronization outbox.

Implementations

impl FileSyncOutbox

pub fn new(file_path: impl Into<PathBuf>) -> SyncResult<Self>

Opens or creates an outbox and validates all existing records.

pub fn file_path(&self) -> &Path

Returns the durable outbox file path.

Trait Implementations

impl Debug for FileSyncOutbox

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

Formats the value using the given formatter.

impl SyncOutbox for FileSyncOutbox

fn try_enqueue(&self, message: SyncMessage, max_len: usize) -> SyncResult<bool>

Enqueues a batch if the current length is below max_len.

fn front(&self) -> SyncResult<Option<SyncMessage>>

Returns the oldest pending batch.

fn acknowledge_front(&self, batch_id: &str) -> SyncResult<()>

Removes the oldest batch only when its identifier matches batch_id.

fn messages(&self) -> SyncResult<Vec<SyncMessage>>

Returns all pending batches in delivery order.

fn len(&self) -> SyncResult<usize>

Returns the number of pending batches.

fn is_empty(&self) -> SyncResult<bool>

Reports whether no batches are pending.