Struct SessionManagerGeneric 

pub struct SessionManagerGeneric<B: StorageBackend> { /* private fields */ }

Backend-agnostic session manager

This is the generic version of SessionManager that works with any StorageBackend implementation (SQLite, PostgreSQL, etc.)

Example

use avocado_core::storage::SqliteBackend;
use avocado_core::session::SessionManagerGeneric;

let backend = SqliteBackend::new("db.sqlite").await?;
let manager = SessionManagerGeneric::new(backend);
let session = manager.start_session(None).await?;

Implementations

impl<B: StorageBackend> SessionManagerGeneric<B>

pub fn new(backend: B) -> Self

Create a new SessionManagerGeneric

Arguments

• backend - Storage backend implementation

Returns

A new SessionManagerGeneric instance

pub fn from_arc(backend: Arc<B>) -> Self

Create from an Arc’d backend (for sharing)

pub fn backend(&self) -> &B

Get a reference to the backend

pub async fn start_session(&self, user_id: Option<&str>) -> Result<Session>

Start a new session

Arguments

• user_id - Optional user identifier

Returns

The newly created session

pub async fn add_user_message( &self, session_id: &str, query: &str, config: CompilerConfig, api_key: Option<&str>, ) -> Result<(Message, WorkingSet)>

Add a user message and compile context

This method:

1. Adds the user message to the database
2. Calls the compiler to generate a WorkingSet from the query
3. Associates the WorkingSet with the session
4. Returns both the Message and WorkingSet

Arguments

• session_id - The session ID
• query - The user’s query
• config - Compiler configuration
• api_key - Optional OpenAI API key (for embeddings)

Returns

Tuple of (Message, WorkingSet)

pub async fn add_user_message_with_explain( &self, session_id: &str, query: &str, config: CompilerConfig, api_key: Option<&str>, explain: bool, ) -> Result<(Message, WorkingSet)>

Add a user message with explain option

pub async fn add_assistant_message( &self, session_id: &str, content: &str, metadata: Option<&Value>, ) -> Result<Message>

Add an assistant response

Arguments

• session_id - The session ID
• content - The assistant’s response
• metadata - Optional metadata (e.g., model info, citations)

Returns

The newly created message

pub async fn get_conversation_history( &self, session_id: &str, max_tokens: Option<usize>, ) -> Result<String>

Get conversation history formatted for LLM consumption

Arguments

• session_id - The session ID
• max_tokens - Optional token limit

Returns

Formatted conversation history as a string

pub async fn replay_session(&self, session_id: &str) -> Result<SessionReplay>

Replay a session for debugging

Arguments

• session_id - The session ID

Returns

SessionReplay with structured debug data

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

Get session by ID

pub async fn list_sessions( &self, user_id: Option<&str>, limit: Option<usize>, ) -> Result<Vec<Session>>

List sessions

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

Delete a session