Struct AsyncLsmManager 

pub struct AsyncLsmManager { /* private fields */ }

Non-blocking LSM manager with WAL

Implementations

impl AsyncLsmManager

pub fn new(config: LsmConfig) -> Result<Self>

Create a new async LSM manager

pub fn insert(&self, key: VectorKey, vector: Vec<f32>) -> Result<(), LsmError>

Insert a vector (with WAL durability)

pub fn insert_batch( &self, items: Vec<(VectorKey, Vec<f32>)>, ) -> Result<(), LsmError>

Insert batch (optimized path)

pub fn seal_async(&self) -> Result<u64, LsmError>

Non-blocking seal - returns immediately

pub fn seal_blocking(&self) -> Result<Arc<SealedSegment>, LsmError>

Blocking seal - waits for completion

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

Search across all segments

pub fn get(&self, key: VectorKey) -> Option<Vec<f32>>

Get vector by key

pub fn flush(&self) -> Result<(), LsmError>

Wait for all pending builds to complete

pub fn stats(&self) -> LsmManagerStats

Get statistics

Trait Implementations

impl Drop for AsyncLsmManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.