Struct ConsumerBacklog 

pub struct ConsumerBacklog {
    pub checkpoint_name: String,
    pub checkpoint: CheckpointData,
    pub segments_behind: usize,
    pub bytes_behind: u64,
    pub lag: Option<Duration>,
}

How far one consumer’s checkpoint trails the newest data in the log directory.

Fields

checkpoint_name: String

The checkpoint_name with which the consumer was configured

checkpoint: CheckpointData

Where the consumer’s reading has reached.

segments_behind: usize

Count of whole segments ordered after the segment defined by checkpoint.

bytes_behind: u64

Total compressed size, in bytes, of the segments counted by segments_behind. Excludes the remainder of the segment that contains the checkpoint, because measuring that would require decompressing it to find the recorded line.

lag: Option<Duration>

Age of the oldest segment not started by the consumer, measured from its modification time, approximating how long the oldest unread data has waited. None when the consumer has reached the newest segment.

Trait Implementations

impl Clone for ConsumerBacklog

fn clone(&self) -> ConsumerBacklog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerBacklog

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

Formats the value using the given formatter.

impl PartialEq for ConsumerBacklog

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConsumerBacklog