Struct RoundConsensusTracker 

pub struct RoundConsensusTracker {
    pub policy: QuorumPolicy,
    pub stats: ConsensusStats,
    /* private fields */
}

Central registry for federated learning round consensus.

All public methods are safe to call from multiple threads concurrently. Internal state is protected by a single RwLock; the design keeps critical sections short to minimise contention.

Fields

policy: QuorumPolicy

Policy applied to every quorum evaluation.

stats: ConsensusStats

Aggregate statistics.

Implementations

impl RoundConsensusTracker

pub fn new(policy: QuorumPolicy) -> Self

Create a new tracker with the given quorum policy.

pub fn begin_round( &self, round_id: RoundId, expected_peers: Vec<String>, ) -> Result<(), ConsensusError>

Register a new round. Returns ConsensusError::RoundAlreadyExists if a round with the same ID already exists.

pub fn cast_vote(&self, vote: PeerVote) -> Result<QuorumResult, ConsensusError>

Cast a vote for a round.

After recording the vote the quorum policy is evaluated. If the policy reaches a terminal verdict (Commit or Abort) the round’s status is updated atomically and the corresponding stat counter is incremented.

Errors

• ConsensusError::RoundNotFound — no such round
• ConsensusError::RoundNotActive — round is already committed/aborted
• ConsensusError::DuplicateVote — peer already voted in this round

pub fn check_round(&self, round_id: &RoundId) -> Option<QuorumResult>

Evaluate the current quorum state of a round without casting a new vote. Returns None if the round does not exist.

pub fn abort_round( &self, round_id: &RoundId, reason: &str, ) -> Result<(), ConsensusError>

Forcibly abort a round.

Errors

• ConsensusError::RoundNotFound — no such round
• ConsensusError::RoundNotActive — round already in terminal state

pub fn complete_rounds(&self) -> Vec<u64>

Return the IDs of all rounds currently in a terminal state (committed or aborted).

pub fn active_round_count(&self) -> usize

Return the number of rounds currently in the Active state.

Trait Implementations

impl Debug for RoundConsensusTracker

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

Formats the value using the given formatter.