Trait fluvio_storage::ReplicaStorage

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

Required methods

fn get_hw(&self) -> Offset

high water mark offset (records that has been replicated)

fn get_leo(&self) -> Offset

log end offset ( records that has been stored)

Loading content...

Implementors

impl ReplicaStorage for FileReplica

fn get_hw(&self) -> Offset

fn get_leo(&self) -> Offset

offset mark that beginning of uncommitted

Loading content...