Struct LogOffsetMetadata 

pub struct LogOffsetMetadata {
    pub offset: i64,
    pub epoch: u32,
}

A log position: an offset together with the leader epoch that produced it.

Fields

offset: i64

epoch: u32

Implementations

impl LogOffsetMetadata

pub fn end_of_epoch_in(epochs: &[u32], epoch: u32) -> LogOffsetMetadata

LogView::end_offset_for_epoch over a log that records the leader epoch of every record: epochs[i] is the epoch of offset i.

The in-memory logs of the simulators and the unit tests use it, so their divergence lookup follows the same rule as the on-disk log.

pub fn follower_truncation_offset(self, log: &dyn LogView) -> i64

Kafka’s RaftLog.truncateToEndOffset: the offset a follower truncates its log to when the leader answers a Fetch with self as the diverging epoch.

The leader’s end offset for the epoch is only an upper bound. The follower’s own copy of that epoch can end earlier, and the records after it then belong to an epoch the leader does not have. Truncating to the leader’s offset alone would keep them, and the next Fetch would diverge at the same point again.

Trait Implementations

impl Clone for LogOffsetMetadata

fn clone(&self) -> LogOffsetMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for LogOffsetMetadata

impl Debug for LogOffsetMetadata

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

Formats the value using the given formatter.

impl Eq for LogOffsetMetadata

impl Hash for LogOffsetMetadata

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

where __H: Hasher,

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 LogOffsetMetadata

fn cmp(&self, other: &LogOffsetMetadata) -> 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 LogOffsetMetadata

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

Equality operator ==.

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

Inequality operator !=.

impl PartialOrd for LogOffsetMetadata

fn partial_cmp(&self, other: &LogOffsetMetadata) -> 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 LogOffsetMetadata