Struct TaskStore 

pub struct TaskStore { /* private fields */ }

Task store for managing async task execution

Implementations

impl TaskStore

pub fn new(default_ttl: Duration, default_poll_interval: Duration) -> Self

Create a new task store

pub fn create_task( &self, session_id: &str, original_request: JsonRpcRequest, requested_ttl: Option<u64>, ) -> (Task, Receiver<Value>)

Create a new task

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

Get task by ID

pub async fn get_task_for_session( &self, task_id: &str, session_id: &str, ) -> Option<Task>

Get task for specific session (enforces session isolation)

pub async fn list_tasks( &self, session_id: &str, cursor: Option<&str>, limit: usize, ) -> (Vec<Task>, Option<String>)

List tasks for a session (with pagination)

pub async fn update_status( &self, task_id: &str, new_status: TaskStatus, status_message: Option<String>, ) -> Result<(), TaskError>

Update task status

pub async fn store_result( &self, task_id: &str, result: Value, ) -> Result<(), TaskError>

Store task result

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

Get stored result

pub async fn wait_for_result( &self, task_id: &str, timeout: Duration, ) -> Result<Value, TaskError>

Wait for task result (blocks until terminal state)

pub async fn cancel_task( &self, task_id: &str, session_id: &str, ) -> Result<Task, TaskError>

Cancel a task

pub async fn cleanup_expired(&self)

Cleanup expired tasks (should be called periodically)

pub fn spawn_cleanup_task(self: Arc<Self>, interval: Duration)

Spawn background cleanup task