mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-29 06:37:17 +00:00
91 lines
2.8 KiB
Go
91 lines
2.8 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/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{1000, 2000, 3000, 4000, 5000, 6000},
|
|
},
|
|
)
|
|
)
|
|
|
|
func (s *Service) updateMetrics() {
|
|
// do not update metrics if genesis time
|
|
// has not been initialized
|
|
if s.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")
|
|
}
|
|
attTopic := p2p.GossipTypeMapping[reflect.TypeOf(&pb.Attestation{})]
|
|
attTopic += s.p2p.Encoding().ProtocolSuffix()
|
|
for i := uint64(0); i < params.BeaconNetworkConfig().AttestationSubnetCount; i++ {
|
|
formattedTopic := fmt.Sprintf(attTopic, digest, i)
|
|
topicPeerCount.WithLabelValues(formattedTopic).Set(float64(len(s.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.p2p.Encoding().ProtocolSuffix()
|
|
if !strings.Contains(topic, "%x") {
|
|
topicPeerCount.WithLabelValues(topic).Set(float64(len(s.p2p.PubSub().ListPeers(topic))))
|
|
continue
|
|
}
|
|
formattedTopic := fmt.Sprintf(topic, digest)
|
|
topicPeerCount.WithLabelValues(formattedTopic).Set(float64(len(s.p2p.PubSub().ListPeers(formattedTopic))))
|
|
}
|
|
}
|