Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Session manager for managing agent sessions with a pluggable backend

Implementations

impl SessionManager

pub fn new(backend: Arc<dyn MemoryBackend>) -> Self

Create a new session manager with the given backend

pub fn in_memory() -> Self

Create a session manager with the default in-memory backend

pub fn sled<P: AsRef<Path>>(path: P) -> Result<Self, MemoryError>

Create a session manager with Sled backend

pub fn sled_temporary() -> Result<Self, MemoryError>

Create a session manager with temporary Sled backend (for testing)

pub fn backend(&self) -> &dyn MemoryBackend

Get the backend reference

pub async fn create_session( &self, agent_id: &str, ) -> Result<Session, MemoryError>

Create a new session for an agent

pub async fn get_or_create_session( &self, agent_id: &str, session_id: Option<&str>, ) -> Result<Session, MemoryError>

Get or create a session for an agent

pub async fn resume_session( &self, token: &str, ) -> Result<Option<Session>, MemoryError>

Resume a session using a resume token

pub async fn save_session(&self, session: &Session) -> Result<(), MemoryError>

Save a session

pub async fn add_message( &self, session_id: &str, message: Message, ) -> Result<Session, MemoryError>

Add a message to a session and save

pub async fn create_resume_token( &self, session_id: &str, ) -> Result<String, MemoryError>

Generate a resume token for a session

pub async fn delete_session(&self, session_id: &str) -> Result<(), MemoryError>

Delete a session

pub async fn list_sessions( &self, agent_id: &str, ) -> Result<Vec<Session>, MemoryError>

List all sessions for an agent

pub async fn clear_agent_sessions( &self, agent_id: &str, ) -> Result<usize, MemoryError>

Clear all sessions for an agent