Struct bastion::prelude::ArtilleryMemberList

pub struct ArtilleryMemberList { /* fields omitted */ }

Implementations

impl ArtilleryMemberList

pub fn new(current: ArtilleryMember) -> ArtilleryMemberList

pub fn available_nodes(&self) -> Vec<ArtilleryMember, Global>

pub fn to_map(&self) -> HashMap<Uuid, ArtilleryMember, RandomState>

pub fn reincarnate_self(&mut self) -> ArtilleryMember

pub fn leave(&mut self) -> ArtilleryMember

pub fn next_random_member(&mut self) -> Option<ArtilleryMember>

pub fn time_out_nodes(
    &mut self,
    expired_hosts: &HashSet<SocketAddr, RandomState>
) -> (Vec<ArtilleryMember, Global>, Vec<ArtilleryMember, Global>)

pub fn mark_node_alive(
    &mut self,
    src_addr: &SocketAddr
) -> Option<ArtilleryMember>

pub fn apply_state_changes(
    &mut self,
    state_changes: Vec<ArtilleryStateChange, Global>,
    from: &SocketAddr
) -> (Vec<ArtilleryMember, Global>, Vec<ArtilleryMember, Global>)

pub fn hosts_for_indirect_ping(
    &self,
    host_count: usize,
    target: &SocketAddr
) -> Vec<SocketAddr, Global>

Random ping enqueuing

pub fn has_member(&self, remote_host: &SocketAddr) -> bool

pub fn add_member(&mut self, member: ArtilleryMember)

pub fn get_member(&self, id: &Uuid) -> Option<ArtilleryMember>

get_member will return artillery member if the given uuid is matches with any of the member in the cluster.