Struct bastion::prelude::ArtilleryMemberList [−][src]
pub struct ArtilleryMemberList { /* fields omitted */ }
Implementations
pub fn available_nodes(&self) -> Vec<ArtilleryMember, Global>ⓘ
pub fn time_out_nodes(
&mut self,
expired_hosts: &HashSet<SocketAddr, RandomState>
) -> (Vec<ArtilleryMember, Global>, Vec<ArtilleryMember, Global>)
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>ⓘ
pub fn hosts_for_indirect_ping(
&self,
host_count: usize,
target: &SocketAddr
) -> Vec<SocketAddr, Global>ⓘ
Random ping enqueuing
get_member
will return artillery member if the given uuid is matches with any of the
member in the cluster.
Auto Trait Implementations
impl RefUnwindSafe for ArtilleryMemberList
impl Send for ArtilleryMemberList
impl Sync for ArtilleryMemberList
impl Unpin for ArtilleryMemberList
impl UnwindSafe for ArtilleryMemberList
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more