Struct ConversationManager 

pub struct ConversationManager { /* private fields */ }

Shared, async conversation history manager.

Thread-safe: clone the Arc to share across tasks. All operations are O(1) amortised apart from build_prompt which is O(turns).

Implementations

impl ConversationManager

pub fn new(config: ConversationConfig) -> Self

Create a new manager with the given configuration.

pub async fn push_user(&self, session: &SessionId, content: impl Into<String>)

Append a user turn to the conversation for session.

pub async fn push_assistant( &self, session: &SessionId, content: impl Into<String>, )

Append an assistant turn to the conversation for session.

pub async fn push_tool(&self, session: &SessionId, content: impl Into<String>)

Append a tool-result turn.

pub async fn push_system(&self, session: &SessionId, content: impl Into<String>)

Append a system turn (overrides the global system prompt for this turn).

pub async fn build_prompt(&self, session: &SessionId, new_input: &str) -> String

Build a full prompt string that includes prior conversation history followed by new_input as the next user message.

The returned string is ready to pass directly to a crate::ModelWorker.

pub async fn get(&self, session: &SessionId) -> Option<Conversation>

Return a snapshot of the conversation for session, or None if no history exists.

pub async fn turn_count(&self, session: &SessionId) -> usize

Return the number of turns currently stored for session.

pub async fn token_count(&self, session: &SessionId) -> usize

Return the estimated token count for session.

pub async fn set_meta( &self, session: &SessionId, key: impl Into<String>, value: impl Into<String>, )

Attach arbitrary metadata to a session’s conversation.

pub async fn clear(&self, session: &SessionId)

Clear the conversation history for session.

pub async fn evict_stale(&self)

Evict all conversations that have been inactive longer than the configured TTL. Call this periodically (e.g. every hour) to reclaim memory.

pub async fn export_json(&self, session: &SessionId) -> Option<String>

Export a conversation as a JSON string for persistence or debugging.

pub async fn active_sessions(&self) -> Vec<String>

Return all active session IDs.

pub async fn len(&self) -> usize

Total number of active conversations.

pub async fn is_empty(&self) -> bool

True if there are no active conversations.

Trait Implementations

impl Clone for ConversationManager

fn clone(&self) -> ConversationManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.