Struct QuorumPolicy 

pub struct QuorumPolicy {
    pub min_peers: usize,
    pub commit_threshold: f64,
    pub timeout: Duration,
}

Policy parameters governing when a round can proceed to aggregation.

Fields

min_peers: usize

Minimum number of peers that must vote for quorum to be considered.

commit_threshold: f64

Fraction of votes (0.0–1.0) that must be Commit for the round to commit. E.g. 0.67 means at least 67 % of votes must be Commit.

timeout: Duration

Maximum time allowed before the round is automatically timed out.

Implementations

impl QuorumPolicy

pub fn check(&self, votes: &[PeerVote], elapsed: Duration) -> QuorumResult

Evaluate the current vote set and elapsed time against this policy.

votes is the full slice of votes cast so far. elapsed is the time since the round started.

Trait Implementations

impl Clone for QuorumPolicy

fn clone(&self) -> QuorumPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QuorumPolicy

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

Formats the value using the given formatter.

impl Default for QuorumPolicy

fn default() -> Self

Returns the “default value” for a type.