Check If Validator Is In Sync Committee (#11860)

prysmaticlabs · Jan 11, 2023 · 2b5125c · 2b5125c
1 parent 1e3a55c
commit 2b5125c
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/validator/client/metrics.go b/validator/client/metrics.go
@@ -190,6 +190,17 @@ var (
 			"pubkey",
 		},
 	)
+	// ValidatorInSyncCommitteeGaugeVec used to track validator statuses by public key.
+	ValidatorInSyncCommitteeGaugeVec = promauto.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Namespace: "validator",
+			Name:      "in_sync_committee",
+			Help:      "validator sync committee.New in Altair hardfork",
+		},
+		[]string{
+			"pubkey",
+		},
+	)
 	// ValidatorInactivityScoreGaugeVec used to track validator inactivity scores.
 	ValidatorInactivityScoreGaugeVec = promauto.NewGaugeVec(
 		prometheus.GaugeOpts{

diff --git a/validator/client/validator.go b/validator/client/validator.go
@@ -923,6 +923,9 @@ func (v *validator) logDuties(slot types.Slot, duties []*ethpb.DutiesResponse_Du
 				ValidatorNextAttestationSlotGaugeVec.WithLabelValues(validatorNotTruncatedKey).Set(float64(duty.AttesterSlot))
 			}
 		}
+		if v.emitAccountMetrics && duty.IsSyncCommittee {
+			ValidatorInSyncCommitteeGaugeVec.WithLabelValues(validatorNotTruncatedKey).Set(float64(1))
+		}
 
 		for _, proposerSlot := range duty.ProposerSlots {
 			proposerIndex := proposerSlot - slotOffset