Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Manages all tasks across sessions.

Implementations

impl TaskManager

pub fn new() -> Self

Create a new task manager.

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

Subscribe to task events.

pub async fn create( &self, kind: TaskKind, session_key: Option<String>, ) -> TaskHandle

Create a new task and return its handle.

pub async fn get(&self, id: TaskId) -> Option<Task>

Get a task by ID.

pub async fn all(&self) -> Vec<Task>

Get all tasks.

pub async fn for_session(&self, session_key: &str) -> Vec<Task>

Get tasks for a specific session.

pub async fn active(&self) -> Vec<Task>

Get active (non-terminal) tasks.

pub async fn foreground_task(&self, session_key: &str) -> Option<Task>

Get the foreground task for a session.

pub async fn set_foreground(&self, id: TaskId) -> Result<(), String>

Set a task as the foreground task for its session.

pub async fn set_background(&self, id: TaskId) -> Result<(), String>

Background a task.

pub async fn update_status(&self, id: TaskId, new_status: TaskStatus)

Update a task’s status.

pub async fn start(&self, id: TaskId)

Mark a task as started.

pub async fn complete(&self, id: TaskId, summary: Option<String>)

Mark a task as completed.

pub async fn fail(&self, id: TaskId, error: String, retryable: bool)

Mark a task as failed.

pub async fn cancel(&self, id: TaskId) -> Result<(), String>

Cancel a task.

pub async fn set_description( &self, id: TaskId, description: &str, ) -> Result<(), String>

Set task description.

pub async fn send_output(&self, id: TaskId, output: TaskOutput)

Send output for a task.

pub async fn cleanup_old(&self, max_age: Duration)

Cleanup completed/cancelled tasks older than the given duration.

pub async fn stats(&self) -> TaskStats

Get task statistics.

Trait Implementations

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.