Enum paxakos::event::Event

#[non_exhaustive]
pub enum Event<I: Invocation> {
    Init {
        status: NodeStatus,
        round: RoundNumOf<I>,
        state: Option<Arc<StateOf<I>>>,
    },
    StatusChange {
        old_status: NodeStatus,
        new_status: NodeStatus,
    },
    Activate(RoundNumOf<I>),
    Install {
        round: RoundNumOf<I>,
        state: Arc<StateOf<I>>,
    },
    Commit {
        round: RoundNumOf<I>,
        log_entry: Arc<LogEntryOf<I>>,
    },
    Apply {
        round: RoundNumOf<I>,
        log_entry: Arc<LogEntryOf<I>>,
        result: EventOf<I>,
    },
    Gaps(Vec<Gap<RoundNumOf<I>>>),
    Directive {
        leader: NodeOf<I>,
        round_num: RoundNumOf<I>,
        coord_num: CoordNumOf<I>,
        timestamp: Instant,
    },
}

Emitted by Node’s poll_events method.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Init

Fields of Init

status: NodeStatusround: RoundNumOf<I>state: Option<Arc<StateOf<I>>>

StatusChange

Fields of StatusChange

old_status: NodeStatusnew_status: NodeStatus

Activate(RoundNumOf<I>)

The node is transitioning to partially active participation.

Tuple Fields of Activate

0: RoundNumOf<I>

Install

A snapshot was installed.

Fields of Install

round: RoundNumOf<I>state: Arc<StateOf<I>>

Commit

An entry has been committed to the log.

The event does not imply that the entry was applied to the shared state.

Fields of Commit

round: RoundNumOf<I>

The round for which log_entry was committed.

log_entry: Arc<LogEntryOf<I>>

The log entry which was committed.

Apply

The next log entry was applied to the state.

Fields of Apply

round: RoundNumOf<I>log_entry: Arc<LogEntryOf<I>>result: EventOf<I>

Gaps(Vec<Gap<RoundNumOf<I>>>)

A log entry was queued, preceeding entries are still missing.

Note: This event is emitted even when the queued entry is within the concurrency bound or if this node created the gap itself. The second case can arise when the leader tries to concurrently append multiple entries and abandons some of the earlier appends.

Tuple Fields of Gaps

0: Vec<Gap<RoundNumOf<I>>>

Directive

This node received a (potentially indirect) directive for the given round and from the given node. The node used the mandate obtained with the given coordination number to issue the directive.

This event is not emitted when this node is disoriented or lagging.

Fields of Directive

leader: NodeOf<I>round_num: RoundNumOf<I>coord_num: CoordNumOf<I>timestamp: Instant

Trait Implementations

impl<I: Invocation> Debug for Event<I>

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

Formats the value using the given formatter.

impl<I: Invocation> From<Event<I>> for ShutdownEvent<I>

fn from(e: Event<I>) -> Self

Performs the conversion.