Struct DistributedProcessTable 

pub struct DistributedProcessTable { /* private fields */ }

Distributed process table tracking processes across all nodes.

Implementations

impl DistributedProcessTable

pub fn new() -> Self

pub fn merge(&mut self, advert: ProcessAdvertisement)

Merge a process advertisement (LWW: latest timestamp wins).

pub fn locate(&self, pid: Pid, node_id: &str) -> Option<&ProcessAdvertisement>

Look up a process by local PID and node ID.

pub fn find_by_type(&self, agent_type: &str) -> Vec<&ProcessAdvertisement>

Find processes by agent type across all nodes.

pub fn find_by_capability(&self, capability: &str) -> Vec<&ProcessAdvertisement>

Find processes offering a specific capability.

pub fn least_loaded_node(&self) -> Option<String>

Find the least-loaded node for scheduling.

pub fn remove_node(&mut self, node_id: &str)

Remove all processes from a node (e.g., when node becomes unreachable).

pub fn mark_node_unreachable(&mut self, node_id: &str)

Mark all processes on a node as unreachable.

pub fn all_advertisements(&self) -> Vec<&ProcessAdvertisement>

Get all process advertisements (for gossip).

pub fn len(&self) -> usize

Number of tracked processes.

pub fn is_empty(&self) -> bool

pub fn assign_pid(&self, pid: u64, ring: &ConsistentHashRing) -> Option<String>

Assign a PID to the optimal node using consistent hashing.

Trait Implementations

impl Default for DistributedProcessTable

fn default() -> Self

Returns the “default value” for a type.