Struct MonitorRegistry 

pub struct MonitorRegistry { /* private fields */ }

Registry for process links and monitors.

Thread-safe via DashMap. Delivers exit signals when processes terminate.

Implementations

impl MonitorRegistry

pub fn new() -> Self

Create a new, empty monitor registry.

pub fn link(&self, pid_a: Pid, pid_b: Pid)

Create a bidirectional link between two processes.

If the link already exists, this is a no-op.

pub fn unlink(&self, pid_a: Pid, pid_b: Pid)

Remove a bidirectional link between two processes.

pub fn monitor(&self, watcher: Pid, target: Pid) -> String

Create a unidirectional monitor: watcher monitors target.

Returns a unique reference ID that can be used to demonitor.

pub fn demonitor(&self, ref_id: &str)

Remove a monitor by its reference ID.

pub fn process_exited( &self, pid: Pid, reason: &ExitReason, ) -> (Vec<(Pid, ExitReason)>, Vec<ProcessDown>)

Called when a process exits. Returns the set of signals to deliver:

• (linked_pid, ExitReason) for each linked process
• ProcessDown for each monitoring process

pub fn get_links(&self, pid: Pid) -> Vec<Pid>

Get all PIDs linked to the given PID.

pub fn get_monitors(&self, pid: Pid) -> Vec<ProcessMonitor>

Get all monitors watching the given PID.

pub fn is_linked(&self, pid_a: Pid, pid_b: Pid) -> bool

Check if two PIDs are linked.

Trait Implementations

impl Default for MonitorRegistry

fn default() -> Self

Returns the “default value” for a type.