Struct VoteCollector 

pub struct VoteCollector<T: NodeType, S: Tally<T>> {
    accumulators: JoinMap<ViewNumber, Option<S::Output>>,
    ballot_boxes: BTreeMap<ViewNumber, Sender<S::Vote>>,
    pending: BTreeMap<ViewNumber, HashMap<T::SignatureKey, S::Vote>>,
    completed: BTreeSet<ViewNumber>,
    signers: BTreeMap<ViewNumber, HashSet<T::SignatureKey>>,
    lower_bound: ViewNumber,
    membership: EpochMembershipCoordinator<T>,
    upgrade_lock: UpgradeLock<T>,
}

Collects votes per view and forms certificate(s) using the strategy S.

Fields

accumulators: JoinMap<ViewNumber, Option<S::Output>>

Tasks collecting votes and forming certificates.

ballot_boxes: BTreeMap<ViewNumber, Sender<S::Vote>>

Where callers submit their votes.

pending: BTreeMap<ViewNumber, HashMap<T::SignatureKey, S::Vote>>

Votes for epochs we have yet to resolve, deduplicated by signer.

completed: BTreeSet<ViewNumber>

Views that had a valid certificate already.

signers: BTreeMap<ViewNumber, HashSet<T::SignatureKey>>

The signers per view.

lower_bound: ViewNumber

The GC threshold.

membership: EpochMembershipCoordinator<T>

upgrade_lock: UpgradeLock<T>

Implementations

impl<T: NodeType, S: Tally<T>> VoteCollector<T, S>

where <S as Tally<T>>::Vote: Ballot<Signer = T::SignatureKey>,

pub fn new(mc: EpochMembershipCoordinator<T>, lock: UpgradeLock<T>) -> Self

pub async fn next(&mut self) -> Option<S::Output>

pub fn accumulate_vote(&mut self, vote: S::Vote)

pub fn retry_pending_votes(&mut self)

pub fn gc(&mut self, view: ViewNumber)

fn resolve_membership(&mut self, vote: &S::Vote) -> Option<EpochMembership<T>>

impl<T, V, C> VoteCollector<T, SimpleTally<T, V, C>>

where T: NodeType, V: Vote<T> + Send + 'static, C: Certificate<T, V::Commitment, Voteable = V::Commitment> + HasEpoch + Send + 'static,

pub fn stats(&self, view: ViewNumber, epoch: EpochNumber) -> Option<VoteStats>

Compute the accumulated stake.

This is the sum across unique signers we’ve routed to the accumulator for view and the cert threshold in epoch. Looks up each signer’s stake on demand — only intended for rare paths like timeout diagnostics. Returns None if no votes have been seen for view or epoch’s stake table is unavailable.