Struct InMemorySubagentTaskTracker 

pub struct InMemorySubagentTaskTracker { /* private fields */ }

Implementations

impl InMemorySubagentTaskTracker

pub fn new() -> Self

pub fn with_max_terminal_tasks(max: usize) -> Self

Construct a tracker with an optional FIFO cap on terminal-state snapshots. Running tasks are never dropped.

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>

pub async fn replace_snapshots(&self, snapshots: Vec<SubagentTaskSnapshot>)

Replace the tracker’s task snapshots with the given set. Cancellers are not restored (they are runtime-only channels tied to live child loops). After replace_snapshots, any task whose status was Running at checkpoint time will appear Running in the tracker but cancel(task_id) will return false because no canceller is registered — callers should normally checkpoint at a quiescent point so no tasks are Running.

Used by SessionStore rehydration to restore the materialized subagent view of a previously-saved session.

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.