Struct UringWriter 

pub struct UringWriter { /* private fields */ }

io_uring writer: write → fsync → journal → fsync as one linked submission.

Durability on return

Identical to SafeWriter: the pack bytes are on the device and a journal row on the device references them. What differs is the cost of getting there — one io_uring_enter instead of four blocking syscalls — not what is promised.

Implementations

impl UringWriter

pub fn create(archive: &Path) -> Result<Self>

Open archive, set up the ring, register the journal staging buffer, and open the journal beside it — appending to the rows already there, and emitting the Arrow IPC schema header only if the file is new.

Returns a named error — never a silent fallback — if this kernel cannot provide what the chain needs. Nothing on disk is touched before that point is passed.

pub fn journal_path(archive: &Path) -> PathBuf

Path of the journal segment beside archive.

pub fn blobs(&self) -> &File

The blob file, for a reader that wants to pread an extent back.

pub fn journal_file(&self) -> &Path

The journal file path this writer is appending rows to.

Trait Implementations

impl ArchiveWrite for UringWriter

fn append(&self, bytes: &[u8]) -> Result<Extent>

Append these bytes and return when this implementation’s durability contract is met. Returns the byte extent written.

fn name(&self) -> &'static str

Name it on a bench row.

fn durability(&self) -> &'static str

One-line statement of what a crash immediately after append returns does to the bytes. On the bench table next to the throughput, because a throughput without this is not a comparison.