Struct OffsetAndTimestamp 

pub struct OffsetAndTimestamp { /* private fields */ }

A container class for offset and timestamp.

Implementations

impl OffsetAndTimestamp

pub fn new(offset: i64, timestamp: i64) -> Result<Self, Error>

Constructs a new OffsetAndTimestamp with the given offset and timestamp.

Arguments

• offset - The offset
• timestamp - The timestamp

Returns

The new OffsetAndTimestamp.

Errors

• Error::is_local_illegal_argument_error If the offset or timestamp is negative

pub fn with_leader_epoch( offset: i64, timestamp: i64, leader_epoch: Option<i32>, ) -> Result<Self, Error>

Constructs a new OffsetAndTimestamp with the given offset, timestamp, and leader epoch.

Arguments

• offset - The offset
• timestamp - The timestamp
• leader_epoch - The leader epoch

Returns

The new OffsetAndTimestamp.

Errors

• Error::is_local_illegal_argument_error If the offset or timestamp is negative

pub fn timestamp(&self) -> i64

The timestamp.

Returns

The timestamp

pub fn offset(&self) -> i64

The offset.

Returns

The offset

pub fn leader_epoch(&self) -> Option<i32>

Get the leader epoch corresponding to the offset that was found (if one exists). This can be provided to seek() to ensure the log hasn’t been truncated prior to fetching.

Returns

The leader epoch or empty if it is not known

Trait Implementations

impl Clone for OffsetAndTimestamp

fn clone(&self) -> OffsetAndTimestamp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetAndTimestamp

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

Formats the value using the given formatter.

impl Display for OffsetAndTimestamp

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

Formats the value using the given formatter.

impl Hash for OffsetAndTimestamp

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 PartialEq for OffsetAndTimestamp

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for OffsetAndTimestamp

impl StructuralPartialEq for OffsetAndTimestamp