services/horizon: Change horizon_ingest_state_verify_ledger_entries m…

…etric to gauge (#4054)
stellar · Nov 9, 2021 · a216798 · a216798
1 parent 30b2402
commit a216798
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 7 deletions.
diff --git a/services/horizon/internal/ingest/main.go b/services/horizon/internal/ingest/main.go
@@ -128,7 +128,7 @@ type Metrics struct {
 
 	// StateVerifyLedgerEntriesCount exposes total number of ledger entries
 	// checked by the state verifier by type.
-	StateVerifyLedgerEntriesCount *prometheus.SummaryVec
+	StateVerifyLedgerEntriesCount *prometheus.GaugeVec
 
 	// LedgerStatsCounter exposes ledger stats counters (like number of ops/changes).
 	LedgerStatsCounter *prometheus.CounterVec
@@ -323,12 +323,10 @@ func (s *system) initMetrics() {
 		},
 	)
 
-	s.metrics.StateVerifyLedgerEntriesCount = prometheus.NewSummaryVec(
-		prometheus.SummaryOpts{
-			Namespace: "horizon", Subsystem: "ingest", Name: "state_verify_ledger_entries_count",
+	s.metrics.StateVerifyLedgerEntriesCount = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Namespace: "horizon", Subsystem: "ingest", Name: "state_verify_ledger_entries",
 			Help: "number of ledger entries downloaded from buckets in a single state verifier run",
-			// Quantile ranks are not relevant here so pass empty map.
-			Objectives: map[float64]float64{},
 		},
 		[]string{"type"},
 	)

diff --git a/services/horizon/internal/ingest/verify.go b/services/horizon/internal/ingest/verify.go
@@ -136,7 +136,7 @@ func (s *system) verifyState(verifyAgainstLatestCheckpoint bool) error {
 				s.Metrics().StateVerifyDuration.Observe(float64(duration))
 				for typ, tot := range totalByType {
 					s.Metrics().StateVerifyLedgerEntriesCount.
-						With(prometheus.Labels{"type": typ}).Observe(float64(tot))
+						With(prometheus.Labels{"type": typ}).Set(float64(tot))
 				}
 			}
 		}