tetragon: Add map_errors_update_total/map_errors_delete_total metrics

Based on previous commit changes changing the current stats metrics to reflect that. Now we have separate metric for update and delete errors, like for execve_map stats: tetragon_map_capacity{map="execve_map"} 10 tetragon_map_entries{map="execve_map"} 10 tetragon_map_errors_delete_total{map="execve_map"} 0 tetragon_map_errors_update_total{map="execve_map"} 3 Signed-off-by: Jiri Olsa <[email protected]>
cilium · Jan 21, 2025 · b8fe12e · b8fe12e
1 parent e05adea
commit b8fe12e
Show file tree

Hide file tree

Showing 3 changed files with 34 additions and 31 deletions.
diff --git a/docs/content/en/docs/reference/metrics.md b/docs/content/en/docs/reference/metrics.md
diff --git a/pkg/metrics/mapmetrics/mapmetrics.go b/pkg/metrics/mapmetrics/mapmetrics.go
@@ -26,9 +26,14 @@ var (
 		"Capacity of a BPF map. Expected to be constant.",
 		nil, []metrics.ConstrainedLabel{MapLabel}, nil,
 	))
-	MapErrors = metrics.MustNewCustomGauge(metrics.NewOpts(
-		consts.MetricsNamespace, "", "map_errors_total",
-		"The number of errors per map.",
+	MapErrorsUpdate = metrics.MustNewCustomGauge(metrics.NewOpts(
+		consts.MetricsNamespace, "", "map_errors_update_total",
+		"The number of failed updates per map.",
+		nil, []metrics.ConstrainedLabel{MapLabel}, nil,
+	))
+	MapErrorsDelete = metrics.MustNewCustomGauge(metrics.NewOpts(
+		consts.MetricsNamespace, "", "map_errors_delete_total",
+		"The number of failed deletes per map.",
 		nil, []metrics.ConstrainedLabel{MapLabel}, nil,
 	))
 )
diff --git a/pkg/observer/observer_stats.go b/pkg/observer/observer_stats.go
@@ -22,7 +22,8 @@ func NewBPFCollector() metrics.CollectorWithInit {
 		metrics.CustomMetrics{
 			mapmetrics.MapSize,
 			mapmetrics.MapCapacity,
-			mapmetrics.MapErrors,
+			mapmetrics.MapErrorsUpdate,
+			mapmetrics.MapErrorsDelete,
 		},
 		collect,
 		collectForDocs,
@@ -72,51 +73,40 @@ func collect(ch chan<- prometheus.Metric) {
 		}
 		defer mapLink.Close()
 
-		updateMapSize(ch, mapLinkStats, name)
 		ch <- mapmetrics.MapCapacity.MustMetric(
 			float64(mapLink.MaxEntries()),
 			name,
 		)
-		updateMapErrors(ch, mapLinkStats, name)
+		update(mapLinkStats, 0, func(sum float64) {
+			ch <- mapmetrics.MapSize.MustMetric(sum, name)
+		})
+		update(mapLinkStats, 1, func(sum float64) {
+			ch <- mapmetrics.MapErrorsUpdate.MustMetric(sum, name)
+		})
+		update(mapLinkStats, 2, func(sum float64) {
+			ch <- mapmetrics.MapErrorsDelete.MustMetric(sum, name)
+		})
 	}
 }
 
-func updateMapSize(ch chan<- prometheus.Metric, mapLinkStats *ebpf.Map, name string) {
+func update(mapLinkStats *ebpf.Map, key int32, update func(sum float64)) {
 	var values []int64
-	if err := mapLinkStats.Lookup(int32(0), &values); err != nil {
+	if err := mapLinkStats.Lookup(key, &values); err != nil {
 		return
 	}
 
 	sum := int64(0)
 	for _, n := range values {
 		sum += n
 	}
-	ch <- mapmetrics.MapSize.MustMetric(
-		float64(sum),
-		name,
-	)
-}
-
-func updateMapErrors(ch chan<- prometheus.Metric, mapLinkStats *ebpf.Map, name string) {
-	var values []int64
-	if err := mapLinkStats.Lookup(int32(1), &values); err != nil {
-		return
-	}
-
-	sum := int64(0)
-	for _, n := range values {
-		sum += n
-	}
-	ch <- mapmetrics.MapErrors.MustMetric(
-		float64(sum),
-		name,
-	)
+	update(float64(sum))
 }
 
 func collectForDocs(ch chan<- prometheus.Metric) {
 	for _, m := range mapmetrics.MapLabel.Values {
 		ch <- mapmetrics.MapSize.MustMetric(0, m)
 		ch <- mapmetrics.MapCapacity.MustMetric(0, m)
-		ch <- mapmetrics.MapErrors.MustMetric(0, m)
+		ch <- mapmetrics.MapErrorsUpdate.MustMetric(0, m)
+		ch <- mapmetrics.MapErrorsDelete.MustMetric(0, m)
 	}
 }