Struct TaskStore 

pub struct TaskStore { /* private fields */ }

Thread-safe task storage

Implementations

impl TaskStore

pub fn new() -> Self

Create a new task store

pub fn create_task( &self, tool_name: &str, arguments: Value, ttl: Option<u64>, ) -> (String, CancellationToken)

Create and store a new task

Returns the task ID and a cancellation token for the spawned work.

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

Get task info by ID

pub fn get_task_full( &self, task_id: &str, ) -> Option<(TaskStatus, Option<CallToolResult>, Option<String>)>

Get full task data by ID (for internal use)

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

List all tasks, optionally filtered by status

pub fn update_progress( &self, task_id: &str, progress: f64, message: Option<String>, ) -> bool

Update task progress

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

Mark a task as requiring input

pub fn complete_task(&self, task_id: &str, result: CallToolResult) -> bool

Mark a task as completed with a result

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

Mark a task as failed with an error

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

Cancel a task

pub fn cleanup_expired(&self) -> usize

Remove expired tasks (call periodically for cleanup)

Trait Implementations

impl Clone for TaskStore

fn clone(&self) -> TaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskStore

fn default() -> Self

Returns the “default value” for a type.