Struct kafka_protocol::messages::describe_log_dirs_response::DescribeLogDirsPartition

#[non_exhaustive]
pub struct DescribeLogDirsPartition {
    pub partition_index: i32,
    pub partition_size: i64,
    pub offset_lag: i64,
    pub is_future_key: bool,
    pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}

Valid versions: 0-4

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.

partition_index: i32

The partition index.

Supported API versions: 0-4

partition_size: i64

The size of the log segments in this partition in bytes.

Supported API versions: 0-4

offset_lag: i64

The lag of the log’s LEO w.r.t. partition’s HW (if it is the current log for the partition) or current replica’s LEO (if it is the future log for the partition)

Supported API versions: 0-4

is_future_key: bool

True if this log is created by AlterReplicaLogDirsRequest and will replace the current log of the replica in the future.

Supported API versions: 0-4

unknown_tagged_fields: BTreeMap<i32, Bytes>

Other tagged fields

Implementations

impl DescribeLogDirsPartition

pub fn with_partition_index(self, value: i32) -> Self

Sets partition_index to the passed value.

The partition index.

Supported API versions: 0-4

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

Sets partition_size to the passed value.

The size of the log segments in this partition in bytes.

Supported API versions: 0-4

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

Sets offset_lag to the passed value.

The lag of the log’s LEO w.r.t. partition’s HW (if it is the current log for the partition) or current replica’s LEO (if it is the future log for the partition)

Supported API versions: 0-4

pub fn with_is_future_key(self, value: bool) -> Self

Sets is_future_key to the passed value.

True if this log is created by AlterReplicaLogDirsRequest and will replace the current log of the replica in the future.

Supported API versions: 0-4

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 DescribeLogDirsPartition

fn clone(&self) -> DescribeLogDirsPartition

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DescribeLogDirsPartition

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

Formats the value using the given formatter.

impl Decodable for DescribeLogDirsPartition

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

Decode the message from the provided buffer and version.

impl Default for DescribeLogDirsPartition

fn default() -> Self

Returns the “default value” for a type.

impl Encodable for DescribeLogDirsPartition

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 DescribeLogDirsPartition

const VERSIONS: VersionRange = _

The valid versions for this message.

const DEPRECATED_VERSIONS: Option<VersionRange> = None

The deprecated versions for this message.

impl PartialEq for DescribeLogDirsPartition

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