Struct ConsensusProtocol 

pub struct ConsensusProtocol {
    pub proposers: HashSet<NodeId>,
    pub acceptors: HashSet<NodeId>,
    pub learners: HashSet<NodeId>,
    pub promised_proposal: HashMap<NodeId, u64>,
    pub accepted_value: HashMap<NodeId, (u64, Vote)>,
    pub proposal_counter: u64,
    pub quorum_size: usize,
}

A Paxos-like consensus protocol for ternary votes.

Supports prepare/promise and accept/ack phases. A proposal is accepted when a quorum of acceptors responds. The final value is determined by summing the ternary votes: negative sum → Neg, positive sum → Pos, zero → Zero.

Fields

proposers: HashSet<NodeId>

acceptors: HashSet<NodeId>

learners: HashSet<NodeId>

promised_proposal: HashMap<NodeId, u64>

accepted_value: HashMap<NodeId, (u64, Vote)>

proposal_counter: u64

quorum_size: usize

Implementations

impl ConsensusProtocol

pub fn new(nodes: &[NodeId]) -> Self

pub fn prepare(&mut self, proposer: NodeId) -> u64

pub fn promise(&mut self, acceptor: NodeId, proposal_num: u64) -> bool

pub fn accept( &mut self, acceptor: NodeId, proposal_num: u64, value: Vote, ) -> bool

pub fn decide(&self) -> Option<Vote>

Trait Implementations

impl Clone for ConsensusProtocol

fn clone(&self) -> ConsensusProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsensusProtocol

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

Formats the value using the given formatter.