Enum paxakos::event::Event [−][src]
#[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>>,
effect: EffectOf<I>,
},
Gaps(Vec<Gap<RoundNumOf<I>>>),
Directive {
kind: DirectiveKind,
leader: NodeOf<I>,
round_num: RoundNumOf<I>,
coord_num: CoordNumOf<I>,
timestamp: Instant,
},
}
Expand description
Emitted by Node
’s poll_events
method.
Variants (Non-exhaustive)
This enum is marked as non-exhaustive
First event that is fired immediately after construction.
Fields of Init
status: NodeStatus
Initial status of the node.
round: RoundNumOf<I>
Round the node is in.
state: Option<Arc<StateOf<I>>>
Initial state or None
when no snapshot was given.
Node’s status changed.
Fields of StatusChange
Activate(RoundNumOf<I>)
The node is transitioning to partially active participation.
Tuple Fields of Activate
0: RoundNumOf<I>
A snapshot was installed.
Fields of Install
round: RoundNumOf<I>
Round node is in after a snapshot was installed.
state: Arc<StateOf<I>>
State the node is in after a snapshot was installed.
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.
The next log entry was applied to the state.
Fields of Apply
round: RoundNumOf<I>
Round the log entry was applied in.
log_entry: Arc<LogEntryOf<I>>
Log entry that was applied.
effect: EffectOf<I>
The event data that the application.
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>>>
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
kind: DirectiveKind
Kind of directive, either Prepare
, Accept
or Commit
.
leader: NodeOf<I>
Leader that issued the directive.
round_num: RoundNumOf<I>
Round for which the directive was issued.
coord_num: CoordNumOf<I>
Coordination number with which the directive was issued.
timestamp: Instant
Time the directive was (locally) registered.
Trait Implementations
Auto Trait Implementations
impl<I> RefUnwindSafe for Event<I> where
<I as Invocation>::CoordNum: RefUnwindSafe,
<<I as Invocation>::State as State>::Effect: RefUnwindSafe,
<<I as Invocation>::State as State>::LogEntry: RefUnwindSafe,
<<I as Invocation>::State as State>::Node: RefUnwindSafe,
<I as Invocation>::RoundNum: RefUnwindSafe,
<I as Invocation>::State: RefUnwindSafe,
impl<I> Unpin for Event<I> where
<<I as Invocation>::State as State>::Effect: Unpin,
<<I as Invocation>::State as State>::Node: Unpin,
impl<I> UnwindSafe for Event<I> where
<I as Invocation>::CoordNum: UnwindSafe,
<<I as Invocation>::State as State>::Effect: UnwindSafe,
<<I as Invocation>::State as State>::LogEntry: RefUnwindSafe,
<<I as Invocation>::State as State>::Node: UnwindSafe,
<I as Invocation>::RoundNum: UnwindSafe,
<I as Invocation>::State: RefUnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more