Struct AgentProcessRegistry 

pub struct AgentProcessRegistry {
    inner: Mutex<HashMap<String, RegistryEntry>>,
    broker: Option<Arc<Broker>>,
}

Fields

inner: Mutex<HashMap<String, RegistryEntry>>

broker: Option<Arc<Broker>>

Implementations

impl AgentProcessRegistry

pub fn new(broker: Option<Arc<Broker>>) -> Self

pub fn ensure_tracker(&self, block_id: &str) -> Arc<dyn TrackerHandle>

Ensure a tracker exists for this block. Idempotent — calling twice for the same block returns the existing tracker so the job survives controller re-creation (e.g. on /clear).

pub fn remove(&self, block_id: &str)

Drop a block’s tracker — call when the pane closes. The tracker’s Drop impl kills the whole process tree (via KILL_ON_JOB_CLOSE on Windows, cgroup.kill on Linux, killpg on macOS).

pub fn list_block(&self, block_id: &str) -> Vec<TrackedProcess>

Current members of a block’s tracker, for the RPC endpoint.

pub fn confidence_of(&self, block_id: &str) -> TrackingConfidence

Confidence of a block’s tracker — drives the “tracking is best-effort on macOS” badge in the swarm UI.

pub fn list_all_blocks(&self) -> Vec<String>

All tracked blocks — used by the swarm panel’s aggregate view.

pub fn kill_tree(&self, block_id: &str) -> bool

Kill the entire process tree for a given block. Returns true if a tracker was found (the kill was dispatched). Does NOT synchronously wait for descendants to actually exit — the poller’s next tick will pick up the state changes and emit agent:process-exited events the frontend can react to.

pub fn kill_pid(&self, block_id: &str, pid: u32) -> bool

Kill a single PID if it’s a member of the given block’s tree. Returns true if the tracker was found and the PID matched.

pub fn poll_and_emit(&self)

Poll every tracked block’s membership and diff against the last-known set. Emits agent:process-added / -exited events for each delta.

Called by a background Tokio task on a ~2s interval.

fn emit(&self, event_name: &str, block_id: &str, data: Value)