Struct NodeStats

pub struct NodeStats {
    pub total_forwarded_rewards: usize,
    pub total_rewards_wallet_balance: usize,
    pub total_memory_usage_mb: usize,
    pub individual_stats: Vec<IndividualNodeStats>,
}

Fields

total_forwarded_rewards: usize

total_rewards_wallet_balance: usize

total_memory_usage_mb: usize

individual_stats: Vec<IndividualNodeStats>

Implementations

impl NodeStats

pub fn fetch_all_node_stats( nodes: &[NodeServiceData], action_sender: UnboundedSender<Action>, )

Fetches statistics from all running nodes and sends the aggregated stats via the action sender.

This method iterates over the provided list of NodeServiceData instances, filters out nodes that are not running, and for each running node, it checks if a metrics port is available. If a metrics port is found, the node’s details (service name, metrics port, and data directory path) are collected. If no metrics port is found, a debug message is logged indicating that the node’s stats will not be fetched.

If there are any nodes with available metrics ports, this method spawns a local task to asynchronously fetch statistics from these nodes using fetch_all_node_stats_inner. The aggregated statistics are then sent via the provided action_sender.

If no running nodes with metrics ports are found, a debug message is logged indicating that there are no running nodes to fetch stats from.

Parameters

• nodes: A slice of NodeServiceData instances representing the nodes to fetch statistics from.
• action_sender: An unbounded sender of Action instances used to send the aggregated node statistics.

Trait Implementations

impl Clone for NodeStats

fn clone(&self) -> NodeStats

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NodeStats

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

Formats the value using the given formatter.

impl Default for NodeStats

fn default() -> NodeStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for NodeStats

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NodeStats

fn eq(&self, other: &NodeStats) -> 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 NodeStats

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for NodeStats

impl StructuralPartialEq for NodeStats