Struct EventuallyPerfectFailureDetector 

pub struct EventuallyPerfectFailureDetector { /* private fields */ }

Detects crashes by heartbeat timeout, and changes its mind.

Implementations

impl EventuallyPerfectFailureDetector

pub fn new( me: NodeId, peers: impl IntoIterator<Item = NodeId>, config: Config, ) -> Self

Detect among peers, adapting as config says.

pub fn suspected(&self) -> impl Iterator<Item = NodeId> + '_

The processes currently suspected. May shrink.

pub fn suspects(&self, node: NodeId) -> bool

Whether node is currently suspected.

pub fn correct(&self) -> impl Iterator<Item = NodeId> + '_

The processes not currently suspected, this one included.

pub fn delay(&self) -> Duration

The silence a peer is currently allowed. Adapts; see the module’s two departures.

pub fn period(&self) -> Duration

How often this process announces itself.

Trait Implementations

impl Debug for EventuallyPerfectFailureDetector

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Detector for EventuallyPerfectFailureDetector

fn classify(ind: Ind) -> DetectorInd

Read one of this detector’s indications in the port’s terms.

impl Protocol for EventuallyPerfectFailureDetector

type Scope = Infallible

No scope conditions of its own: ◇P2’s conditions are on the network, not on a scope this protocol is told about.

type Meta = Infallible

Keeps nothing durably. A restarted detector suspects nobody and learns again.

fn on_init(&mut self, cx: &mut ProtoCx<'_, Self>)

⟨ ◇P, Init ⟩ do alive := Π; suspected := ∅; delay := Δ; starttimer(delay).

fn on_msg( &mut self, from: NodeId, Heartbeat: Heartbeat, cx: &mut ProtoCx<'_, Self>, )

A heartbeat is alive := alive ∪ {p}. Note what is not here: no check against suspected. Hearing from a suspected process is exactly the case Restore exists for, and the round’s own pass is where it is noticed.

type Cmd = Infallible

Requests from the layer above.

type Ind = Ind

Indications to the layer above — this protocol delivering on its guarantee.

type Msg = Heartbeat

What crosses the wire to a peer running the same protocol.

type Note = Note

The vocabulary in which this protocol narrates its decisions.

type Entry = Infallible

The durable entries this protocol appends: what accumulates.

fn on_cmd(&mut self, cmd: Cmd, _cx: &mut ProtoCx<'_, Self>)

Handle a request from the layer above.

fn on_timer(&mut self, id: TimerId, cx: &mut ProtoCx<'_, Self>)

Handle a timer that fired somewhere in this protocol or in what it composes.

fn on_recovery( &mut self, _cx: &mut Cx<'_, Self::Msg, Self::Ind, Self::Note, Self::Meta, Self::Entry>, )

Resume after a crash, reading what survived.

fn on_scope_event( &mut self, _scope: Self::Scope, _cx: &mut Cx<'_, Self::Msg, Self::Ind, Self::Note, Self::Meta, Self::Entry>, )

Handle a boundary of a scope this protocol’s guarantees depend on — its end, or the beginning of the one that succeeds it.