Struct WriteBuffer 

pub struct WriteBuffer { /* private fields */ }

Write buffer for time-series data

Provides thread-safe buffering with automatic flush triggers.

Implementations

impl WriteBuffer

pub fn new(config: BufferConfig) -> Self

Create new write buffer

pub fn with_defaults() -> Self

Create with default configuration

pub async fn insert(&self, series_id: u64, point: DataPoint) -> TsdbResult<bool>

Insert a data point into the buffer

Returns true if buffer should be flushed

pub async fn insert_batch( &self, entries: &[(u64, DataPoint)], ) -> TsdbResult<bool>

Insert multiple points in a batch

pub async fn flush_series(&self, series_id: u64) -> TsdbResult<Vec<DataPoint>>

Flush all buffers for a specific series

pub async fn flush_all(&self) -> TsdbResult<HashMap<u64, Vec<DataPoint>>>

Flush all buffers

Returns map of series_id → data points

pub async fn stats(&self) -> BufferStats

Get buffer statistics

pub async fn series_needing_flush(&self) -> Vec<u64>

Check which series need flushing