Struct FailureDetectorRegistry 

pub struct FailureDetectorRegistry { /* private fields */ }

Implementations

impl FailureDetectorRegistry

pub fn new( factory: Arc<dyn Fn() -> Arc<dyn FailureDetector> + Send + Sync>, ) -> Self

pub fn default_phi() -> Self

Default detector: PhiAccrualFailureDetector with phi threshold 8, 1000-sample window, ~100ms heartbeat, 3s acceptable pause, 1s warm-up.

pub fn heartbeat(&self, from: &Address)

pub fn is_available(&self, address: &Address) -> bool

pub fn remove(&self, address: &Address)

pub fn addresses(&self) -> Vec<String>

Trait Implementations

impl Clone for FailureDetectorRegistry

fn clone(&self) -> FailureDetectorRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.