Struct InMemoryDocumentStore 

pub struct InMemoryDocumentStore { /* private fields */ }

In-memory document store

Q5: uses tokio::sync::RwLock (consistent with InMemoryVectorStore), methods .await directly without blocking the executor; and there are no synchronous _blocking methods called from async contexts, so there is no blocking_read/write panic constraint.

Implementations

impl InMemoryDocumentStore

pub fn new() -> InMemoryDocumentStore

Creates a new in-memory document store

Trait Implementations

impl Default for InMemoryDocumentStore

fn default() -> InMemoryDocumentStore

Returns the “default value” for a type.

impl DocumentStore for InMemoryDocumentStore

fn add_document<'life0, 'async_trait>( &'life0 self, document: Document, ) -> Pin<Box<dyn Future<Output = Result<String, VectorStoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryDocumentStore: 'async_trait,

Adds a document

fn add_documents<'life0, 'async_trait>( &'life0 self, documents: Vec<Document>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, VectorStoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryDocumentStore: 'async_trait,

Adds documents in bulk

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryDocumentStore: 'async_trait,

Gets a document

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryDocumentStore: 'async_trait,

Deletes a document

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

where 'life0: 'async_trait, InMemoryDocumentStore: 'async_trait,

Gets the document count

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

where 'life0: 'async_trait, InMemoryDocumentStore: 'async_trait,

Clears the store