Skip to main content

alive_datanodes

Function alive_datanodes 

Source
pub(crate) fn alive_datanodes(
    timer: &impl SystemTimer,
    nodes: Vec<NodeInfo>,
    active_duration: Duration,
    filter: Option<for<'a> fn(&'a NodeWorkloads) -> bool>,
) -> Vec<Peer>