Struct FactsExchange 

pub struct FactsExchange { /* private fields */ }

Node-local facts distribution.

Implementations

impl FactsExchange

pub fn new( key: SigningKey, membership: Arc<ClusterMembership>, runtime: Arc<MeshRuntime>, policy: FactsTrustPolicy, ) -> Arc<Self>

Exchange for the node owning key, sending over runtime and caching in membership.

pub fn start(self: &Arc<Self>)

Install as the runtime’s facts sink and announce the current facts to every peer that joins or recovers. Call once.

pub fn on_peer_gone(&self, node_id: &str) -> bool

A peer’s connection ended or its admission was revoked: lower its mesh-derived tier to Discovered. An operator-set tier stays.

pub fn node_id(&self) -> &str

This node’s id.

pub fn membership(&self) -> &Arc<ClusterMembership>

The membership whose cache this exchange fills.

pub async fn publish( &self, facts: NodeFacts, now: u64, ) -> Result<u64, NodeFactsAdvertError>

Sign facts as the new base (its seq is replaced by the next one), cache them as the local node (pinned) and send them to every peer.

pub async fn update_live( &self, probed: NodeFacts, now: u64, ) -> Result<Published, NodeFactsAdvertError>

Publish a fresh probe of the local node: a delta when only live state (capability states, free memory) changed since the last base, a new base when the capability set changed or the base is nearing its TTL, nothing when nothing changed.

pub fn ingest( &self, ctx: &PeerCtx, wire: FactsWire, now: u64, replies: &mut Vec<FactsWire>, ) -> Result<IngestOutcome, IngestError>

Self::ingest_from with no connection id (no per-connection quota).

pub fn ingest_from( &self, ctx: &PeerCtx, conn: u64, wire: FactsWire, now: u64, replies: &mut Vec<FactsWire>, ) -> Result<IngestOutcome, IngestError>

Receive one facts message from connection conn (identity ctx), at now. Replies to send back to the peer are appended to replies.

The tier is derived from ctx on every frame: a node that is no longer admitted drops back to Discovered with its next frame (or when its connection goes, see Self::start); only a tier an operator set is kept.

Trait Implementations

impl PeerControlSink for FactsExchange

fn on_peer_control( &self, ctx: &PeerCtx, conn: u64, payload: &Value, ) -> Vec<Value>

Handle one control payload from ctx.peer_id; return replies.