Struct InMemoryVectorStore 

pub struct InMemoryVectorStore { /* private fields */ }

In-memory vector store implementation

Stores documents in a HashMap protected by RwLock for thread-safety. Uses brute-force similarity search (suitable for small datasets).

Implementations

impl InMemoryVectorStore

pub fn new() -> Self

Create a new in-memory vector store with default settings

pub fn with_metric(metric: DistanceMetric) -> Self

Create with a specific distance metric

pub fn with_dimensions(dimensions: usize) -> Self

Create with expected dimensions for validation

pub fn with_config(metric: DistanceMetric, dimensions: usize) -> Self

Create with both metric and dimensions

pub fn clear(&self)

Clear all documents

Trait Implementations

impl Default for InMemoryVectorStore

fn default() -> Self

Returns the “default value” for a type.

impl VectorStore for InMemoryVectorStore

fn upsert<'life0, 'async_trait>( &'life0 self, documents: Vec<EmbeddedDocument>, ) -> Pin<Box<dyn Future<Output = Result<UpsertStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert or update documents in the store

fn search<'life0, 'async_trait>( &'life0 self, query_embedding: Vec<f32>, filter: Option<Filter>, top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchResult>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Search for similar vectors

fn delete<'life0, 'async_trait>( &'life0 self, ids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<DeleteStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete documents by ID

fn get<'life0, 'async_trait>( &'life0 self, ids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<EmbeddedDocument>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get documents by ID

fn count<'life0, 'async_trait>( &'life0 self, filter: Option<Filter>, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Count documents, optionally filtered

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HealthStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check backend health/connectivity

fn backend_name(&self) -> &'static str

Get the name of this backend (for logging/debugging)

fn dimensions(&self) -> Option<usize>

Get configured vector dimensions (if known)