Struct rustdb::buf::ReadBufStg

pub struct ReadBufStg<const N: usize> { /* private fields */ }

ReadBufStg buffers small (up to limit) reads to the underlying storage. Only supported functions are read and reset.

See implementation of AtomicFile for how this is used in conjunction with WMap.

N is buffer size.

Implementations

impl<const N: usize> ReadBufStg<N>

pub fn new(stg: Box<dyn Storage>, limit: usize, max_buf: usize) -> Box<Self>

Trait Implementations

impl<const N: usize> Storage for ReadBufStg<N>

fn size(&self) -> u64

Get the size of the underlying storage. Note : this is valid initially and after a commit but is not defined after write is called.

fn read(&self, start: u64, data: &mut [u8])

Read data from storage.

fn write(&mut self, _start: u64, _data: &[u8])

Write byte slice to storage.

fn commit(&mut self, _size: u64)

Finish write transaction, size is new size of underlying storage.

fn reset(&mut self)

Reset buffer

fn write_vec(&mut self, start: u64, data: Vec<u8>)

Write byte Vec to storage.

fn write_data(&mut self, start: u64, data: Data, off: usize, len: usize)

Write Data slice to storage.

fn write_u64(&mut self, start: u64, value: u64)

Write u64 to storage.

fn read_u64(&self, start: u64) -> u64

Read u64 from storage.

fn clone(&self) -> Box<dyn Storage>

fn wait_complete(&self)

Wait until current writes are complete.