chore: fine-tune FluentdPredictedBufferGrowth

csatib02 · csatib02 · commit 33af9840ad39 · 2025-06-02T10:27:28.000+02:00
Signed-off-by: Bence Csati &lt;bence.csati@axoflow.com&gt;
diff --git a/pkg/resources/fluentd/prometheusrules.go b/pkg/resources/fluentd/prometheusrules.go
@@ -121,7 +121,7 @@ func (r *Reconciler) prometheusRules() (runtime.Object, reconciler.DesiredState,
 			},
 			{
 				Alert: "FluentdPredictedBufferGrowth",
-				Expr:  intstr.FromString(fmt.Sprintf("sum(predict_linear(fluentd_output_status_buffer_total_bytes{%[1]s}[10m], 600)) > sum(fluentd_output_status_buffer_total_bytes{%[1]s}) * 1.5", nsJobLabel)),
+				Expr:  intstr.FromString(fmt.Sprintf("sum(predict_linear(fluentd_output_status_buffer_total_bytes{%[1]s}[10m], 600)) > sum(fluentd_output_status_buffer_total_bytes{%[1]s}) * 1.5 and sum(fluentd_output_status_buffer_total_bytes{%[1]s}) > 10 * 1024 * 1024", nsJobLabel)),
 				For:   prometheus_operator.Duration("10m"),
 				Labels: map[string]string{
 					"rulegroup": ruleGroupName,

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ func (r *Reconciler) prometheusRules() (runtime.Object, reconciler.DesiredState,`
`121`	`121`	`},`
`122`	`122`	`{`
`123`	`123`	`Alert: "FluentdPredictedBufferGrowth",`
`124`		`- Expr: intstr.FromString(fmt.Sprintf("sum(predict_linear(fluentd_output_status_buffer_total_bytes{%[1]s}[10m], 600)) > sum(fluentd_output_status_buffer_total_bytes{%[1]s}) * 1.5", nsJobLabel)),`
	`124`	`+ Expr: intstr.FromString(fmt.Sprintf("sum(predict_linear(fluentd_output_status_buffer_total_bytes{%[1]s}[10m], 600)) > sum(fluentd_output_status_buffer_total_bytes{%[1]s}) * 1.5 and sum(fluentd_output_status_buffer_total_bytes{%[1]s}) > 10 * 1024 * 1024", nsJobLabel)),`
`125`	`125`	`For: prometheus_operator.Duration("10m"),`
`126`	`126`	`Labels: map[string]string{`
`127`	`127`	`"rulegroup": ruleGroupName,`