Trait fluvio_dataplane_protocol::PartitionOffset

pub trait PartitionOffset {
    pub fn last_stable_offset(&self) -> i64;
    pub fn start_offset(&self) -> i64;
}

Offset information about Partition

Required methods

pub fn last_stable_offset(&self) -> i64

last offset that was committed

pub fn start_offset(&self) -> i64

Loading content...

Implementors

Loading content...