feat: add file exporter

Signed-off-by: Bence Csati <bence.csati@axoflow.com>

Author: csatib02

pkg/resources/otel_conf_gen/otel_conf_gen.go

@@ -66,6 +66,7 @@ func (cfgInput *OtelColConfigInput) generateExporters(ctx context.Context) map[s
 	maps.Copy(exporters, exporter.GenerateOTLPGRPCExporters(ctx, cfgInput.ResourceRelations))
 	maps.Copy(exporters, exporter.GenerateOTLPHTTPExporters(ctx, cfgInput.ResourceRelations))
 	maps.Copy(exporters, exporter.GenerateFluentforwardExporters(ctx, cfgInput.ResourceRelations))
+	maps.Copy(exporters, exporter.GenerateFileExporter(ctx, cfgInput.ResourceRelations))
 	if cfgInput.Debug {
 		maps.Copy(exporters, exporter.GenerateDebugExporters())
 	}
@@ -244,6 +245,11 @@ func (cfgInput *OtelColConfigInput) generateNamedPipelines() map[string]*otelv1b
 					if output.Output.Spec.Fluentforward != nil {
 						exporters = []string{components.GetExporterNameForOutput(output.Output), outputCountConnectorName, outputBytesConnectorName}
 					}
+
+					if output.Output.Spec.File != nil {
+						exporters = []string{components.GetExporterNameForOutput(output.Output), outputCountConnectorName, outputBytesConnectorName}
+					}
+
 					if cfgInput.Debug {
 						exporters = append(exporters, "debug")
 					}

pkg/resources/otel_conf_gen/pipeline/components/common.go

@@ -49,6 +49,8 @@ func GetExporterNameForOutput(output v1alpha1.Output) string {
 		exporterName = fmt.Sprintf("otlphttp/%s_%s", output.Namespace, output.Name)
 	} else if output.Spec.Fluentforward != nil {
 		exporterName = fmt.Sprintf("fluentforwardexporter/%s_%s", output.Namespace, output.Name)
+	} else if output.Spec.File != nil {
+		exporterName = fmt.Sprintf("file/%s_%s", output.Namespace, output.Name)
 	}
 
 	return exporterName

pkg/resources/otel_conf_gen/pipeline/components/exporter/file_exporter.go

@@ -0,0 +1,50 @@
+// Copyright © 2025 Kube logging authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//    http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exporter
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+
+	"sigs.k8s.io/controller-runtime/pkg/log"
+
+	"github.com/kube-logging/telemetry-controller/pkg/resources/otel_conf_gen/pipeline/components"
+)
+
+func GenerateFileExporter(ctx context.Context, resourceRelations components.ResourceRelations) map[string]any {
+	logger := log.FromContext(ctx)
+
+	result := make(map[string]any)
+	for _, output := range resourceRelations.OutputsWithSecretData {
+		if output.Output.Spec.File != nil {
+			fileValuesMarshaled, err := json.Marshal(output.Output.Spec.File)
+			if err != nil {
+				logger.Error(errors.New("failed to compile config for output"), "failed to compile config for output %q", output.Output.NamespacedName().String())
+				continue
+			}
+			var fileValues map[string]any
+			if err := json.Unmarshal(fileValuesMarshaled, &fileValues); err != nil {
+				logger.Error(errors.New("failed to compile config for output"), "failed to compile config for output %q", output.Output.NamespacedName().String())
+				continue
+			}
+
+			result[fmt.Sprintf("file/%s_%s", output.Output.Namespace, output.Output.Name)] = fileValues
+		}
+	}
+
+	return result
+}