fix: use a separate path to mount custom config for the operator

Signed-off-by: Peter Wilcsinszky <[email protected]>

Author: pepov

pkg/resources/fluentbit/config.go

@@ -17,14 +17,17 @@ package fluentbit
 const BaseConfigName = "fluent-bit.conf"
 const UpstreamConfigName = "upstream.conf"
 const CustomParsersConfigName = "custom-parsers.conf"
+const StockConfigPath = "/fluent-bit/etc"
+const StockBinPath = "/fluent-bit/bin/fluent-bit"
+const OperatorConfigPath = "/fluent-bit/etc-operator"
 
 var fluentBitConfigTemplate = `
 [SERVICE]
     Flush        {{ .Flush }}
     Grace        {{ .Grace }}
     Daemon       Off
     Log_Level    {{ .LogLevel }}
-    Parsers_File parsers.conf
+    Parsers_File {{ .DefaultParsers }}
     {{- if .CustomParsers }}
     Parsers_File {{ .CustomParsers }}
     {{- end }}

pkg/resources/fluentbit/configsecret.go

@@ -69,6 +69,7 @@ type fluentBitConfig struct {
 	FilterModify            []v1beta1.FilterModify
 	FluentForwardOutput     *fluentForwardOutputConfig
 	SyslogNGOutput          *syslogNGOutputConfig
+	DefaultParsers          string
 	CustomParsers           string
 }
 
@@ -191,8 +192,10 @@ func (r *Reconciler) configSecret() (runtime.Object, reconciler.DesiredState, er
 		FilterModify:            r.fluentbitSpec.FilterModify,
 	}
 
+	input.DefaultParsers = fmt.Sprintf("%s/%s", StockConfigPath, "parsers.conf")
+
 	if r.fluentbitSpec.CustomParsers != "" {
-		input.CustomParsers = fmt.Sprintf("/fluent-bit/etc/%s", CustomParsersConfigName)
+		input.CustomParsers = fmt.Sprintf("%s/%s", OperatorConfigPath, CustomParsersConfigName)
 	}
 
 	if r.fluentbitSpec.Metrics != nil {

pkg/resources/fluentbit/daemonset.go

@@ -124,6 +124,9 @@ func (r *Reconciler) fluentbitContainer() *corev1.Container {
 			Privileged:               r.fluentbitSpec.Security.SecurityContext.Privileged,
 			SELinuxOptions:           r.fluentbitSpec.Security.SecurityContext.SELinuxOptions,
 		},
+		Command: []string{
+			StockBinPath, "-c", fmt.Sprintf("%s/%s", OperatorConfigPath, BaseConfigName),
+		},
 		Env:            r.fluentbitSpec.EnvVars,
 		LivenessProbe:  r.fluentbitSpec.LivenessProbe,
 		ReadinessProbe: r.fluentbitSpec.ReadinessProbe,
@@ -155,7 +158,7 @@ func (r *Reconciler) generateVolumeMounts() (v []corev1.VolumeMount) {
 		},
 		{
 			Name:      "config",
-			MountPath: "/fluent-bit/etc/",
+			MountPath: OperatorConfigPath,
 		},
 	}