pub struct SubagentRegistry { /* private fields */ }Implementations§
Source§impl SubagentRegistry
impl SubagentRegistry
pub fn new() -> Self
Sourcepub fn register(&mut self, handle: SubagentHandle) -> String
pub fn register(&mut self, handle: SubagentHandle) -> String
Register a handle and return its id.
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>
Sourcepub fn release_finished_resources(&mut self, id: &str)
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.
Sourcepub fn list_active(&self) -> Vec<(String, String, SubagentStatus)>
pub fn list_active(&self) -> Vec<(String, String, SubagentStatus)>
Returns (id, agent_name, status) for every tracked handle.
Sourcepub fn display_rows(&self) -> Vec<SubagentDisplayRow>
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.
Sourcepub fn iter_mut_handles(&mut self) -> impl Iterator<Item = &mut SubagentHandle>
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).
Sourcepub fn cleanup_finished_with_ttl(&mut self, ttl: Duration)
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.
Sourcepub fn cleanup_finished_with_ttl_and_retention(
&mut self,
ttl: Duration,
retain_unreconciled: impl Fn(&str) -> bool,
)
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.
Sourcepub fn cleanup_finished(&mut self)
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§
Source§impl Debug for SubagentRegistry
impl Debug for SubagentRegistry
Auto Trait Implementations§
impl !RefUnwindSafe for SubagentRegistry
impl !UnwindSafe for SubagentRegistry
impl Freeze for SubagentRegistry
impl Send for SubagentRegistry
impl Sync for SubagentRegistry
impl Unpin for SubagentRegistry
impl UnsafeUnpin for SubagentRegistry
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.