Struct UpdateBuffer 

pub struct UpdateBuffer { /* private fields */ }

Buffer for batching online updates

Implementations

impl UpdateBuffer

pub fn new(config: OnlineUpdateConfig) -> Self

Create a new update buffer

pub fn buffer_insert(&self, id: VectorId, vector: Vec<f32>)

Add an insert to the buffer

pub fn buffer_delete(&self, id: VectorId)

Add a delete to the buffer

pub fn should_flush(&self) -> bool

Check if buffer should be flushed

pub fn flush_inserts(&self) -> Vec<(VectorId, Vec<f32>)>

Flush pending inserts and return them

pub fn flush_deletes(&self) -> HashSet<VectorId>

Flush pending deletes and return them

pub fn stats(&self) -> OnlineUpdateStats

Get buffer statistics

Trait Implementations

impl Debug for UpdateBuffer

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

Formats the value using the given formatter.