Struct WriteBuffer 

pub struct WriteBuffer { /* private fields */ }

In-memory write buffer for time-series data points.

Implementations

impl WriteBuffer

pub fn new(config: WriteBufferConfig) -> Self

Create a new write buffer with the given configuration.

pub fn state(&self) -> BufferState

Current buffer state.

pub fn stats(&self) -> &BufferStats

Return a snapshot of current buffer statistics.

pub fn len(&self) -> usize

Number of data points currently held.

pub fn is_empty(&self) -> bool

True if no points are currently buffered.

pub fn is_full(&self) -> bool

True if the buffer has reached maximum capacity.

pub fn push(&mut self, point: DataPoint) -> WriteBufferResult<()>

Push a data point into the buffer.

Errors

Returns WriteBufferError::BufferFull when the buffer is at capacity and backpressure should be applied by the caller.

pub fn push_batch( &mut self, points: impl IntoIterator<Item = DataPoint>, ) -> usize

Push multiple data points at once.

Points are added until the buffer is full; returns the number actually pushed.

pub fn should_flush(&self) -> bool

True if the current policy conditions require a flush.

pub fn flush(&mut self) -> WriteBufferResult<Vec<DataPoint>>

Flush all buffered data points, sorted by timestamp.

Writes a WAL entry if enable_wal is set and a sink is provided. Returns the flushed points in ascending timestamp order.

pub fn flush_with_wal<W: WalSink>( &mut self, wal: &mut W, ) -> WriteBufferResult<Vec<DataPoint>>

Flush with a WAL sink.

pub fn partial_flush( &mut self, count: usize, ) -> WriteBufferResult<Vec<DataPoint>>

Flush only the oldest data points (those with the smallest timestamps).

count specifies how many points to flush (0 = use config default). Points are sorted by timestamp before selection.