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<TaskObject>

Get task object by ID

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

Get full task result by ID (task object, result, error)

pub async fn wait_for_completion( &self, task_id: &str, ) -> Option<(TaskObject, Option<CallToolResult>, Option<String>)>

Wait for a task to reach a terminal state, then return its result.

If the task is already terminal, returns immediately. Otherwise blocks until the task completes, fails, or is cancelled.

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

List all tasks, optionally filtered by status

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<TaskObject>

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.