Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Manages async task submission, tracking, and cancellation.

Implementations

impl TaskManager

pub fn from_settings(settings: &ApcoreSettings) -> Self

Create a new TaskManager from settings.

pub fn submit( &self, task_id: String, module_id: String, ) -> Result<(String, CancelToken), AxumApcoreError>

Submit a new async task. Returns the task ID and a CancelToken.

pub fn get_status(&self, task_id: &str) -> Option<TaskStatus>

Get the status of a task.

pub fn get_task_info(&self, task_id: &str) -> Option<TaskInfo>

Get full info for a task.

pub fn get_result(&self, task_id: &str) -> Option<Value>

Get the result of a completed task.

pub fn list_tasks(&self, status_filter: Option<&str>) -> Vec<TaskInfo>

List tasks, optionally filtered by status.

pub fn complete(&self, task_id: &str, result: Value)

Mark a task as completed with a result.

pub fn fail(&self, task_id: &str, error: String)

Mark a task as failed with an error message.

pub fn cancel(&self, task_id: &str) -> bool

Cancel a running task.

pub fn cleanup(&self, max_age_secs: u64) -> usize

Remove completed/failed/cancelled tasks older than the cleanup age.

pub fn count(&self) -> (usize, usize, usize, usize)

Count tasks by status.

Trait Implementations

impl Clone for TaskManager

fn clone(&self) -> TaskManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.