Struct rustdb::buf::ReadBufStg

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

ReadBufStg buffers small (up to limit) reads to the underlying storage using multiple buffers. 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>

limit is the size of a read that is considered “small”, max_buf is the maximum number of buffers used.

Trait Implementations

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

fn drop(&mut self)

Executes the destructor for this type.

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

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

Read data from storage.

fn reset(&mut self)

Clears the buffers.

fn size(&self) -> u64

Panics.

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

Panics.

fn commit(&mut self, _size: u64)

Panics.

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>

Clone.

fn wait_complete(&self)

Wait until current writes are complete.