Struct InMemorySubagentTaskTracker 

pub struct InMemorySubagentTaskTracker { /* private fields */ }

Implementations

impl InMemorySubagentTaskTracker

pub fn new() -> Self

pub async fn register_canceller(&self, task_id: &str, token: CancellationToken)

Register a CancellationToken for a running task so callers can trigger cancellation through cancel(task_id). The task executor is expected to remove the entry on exit via clear_canceller.

pub async fn clear_canceller(&self, task_id: &str)

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

Fire the registered token and mark the snapshot as Cancelled. Returns true if a token was found (caller can interpret as “cancellation initiated”), false if the task id was unknown or the task already finished. The eventual SubagentEnd event won’t overwrite the Cancelled status — see record_event.

pub async fn record_event(&self, event: &AgentEvent)

Apply a single agent event to the tracker. Non-subagent events are ignored.

pub async fn get(&self, task_id: &str) -> Option<SubagentTaskSnapshot>

pub async fn list(&self) -> Vec<SubagentTaskSnapshot>

pub async fn list_pending(&self) -> Vec<SubagentTaskSnapshot>

pub async fn list_for_parent( &self, parent_session_id: &str, ) -> Vec<SubagentTaskSnapshot>

Trait Implementations

impl Debug for InMemorySubagentTaskTracker

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

Formats the value using the given formatter.

impl Default for InMemorySubagentTaskTracker

fn default() -> InMemorySubagentTaskTracker

Returns the “default value” for a type.