Struct VersionVector 

pub struct VersionVector { /* private fields */ }

Per-replica contiguous prefixes for anti-entropy pulls.

get(replica) == n means every sequence 1..=n for that replica is known. Later records that arrive before earlier records must not advance this prefix, otherwise since could hide gaps.

Implementations

impl VersionVector

pub fn new() -> Self

pub fn get(&self, replica: u64) -> u64

pub fn observe(&mut self, id: RecordId)

Advance this prefix only when id is the next contiguous sequence.

Use EventLog to ingest out-of-order records; the log remembers gaps and advances this vector once the prefix is complete.

pub fn includes(&self, id: RecordId) -> bool

pub fn entries(&self) -> &BTreeMap<u64, u64>

Trait Implementations

impl Clone for VersionVector

fn clone(&self) -> VersionVector

Returns a duplicate of the value. Read more

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

Performs copy-assignment from source. Read more

impl Debug for VersionVector

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

Formats the value using the given formatter. Read more

impl Default for VersionVector

fn default() -> VersionVector

Returns the “default value” for a type. Read more

impl Eq for VersionVector

impl PartialEq for VersionVector

fn eq(&self, other: &VersionVector) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for VersionVector