Struct SubagentRegistry 

pub struct SubagentRegistry { /* private fields */ }

Implementations

impl SubagentRegistry

pub fn new() -> SubagentRegistry

pub fn archive_path(&self, id: &str) -> Option<PathBuf>

Resume archive of id, whether its handle is still live or was reaped.

pub fn register(&mut self, handle: SubagentHandle) -> String

Register a handle and return its id.

pub fn register_with_cancellation( &mut self, handle: SubagentHandle, origin: Option<&CancellationToken>, ) -> String

pub fn set_spawn_cancellation( &mut self, cancel: Option<CancellationToken>, ) -> u64

Frontend-owned launch fence. Model tools cannot clear or replace it.

pub fn cancel_spawn_epoch(&mut self, epoch: u64)

A stale deadline/Drop must not cancel workers belonging to newer work.

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

pub fn get_mut(&mut self, id: &str) -> Option<&mut SubagentHandle>

pub fn remove(&mut self, id: &str) -> Option<SubagentHandle>

pub fn release_finished_resources(&mut self, id: &str)

Drop finished execution transports and resumable context while retaining bounded terminal diagnostics and output under normal session retention.

pub fn list_active(&self) -> Vec<(String, String, SubagentStatus)>

Returns (id, agent_name, status) for every tracked handle.

pub fn display_rows(&self) -> Vec<SubagentDisplayRow>

Snapshot of every tracked handle for TUI reconcile. Reads all state under the lock POISON-SAFE; exposes cancel_requested which list_active() does not.

pub fn iter_mut_handles(&mut self) -> impl Iterator<Item = &mut SubagentHandle>

Drop handles that are no longer running. Iterate over all handles mutably (for bulk operations like cancel-all).

pub fn cleanup_finished_with_ttl(&mut self, ttl: Duration)

Reap a finished handle iff: (a) its result was collected via subagent_collect, OR (b) it has been finished longer than ttl (abandoned). Finished-but-uncollected handles inside the TTL are RETAINED so the completion event can wake the parent and collect still succeeds.

Additionally, handles whose OS thread is still running (e.g. still in the finalizer path) are deferred — joining a live thread blocks the TUI loop. They will be reaped on the next cleanup pass once the thread exits. Orchestration-required expired handles become bounded tombstones instead of being removed; a later collect/reconcile makes them normally reapable.

pub fn cleanup_finished_with_ttl_and_retention( &mut self, ttl: Duration, retain_unreconciled: impl Fn(&str) -> bool, )

Reap normally, except that an expired uncollected handle still required by orchestration is downgraded to a bounded, collectible tombstone.

pub fn cleanup_finished(&mut self)

Reap finished handles using the production TTL. Finished-but-uncollected handles within the TTL window are retained.

Trait Implementations

impl Debug for SubagentRegistry

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

Formats the value using the given formatter.

impl Default for SubagentRegistry

fn default() -> SubagentRegistry

Returns the “default value” for a type.