cerc-io/lighthouse
10
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Add metrics for validator subscriptions (#1302)

Browse Source
This commit is contained in:
Paul Hauner 2020-06-28 10:47:03 +10:00 committed by GitHub
parent 3953204727
commit 6e7d5c6a7c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
beacon_node/network/src/attestation_service/mod.rs
View File

@ -2,6 +2,7 @@
//! given time. It schedules subscriptions to shard subnets, requests peer discoveries and //! given time. It schedules subscriptions to shard subnets, requests peer discoveries and
//! determines whether attestations should be aggregated and/or passed to the beacon node. //! determines whether attestations should be aggregated and/or passed to the beacon node.
use crate::metrics;
use beacon_chain::{BeaconChain, BeaconChainTypes}; use beacon_chain::{BeaconChain, BeaconChainTypes};
use eth2_libp2p::{types::GossipKind, NetworkGlobals}; use eth2_libp2p::{types::GossipKind, NetworkGlobals};
use futures::prelude::*; use futures::prelude::*;
@ -191,6 +192,7 @@ impl<T: BeaconChainTypes> AttestationService<T> {
subscriptions: Vec<ValidatorSubscription>, subscriptions: Vec<ValidatorSubscription>,
) -> Result<(), String> { ) -> Result<(), String> {
for subscription in subscriptions { for subscription in subscriptions {
metrics::inc_counter(&metrics::SUBNET_SUBSCRIPTION_REQUESTS);
//NOTE: We assume all subscriptions have been verified before reaching this service //NOTE: We assume all subscriptions have been verified before reaching this service
// Registers the validator with the attestation service. // Registers the validator with the attestation service.
@ -237,6 +239,7 @@ impl<T: BeaconChainTypes> AttestationService<T> {
// TODO: Implement // TODO: Implement
if subscription.is_aggregator { if subscription.is_aggregator {
metrics::inc_counter(&metrics::SUBNET_SUBSCRIPTION_AGGREGATOR_REQUESTS);
// set the subscription timer to subscribe to the next subnet if required // set the subscription timer to subscribe to the next subnet if required
if let Err(e) = self.subscribe_to_subnet(exact_subnet.clone()) { if let Err(e) = self.subscribe_to_subnet(exact_subnet.clone()) {
warn!(self.log, warn!(self.log,

12
beacon_node/network/src/metrics.rs
View File

@ -36,4 +36,16 @@ lazy_static! {
"network_gossip_aggregated_attestations_tx_total", "network_gossip_aggregated_attestations_tx_total",
"Count of gossip aggregated attestations transmitted" "Count of gossip aggregated attestations transmitted"
); );
/*
* Attestation subnet subscriptions
*/
pub static ref SUBNET_SUBSCRIPTION_REQUESTS: Result<IntCounter> = try_create_int_counter(
"network_subnet_subscriptions_total",
"Count of validator subscription requests."
);
pub static ref SUBNET_SUBSCRIPTION_AGGREGATOR_REQUESTS: Result<IntCounter> = try_create_int_counter(
"network_subnet_subscriptions_aggregator_total",
"Count of validator subscription requests where the subscriber is an aggregator."
);
} }