Trait ClusterCommunicator

pub trait ClusterCommunicator {
    // Required methods
    fn send_message(&self, target: &str, msg: &Message<'_>) -> bool;
    fn handle_message(&mut self, msg: &Message<'_>);
    fn get_nghbr_sample(
        &self,
        a: &HashMap<String, DateTime<Utc>>,
    ) -> Vec<String>;
    fn comm_recv_gossip(&mut self, payload: &Vec<String>);
    fn update_neighbors(&mut self);
    fn delinquent_node_check(&mut self);
}

Required Methods

fn send_message(&self, target: &str, msg: &Message<'_>) -> bool

fn handle_message(&mut self, msg: &Message<'_>)

fn get_nghbr_sample(&self, a: &HashMap<String, DateTime<Utc>>) -> Vec<String>

fn comm_recv_gossip(&mut self, payload: &Vec<String>)

fn update_neighbors(&mut self)

fn delinquent_node_check(&mut self)

Implementors