Struct BatchWriter 

pub struct BatchWriter { /* private fields */ }

High-throughput write path that buffers metric points and flushes in batches.

Usage

use oxirs_tsdb::write::batch_writer::{BatchWriter, BatchWriterConfig, MetricPoint};
use std::path::Path;

let cfg = BatchWriterConfig::default();
let mut bw = BatchWriter::open(Path::new("/tmp/tsdb_wal.bin"), cfg)?;

bw.write_point(MetricPoint::new("cpu", 1_700_000_000_000, 42.5))?;

let seq = bw.flush()?;
println!("flushed; last seq = {seq}");

Implementations

impl BatchWriter

pub fn open(path: &Path, config: BatchWriterConfig) -> TsdbResult<Self>

Open (or create) a BatchWriter backed by a CRC-protected WAL at path.

pub fn total_flushed(&self) -> u64

Return total points flushed since creation.

pub fn buffered_count(&self) -> usize

Return the number of points currently buffered.

pub fn batch_capacity(&self) -> usize

Return the configured batch capacity.

pub fn write_point(&mut self, point: MetricPoint) -> TsdbResult<()>

Enqueue a single metric point.

If the buffer is full, automatically flushes first.

pub fn write_batch(&mut self, points: &[MetricPoint]) -> TsdbResult<u64>

Enqueue a batch of metric points, flushing automatically when needed.

Returns the WAL sequence number of the last committed record.

pub fn flush(&mut self) -> TsdbResult<u64>

Flush all buffered points to the WAL.

Returns the WAL sequence number of the last committed record, or 0 if the buffer was empty.

pub fn replay_wal(path: &Path) -> TsdbResult<Vec<MetricPoint>>

Replay the WAL from disk (e.g. after a crash).