Skip to content

Commit c5160fd

Browse files
apollo_network_benchmark: added ping latency metrics
1 parent 0789a94 commit c5160fd

File tree

1 file changed

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

1 file changed

+6
-1
lines changed

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

Lines changed: 6 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
EventMetrics,
9+
LatencyMetrics,
910
NetworkMetrics,
1011
SqmrNetworkMetrics,
1112
EVENT_TYPE_LABELS,
@@ -36,6 +37,8 @@ define_metrics!(
3637
MetricCounter { NETWORK_STRESS_TEST_RECEIVED_MESSAGES, "network_stress_test_received_messages", "Number of stress test messages received via broadcast", init = 0 },
3738
LabeledMetricCounter { NETWORK_DROPPED_BROADCAST_MESSAGES, "network_dropped_broadcast_messages", "Number of dropped broadcast messages by reason", init = 0, labels = NETWORK_BROADCAST_DROP_LABELS },
3839
LabeledMetricCounter { NETWORK_EVENT_COUNTER, "network_event_counter", "Network events counter by type", init = 0, labels = EVENT_TYPE_LABELS },
40+
41+
MetricHistogram { PING_LATENCY_SECONDS, "ping_latency_seconds", "Ping latency in seconds" },
3942
},
4043
);
4144

@@ -84,12 +87,14 @@ pub fn create_network_metrics() -> apollo_network::metrics::NetworkMetrics {
8487

8588
let event_metrics = EventMetrics { event_counter: NETWORK_EVENT_COUNTER };
8689

90+
let latency_metrics = LatencyMetrics { ping_latency_seconds: PING_LATENCY_SECONDS };
91+
8792
NetworkMetrics {
8893
num_connected_peers: NETWORK_CONNECTED_PEERS,
8994
num_blacklisted_peers: NETWORK_BLACKLISTED_PEERS,
9095
broadcast_metrics_by_topic: Some(broadcast_metrics_by_topic),
9196
sqmr_metrics: Some(sqmr_metrics),
9297
event_metrics: Some(event_metrics),
93-
latency_metrics: None,
98+
latency_metrics: Some(latency_metrics),
9499
}
95100
}

0 commit comments

Comments
 (0)