Struct StreamBuffer 

pub struct StreamBuffer { /* private fields */ }

A buffer for streaming vector updates.

Design

The buffer maintains:

1. Insert buffer: New vectors not yet in main index
2. Delete set: IDs marked for deletion (applied during compaction)

During search, both buffer and main index are queried, with delete set filtering applied to results.

Implementations

impl StreamBuffer

pub fn new() -> Self

pub fn with_config(config: StreamBufferConfig) -> Self

pub fn insert(&mut self, id: u32, vector: Vec<f32>) -> Result<()>

Insert a vector into the buffer.

pub fn delete(&mut self, id: u32)

Mark an ID for deletion.

pub fn needs_compaction(&self) -> bool

Check if buffer needs compaction.

pub fn drain(&mut self) -> (HashMap<u32, Vec<f32>>, HashSet<u32>)

Drain the buffer for compaction.

pub fn insert_count(&self) -> usize

Number of buffered inserts.

pub fn delete_count(&self) -> usize

Number of pending deletes.

pub fn is_deleted(&self, id: u32) -> bool

Check if an ID is pending delete.

pub fn get(&self, id: u32) -> Option<&Vec<f32>>

Get a vector from the buffer (if present).

pub fn iter(&self) -> impl Iterator<Item = (u32, &Vec<f32>)>

Iterate over buffered vectors.

pub fn search(&self, query: &[f32], k: usize) -> Vec<(u32, f32)>

Brute-force search in buffer.

Returns (id, distance) pairs sorted by distance ascending.

Trait Implementations

impl Debug for StreamBuffer

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

Formats the value using the given formatter.

impl Default for StreamBuffer

fn default() -> Self

Returns the “default value” for a type.