Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Central management layer for all observable tasks.

Sub-registries (BgRegistry, TermRegistry, Executor, agent_ctrl) register tasks here on spawn and call finish when the task ends. Typed operations (bash.output, term.input, term.capture) stay on the sub-registries and are looked up by source_handle.

Implementations

impl TaskRegistry

pub fn new() -> Self

pub fn register( &self, kind: TaskKind, label: String, source_handle: String, session_id: String, cancel: CancellationToken, ) -> TaskId

pub fn register_with_kill_hook( &self, kind: TaskKind, label: String, source_handle: String, session_id: String, cancel: CancellationToken, kill_hook: Option<Arc<dyn Fn() + Send + Sync>>, ) -> TaskId

pub fn lookup(&self, id: &TaskId) -> Option<TaskSnapshot>

pub fn lookup_by_handle(&self, handle: &str) -> Option<TaskSnapshot>

Find a task by its source handle (e.g. “bg_1”, “term_2”, run_id).

pub fn list(&self, filter: &TaskFilter) -> Vec<TaskSnapshot>

pub fn kill(&self, id: &TaskId) -> bool

pub fn finish(&self, id: &TaskId, status: TaskStatus)

Transition a task to a terminal status. Called by the owning sub-registry when the task finishes.

pub fn reap(&self, id: &TaskId)

pub fn subscribe(&self) -> Receiver<TaskEvent>

pub fn running_count(&self) -> usize

Trait Implementations

impl Clone for TaskRegistry

fn clone(&self) -> TaskRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.