Struct ReconCycle 

pub struct ReconCycle {
    pub peers_attempted: u64,
    pub peers_exchanged: u64,
    pub ranges_diverged: u64,
    pub ranges_repaired: u64,
}

Outcome of a single reconciliation pass.

All four counters are simple totals over the peers visited during one cycle of EntropyDriver::run_cycle.

Examples

use dynomite::entropy::driver::ReconCycle;
let mut c = ReconCycle::default();
c.record_attempted();
c.record_exchanged(128);
assert_eq!(c.peers_attempted, 1);
assert_eq!(c.peers_exchanged, 1);
assert_eq!(c.ranges_diverged, 1);
assert_eq!(c.ranges_repaired, 1);

Fields

peers_attempted: u64

Peers the driver attempted to dial during the cycle.

peers_exchanged: u64

Peers the driver successfully exchanged a snapshot with.

ranges_diverged: u64

Number of divergent ranges observed (one per peer when the snapshot was non-empty).

ranges_repaired: u64

Number of divergent ranges actually repaired (currently equals Self::ranges_diverged: every range pushed is considered repaired once the receiver acknowledges by closing the socket).

Implementations

impl ReconCycle

pub fn record_attempted(&mut self)

Note that the driver dialled one more peer.

pub fn record_exchanged(&mut self, bytes: usize)

Note that one peer interaction completed successfully. bytes is the plaintext snapshot length the sender pushed; non-zero values are interpreted as one divergent range repaired.

pub fn merge(&mut self, other: ReconCycle)

Merge other into self.

Trait Implementations

impl Clone for ReconCycle

fn clone(&self) -> ReconCycle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReconCycle

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

Formats the value using the given formatter.

impl Default for ReconCycle

fn default() -> ReconCycle

Returns the “default value” for a type.

impl PartialEq for ReconCycle

fn eq(&self, other: &ReconCycle) -> 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 Copy for ReconCycle

impl Eq for ReconCycle

impl StructuralPartialEq for ReconCycle