Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory vector store using brute-force search.

This is the simplest implementation, suitable for:

• Testing and development
• Small datasets (< 10,000 vectors)
• Prototyping before moving to a production database

Example

use phago_vectors::{InMemoryStore, VectorStore, VectorRecord};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let store = InMemoryStore::new(3);

    // Insert records
    store.upsert(vec![
        VectorRecord::new("a", vec![1.0, 0.0, 0.0]),
        VectorRecord::new("b", vec![0.0, 1.0, 0.0]),
        VectorRecord::new("c", vec![0.7, 0.7, 0.0]),
    ]).await?;

    // Search
    let results = store.search(&[1.0, 0.0, 0.0], 2).await?;
    assert_eq!(results[0].id, "a");

    Ok(())
}

Implementations

impl InMemoryStore

pub fn new(dimension: usize) -> Self

Create a new in-memory store with the specified dimension.

Uses cosine similarity by default.

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

Create a new in-memory store with a specific distance metric.

Trait Implementations

impl VectorStore for InMemoryStore

fn name(&self) -> &str

Get the name of this backend.

fn dimension(&self) -> usize

Get the vector dimension.

fn metric(&self) -> DistanceMetric

Get the distance metric.

fn upsert<'life0, 'async_trait>( &'life0 self, records: Vec<VectorRecord>, ) -> Pin<Box<dyn Future<Output = VectorResult<()>> + Send + 'async_trait>>

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

Insert or update records in the store.

fn search<'life0, 'life1, 'async_trait>( &'life0 self, vector: &'life1 [f32], k: usize, ) -> Pin<Box<dyn Future<Output = VectorResult<Vec<SearchResult>>> + Send + 'async_trait>>

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

Search for similar vectors.

fn search_with_filter<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, vector: &'life1 [f32], k: usize, filter: &'life2 HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = VectorResult<Vec<SearchResult>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Search with metadata filter.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = VectorResult<Option<VectorRecord>>> + Send + 'async_trait>>

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

Get a record by ID.

fn get_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ids: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = VectorResult<Vec<VectorRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get multiple records by ID.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = VectorResult<()>> + Send + 'async_trait>>

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

Delete a record by ID.

fn delete_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ids: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = VectorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete multiple records by ID.

fn count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = VectorResult<usize>> + Send + 'async_trait>>

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

Get the total number of records in the store.

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

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

Clear all records from the store.