Struct McpTaskStore 

pub struct McpTaskStore { /* private fields */ }

Thread-safe in-memory store for McpTask entries.

Spawn with McpTaskStore::new; wire JSON-RPC dispatch into McpServer by calling insert, get, and cancel from your handler’s tasks/* method implementations.

Implementations

impl McpTaskStore

pub fn new() -> Self

Create a new empty store.

pub async fn insert(&self, task: McpTask) -> String

Insert a task and return its ID.

pub async fn get(&self, id: &str) -> Option<McpTask>

Retrieve a task by ID, returning None if not found or expired.

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

Transition a task to Cancelled. Returns false if the task is not found, expired, or already in a terminal state.

pub async fn update_state(&self, id: &str, state: McpTaskState) -> bool

Update the state of a task. Returns false if the task is not found or expired.

pub async fn complete(&self, id: &str, result: Value) -> bool

Set a completed result on a task, transitioning it to Completed.

pub async fn fail(&self, id: &str, error: impl Into<String>) -> bool

Fail a task with an error message, transitioning it to Failed.

pub async fn evict_expired(&self) -> usize

Evict all expired task entries.

pub async fn len(&self) -> usize

Return the number of tasks currently in the store (including expired).

pub async fn is_empty(&self) -> bool

Return true if the store has no tasks.

Trait Implementations

impl Clone for McpTaskStore

fn clone(&self) -> McpTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for McpTaskStore

fn default() -> Self

Returns the “default value” for a type.