Trait fluvio_storage::ReplicaStorage

pub trait ReplicaStorage {
    pub fn get_hw(&self) -> Offset;
    pub fn get_leo(&self) -> Offset;
}

Required methods

pub fn get_hw(&self) -> Offset

high water mark offset (records that has been replicated)

pub fn get_leo(&self) -> Offset

log end offset ( records that has been stored)

Loading content...

Implementors

impl ReplicaStorage for FileReplica

pub fn get_hw(&self) -> Offset

pub fn get_leo(&self) -> Offset

offset mark that beginning of uncommitted

Loading content...