Struct PeerDeltaBuffer 

pub struct PeerDeltaBuffer<D: Lattice> {
    delta: Option<D>,
    from_seq: SeqNo,
    to_seq: SeqNo,
}

Per-peer delta buffer for causal mode

Stores deltas that need to be sent to a specific peer, along with the sequence range they cover.

Fields

delta: Option<D>

The accumulated delta to send

from_seq: SeqNo

Sequence number before the first delta in buffer

to_seq: SeqNo

Sequence number of the last delta in buffer

Implementations

impl<D: Lattice> PeerDeltaBuffer<D>

pub fn new() -> Self

pub fn start_from(seq: SeqNo) -> Self

Start tracking from a specific sequence number

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

Add a delta to this buffer

pub fn has_pending(&self) -> bool

Check if buffer has pending deltas

pub fn take(&mut self) -> Option<(D, SeqNo, SeqNo)>

Take the delta, clearing the buffer

pub fn clear(&mut self)

Clear the buffer (on successful ack)

pub fn reset_from(&mut self, seq: SeqNo)

Reset the buffer from a new sequence (after peer reconnect)

Trait Implementations

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

fn clone(&self) -> PeerDeltaBuffer<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 PeerDeltaBuffer<D>

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

Formats the value using the given formatter.

impl<D: Lattice> Default for PeerDeltaBuffer<D>

fn default() -> Self

Returns the “default value” for a type.