Struct LocalVectorStore 

pub struct LocalVectorStore { /* private fields */ }

In-memory vector store using brute-force cosine similarity search.

This store keeps all vectors in memory and performs exact nearest neighbor search using cosine similarity. While not as efficient as approximate methods like HNSW for large datasets, it’s simple, fast for small to medium datasets, and provides exact results.

Features

• Fast in-memory storage with RwLock for thread-safety
• Exact nearest neighbor search using cosine similarity
• Optional similarity threshold filtering
• Agent-specific filtering
• No external dependencies

Example

use ceylon_next::memory::vector::{LocalVectorStore, VectorEntry, VectorStore};
use std::sync::Arc;

#[tokio::main]
async fn main() {
    let store = LocalVectorStore::new(384);

    let entry = VectorEntry::new(
        "memory-1".to_string(),
        "agent-1".to_string(),
        "Hello world".to_string(),
        vec![0.1; 384],
        None,
    );

    let id = store.store(entry).await.unwrap();
    println!("Stored vector with ID: {}", id);

    // Search for similar vectors
    let query = vec![0.1; 384];
    let results = store.search(&query, Some("agent-1"), 5, None).await.unwrap();
    println!("Found {} similar vectors", results.len());
}

Implementations

impl LocalVectorStore

pub fn new(dimension: usize) -> Self

Creates a new local vector store.

Arguments

• dimension - The dimensionality of vectors to store

Example

use ceylon_next::memory::vector::LocalVectorStore;

let store = LocalVectorStore::new(384);

pub fn with_capacity(dimension: usize, capacity: usize) -> Self

Creates a new local vector store with pre-allocated capacity.

Arguments

• dimension - The dimensionality of vectors to store
• capacity - Initial capacity for the vector storage

Trait Implementations

impl VectorStore for LocalVectorStore

fn store<'life0, 'async_trait>( &'life0 self, entry: VectorEntry, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

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

Stores a vector entry.

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

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

Stores multiple vector entries in batch.

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

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

Retrieves a vector entry by ID.

fn search<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_vector: &'life1 [f32], agent_id: Option<&'life2 str>, limit: usize, threshold: Option<f32>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchResult>, String>> + Send + 'async_trait>>

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

Searches for similar vectors using cosine similarity.

fn clear_agent_vectors<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Deletes all vectors for an agent.

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

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

Returns the number of vectors stored.

fn dimension(&self) -> usize

Returns the dimension of vectors in this store.