feat(confgen): add bytes connector to test fixture

Signed-off-by: Szilard Parrag <[email protected]>
kube-logging · Jan 10, 2025 · 987a4d1 · 987a4d1
1 parent 2fc066b
commit 987a4d1
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 0 deletions.
diff --git a/internal/controller/telemetry/otel_conf_gen/otel_col_conf_test_fixtures/complex.yaml b/internal/controller/telemetry/otel_conf_gen/otel_col_conf_test_fixtures/complex.yaml
@@ -1,4 +1,11 @@
 connectors:
+  bytes/exporter:
+    logs:
+      otelcol_exporter_sent_log_records_bytes:
+        description:
+          Bytes of log records successfully sent to destination
+        attributes:
+          - key: exporter
   count/output_metrics:
     logs:
       telemetry_controller_output_log_count:
@@ -356,6 +363,7 @@ service:
       exporters:
       - otlphttp/collector_loki-test-output
       - count/output_metrics
+      - bytes/exporter
       processors:
       - memory_limiter
       - attributes/exporter_name_loki-test-output
@@ -365,6 +373,7 @@ service:
       exporters:
       - otlp/collector_otlp-test-output
       - count/output_metrics
+      - bytes/exporter
       processors:
       - memory_limiter
       - attributes/exporter_name_otlp-test-output
@@ -375,6 +384,7 @@ service:
       exporters:
       - otlp/collector_otlp-test-output-2
       - count/output_metrics
+      - bytes/exporter
       processors:
       - memory_limiter
       - attributes/exporter_name_otlp-test-output-2
@@ -384,6 +394,7 @@ service:
       exporters:
       - fluentforwardexporter/collector_fluentforward-test-output
       - count/output_metrics
+      - bytes/exporter
       processors:
       - memory_limiter
       - attributes/exporter_name_fluentforward-test-output
@@ -393,6 +404,7 @@ service:
       exporters:
       - otlp/collector_otlp-test-output-2
       - count/output_metrics
+      - bytes/exporter
       processors:
       - memory_limiter
       - attributes/exporter_name_otlp-test-output-2
@@ -453,6 +465,15 @@ service:
       - attributes/metricattributes
       receivers:
       - count/output_metrics
+    metrics/output_bytes:
+      exporters:
+      - prometheus/message_metrics_exporter
+      processors:
+      - memory_limiter
+      - deltatocumulative
+      - attributes/metricattributes
+      receivers:
+      - bytes/exporter
     metrics/tenant:
       exporters:
       - prometheus/message_metrics_exporter

diff --git a/internal/controller/telemetry/otel_conf_gen/otel_conf_gen_test.go b/internal/controller/telemetry/otel_conf_gen/otel_conf_gen_test.go
@@ -479,6 +479,11 @@ func TestOtelColConfigInput_generateNamedPipelines(t *testing.T) {
 					[]string{"deltatocumulative", "attributes/metricattributes"},
 					[]string{"prometheus/message_metrics_exporter"},
 				),
+				"metrics/output_bytes": pipeline.GeneratePipeline(
+					[]string{"bytes/exporter"},
+					[]string{"deltatocumulative", "attributes/metricattributes"},
+					[]string{"prometheus/message_metrics_exporter"},
+				),
 				"metrics/tenant": pipeline.GeneratePipeline(
 					[]string{"count/tenant_metrics"},
 					[]string{"deltatocumulative", "attributes/metricattributes"},
@@ -690,6 +695,11 @@ func TestOtelColConfigInput_generateNamedPipelines(t *testing.T) {
 					Processors: []string{"deltatocumulative", "attributes/metricattributes"},
 					Exporters:  []string{"prometheus/message_metrics_exporter"},
 				},
+				"metrics/output_bytes": {
+					Receivers:  []string{"bytes/exporter"},
+					Processors: []string{"deltatocumulative", "attributes/metricattributes"},
+					Exporters:  []string{"prometheus/message_metrics_exporter"},
+				},
 				"metrics/tenant": {
 					Receivers:  []string{"count/tenant_metrics"},
 					Processors: []string{"deltatocumulative", "attributes/metricattributes"},