Struct LoggedUniformTotalOrderBroadcast 

pub struct LoggedUniformTotalOrderBroadcast<V: Clone + Ord> { /* private fields */ }

A totally ordered log whose sequence survives a restart.

Implementations

impl<V: Clone + Ord> LoggedUniformTotalOrderBroadcast<V>

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

A totally ordered log among peers whose sequence survives a restart.

pub fn entries(&self) -> &[OrderedSlot<V>]

The agreed sequence as this process holds it.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn round(&self) -> u64

pub fn instances(&self) -> usize

Trait Implementations

impl<V: Clone + Ord> Protocol for LoggedUniformTotalOrderBroadcast<V>

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

upon event ⟨ Recovery ⟩, with the two facilities the page assumes discharged here: the runtime that re-instantiates consensus instances, and the buffering behind such that.

type Cmd = Cmd<V>

Requests from the layer above.

type Ind = Ind<V>

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

type Msg = Wire<<LoggedUniformReliableBroadcast<V> as Protocol>::Msg, Wire<BTreeSet<(NodeId, V)>>>

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 Meta = Durable<V>

The durable value this protocol rewrites: a position, a count, an epoch. Small enough that rewriting it costs nothing.

type Entry = Record<V>

The durable entries this protocol appends: what accumulates.

fn on_cmd(&mut self, cmd: Cmd<V>, cx: &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_init(&mut self, cx: &mut ProtoCx<'_, Self>)

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

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.

impl<V: Clone + Ord> TotalOrderLog<V> for LoggedUniformTotalOrderBroadcast<V>

fn append(value: V) -> Cmd<V>

The request that appends value to the log.

fn read(from: Position) -> Cmd<V>

The request that reads the ordered sequence from from onwards.

fn classify(ind: Ind<V>) -> LogInd<V>

What this indication means to the layer above.