Trait gary_core::comm::ClusterCommunicator

pub trait ClusterCommunicator {
    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)

Loading content...

Implementors

Loading content...