Struct FileStore 

pub struct FileStore { /* private fields */ }

A file-based implementation of the Memory trait.

This provides persistent storage of conversation history using files. Supports both JSON (human-readable) and MessagePack (compact binary) formats.

Examples

use ceylon::memory::{FileStore, StorageFormat};
use std::sync::Arc;

#[tokio::main]
async fn main() {
    // JSON format
    let memory = Arc::new(
        FileStore::new("memory.json", StorageFormat::Json).await.unwrap()
    );

    // MessagePack format
    let memory_mp = Arc::new(
        FileStore::new("memory.msgpack", StorageFormat::MessagePack).await.unwrap()
    );
}

Implementations

impl FileStore

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

Creates a new file-based store with the given file path and format.

Arguments

• file_path - Path to the storage file
• format - Serialization format (JSON or MessagePack)

Examples

use ceylon::memory::{FileStore, StorageFormat};

#[tokio::main]
async fn main() {
    let store = FileStore::new("memory.json", StorageFormat::Json).await.unwrap();
}

pub fn file_path(&self) -> &PathBuf

Returns the path to the storage file.

pub fn format(&self) -> StorageFormat

Returns the storage format being used.

Trait Implementations

impl Memory for FileStore

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.