Skip to content

Commit 9fa62de

Browse files
apollo_network_benchmark: added network event metrics
1 parent 0e49478 commit 9fa62de

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" },
@@ -87,12 +91,15 @@ pub fn create_network_metrics() -> apollo_network::metrics::NetworkMetrics {
8791
num_active_outbound_sessions: NETWORK_ACTIVE_OUTBOUND_SESSIONS,
8892
};
8993

94+
// Create event metrics for network events monitoring
95+
let event_metrics = EventMetrics { event_counter: NETWORK_EVENT_COUNTER };
96+
9097
NetworkMetrics {
9198
num_connected_peers: NETWORK_CONNECTED_PEERS,
9299
num_blacklisted_peers: NETWORK_BLACKLISTED_PEERS,
93100
broadcast_metrics_by_topic: Some(broadcast_metrics_by_topic),
94101
sqmr_metrics: Some(sqmr_metrics),
95-
event_metrics: None,
102+
event_metrics: Some(event_metrics),
96103
latency_metrics: None,
97104
}
98105
}

0 commit comments

Comments
 (0)