Struct EpochChange 

pub struct EpochChange { /* private fields */ }

A sequence of epochs, driven by who is trusted.

Implementations

impl EpochChange

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

Epoch-change among peers, over a leader detector with the given heartbeat and timeout and a best-effort broadcast whose links retransmit every retransmit.

pub fn last_timestamp(&self) -> u64

The epoch this process has most recently started, if any.

pub fn trusted(&self) -> NodeId

Who this process currently trusts.

Trait Implementations

impl Debug for EpochChange

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

Formats the value using the given formatter.

impl Protocol for EpochChange

type Meta = Infallible

Keeps nothing durably. logged_epoch_change is the variant that does.

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

upon event ⟨ ec, Init ⟩ — the state is set in new; this starts the detector, whose first Trust may immediately make this process announce an epoch.

type Cmd = Infallible

Requests from the layer above.

type Ind = Ind

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

type Msg = Wire<Wire<EpochMsg>>

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

Handle a request from the layer above.

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