Struct SqliteSession 

pub struct SqliteSession { /* private fields */ }

A Session implementation that uses SQLite for persistent storage.

SqliteSession provides a durable way to store conversation history, making it ideal for applications that need to maintain state across restarts. It uses sqlx for asynchronous database operations.

Implementations

impl SqliteSession

pub async fn new( session_id: impl Into<String>, db_path: impl AsRef<Path>, ) -> Result<Self>

Creates a new SqliteSession with a specific database file path.

This method establishes a connection pool to the SQLite database and runs migrations to ensure the necessary tables are created.

Arguments

• session_id - A unique identifier for the conversation session.
• db_path - The path to the SQLite database file.

pub async fn new_default(session_id: impl Into<String>) -> Result<Self>

Creates a new SqliteSession using the default database path “sessions.db”.

pub async fn new_in_memory(session_id: impl Into<String>) -> Result<Self>

Creates an in-memory SqliteSession, useful for testing.

This version does not write to the filesystem, so the session data will be lost when the connection is closed.

Trait Implementations

impl Debug for SqliteSession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Session for SqliteSession

fn session_id(&self) -> &str

Returns the unique identifier for the session.

fn get_items<'life0, 'async_trait>( &'life0 self, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunItem>>> + Send + 'async_trait>>

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

Retrieves a list of RunItems from the session.

fn add_items<'life0, 'async_trait>( &'life0 self, items: Vec<RunItem>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Adds a vector of RunItems to the session.

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

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

Removes and returns the most recent RunItem from the session.

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

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

Clears all items from the session, effectively resetting the conversation.

fn get_messages<'life0, 'async_trait>( &'life0 self, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Retrieves the conversation history as a vector of Messages.