Struct CopyWriter 

pub struct CopyWriter { /* private fields */ }

A copy being written under its temporary name. Dropping it leaves the bytes for the caller’s recorded cleanup.

Implementations

impl CopyWriter

pub async fn append(&mut self, bytes: &[u8]) -> Result<(), FileError>

Append one bounded buffer, completing its disk write before returning.

pub async fn publish( self, path: &Path, batch: &mut FlushBatch, ) -> Result<(), FileError>

Sync the bytes, then rename them to path, where nothing may be, in the same folder, so the copy is whole under its final name or not there. The copy counts in batch, whose flush syncs the folder and makes the copy durable before the commit that records it.