Struct LayeredMemory 

pub struct LayeredMemory<S: EntryStore, I: IndexSearcher> { /* private fields */ }

Default layered memory backed by an entry store and index searcher.

Implementations

impl<S: EntryStore, I: IndexSearcher> LayeredMemory<S, I>

pub fn new(store: Arc<S>, searcher: Arc<I>) -> Self

Create a new LayeredMemory.

Trait Implementations

impl<S: EntryStore, I: IndexSearcher> ConversationMemory for LayeredMemory<S, I>

fn append<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, message: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Append a message to the session.

fn recent<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, n: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + 'async_trait>>

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

Return the most recent n messages, newest last.

fn evict<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, keep: usize, ) -> Pin<Box<dyn Future<Output = Result<usize, StoreError>> + Send + 'async_trait>>

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

Evict the oldest messages, keeping only the keep most recent.

impl<S: EntryStore, I: IndexSearcher> FactMemory for LayeredMemory<S, I>

fn remember<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, fact: &'life1 str, tags: &'life2 [String], ) -> Pin<Box<dyn Future<Output = Result<String, StoreError>> + Send + 'async_trait>>

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

Store a fact with optional tags and return a unique identifier.

fn recall<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, f32, Vec<String>)>, StoreError>> + Send + 'async_trait>>

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

Recall facts matching the query.

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

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

Delete a fact by its unique ID.

impl<S: EntryStore, I: IndexSearcher> ProjectMemory for LayeredMemory<S, I>

fn put<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project_id: &'life1 str, key: &'life2 str, value: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Store a key-value pair in the project namespace.

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

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

Retrieve a value by key.

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

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

List all keys in the project namespace.

fn search<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, project_id: &'life1 str, query: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, f32)>, StoreError>> + Send + 'async_trait>>

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

Search for entries matching the query string.

impl<S: EntryStore, I: IndexSearcher> SummaryMemory for LayeredMemory<S, I>

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

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

Retrieve the most recent summary for a scope.

fn store<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, scope: &'life1 str, summary: &'life2 str, source: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Store a new summary for a scope.

fn history<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String, u64)>, StoreError>> + Send + 'async_trait>>

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

Return the summary history for a scope, newest first.

impl<S: EntryStore, I: IndexSearcher> UserProfileMemory for LayeredMemory<S, I>

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

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

Retrieve all preferences for a user as a flat key-value map.

fn set_preference<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, user_id: &'life1 str, key: &'life2 str, value: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Set or update a single preference key.

fn remove_preference<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Remove a single preference key.