Struct CommunicationManager 

pub struct CommunicationManager {
    pub protocol: CommunicationProtocol,
    pub connections: HashMap<String, Connection>,
    pub message_queues: HashMap<String, VecDeque<Message>>,
    pub statistics: CommunicationStatistics,
}

Communication manager for inter-node communication

Fields

protocol: CommunicationProtocol

Communication protocol

connections: HashMap<String, Connection>

Active connections

message_queues: HashMap<String, VecDeque<Message>>

Message queues

statistics: CommunicationStatistics

Communication statistics

Implementations

impl CommunicationManager

pub fn new() -> Self

Create a new communication manager

pub fn connect(&mut self, address: &str) -> Result<(), String>

Establish connection to a node

pub fn disconnect(&mut self, address: &str)

Disconnect from a node

pub fn send( &mut self, destination: &str, message: Message, ) -> Result<(), String>

Send a message

pub fn receive(&mut self, source: &str) -> Vec<Message>

Receive messages from a node

Trait Implementations

impl Debug for CommunicationManager

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

Formats the value using the given formatter.

impl Default for CommunicationManager

fn default() -> Self

Returns the “default value” for a type.