Struct GeometricConsensus 

pub struct GeometricConsensus { /* private fields */ }

A geometric consensus protocol implementation

Implementations

impl GeometricConsensus

pub fn new(node_id: Uuid, initial_state: GA3) -> Self

Create a new consensus protocol instance

pub async fn propose(&mut self, value: GA3) -> Result<(), Box<dyn Error>>

Propose a value for consensus

pub async fn geometric_consensus( &self, proposals: &[GA3], threshold: f64, ) -> Result<GA3, Box<dyn Error>>

Compute consensus from a set of proposals using geometric algebra

pub async fn run_consensus_round( &mut self, proposal: GA3, participants: &[Uuid], ) -> Result<Option<GA3>, Box<dyn Error>>

Run a full consensus round

pub async fn sync_crdt_state( &self, _other_node: Uuid, ) -> Result<(), Box<dyn Error>>

Sync CRDT state with another node

pub async fn handle_sync_message(&self, crdt_state: GeometricCRDT)

Handle an incoming sync message

pub async fn get_current_state(&self) -> GA3

Get the current consensus state