mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-08 10:41:19 +00:00
d1fa88ce4b
* pooling attestations * add test * change limit * comment * terence's review * handle zero case * add metrics * more metrics
44 lines
1.2 KiB
Go
44 lines
1.2 KiB
Go
package attestation
|
|
|
|
import (
|
|
"strconv"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
"github.com/prometheus/client_golang/prometheus/promauto"
|
|
pb "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1"
|
|
"github.com/prysmaticlabs/prysm/shared/params"
|
|
)
|
|
|
|
var (
|
|
validatorLastVoteGauge = promauto.NewGaugeVec(prometheus.GaugeOpts{
|
|
Name: "validators_last_vote",
|
|
Help: "Votes of validators, updated when there's a new attestation",
|
|
}, []string{
|
|
"validatorIndex",
|
|
})
|
|
totalAttestationSeen = promauto.NewGauge(prometheus.GaugeOpts{
|
|
Name: "total_seen_attestations",
|
|
Help: "Total number of attestations seen by the validators",
|
|
})
|
|
|
|
attestationPoolLimit = promauto.NewGauge(prometheus.GaugeOpts{
|
|
Name: "attestation_pool_limit",
|
|
Help: "The limit of the attestation pool",
|
|
})
|
|
attestationPoolSize = promauto.NewGauge(prometheus.GaugeOpts{
|
|
Name: "attestation_pool_size",
|
|
Help: "The current size of the attestation pool",
|
|
})
|
|
)
|
|
|
|
func reportVoteMetrics(index uint64, block *pb.BeaconBlock) {
|
|
// Don't update vote metrics if the incoming block is nil.
|
|
if block == nil {
|
|
return
|
|
}
|
|
|
|
s := params.BeaconConfig().GenesisSlot
|
|
validatorLastVoteGauge.WithLabelValues(
|
|
"v" + strconv.Itoa(int(index))).Set(float64(block.Slot - s))
|
|
}
|