Struct kafka_protocol::messages::describe_quorum_response::ReplicaStateBuilder

pub struct ReplicaStateBuilder { /* private fields */ }

Builder for ReplicaState.

Implementations

impl ReplicaStateBuilder

pub fn replica_id(&mut self, value: BrokerId) -> &mut Self

Supported API versions: 0-1

pub fn log_end_offset(&mut self, value: i64) -> &mut Self

The last known log end offset of the follower or -1 if it is unknown

Supported API versions: 0-1

pub fn last_fetch_timestamp(&mut self, value: i64) -> &mut Self

The last known leader wall clock time time when a follower fetched from the leader. This is reported as -1 both for the current leader or if it is unknown for a voter

Supported API versions: 1

pub fn last_caught_up_timestamp(&mut self, value: i64) -> &mut Self

The leader wall clock append time of the offset for which the follower made the most recent fetch request. This is reported as the current time for the leader and -1 if unknown for a voter

Supported API versions: 1

pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes> ) -> &mut Self

Other tagged fields

pub fn build(&self) -> Result<ReplicaState, ReplicaStateBuilderError>

Builds a new ReplicaState.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for ReplicaStateBuilder

fn clone(&self) -> ReplicaStateBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for ReplicaStateBuilder

fn default() -> Self

Returns the “default value” for a type.