Struct ReplicationBacklog 

pub struct ReplicationBacklog { /* private fields */ }

Implementations

impl ReplicationBacklog

pub fn new(max_bytes: usize, shard_count: usize) -> Self

pub fn push(&mut self, frame: Bytes, mutations: &[ReplicationMutation])

pub fn push_encoded(&mut self, frame: Bytes, mutations: &[ReplicationMutation])

pub fn catch_up_since( &self, watermarks: &ShardWatermarks, ) -> Result<BacklogCatchUp>

pub fn decode_frames(frames: &[Bytes]) -> Result<Vec<ReplicationFrame>>

pub fn latest_watermarks(&self) -> ShardWatermarks

pub fn retained_bytes(&self) -> usize

Trait Implementations

impl Debug for ReplicationBacklog

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

Formats the value using the given formatter.