Struct WriterFolder 

pub struct WriterFolder { /* private fields */ }

One area’s folder, held for a run of files made in it: the store’s read lock, taken once, and the folder’s resolved path, shared by every writer made here. The lock lasts until the last of those writers, and any batch one finished into, lets go of it.

Implementations

impl WriterFolder

pub fn create(&self, name: &FileName) -> Result<FileWriter, FileError>

Create name here for asynchronous streaming without replacing anything.

pub fn write_whole( &self, name: &FileName, bytes: &[u8], batch: &mut FlushBatch, ) -> Result<(), FileError>

Create name here holding all of bytes and count it in batch, as FileWriter::write_from does for a source it reads, but in this one call: it blocks on the file’s I/O, so a caller on an async runtime runs it on the blocking pool.

Trait Implementations

impl Clone for WriterFolder

fn clone(&self) -> WriterFolder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.