Struct FileSyncOutbox 

pub struct FileSyncOutbox { /* private fields */ }

Crash-consistent incremental file-backed synchronization outbox.

Implementations

impl FileSyncOutbox

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

Opens or creates a V2 outbox and validates every complete journal frame.

pub fn file_path(&self) -> &Path

Returns the durable outbox journal path.

Trait Implementations

impl Debug for FileSyncOutbox

fn fmt(&self, formatter: &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 peek(&self, limit: usize, max_bytes: usize) -> SyncResult<Vec<SyncMessage>>

Returns a delivery-order page bounded before cloning message payloads.

fn stats(&self) -> SyncResult<SyncOutboxStats>

Returns payload-free queue statistics.

fn mark_attempt(&self, batch_id: &str, next_ready_at_ms: u64) -> SyncResult<u32>

Records one failed delivery attempt and its next eligible timestamp.

fn next_ready( &self, now_ms: u64, limit: usize, max_bytes: usize, ) -> SyncResult<Vec<SyncMessage>>

Returns the ready delivery-order prefix within both page bounds.

fn acknowledge_receipt(&self, receipt: &SyncOutboxReceipt) -> SyncResult<usize>

Acknowledges the exact ordered prefix named by a partial receipt.

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

Reports whether no batches are pending.