mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-25 21:07:18 +00:00
101 lines
3.2 KiB
Go
101 lines
3.2 KiB
Go
package sync
|
|
|
|
import (
|
|
"fmt"
|
|
"reflect"
|
|
"strings"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
"github.com/prometheus/client_golang/prometheus/promauto"
|
|
pb "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/p2p"
|
|
"github.com/prysmaticlabs/prysm/cmd/beacon-chain/flags"
|
|
"github.com/prysmaticlabs/prysm/shared/params"
|
|
)
|
|
|
|
var (
|
|
topicPeerCount = promauto.NewGaugeVec(
|
|
prometheus.GaugeOpts{
|
|
Name: "p2p_topic_peer_count",
|
|
Help: "The number of peers subscribed to a given topic.",
|
|
}, []string{"topic"},
|
|
)
|
|
messageReceivedCounter = promauto.NewCounterVec(
|
|
prometheus.CounterOpts{
|
|
Name: "p2p_message_received_total",
|
|
Help: "Count of messages received.",
|
|
},
|
|
[]string{"topic"},
|
|
)
|
|
messageFailedValidationCounter = promauto.NewCounterVec(
|
|
prometheus.CounterOpts{
|
|
Name: "p2p_message_failed_validation_total",
|
|
Help: "Count of messages that failed validation.",
|
|
},
|
|
[]string{"topic"},
|
|
)
|
|
messageFailedProcessingCounter = promauto.NewCounterVec(
|
|
prometheus.CounterOpts{
|
|
Name: "p2p_message_failed_processing_total",
|
|
Help: "Count of messages that passed validation but failed processing.",
|
|
},
|
|
[]string{"topic"},
|
|
)
|
|
numberOfTimesResyncedCounter = promauto.NewCounter(
|
|
prometheus.CounterOpts{
|
|
Name: "number_of_times_resynced",
|
|
Help: "Count the number of times a node resyncs.",
|
|
},
|
|
)
|
|
|
|
arrivalBlockPropagationHistogram = promauto.NewHistogram(
|
|
prometheus.HistogramOpts{
|
|
Name: "block_arrival_latency_milliseconds",
|
|
Help: "Captures blocks propagation time. Blocks arrival in milliseconds distribution",
|
|
Buckets: []float64{250, 500, 1000, 1500, 2000, 4000, 8000, 16000},
|
|
},
|
|
)
|
|
)
|
|
|
|
func (s *Service) updateMetrics() {
|
|
// do not update metrics if genesis time
|
|
// has not been initialized
|
|
if s.cfg.Chain.GenesisTime().IsZero() {
|
|
return
|
|
}
|
|
// We update the dynamic subnet topics.
|
|
digest, err := s.forkDigest()
|
|
if err != nil {
|
|
log.WithError(err).Debugf("Could not compute fork digest")
|
|
}
|
|
indices := s.aggregatorSubnetIndices(s.cfg.Chain.CurrentSlot())
|
|
attTopic := p2p.GossipTypeMapping[reflect.TypeOf(&pb.Attestation{})]
|
|
attTopic += s.cfg.P2P.Encoding().ProtocolSuffix()
|
|
if flags.Get().SubscribeToAllSubnets {
|
|
for i := uint64(0); i < params.BeaconNetworkConfig().AttestationSubnetCount; i++ {
|
|
formattedTopic := fmt.Sprintf(attTopic, digest, i)
|
|
topicPeerCount.WithLabelValues(formattedTopic).Set(float64(len(s.cfg.P2P.PubSub().ListPeers(formattedTopic))))
|
|
}
|
|
} else {
|
|
for _, committeeIdx := range indices {
|
|
formattedTopic := fmt.Sprintf(attTopic, digest, committeeIdx)
|
|
topicPeerCount.WithLabelValues(formattedTopic).Set(float64(len(s.cfg.P2P.PubSub().ListPeers(formattedTopic))))
|
|
}
|
|
}
|
|
|
|
// We update all other gossip topics.
|
|
for topic := range p2p.GossipTopicMappings {
|
|
// We already updated attestation subnet topics.
|
|
if strings.Contains(topic, "beacon_attestation") {
|
|
continue
|
|
}
|
|
topic += s.cfg.P2P.Encoding().ProtocolSuffix()
|
|
if !strings.Contains(topic, "%x") {
|
|
topicPeerCount.WithLabelValues(topic).Set(float64(len(s.cfg.P2P.PubSub().ListPeers(topic))))
|
|
continue
|
|
}
|
|
formattedTopic := fmt.Sprintf(topic, digest)
|
|
topicPeerCount.WithLabelValues(formattedTopic).Set(float64(len(s.cfg.P2P.PubSub().ListPeers(formattedTopic))))
|
|
}
|
|
}
|