Struct WriteAheadLog 

pub struct WriteAheadLog { /* private fields */ }

Write-ahead log backed by SQLite.

Implementations

impl WriteAheadLog

pub async fn new( path: impl AsRef<Path>, max_items: u64, ) -> Result<Self, StorageError>

Create a new WAL at the given path.

pub async fn with_max_bytes( path: impl AsRef<Path>, max_items: u64, max_bytes: u64, ) -> Result<Self, StorageError>

Create a new WAL with custom max size limit.

pub async fn write(&self, item: &SyncItem) -> Result<(), StorageError>

Write an item to the WAL.

pub fn file_size_bytes(&self) -> Result<u64>

Get the WAL file size in bytes.

pub async fn checkpoint(&self) -> Result<(), StorageError>

Run a WAL checkpoint to reclaim disk space. Call this after draining to prevent unbounded file growth.

pub fn has_pending(&self) -> bool

Check if WAL has items to drain.

pub fn stats(&self, mysql_healthy: bool) -> WalStats

Get current stats.

pub fn under_pressure(&self) -> bool

Check if WAL is under pressure (>= 80% full).

pub async fn drain_to( &self, mysql: &dyn ArchiveStore, batch_size: usize, ) -> Result<Vec<String>, StorageError>

Drain items from WAL to MySQL using batch operations.

Returns IDs of items successfully drained, or error if MySQL unreachable.

pub fn path(&self) -> &str

Get the path to the WAL file.