archive error stat

Author: cheggaaa

archive/archive.go

@@ -267,6 +267,7 @@ func (a *archive) check(ctx context.Context) error {
 				skip++
 				continue
 			}
+			a.stat.archiveError.Add(1)
 			return indexStore.MarkError(ctx, spaceId, err.Error())
 		}
 		log.Info("space is archived", zap.String("spaceId", spaceId), zap.Duration("dur", time.Since(st)))

archive/stat.go

@@ -7,8 +7,9 @@ import (
 )
 
 type archiveStat struct {
-	archived atomic.Uint32
-	restored atomic.Uint32
+	archived     atomic.Uint32
+	archiveError atomic.Uint32
+	restored     atomic.Uint32
 }
 
 func registerMetric(s *archiveStat, registry *prometheus.Registry) {
@@ -26,4 +27,11 @@ func registerMetric(s *archiveStat, registry *prometheus.Registry) {
 	}, func() float64 {
 		return float64(s.restored.Load())
 	}))
+	registry.MustRegister(prometheus.NewGaugeFunc(prometheus.GaugeOpts{
+		Namespace: "node",
+		Subsystem: "archive",
+		Name:      "error",
+	}, func() float64 {
+		return float64(s.archiveError.Load())
+	}))
 }