Struct LocalStorage 

pub struct LocalStorage { /* private fields */ }

Local SQLite storage implementation

Uses a Mutex<Connection> to ensure thread-safe access to the underlying libsql connection, which is not Send + Sync by default.

Implementations

impl LocalStorage

pub async fn new(db_path: &str) -> Result<Self, StorageError>

Create a new local storage instance

pub async fn from_connection(conn: Connection) -> Result<Self, StorageError>

Create from existing connection (for use with AgentClient)

This will initialize the database schema if it hasn’t been set up yet.

pub fn connection(&self) -> &Mutex<Connection>

Get connection reference (locked)

Useful for direct SQL access in tests or migrations.

Trait Implementations

impl SessionStorage for LocalStorage

fn list_sessions<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 ListSessionsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListSessionsResult, StorageError>> + Send + 'async_trait>>

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

List all sessions

fn get_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Session, StorageError>> + Send + 'async_trait>>

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

Get a session by ID (includes active checkpoint)

fn create_session<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 CreateSessionRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateSessionResult, StorageError>> + Send + 'async_trait>>

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

Create a new session with initial checkpoint

fn update_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, request: &'life1 UpdateSessionRequest, ) -> Pin<Box<dyn Future<Output = Result<Session, StorageError>> + Send + 'async_trait>>

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

Update session metadata (title, visibility)

fn delete_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a session

fn list_checkpoints<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, query: &'life1 ListCheckpointsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListCheckpointsResult, StorageError>> + Send + 'async_trait>>

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

List checkpoints for a session

fn get_checkpoint<'life0, 'async_trait>( &'life0 self, checkpoint_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Get a checkpoint by ID

fn create_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, request: &'life1 CreateCheckpointRequest, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Create a new checkpoint for a session

fn get_active_checkpoint<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, StorageError>> + Send + 'async_trait>>

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

Get the latest/active checkpoint for a session

fn get_session_stats<'life0, 'async_trait>( &'life0 self, _session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<SessionStats, StorageError>> + Send + 'async_trait>>

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

Get session stats (optional - returns default if not supported)