atomr-remote 0.1.0

Cross-process and cross-host actor messaging for atomr — TCP transport, framed PDU codec, ack'd delivery, endpoint state machine, watcher.
Documentation 
1
2
3
4
5
6
7
8
9
10
11

//! Failure detector trait. akka.net: `Remote/FailureDetector.cs`.

use std::time::Duration;

pub trait FailureDetector: Send + Sync {
    fn is_available(&self) -> bool;
    fn is_monitoring(&self) -> bool;
    fn heartbeat(&self);
    fn reset(&self);
    fn since_last_heartbeat(&self) -> Option<Duration>;
}