Struct ClusterProbe 

pub struct ClusterProbe { /* private fields */ }

Implementations

impl ClusterProbe

pub fn new(bus: TelemetryBus) -> Self

pub fn set_self_address(&self, addr: impl Into<String>)

pub fn set_leader(&self, leader: Option<String>)

pub fn update(&self, next: ClusterStateInfo)

Replace the current snapshot and emit a diff event describing the change. Consumers that already track a baseline can use the diff directly; dashboards that just want the latest value can poll Self::snapshot.

pub fn snapshot(&self) -> ClusterStateInfo

pub fn member_count(&self) -> usize

pub fn unreachable_count(&self) -> usize

impl ClusterProbe

pub fn update_from_gossip(&self, gossip: &Gossip)

Convenience: update from a live atomr-cluster::Gossip.

pub fn update_from_state(&self, state: &MembershipState)

Convenience: update from a atomr-cluster::MembershipState.