Struct StagingBuffer 

pub struct StagingBuffer { /* private fields */ }

Staging buffer with pending vectors awaiting HNSW insertion.

Implementations

impl StagingBuffer

pub fn new() -> Self

pub fn add(&mut self, external_id: usize, vector: Vec<f32>) -> bool

Add a vector to the staging buffer. Returns true if auto-flush is needed.

pub fn pending_count(&self) -> usize

Number of pending vectors.

pub fn search_merged( &self, live: &HnswIndex, query: &[f32], k: usize, ef: usize, metric: DistanceMetric, ) -> Vec<(usize, f32)>

Search both the live HNSW index and the pending buffer, merging results.

pub fn flush(&mut self, index: &mut HnswIndex)

Flush all pending vectors into the live HNSW index.

Trait Implementations

impl Default for StagingBuffer

fn default() -> Self

Returns the “default value” for a type.