Struct FairLossLink 

pub struct FairLossLink<P>(/* private fields */);

The link the book’s stack starts from: send it, and hope.

No retransmission, no deduplication, no timer, no state. What arrives, arrives.

Implementations

impl<P> FairLossLink<P>

pub fn new() -> Self

Trait Implementations

impl<P: Debug> Debug for FairLossLink<P>

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

Formats the value using the given formatter.

impl<P: Default> Default for FairLossLink<P>

fn default() -> FairLossLink<P>

Returns the “default value” for a type.

impl<P: Clone> Link<P> for FairLossLink<P>

The fair-loss link satisfies the link port, and only its unscoped half.

It does not report scope boundaries because it cannot observe any — it holds no session, no epoch and no state whatever. A layer that repairs a scope ending gets nothing from this link, which is the honest outcome rather than a boundary invented to satisfy a bound.

fn send(to: NodeId, msg: P) -> Cmd<P>

The request that sends msg to to.

fn classify(_: Ind<P>) -> LinkInd<P>

What this indication means to the layer above.

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

type Scope = Infallible

No scope conditions. FLL1 to FLL3 are stated over correct processes and hold as long as one is correct; there is no session to end and nothing this link could report about one.

type Meta = Infallible

Keeps nothing durably, because it keeps nothing at all.

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 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<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.