Struct IsrCandidateFacts 

pub struct IsrCandidateFacts {
    pub role: IsrMemberRole,
    pub follower_log_end: i64,
    pub leader_log_end: i64,
    pub leader_high_watermark: i64,
    pub leader_epoch_start: Option<i64>,
    pub caught_up_within_lag: bool,
    pub eligibility: IsrEligibilityFacts,
}

What the leader knows about one candidate at an ISR maintenance scan, read once at the scan’s single timestamp.

Fields

role: IsrMemberRole

follower_log_end: i64

Kafka’s ReplicaState.logEndOffset: the follower’s last fetch offset, -1 before it fetched from this leader.

leader_log_end: i64

The leader’s log end offset.

leader_high_watermark: i64

The leader’s high watermark.

leader_epoch_start: Option<i64>

Kafka’s Partition.leaderEpochStartOffsetOpt: the log end offset at which this leader’s epoch began, None while unknown.

caught_up_within_lag: bool

The follower’s last caught-up time is within replica.lag.time.max.ms.

eligibility: IsrEligibilityFacts

Trait Implementations

impl Clone for IsrCandidateFacts

fn clone(&self) -> IsrCandidateFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for IsrCandidateFacts

impl Debug for IsrCandidateFacts

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

Formats the value using the given formatter.

impl Eq for IsrCandidateFacts

impl PartialEq for IsrCandidateFacts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for IsrCandidateFacts