Struct StateDivergenceCheck 

pub struct StateDivergenceCheck { /* private fields */ }

Health check for monitoring state convergence.

This check monitors the state reconciliation engine to ensure that state is converging properly across the network. State divergence can indicate network partitions, bugs in the reconciliation logic, or other serious issues.

Status Determination

• Healthy: State is converging normally
• Degraded: State convergence is slow or stalled
• Unhealthy: State divergence detected

Example

use elara_runtime::health::{StateDivergenceCheck, HealthCheck};
use elara_runtime::node::Node;
use std::sync::Arc;

let node = Arc::new(Node::new());
let check = StateDivergenceCheck::new(node);
let result = check.check();

Implementations

impl StateDivergenceCheck

pub fn new(node: Arc<Node>) -> Self

Creates a new StateDivergenceCheck.

Arguments

• node - Arc reference to the Node to monitor

Example

use elara_runtime::health::StateDivergenceCheck;
use elara_runtime::node::Node;
use std::sync::Arc;

let node = Arc::new(Node::new());
let check = StateDivergenceCheck::new(node);

pub fn with_threshold(node: Arc<Node>, max_pending_events: usize) -> Self

Creates a new StateDivergenceCheck with a custom threshold.

Arguments

• node - Arc reference to the Node to monitor
• max_pending_events - Maximum pending events before degraded status

Example

use elara_runtime::health::StateDivergenceCheck;
use elara_runtime::node::Node;
use std::sync::Arc;

let node = Arc::new(Node::new());
let check = StateDivergenceCheck::with_threshold(node, 500);

pub fn max_pending_events(&self) -> usize

Returns the configured maximum pending events threshold.

Trait Implementations

impl HealthCheck for StateDivergenceCheck

fn name(&self) -> &str

Returns the name of this health check.

fn check(&self) -> HealthCheckResult

Performs the health check and returns the result.