Trait ConsensusManager 

pub trait ConsensusManager<T>: Send + Sync {
    // Required methods
    async fn initialize(&mut self) -> Result<()>;
    async fn propose(
        &mut self,
        proposal: ConsensusProposal<T>,
    ) -> Result<String>;
    async fn vote(
        &mut self,
        proposal_id: &str,
        vote: ConsensusVote,
    ) -> Result<()>;
    async fn get_decision(
        &self,
        proposal_id: &str,
    ) -> Result<Option<ConsensusDecision<T>>>;
    async fn handle_node_failure(&mut self, node_id: &str) -> Result<()>;
    async fn handle_node_recovery(&mut self, node_id: &str) -> Result<()>;
    async fn get_state(&self) -> Result<ConsensusSystemState>;
    async fn get_health_score(&self) -> Result<f64>;
    async fn shutdown(&mut self) -> Result<()>;
}

Consensus manager trait for different algorithms

Required Methods

async fn initialize(&mut self) -> Result<()>

Initialize consensus manager

async fn propose(&mut self, proposal: ConsensusProposal<T>) -> Result<String>

Propose a value for consensus

async fn vote(&mut self, proposal_id: &str, vote: ConsensusVote) -> Result<()>

Vote on a proposal

async fn get_decision( &self, proposal_id: &str, ) -> Result<Option<ConsensusDecision<T>>>

Get consensus decision if available

async fn handle_node_failure(&mut self, node_id: &str) -> Result<()>

Handle node failure

async fn handle_node_recovery(&mut self, node_id: &str) -> Result<()>

Handle node recovery

async fn get_state(&self) -> Result<ConsensusSystemState>

Get current consensus state

async fn get_health_score(&self) -> Result<f64>

Get health score

async fn shutdown(&mut self) -> Result<()>

Shutdown consensus manager

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors