Struct WriteBuffer 

pub struct WriteBuffer { /* private fields */ }

Write buffer for batched operations.

Provides durability through WAL and performance through batching.

Example

use rag_plusplus_core::buffer::{WriteBuffer, WriteBufferConfig};

let wal = WalWriter::new(wal_config)?;
let mut store = InMemoryStore::new();
let mut index = FlatIndex::new(IndexConfig::new(128));

let mut buffer = WriteBuffer::new(
    WriteBufferConfig::new(),
    Arc::new(wal),
);

buffer.insert(record)?;
buffer.update_stats(&id, 0.9)?;

// Flush to store and index
buffer.flush(&mut store, &mut index)?;

Implementations

impl WriteBuffer

pub fn new(config: WriteBufferConfig, wal: Arc<WalWriter>) -> Self

Create a new write buffer with WAL.

pub fn without_wal(config: WriteBufferConfig) -> Self

Create a write buffer without WAL (testing/in-memory only).

pub fn insert(&self, record: MemoryRecord) -> Result<()>

Insert a record.

The record is logged to WAL (if enabled) and buffered.

pub fn update_stats(&self, id: &RecordId, outcome: f64) -> Result<()>

Update record statistics.

pub fn delete(&self, id: &RecordId) -> Result<()>

Delete a record.

pub fn flush<S: RecordStore, I: VectorIndex>( &self, store: &mut S, index: &mut I, ) -> Result<FlushResult>

Flush buffer to store and index.

All buffered operations are applied atomically.

pub fn flush_to_store<S: RecordStore>( &self, store: &mut S, ) -> Result<FlushResult>

Flush only to store (no index update).

pub fn maybe_flush<S: RecordStore, I: VectorIndex>( &self, store: &mut S, index: &mut I, ) -> Result<bool>

Auto-flush if buffer thresholds are exceeded.

Returns true if flush occurred.

pub fn stats(&self) -> BufferStats

Get buffer statistics.

pub fn is_empty(&self) -> bool

Check if buffer is empty.

pub fn len(&self) -> usize

Get number of buffered operations.

Trait Implementations

impl Debug for WriteBuffer

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

Formats the value using the given formatter.