Struct ProcessRegistry 

pub struct ProcessRegistry { /* private fields */ }

A thread-safe registry of all running processes.

The registry maintains mappings from:

• PIDs to process handles
• Registered names to PIDs

Examples

use starlang_runtime::ProcessRegistry;

let registry = ProcessRegistry::new();
// Processes are registered when spawned via the runtime

Implementations

impl ProcessRegistry

pub fn new() -> Self

Creates a new empty registry.

pub fn register(&self, handle: ProcessHandle)

Registers a process in the registry.

pub fn unregister(&self, pid: Pid) -> Option<ProcessHandle>

Removes a process from the registry.

Also removes any name registrations for this process.

pub fn get(&self, pid: Pid) -> Option<ProcessHandle>

Gets a handle to a process by PID.

pub fn contains(&self, pid: Pid) -> bool

Returns true if a process with the given PID exists.

pub fn len(&self) -> usize

Returns the number of registered processes.

pub fn is_empty(&self) -> bool

Returns true if the registry is empty.

pub fn send_raw(&self, pid: Pid, data: Vec<u8>) -> Result<(), SendError>

Sends a raw message to a process.

If the PID refers to a remote process and distribution is configured, the message will be routed through the distribution layer.

pub fn send<M: Term>(&self, pid: Pid, msg: &M) -> Result<(), SendError>

Sends a typed message to a process.

pub fn register_name(&self, name: String, pid: Pid) -> bool

Registers a name for a process.

Returns false if the name is already registered.

pub fn whereis(&self, name: &str) -> Option<Pid>

Looks up a process by registered name.

pub fn unregister_name(&self, name: &str) -> Option<Pid>

Unregisters a name.

Returns the PID that was registered, if any.

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

Returns all registered names.

pub fn pids(&self) -> Vec<Pid>

Returns all process PIDs.

pub fn for_each<F>(&self, f: F)

where F: FnMut(ProcessHandle),

Iterates over all processes, calling the provided function.

Trait Implementations

impl Clone for ProcessRegistry

fn clone(&self) -> ProcessRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessRegistry

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

Formats the value using the given formatter.

impl Default for ProcessRegistry

fn default() -> Self

Returns the “default value” for a type.