Add Processors for patroni and bouncer metrics

tony-landreth · tony-landreth · commit 90ae16392a31 · 2025-02-21T11:50:28.000-05:00
diff --git a/internal/collector/patroni.go b/internal/collector/patroni.go
@@ -162,6 +162,10 @@ func EnablePatroniMetrics(ctx context.Context,
 		// Add Metrics Pipeline
 		outConfig.Pipelines[PatroniMetrics] = Pipeline{
 			Receivers: []ComponentID{Prometheus},
+			Processors: []ComponentID{
+				SubSecondBatchProcessor,
+				CompactingProcessor,
+			},
 			Exporters: []ComponentID{Prometheus},
 		}
 	}
diff --git a/internal/collector/pgbouncer.go b/internal/collector/pgbouncer.go
@@ -186,6 +186,10 @@ func EnablePgBouncerMetrics(ctx context.Context, config *Config, sqlQueryUsernam
 		// Add Metrics Pipeline
 		config.Pipelines[PGBouncerMetrics] = Pipeline{
 			Receivers: []ComponentID{SqlQuery},
+			Processors: []ComponentID{
+				SubSecondBatchProcessor,
+				CompactingProcessor,
+			},
 			Exporters: []ComponentID{Prometheus},
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -162,6 +162,10 @@ func EnablePatroniMetrics(ctx context.Context,`
`162`	`162`	`// Add Metrics Pipeline`
`163`	`163`	`outConfig.Pipelines[PatroniMetrics] = Pipeline{`
`164`	`164`	`Receivers: []ComponentID{Prometheus},`
	`165`	`+ Processors: []ComponentID{`
	`166`	`+ SubSecondBatchProcessor,`
	`167`	`+ CompactingProcessor,`
	`168`	`+ },`
`165`	`169`	`Exporters: []ComponentID{Prometheus},`
`166`	`170`	`}`
`167`	`171`	`}`
Original file line number	Diff line number	Diff line change
`@@ -186,6 +186,10 @@ func EnablePgBouncerMetrics(ctx context.Context, config *Config, sqlQueryUsernam`
`186`	`186`	`// Add Metrics Pipeline`
`187`	`187`	`config.Pipelines[PGBouncerMetrics] = Pipeline{`
`188`	`188`	`Receivers: []ComponentID{SqlQuery},`
	`189`	`+ Processors: []ComponentID{`
	`190`	`+ SubSecondBatchProcessor,`
	`191`	`+ CompactingProcessor,`
	`192`	`+ },`
`189`	`193`	`Exporters: []ComponentID{Prometheus},`
`190`	`194`	`}`
`191`	`195`	`}`