Struct WriteBuffer

pub struct WriteBuffer { /* private fields */ }

A sharded write buffer for staging incoming data points before flushing to storage. Uses a HashMap where keys are series names and values are mutex-protected Vecs.

Implementations

impl WriteBuffer

pub fn stage(&mut self, series: &str, point: DataPoint) -> Result<(), DbError>

Stages a single data point into the buffer for the corresponding series. If the series buffer doesn’t exist, it’s created. Acquires a lock only on the specific series buffer being written to.

pub fn drain_all_buffers(&mut self) -> HashMap<String, Vec<DataPoint>>

Drains all data from all series buffers, returning it for flushing. This requires acquiring locks on all buffers sequentially. Consider potential performance implications if there are many series. Returns a HashMap mapping series names to their drained data points.

Trait Implementations

impl Debug for WriteBuffer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WriteBuffer

fn default() -> WriteBuffer

Returns the “default value” for a type.