Struct StubbornLink 

pub struct StubbornLink<M> { /* private fields */ }

Retransmits until told to stop.

Adds nothing to the wire: what it transmits is exactly the payload it was given. That is why a three-layer stack built on it carries only one header.

Implementations

impl<M> StubbornLink<M>

pub fn new(interval: Duration) -> Self

Retransmit everything outstanding every interval.

pub fn outstanding(&self) -> usize

How many transmissions are still being retried.

pub fn interval(&self) -> Duration

The retransmission interval.

Trait Implementations

impl<M: Debug> Debug for StubbornLink<M>

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

Formats the value using the given formatter.

impl<M: Clone> Protocol for StubbornLink<M>

type Scope = Infallible

No scope conditions: this protocol’s guarantees do not lapse.

type Meta = Infallible

Keeps nothing durably: a crash loses everything this protocol knows.

type Cmd = Cmd<M>

Requests from the layer above.

type Ind = Ind<M>

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

type Msg = M

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

Handle a request from the layer above.

fn on_msg(&mut self, from: NodeId, msg: M, 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.