Struct DistributedRuntime 

pub struct DistributedRuntime { /* private fields */ }

Distributed runtime coordinator

Implementations

impl DistributedRuntime

pub fn new(node_id: Uuid) -> Self

Create a new distributed runtime

pub fn register_node(&self, node: NodeInfo) -> Result<()>

Register a node in the cluster

pub fn unregister_node(&self, node_id: Uuid) -> Result<()>

Unregister a node

pub async fn send_to_agent( &self, from_agent: Uuid, to_agent: Uuid, payload: Value, message_type: String, ) -> Result<()>

Send message to agent on any node

pub fn get_agent_node(&self, agent_id: Uuid) -> Option<Uuid>

Get node for agent

pub fn get_nodes(&self) -> Vec<NodeInfo>

Get all nodes

pub fn get_healthy_nodes(&self) -> Vec<NodeInfo>

Get healthy nodes

pub fn find_best_node(&self) -> Option<Uuid>

Find best node for new agent (load balancing)

pub fn heartbeat( &self, node_id: Uuid, cpu_usage: f32, memory_usage: f32, ) -> Result<()>

Heartbeat to update node status

pub fn check_node_health(&self, timeout_seconds: i64) -> Vec<Uuid>

Check for dead nodes (no heartbeat)

pub fn try_recv_message(&self) -> Option<DistributedMessage>

Try to receive a message from the queue (non-blocking)

pub async fn receive_messages<F>(&self, handler: F) -> Result<()>

where F: FnMut(DistributedMessage) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send,

Receive messages with a handler (blocking until handler returns)

pub async fn process_pending_messages<F>(&self, handler: F) -> Result<usize>

where F: Fn(&DistributedMessage) -> Result<()>,

Process pending messages with a batch handler

pub fn pending_message_count(&self) -> usize

Get the number of pending messages in the queue

pub fn total_messages_sent(&self) -> usize

Get the total number of messages sent through this node

pub fn total_messages_received(&self) -> usize

Get the total number of messages received by this node

pub fn get_message_stats(&self) -> MessageStats

Get message processing statistics

pub fn reset_message_stats(&self)

Reset message statistics