Struct FetchMetadata 

pub struct FetchMetadata { /* private fields */ }

Java FetchMetadata (incremental fetch session id and epoch).

encode_fetch_request writes Self::LEGACY (session_id 0 / epoch -1): close any session and do not create one. encode_fetch_request_with_session writes this value on v7+. Below v7 SessionId / SessionEpoch are omitted even when this is not LEGACY; decode fills Self::LEGACY. std::fmt::Display is Java toString ((sessionId=INVALID, epoch=FINAL)).

Implementations

impl FetchMetadata

pub const INVALID_SESSION_ID: i32 = 0

Java FetchMetadata.INVALID_SESSION_ID.

pub const INITIAL_EPOCH: i32 = 0

Java FetchMetadata.INITIAL_EPOCH.

pub const FINAL_EPOCH: i32 = -1

Java FetchMetadata.FINAL_EPOCH.

pub const INITIAL: Self

Java FetchMetadata.INITIAL.

pub const LEGACY: Self

Java FetchMetadata.LEGACY.

pub const fn new(session_id: i32, epoch: i32) -> Self

Java FetchMetadata(int, int).

pub const fn session_id(self) -> i32

Java FetchMetadata.sessionId.

pub const fn epoch(self) -> i32

Java FetchMetadata.epoch.

pub const fn is_full(self) -> bool

Java FetchMetadata.isFull.

pub const fn next_epoch(prev_epoch: i32) -> i32

Java FetchMetadata.nextEpoch.

pub const fn next_close_existing(self) -> Self

Java FetchMetadata.nextCloseExisting.

pub const fn next_close_existing_attempt_new(self) -> Self

Java FetchMetadata.nextCloseExistingAttemptNew.

pub const fn new_incremental(session_id: i32) -> Self

Java FetchMetadata.newIncremental.

pub const fn next_incremental(self) -> Self

Java FetchMetadata.nextIncremental.

Trait Implementations

impl Clone for FetchMetadata

fn clone(&self) -> FetchMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for FetchMetadata

impl Debug for FetchMetadata

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

Formats the value using the given formatter.

impl Display for FetchMetadata

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

Formats the value using the given formatter.

impl Eq for FetchMetadata

impl Hash for FetchMetadata

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 FetchMetadata

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FetchMetadata