Struct BlockingWriter 

pub struct BlockingWriter { /* private fields */ }

Blocking writer using mutex-guarded file I/O

This is the portable implementation using parking_lot::Mutex<std::fs::File>. It provides the same API that a future io_uring backend would expose, allowing transparent upgrades on Linux 5.6+.

⚠️ Blocking I/O

All methods (write, flush, sync) perform synchronous file I/O under a blocking mutex. Do not call from async contexts (tokio worker threads) — use tokio::task::spawn_blocking to wrap calls, or use the async AsyncFile from async_io.rs instead.

Implementations

impl BlockingWriter

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

Create a new blocking writer

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

Open an existing file for writing

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

Write data (queued for batching)

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

Flush pending writes

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

Sync data to disk (fdatasync)

pub fn offset(&self) -> u64

Get current write offset

pub fn stats(&self) -> IoUringStatsSnapshot

Get statistics