Skip to content

Commit 74f56ff

Browse files
apollo_network_benchmark: added SQMR session metrics
1 parent 5095a65 commit 74f56ff

File tree

1 file changed

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

1 file changed

+9
-1
lines changed

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

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ use apollo_metrics::metrics::LossyIntoF64;
66
use apollo_network::metrics::{
77
BroadcastNetworkMetrics,
88
NetworkMetrics,
9+
SqmrNetworkMetrics,
910
NETWORK_BROADCAST_DROP_LABELS,
1011
};
1112

@@ -27,6 +28,8 @@ define_metrics!(
2728

2829
MetricGauge { NETWORK_CONNECTED_PEERS, "network_connected_peers", "Number of connected peers in the network" },
2930
MetricGauge { NETWORK_BLACKLISTED_PEERS, "network_blacklisted_peers", "Number of blacklisted peers in the network" },
31+
MetricGauge { NETWORK_ACTIVE_INBOUND_SESSIONS, "network_active_inbound_sessions", "Number of active inbound SQMR sessions" },
32+
MetricGauge { NETWORK_ACTIVE_OUTBOUND_SESSIONS, "network_active_outbound_sessions", "Number of active outbound SQMR sessions" },
3033
MetricCounter { NETWORK_STRESS_TEST_SENT_MESSAGES, "network_stress_test_sent_messages", "Number of stress test messages sent via broadcast", init = 0 },
3134
MetricCounter { NETWORK_STRESS_TEST_RECEIVED_MESSAGES, "network_stress_test_received_messages", "Number of stress test messages received via broadcast", init = 0 },
3235
LabeledMetricCounter { NETWORK_DROPPED_BROADCAST_MESSAGES, "network_dropped_broadcast_messages", "Number of dropped broadcast messages by reason", init = 0, labels = NETWORK_BROADCAST_DROP_LABELS },
@@ -71,11 +74,16 @@ pub fn create_network_metrics() -> apollo_network::metrics::NetworkMetrics {
7174
let mut broadcast_metrics_by_topic = HashMap::new();
7275
broadcast_metrics_by_topic.insert(TOPIC.hash(), stress_test_broadcast_metrics);
7376

77+
let sqmr_metrics = SqmrNetworkMetrics {
78+
num_active_inbound_sessions: NETWORK_ACTIVE_INBOUND_SESSIONS,
79+
num_active_outbound_sessions: NETWORK_ACTIVE_OUTBOUND_SESSIONS,
80+
};
81+
7482
NetworkMetrics {
7583
num_connected_peers: NETWORK_CONNECTED_PEERS,
7684
num_blacklisted_peers: NETWORK_BLACKLISTED_PEERS,
7785
broadcast_metrics_by_topic: Some(broadcast_metrics_by_topic),
78-
sqmr_metrics: None,
86+
sqmr_metrics: Some(sqmr_metrics),
7987
event_metrics: None,
8088
latency_metrics: None,
8189
}

0 commit comments

Comments
 (0)