Struct ReplicaState

#[non_exhaustive]
pub struct ReplicaState {
    pub replica_id: BrokerId,
    pub replica_directory_id: Uuid,
    pub log_end_offset: i64,
    pub last_fetch_timestamp: i64,
    pub last_caught_up_timestamp: i64,
    pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}

Valid versions: 0-2

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

replica_id: BrokerId

Supported API versions: 0-2

replica_directory_id: Uuid

Supported API versions: 2

log_end_offset: i64

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

Supported API versions: 0-2

last_fetch_timestamp: i64

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-2

last_caught_up_timestamp: i64

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-2

unknown_tagged_fields: BTreeMap<i32, Bytes>

Other tagged fields

Implementations

impl ReplicaState

pub fn with_replica_id(self, value: BrokerId) -> Self

Sets replica_id to the passed value.

Supported API versions: 0-2

pub fn with_replica_directory_id(self, value: Uuid) -> Self

Sets replica_directory_id to the passed value.

Supported API versions: 2

pub fn with_log_end_offset(self, value: i64) -> Self

Sets log_end_offset to the passed value.

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

Supported API versions: 0-2

pub fn with_last_fetch_timestamp(self, value: i64) -> Self

Sets last_fetch_timestamp to the passed value.

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-2

pub fn with_last_caught_up_timestamp(self, value: i64) -> Self

Sets last_caught_up_timestamp to the passed value.

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-2

pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self

Sets unknown_tagged_fields to the passed value.

pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self

Inserts an entry into unknown_tagged_fields.

Trait Implementations

impl Clone for ReplicaState

fn clone(&self) -> ReplicaState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicaState

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

Formats the value using the given formatter.

impl Decodable for ReplicaState

Available on crate feature client only.

fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self>

Decode the message from the provided buffer and version.

impl Default for ReplicaState

fn default() -> Self

Returns the “default value” for a type.

impl Encodable for ReplicaState

Available on crate feature broker only.

fn encode<B: ByteBufMut>(&self, buf: &mut B, version: i16) -> Result<()>

Encode the message into the target buffer.

fn compute_size(&self, version: i16) -> Result<usize>

Compute the total size of the message when encoded.

impl Message for ReplicaState

const VERSIONS: VersionRange

The valid versions for this message.

const DEPRECATED_VERSIONS: Option<VersionRange> = None

The deprecated versions for this message.

impl PartialEq for ReplicaState

fn eq(&self, other: &ReplicaState) -> 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 StructuralPartialEq for ReplicaState