Skip to content

Commit 0789a94

Browse files
apollo_network_benchmark: added network event metrics
1 parent ce5b018 commit 0789a94

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
@@ -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

@@ -33,6 +35,7 @@ define_metrics!(
3335
MetricCounter { NETWORK_STRESS_TEST_SENT_MESSAGES, "network_stress_test_sent_messages", "Number of stress test messages sent via broadcast", init = 0 },
3436
MetricCounter { NETWORK_STRESS_TEST_RECEIVED_MESSAGES, "network_stress_test_received_messages", "Number of stress test messages received via broadcast", init = 0 },
3537
LabeledMetricCounter { NETWORK_DROPPED_BROADCAST_MESSAGES, "network_dropped_broadcast_messages", "Number of dropped broadcast messages by reason", init = 0, labels = NETWORK_BROADCAST_DROP_LABELS },
38+
LabeledMetricCounter { NETWORK_EVENT_COUNTER, "network_event_counter", "Network events counter by type", init = 0, labels = EVENT_TYPE_LABELS },
3639
},
3740
);
3841

@@ -79,12 +82,14 @@ pub fn create_network_metrics() -> apollo_network::metrics::NetworkMetrics {
7982
num_active_outbound_sessions: NETWORK_ACTIVE_OUTBOUND_SESSIONS,
8083
};
8184

85+
let event_metrics = EventMetrics { event_counter: NETWORK_EVENT_COUNTER };
86+
8287
NetworkMetrics {
8388
num_connected_peers: NETWORK_CONNECTED_PEERS,
8489
num_blacklisted_peers: NETWORK_BLACKLISTED_PEERS,
8590
broadcast_metrics_by_topic: Some(broadcast_metrics_by_topic),
8691
sqmr_metrics: Some(sqmr_metrics),
87-
event_metrics: None,
92+
event_metrics: Some(event_metrics),
8893
latency_metrics: None,
8994
}
9095
}

0 commit comments

Comments
 (0)