Struct ValidatorClientMonitor

pub struct ValidatorClientMonitor<A: Clone> { /* private fields */ }

Monitors validator interactions from the client’s perspective.

This component:

• Collects client-side metrics from TransactionDriver operations
• Runs periodic health checks on all validators from the client
• Maintains client-observed statistics for reliability and latency
• Provides intelligent validator selection based on client-observed performance
• Handles epoch changes by cleaning up stale validator data

The monitor runs a background task for health checks and uses exponential moving averages to smooth client-side measurements.

Implementations

impl<A> ValidatorClientMonitor<A>

where A: AuthorityAPI + Send + Sync + 'static + Clone,

pub fn new( config: ValidatorClientMonitorConfig, metrics: Arc<ValidatorClientMetrics>, authority_aggregator: Arc<ArcSwap<AuthorityAggregator<A>>>, ) -> Arc<Self>

impl<A: Clone> ValidatorClientMonitor<A>

pub fn record_interaction_result(&self, feedback: OperationFeedback)

Record client-observed interaction result with a validator.

Records operation results including success/failure status and latency from the client’s perspective. Updates both Prometheus metrics and internal client statistics. This is the primary interface for the TransactionDriver to report client-observed validator interactions. TODO: Consider adding a byzantine flag to the feedback.

pub fn select_shuffled_preferred_validators( &self, committee: &Committee, k: usize, ) -> Vec<AuthorityName>

Select validators based on client-observed performance with shuffled top k.

We need to pass the current committee here because it is possible that the fullnode is in the middle of a committee change when this is called, and we need to maintain an invariant that the selected validators are always in the committee passed in.

We shuffle the top k validators to avoid the same validator being selected too many times in a row and getting overloaded.

Returns a vector containing:

1. The top k validators by score (shuffled)
2. The remaining validators ordered by score (not shuffled)