Struct InMemoryDocumentStore 

pub struct InMemoryDocumentStore { /* private fields */ }

内存文档存储

Q5: 用 tokio::sync::RwLock(与 InMemoryVectorStore 一致),方法内直接 .await, 不会阻塞 executor;且没有同步 _blocking 方法在 async 上下文中被调用,不存在 blocking_read/write 会 panic 的约束。

Implementations

impl InMemoryDocumentStore

pub fn new() -> InMemoryDocumentStore

创建新的内存文档存储

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,

添加文档

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,

批量添加文档

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,

获取文档

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,

删除文档

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

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

获取文档数量

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

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

清空存储