Trait StreamingIndex 

pub trait StreamingIndex {
    // Required methods
    fn apply(&mut self, op: UpdateOp) -> Result<()>;
    fn apply_batch(&mut self, batch: UpdateBatch) -> Result<UpdateStats>;
    fn compact(&mut self) -> Result<UpdateStats>;
    fn stats(&self) -> StreamingStats;
}

Trait for indices that support streaming updates.

Required Methods

fn apply(&mut self, op: UpdateOp) -> Result<()>

Apply a single update operation.

fn apply_batch(&mut self, batch: UpdateBatch) -> Result<UpdateStats>

Apply a batch of updates atomically.

fn compact(&mut self) -> Result<UpdateStats>

Compact/merge buffered updates into main index.

fn stats(&self) -> StreamingStats

Get streaming statistics.

Implementors