Struct StubbornBroadcast 

pub struct StubbornBroadcast<P: Clone> { /* private fields */ }

Fan-out that never gives up.

Implementations

impl<P: Clone> StubbornBroadcast<P>

pub fn new( me: NodeId, members: impl IntoIterator<Item = NodeId>, interval: Duration, ) -> Self

Broadcast among members, which must include me, retransmitting every interval.

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

The process set. This layer’s whole state, besides what is still being transmitted.

pub fn outstanding_count(&self) -> usize

How many broadcasts are still being retransmitted. Nothing retires one but Cmd::Stop.

Trait Implementations

impl<P: Debug + Clone> Debug for StubbornBroadcast<P>

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

Formats the value using the given formatter.

impl<P: Clone> Protocol for StubbornBroadcast<P>

type Meta = Infallible

Keeps nothing durably: what it is transmitting is rebuilt by the layer above on recovery.

type Cmd = Cmd<P>

Requests from the layer above.

type Ind = Ind<P>

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

type Msg = P

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

type Scope = Infallible

Scopes whose boundaries this protocol’s guarantees depend on, and which it can observe.

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<P>, cx: &mut ProtoCx<'_, Self>)

Handle a request from the layer above.

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

Handle a message received from from.

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_init( &mut self, _cx: &mut Cx<'_, Self::Msg, Self::Ind, Self::Note, Self::Meta, Self::Entry>, )

Begin, on a first start — when nothing has been written down.

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.