Struct OffsetInfo 

pub struct OffsetInfo {
    pub offset: i64,
    pub high_watermark: Option<i64>,
    pub last_updated: DateTime<Utc>,
    pub metadata: Option<String>,
}

Offset information for a partition

Fields

offset: i64

Current committed offset

high_watermark: Option<i64>

High watermark (latest available offset in partition)

last_updated: DateTime<Utc>

Timestamp when offset was last updated

metadata: Option<String>

Metadata associated with this offset

Implementations

impl OffsetInfo

pub fn new(offset: i64) -> Self

Create new offset info

pub fn with_high_watermark(offset: i64, high_watermark: i64) -> Self

Create with high watermark

pub fn lag(&self) -> Option<i64>

Calculate lag (difference between high watermark and current offset)

Trait Implementations

impl Clone for OffsetInfo

fn clone(&self) -> OffsetInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetInfo

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OffsetInfo

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OffsetInfo

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

where __S: Serializer,

Serialize this value into the given Serde serializer.