Enum Event 

pub enum Event {
    ElectionTimeout,
    FetchTimeout,
    CheckQuorumTimeout,
    ReceiveVoteRequest {
        from: NodeId,
        cluster_id: Option<Uuid>,
        voter_id: NodeId,
        voter_directory_id: Uuid,
        candidate_epoch: Epoch,
        candidate: NodeId,
        candidate_directory_id: Uuid,
        candidate_log_end: LogEnd,
        pre_vote: bool,
    },
    ReceiveVoteResponse {
        from: NodeId,
        epoch: Epoch,
        vote_granted: bool,
    },
    ReceiveBeginQuorumEpoch {
        leader_id: NodeId,
        leader_epoch: Epoch,
    },
    ReceiveEndQuorumEpoch {
        leader_id: NodeId,
        leader_epoch: Epoch,
        successor_rank: SuccessorRank,
    },
    ReceiveFetch {
        from: NodeId,
        fetch_epoch: Epoch,
        fetch_offset: i64,
    },
    ReceiveFetchSnapshot {
        from: NodeId,
    },
    ReceiveFetchResponse {
        leader_id: NodeId,
        leader_epoch: Epoch,
        diverging: Option<LogOffsetMetadata>,
    },
    ReceiveLeaderlessEpoch {
        epoch: Epoch,
    },
}

Variants

ElectionTimeout

The election timer fired.

FetchTimeout

The fetch timer fired.

The follower or observer lost contact with the leader.

CheckQuorumTimeout

The leader’s check-quorum timer fired.

A majority of the voters has not fetched within the check-quorum window, so this leader has lost the quorum and resigns (KAFKA-15489).

ReceiveVoteRequest

A peer asks us for our vote.

Fields

from: NodeId

cluster_id: Option<Uuid>

Optional cluster identity from the Vote request.

voter_id: NodeId

The recipient of this Vote, that is, the wire top-level voterId.

KIP-595 and Kafka’s KafkaRaftClient check that an incoming Vote targets this node before they consider the grant. They reject a request that is addressed to a different voter.

voter_directory_id: Uuid

KIP-853 directory identity of the receiving voter.

candidate_epoch: Epoch

candidate: NodeId

candidate_directory_id: Uuid

KIP-853 directory identity of the candidate.

candidate_log_end: LogEnd

pre_vote: bool

ReceiveVoteResponse

A peer answered our Vote.

The wire does NOT carry the round, that is, pre-vote against real vote. The candidate infers the round from its own Prospective or Candidate role and epoch (KIP-996). This matches Kafka’s field-less VoteResponse.

Fields

from: NodeId

epoch: Epoch

vote_granted: bool

ReceiveBeginQuorumEpoch

A leader announces its epoch to us.

Fields

leader_id: NodeId

leader_epoch: Epoch

ReceiveEndQuorumEpoch

A resigning leader tells us to start an election.

Fields

leader_id: NodeId

leader_epoch: Epoch

successor_rank: SuccessorRank

Where this replica stands in the leader’s preferred candidates.

ReceiveFetch

Leader side: a follower fetched at this position.

Fields

from: NodeId

fetch_epoch: Epoch

fetch_offset: i64

ReceiveFetchSnapshot

Leader side: a follower asked us for a byte window of a snapshot.

KIP-630 catch-up carries no fetch offset the leader can score, but it is still contact from that voter, and Kafka counts it toward check-quorum exactly as it counts a Fetch.

Fields

from: NodeId

ReceiveFetchResponse

Follower side: the leader answered our Fetch.

Fields

leader_id: NodeId

leader_epoch: Epoch

diverging: Option<LogOffsetMetadata>

Holds a value when the leader signalled log divergence.

ReceiveLeaderlessEpoch

A Fetch or Vote response came from a newer epoch that names no leader yet.

Kafka’s KafkaRaftClient.maybeTransition moves the replica to Unattached in that epoch, and an observer then looks for the leader at once.

Fields

epoch: Epoch

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for Event

impl Debug for Event

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

Formats the value using the given formatter.

impl Eq for Event

impl Hash for Event

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for Event

fn cmp(&self, other: &Event) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Event

fn eq(&self, other: &Event) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PartialOrd for Event

fn partial_cmp(&self, other: &Event) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for Event