Struct PortableWalWriter 

pub struct PortableWalWriter { /* private fields */ }

Optimized WAL writer using io_uring or fallback

This writer supports both direct writes and batched operations. Batched writes can improve throughput by reducing syscall overhead.

Batching Mode

When using batched mode:

1. Writes are queued in a batch
2. When batch reaches max_batch_bytes or flush_batch() is called, all writes execute
3. Sync is deferred until batch execution

Example

let wal = PortableWalWriter::new("wal.log", IoUringConfig::default())?;

// Direct write (immediate)
wal.append(b"entry1")?;

// Batched write (queued)
wal.append_batched(b"entry2")?;
wal.append_batched(b"entry3")?;
wal.flush_batch()?; // Execute all batched writes

Implementations

impl PortableWalWriter

pub fn new(path: impl AsRef<Path>, config: IoUringConfig) -> Result<Self>

Create a new WAL writer

pub fn append(&self, data: &[u8]) -> Result<u64>

Append data to the WAL (direct write, immediate)

pub fn append_batched(&self, data: &[u8]) -> Result<u64>

Append data to the WAL in batched mode

The write is queued and executed when:

• flush_batch() is called
• The batch exceeds max_batch_bytes

Returns the number of pending bytes in the batch

pub fn flush_batch(&self) -> Result<()>

Flush all batched writes to disk

Executes all pending write operations in the batch and syncs to disk.

pub fn pending_batch_bytes(&self) -> u64

Get the number of pending bytes in the batch

pub fn pending_batch_ops(&self) -> usize

Get the number of pending operations in the batch

pub fn has_pending_batch(&self) -> bool

Check if there are pending batched writes

pub fn append_with_checksum(&self, data: &[u8]) -> Result<u64>

Append with CRC32 checksum

pub fn append_with_checksum_batched(&self, data: &[u8]) -> Result<u64>

Append with CRC32 checksum in batched mode

pub fn sync(&self) -> Result<()>

Flush and sync the WAL

pub fn size(&self) -> u64

Get current WAL size

pub fn max_batch_bytes(&self) -> u64

Get max batch bytes threshold

pub fn stats(&self) -> IoUringStatsSnapshot

Get statistics