Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

A SQLite-backed implementation of the Memory trait.

This provides persistent storage of conversation history using SQLite. All conversations are stored in a local SQLite database file.

Examples

use ceylon::memory::SqliteStore;
use std::sync::Arc;

#[tokio::main]
async fn main() {
    let memory = Arc::new(
        SqliteStore::new("agent_memory.db").await.unwrap()
    );
}

Implementations

impl SqliteStore

pub async fn new<P: Into<PathBuf>>(db_path: P) -> Result<Self, String>

Creates a new SQLite store with the given database path.

Arguments

• db_path - Path to the SQLite database file (will be created if it doesn’t exist)

Examples

use ceylon::memory::SqliteStore;

#[tokio::main]
async fn main() {
    let store = SqliteStore::new("memory.db").await.unwrap();
}

pub fn db_path(&self) -> &PathBuf

Returns the path to the database file.

Trait Implementations

impl Memory for SqliteStore

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

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

Stores a conversation in memory.

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

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

Retrieves a specific conversation by ID.

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

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

Retrieves all conversations for an agent.

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

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

Retrieves the most recent N conversations for an agent.

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

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

Searches conversations for a query string.

fn clear_agent_memory<'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,

Clears all memory for an agent.