Struct ThreadManager 

pub struct ThreadManager { /* private fields */ }

Manages all agent threads with event emission.

Implementations

impl ThreadManager

pub fn new() -> Self

Create a new thread manager.

pub fn with_config(config: ThreadManagerConfig) -> Self

Create with custom config.

pub fn subscribe(&self) -> Receiver<ThreadEvent>

Subscribe to thread events.

pub fn create_chat(&mut self, label: impl Into<String>) -> ThreadId

Create a new chat thread and make it foreground.

pub fn create_subagent( &mut self, label: impl Into<String>, agent_id: impl Into<String>, task: impl Into<String>, parent_id: Option<ThreadId>, ) -> ThreadId

Create a sub-agent thread.

pub fn create_background( &mut self, label: impl Into<String>, purpose: impl Into<String>, parent_id: Option<ThreadId>, ) -> ThreadId

Create a background thread.

pub fn create_task( &mut self, label: impl Into<String>, action: impl Into<String>, parent_id: Option<ThreadId>, ) -> ThreadId

Create a task thread.

pub fn get(&self, id: ThreadId) -> Option<&AgentThread>

Get a thread by ID.

pub fn get_mut(&mut self, id: ThreadId) -> Option<&mut AgentThread>

Get a mutable thread by ID.

pub fn foreground(&self) -> Option<&AgentThread>

Get the foreground thread.

pub fn foreground_mut(&mut self) -> Option<&mut AgentThread>

Get the foreground thread mutably.

pub fn foreground_id(&self) -> Option<ThreadId>

Get foreground thread ID.

pub fn list(&self) -> Vec<&AgentThread>

List all threads.

pub fn list_info(&self) -> Vec<ThreadInfo>

List thread info for sidebar display.

pub fn set_description(&mut self, id: ThreadId, description: impl Into<String>)

Set description for a thread.

pub fn set_foreground_description(&mut self, description: impl Into<String>)

Set description for the foreground thread.

pub fn set_status(&mut self, id: ThreadId, status: ThreadStatus)

Update thread status.

pub fn switch_foreground(&mut self, id: ThreadId) -> bool

Switch foreground to a different thread.

pub fn clear_foreground(&mut self)

Clear the foreground — no thread is active (background all).

pub fn rename(&mut self, id: ThreadId, new_label: impl Into<String>) -> bool

Rename a thread.

pub fn find_best_match(&self, content: &str) -> Option<ThreadId>

Find the best matching thread for a given message content. Returns the thread ID if a good match is found, None otherwise.

pub fn complete( &mut self, id: ThreadId, summary: Option<String>, result: Option<String>, )

Mark a thread as completed.

pub fn fail(&mut self, id: ThreadId, error: impl Into<String>)

Mark a thread as failed.

pub fn add_message( &mut self, id: ThreadId, role: MessageRole, content: impl Into<String>, )

Add a message to a thread.

pub fn add_foreground_message( &mut self, role: MessageRole, content: impl Into<String>, )

Add a message to the foreground thread.

pub fn remove(&mut self, id: ThreadId) -> Option<AgentThread>

Remove a thread.

pub fn cleanup_ephemeral(&mut self)

Clean up old ephemeral threads.

pub fn build_global_context(&self) -> String

Build global context from all threads that share context.

pub fn save_to_file(&self, path: &Path) -> Result<()>

Save threads to a file.

pub fn load_from_file(path: &Path) -> Result<Self>

Load threads from a file.

pub fn load_or_default(path: &Path) -> Self

Load from file or create with default chat thread.

pub fn create_thread(&mut self, label: impl Into<String>) -> ThreadId

Alias for create_chat (old API compatibility).

pub fn switch_to(&mut self, id: ThreadId) -> Option<ThreadId>

Alias for switch_foreground that returns old foreground ID (old API compatibility).

pub fn get_by_id(&self, id: ThreadId) -> Option<&AgentThread>

Get a thread by ID (compatibility - already exists as get()).

pub fn get_by_id_mut(&mut self, id: ThreadId) -> Option<&mut AgentThread>

Get a mutable thread by ID (compatibility - already exists as get_mut()).

Trait Implementations

impl Default for ThreadManager

fn default() -> Self

Returns the “default value” for a type.