Struct ReplicaInfo 

pub struct ReplicaInfo { /* private fields */ }

A description of a replica on a particular broker.

Implementations

impl ReplicaInfo

pub fn new(size: i64, offset_lag: i64, is_future: bool) -> Self

Creates a new ReplicaInfo.

Arguments

• size - the total size of the log segments in this replica in bytes.
• offset_lag - the lag of the log’s LEO with respect to the partition’s high watermark.
• is_future - whether this replica has been created by an AlterReplicaLogDirsRequest.

pub fn size(&self) -> i64

Returns the total size of the log segments in this replica in bytes.

This value does not include the size of data stored in remote storage.

pub fn offset_lag(&self) -> i64

Returns the lag of the log’s LEO with respect to the partition’s high watermark (if it is the current log for the partition) or the current replica’s LEO (if it is the future log for the partition).

pub fn is_future(&self) -> bool

Whether this replica has been created by an AlterReplicaLogDirsRequest but has not yet replaced the current replica on the broker.

Returns

true if this log is created by AlterReplicaLogDirsRequest and will replace the current log of the replica at some time in the future.

Trait Implementations

impl Clone for ReplicaInfo

fn clone(&self) -> ReplicaInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicaInfo

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

Formats the value using the given formatter.

impl Display for ReplicaInfo

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

Formats the value using the given formatter.