Enum PeerRequest 

pub enum PeerRequest {
    Vote {
        cluster_id: Option<Uuid>,
        voter_id: NodeId,
        voter_directory_id: Uuid,
        candidate_epoch: Epoch,
        candidate: NodeId,
        candidate_directory_id: Uuid,
        last_epoch: Epoch,
        last_offset: i64,
        pre_vote: bool,
    },
    BeginQuorumEpoch {
        cluster_id: Option<Uuid>,
        voter_id: NodeId,
        voter_directory_id: Uuid,
        leader_id: NodeId,
        leader_epoch: Epoch,
        leader_endpoints: Vec<VoterEndpoint>,
    },
    EndQuorumEpoch {
        cluster_id: Option<Uuid>,
        leader_id: NodeId,
        leader_epoch: Epoch,
        preferred_candidates: Vec<PreferredCandidate>,
    },
    Fetch {
        cluster_id: Option<Uuid>,
        from: NodeId,
        max_wait_ms: i32,
        current_leader_epoch: i32,
        fetch_epoch: Epoch,
        fetch_offset: i64,
        replica_directory_id: Uuid,
        high_watermark: i64,
    },
    FetchSnapshot {
        cluster_id: Option<Uuid>,
        from: NodeId,
        current_leader_epoch: i32,
        snapshot_id: SnapshotId,
        position: i64,
        max_bytes: i32,
    },
}

A peer RPC request body, as encoded by the sending engine and decoded by the receiving engine’s inbound dispatch.

Variants

Vote

Fields

cluster_id: Option<Uuid>

voter_id: NodeId

The recipient voter this request is addressed to. This is the wire top-level voterId. The JVM validates that an incoming Vote is addressed to it before it considers the grant, and it silently rejects a stale voterId or a voterId of -1. broadcast_vote builds this field for each recipient.

voter_directory_id: Uuid

candidate_epoch: Epoch

candidate: NodeId

candidate_directory_id: Uuid

last_epoch: Epoch

last_offset: i64

pre_vote: bool

BeginQuorumEpoch

Fields

cluster_id: Option<Uuid>

The sender’s cluster id, which the recipient checks.

voter_id: NodeId

The recipient voter key: VoterId and VoterDirectoryId, which the recipient checks against its own (isValidVoterKey). broadcast_begin_quorum_epoch builds it for each recipient.

voter_directory_id: Uuid

leader_id: NodeId

leader_epoch: Epoch

leader_endpoints: Vec<VoterEndpoint>

The leader’s own listeners: LeaderEndpoints, which a recipient whose voter set does not name the leader dials it at.

EndQuorumEpoch

Fields

cluster_id: Option<Uuid>

The sender’s cluster id, which the recipient checks.

leader_id: NodeId

leader_epoch: Epoch

preferred_candidates: Vec<PreferredCandidate>

The voters in order of replication progress, most caught up first, each with its directory id: PreferredCandidates (KIP-853).

Fetch

Fields

cluster_id: Option<Uuid>

The sender’s cluster id, which the leader checks.

from: NodeId

max_wait_ms: i32

How long the leader may hold the request when it has nothing new: MaxWaitMs.

current_leader_epoch: i32

The epoch the sender is in: CurrentLeaderEpoch, which the responder checks in validateLeaderOnlyRequest. Raw, as for FetchSnapshot, so a negative epoch stays fenced.

fetch_epoch: Epoch

The epoch of the sender’s last fetched record: LastFetchedEpoch, which the leader checks for divergence.

fetch_offset: i64

replica_directory_id: Uuid

high_watermark: i64

The sender’s high watermark, or -1 while it knows none: HighWatermark (v18). The leader answers at once when its own is higher.

FetchSnapshot

Fields

cluster_id: Option<Uuid>

The sender’s cluster id, which the leader checks.

from: NodeId

current_leader_epoch: i32

The epoch the sender believes the leader holds: CurrentLeaderEpoch, which the leader checks against its own.

snapshot_id: SnapshotId

position: i64

max_bytes: i32

Implementations

impl PeerRequest

pub fn try_encode(&self) -> Option<Bytes>

Encode after checking the Vote identity and epoch wire range.

pub fn decode(buf: &[u8]) -> Option<Self>

Decodes a request body. Returns None on a malformed frame.

Trait Implementations

impl Clone for PeerRequest

fn clone(&self) -> PeerRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerRequest

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

Formats the value using the given formatter.

impl Eq for PeerRequest

impl PartialEq for PeerRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PeerRequest