add err check

elastic · Dec 22, 2024 · 52ed64d · 52ed64d
1 parent 5304c50
commit 52ed64d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/metricbeat/module/pgbouncer/pools/pools.go b/metricbeat/module/pgbouncer/pools/pools.go
@@ -59,8 +59,10 @@ func (m *MetricSet) Fetch(ctx context.Context, reporter mb.ReporterV2) error {
 	for _, result := range results {
 		var data mapstr.M
 
-		data, _ = schema.Apply(result)
-
+		data, err := schema.Apply(result)
+		if err != nil {
+			return fmt.Errorf("error mapping result: %w", err)
+		}
 		reporter.Event(mb.Event{
 			MetricSetFields: data,
 		})

diff --git a/metricbeat/module/pgbouncer/stats/stats.go b/metricbeat/module/pgbouncer/stats/stats.go
@@ -59,8 +59,10 @@ func (m *MetricSet) Fetch(ctx context.Context, reporter mb.ReporterV2) error {
 	for _, result := range results {
 		var data mapstr.M
 
-		data, _ = schema.Apply(result)
-
+		data, err = schema.Apply(result)
+		if err != nil {
+			return fmt.Errorf("error mapping result: %w", err)
+		}
 		reporter.Event(mb.Event{
 			MetricSetFields: data,
 		})