Skip to content

Commit f6b5f12

Browse files
apollo_network_benchmark: added network event metrics
1 parent 9f1fb1f commit f6b5f12

File tree

1 file changed

+8
-1
lines changed
  • crates/apollo_network_benchmark/src/bin/broadcast_network_stress_test_node

1 file changed

+8
-1
lines changed

crates/apollo_network_benchmark/src/bin/broadcast_network_stress_test_node/metrics.rs

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,10 @@ use apollo_metrics::define_metrics;
55
use apollo_metrics::metrics::LossyIntoF64;
66
use apollo_network::metrics::{
77
BroadcastNetworkMetrics,
8+
EventMetrics,
89
NetworkMetrics,
910
SqmrNetworkMetrics,
11+
EVENT_TYPE_LABELS,
1012
NETWORK_BROADCAST_DROP_LABELS,
1113
};
1214

@@ -34,6 +36,8 @@ define_metrics!(
3436
MetricCounter { NETWORK_STRESS_TEST_SENT_MESSAGES, "network_stress_test_sent_messages", "Number of stress test messages sent via broadcast", init = 0 },
3537
MetricCounter { NETWORK_STRESS_TEST_RECEIVED_MESSAGES, "network_stress_test_received_messages", "Number of stress test messages received via broadcast", init = 0 },
3638
LabeledMetricCounter { NETWORK_DROPPED_BROADCAST_MESSAGES, "network_dropped_broadcast_messages", "Number of dropped broadcast messages by reason", init = 0, labels = NETWORK_BROADCAST_DROP_LABELS },
39+
LabeledMetricCounter { NETWORK_EVENT_COUNTER, "network_event_counter", "Network events counter by type", init = 0, labels = EVENT_TYPE_LABELS },
40+
3741
// system metrics for the node
3842
MetricGauge { SYSTEM_TOTAL_MEMORY_BYTES, "system_total_memory_bytes", "Total system memory in bytes" },
3943
MetricGauge { SYSTEM_AVAILABLE_MEMORY_BYTES, "system_available_memory_bytes", "Available system memory in bytes" },
@@ -100,12 +104,15 @@ pub fn create_network_metrics() -> apollo_network::metrics::NetworkMetrics {
100104
num_active_outbound_sessions: NETWORK_ACTIVE_OUTBOUND_SESSIONS,
101105
};
102106

107+
// Create event metrics for network events monitoring
108+
let event_metrics = EventMetrics { event_counter: NETWORK_EVENT_COUNTER };
109+
103110
NetworkMetrics {
104111
num_connected_peers: NETWORK_CONNECTED_PEERS,
105112
num_blacklisted_peers: NETWORK_BLACKLISTED_PEERS,
106113
broadcast_metrics_by_topic: Some(broadcast_metrics_by_topic),
107114
sqmr_metrics: Some(sqmr_metrics),
108-
event_metrics: None,
115+
event_metrics: Some(event_metrics),
109116
latency_metrics: None,
110117
}
111118
}

0 commit comments

Comments
 (0)