Struct DeltaBuffer 

pub struct DeltaBuffer<D: Lattice> { /* private fields */ }

Buffer for outgoing deltas with grouping support

Implementations

impl<D: Lattice> DeltaBuffer<D>

pub fn new(max_buffer_size: usize) -> Self

pub fn push(&mut self, delta: D)

Add a new delta to the buffer

pub fn deltas_since(&self, acked_seq: SeqNo) -> Vec<&TaggedDelta<D>>

Get deltas for sending to a peer that has acked up to acked_seq

pub fn delta_group_since(&self, acked_seq: SeqNo) -> Option<D>

Create a delta-group (joined deltas) for a peer

pub fn ack(&mut self, acked_seq: SeqNo) -> usize

Acknowledge that a peer has received up to seq Deltas before this can be GC’d if all peers have acked

pub fn current_seq(&self) -> SeqNo

Current sequence number

pub fn len(&self) -> usize

Number of buffered deltas

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn clear(&mut self)

Clear all buffered deltas

Trait Implementations

impl<D: Clone + Lattice> Clone for DeltaBuffer<D>

fn clone(&self) -> DeltaBuffer<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D: Debug + Lattice> Debug for DeltaBuffer<D>

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

Formats the value using the given formatter.