Struct ConsensusState 

pub struct ConsensusState {
    pub holonomy: f64,
    pub peer_agreement: f64,
    pub crdt_version: BTreeMap<u64, u64>,
}

Consensus state captures cycle coherence via holonomy integral and peer agreement with a CRDT version vector.

Fields

holonomy: f64

Cycle integral (0 = coherent)

peer_agreement: f64

Fraction of agreeing peers (0-1)

crdt_version: BTreeMap<u64, u64>

State vector clock (agent_id -> version)

Implementations

impl ConsensusState

pub fn new( holonomy: f64, peer_agreement: f64, crdt_version: BTreeMap<u64, u64>, ) -> Self

pub fn default() -> Self

pub fn check_alignment(&self) -> Vec<String>

Check alignment: holonomy should approach 0

pub fn merge(&self, other: &Self) -> Self

Merge: min holonomy (most coherent), max peer agreement, supmerge version vectors (pointwise max). All semilattice operations.

Trait Implementations

impl Clone for ConsensusState

fn clone(&self) -> ConsensusState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsensusState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ConsensusState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConsensusState

fn eq(&self, other: &ConsensusState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ConsensusState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConsensusState