test(integration): add tailing sidecar test

Signed-off-by: Dominik Rosiek <drosiek@sumologic.com>

Author: Dominik Rosiek

tests/integration/features.go

@@ -31,18 +31,19 @@ import (
 type MetricsCollector string
 
 const (
-	tickDuration                        = 3 * time.Second
-	waitDuration                        = 1 * time.Minute
-	expectedEventCount uint             = 50 // number determined experimentally
-	logsGeneratorCount uint             = 1000
-	logRecords                          = 4   // number of log records in single loop, see: tests/integration/yamls/pod_multiline_long_lines.yaml
-	logLoops                            = 500 // number of loops in which logs are generated, see: tests/integration/yamls/pod_multiline_long_lines.yaml
-	multilineLogCount  uint             = logRecords * logLoops
-	tracesPerExporter  uint             = 5 // number of traces generated per exporter
-	spansPerTrace      uint             = 2
-	Prometheus         MetricsCollector = "prometheus"
-	Otelcol            MetricsCollector = "otelcol"
-	Fluentd            MetricsCollector = "fluentd"
+	tickDuration                         = 3 * time.Second
+	waitDuration                         = 1 * time.Minute
+	expectedEventCount  uint             = 50 // number determined experimentally
+	logsGeneratorCount  uint             = 1000
+	logRecords                           = 4   // number of log records in single loop, see: tests/integration/yamls/pod_multiline_long_lines.yaml
+	logLoops                             = 500 // number of loops in which logs are generated, see: tests/integration/yamls/pod_multiline_long_lines.yaml
+	multilineLogCount   uint             = logRecords * logLoops
+	tracesPerExporter   uint             = 5 // number of traces generated per exporter
+	spansPerTrace       uint             = 2
+	Prometheus          MetricsCollector = "prometheus"
+	Otelcol             MetricsCollector = "otelcol"
+	Fluentd             MetricsCollector = "fluentd"
+	TailingSidecarCount uint             = 150 // number of logs generated by tailing sidecar test (50 * 3), see: tests/inegration/yamls/tailing-sidecar-test.yaml
 )
 
 func GetMetricsFeature(expectedMetrics []string, metricsCollector MetricsCollector) features.Feature {
@@ -482,6 +483,25 @@ func GetTracesFeature() features.Feature {
 		Feature()
 }
 
+func GetTailingSidecarFeature() features.Feature {
+	return features.New("tailing sidecar test").
+		Setup(stepfuncs.KubectlApplyFOpt(internal.TailingSidecarTest, internal.TailingSidecarTestNamespace)).
+		Assess("tailing sidecar test logs present", stepfuncs.WaitUntilExpectedLogsPresent(
+			TailingSidecarCount,
+			map[string]string{
+				"namespace":  internal.TailingSidecarTestNamespace,
+				"deployment": internal.TailingSidecarTestDeploymentName,
+			},
+			internal.ReceiverMockNamespace,
+			internal.ReceiverMockServiceName,
+			internal.ReceiverMockServicePort,
+			waitDuration,
+			tickDuration,
+		)).
+		Teardown(stepfuncs.KubectlDeleteFOpt(internal.TailingSidecarTest, internal.TailingSidecarTestNamespace)).
+		Feature()
+}
+
 type featureCheck func(*features.FeatureBuilder) *features.FeatureBuilder
 
 func GetInstallFeature(installChecks []featureCheck) features.Feature {
@@ -877,3 +897,16 @@ func CheckFluentdEventsInstall(builder *features.FeatureBuilder) *features.Featu
 				return ctx
 			})
 }
+
+func CheckTailingSidecarOperatorInstall(builder *features.FeatureBuilder) *features.FeatureBuilder {
+	return builder.
+		Assess("tailing sidecar deployment is ready",
+			stepfuncs.WaitUntilDeploymentIsReady(
+				waitDuration,
+				tickDuration,
+				stepfuncs.WithNameF(
+					stepfuncs.ReleaseFormatter("%s-tailing-sidecar-operator"),
+				),
+			),
+		)
+}

tests/integration/helm_tailing_sidecar_test.go

@@ -0,0 +1,21 @@
+//go:build onlylatest
+// +build onlylatest
+
+package integration
+
+import (
+	"testing"
+)
+
+func Test_Helm_Tailing_Sidecar(t *testing.T) {
+	installChecks := []featureCheck{
+		CheckOtelcolMetadataLogsInstall,
+		CheckTailingSidecarOperatorInstall,
+	}
+
+	featInstall := GetInstallFeature(installChecks)
+
+	featTailingSidecarTest := GetTailingSidecarFeature()
+
+	testenv.Test(t, featInstall, featTailingSidecarTest)
+}

tests/integration/internal/constants.go

@@ -37,6 +37,10 @@ const (
 	MultilineLogsPodName   = "multiline-logs-generator"
 	MultilineLogsGenerator = "yamls/multiline-logs-generator.yaml"
 
+	TailingSidecarTestNamespace      = "tailing-sidecar"
+	TailingSidecarTest               = "yamls/tailing-sidecar-test.yaml"
+	TailingSidecarTestDeploymentName = "test-tailing-sidecar-operator"
+
 	// useful regular expressions for matching metadata
 	PodDeploymentSuffixRegex = "-[a-z0-9]{9,10}-[a-z0-9]{4,5}" // the Pod suffix for Deployments
 	PodDaemonSetSuffixRegex  = "-[a-z0-9]{4,5}"

tests/integration/values/values_helm_tailing_sidecar.yaml

@@ -0,0 +1,10 @@
+sumologic:
+  events:
+    enabled: false
+  metrics:
+    enabled: false
+  traces:
+    enabled: false
+
+tailing-sidecar-operator:
+  enabled: true

tests/integration/yamls/tailing-sidecar-test.yaml

@@ -0,0 +1,76 @@
+---
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: tailing-sidecar
+---
+apiVersion: tailing-sidecar.sumologic.com/v1
+kind: TailingSidecarConfig
+metadata:
+  name: test-tailing-sidecar-operator
+  namespace: tailing-sidecar
+spec:
+  podSelector:
+    matchLabels:
+      test-tailing-sidecar: "true"
+  configs:
+    test-sidecar:
+      volumeMount:
+        name: varlogconfig
+        mountPath: /varconfig/log
+      path: /varconfig/log/example2.log
+      annotations:
+        sourceCategory: test-sidecar
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: test-tailing-sidecar-operator
+  namespace: tailing-sidecar
+  labels:
+    app: test-tailing-sidecar-operator
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      tailing-sidecar: "true"
+      test-tailing-sidecar: "true"
+      app: test-tailing-sidecar-operator
+  template:
+    metadata:
+      name: test-tailing-sidecar-operator
+      namespace: tailing-sidecar
+      annotations:
+        tailing-sidecar: varlog:/var/log/example0.log;named-container:varlog:/var/log/example1.log
+      labels:
+        tailing-sidecar: "true"
+        test-tailing-sidecar: "true"
+        app: test-tailing-sidecar-operator
+    spec:
+      containers:
+        - name: count
+          image: bash
+          args:
+            - /usr/local/bin/bash
+            - -c
+            - >
+              i=0; for i in {1..50}; do
+                echo "example0: $i $(date)" >> /var/log/example0.log;
+                echo "example1: $i $(date)" >> /var/log/example1.log;
+                echo "example2: $i $(date)" >> /varconfig/log/example2.log;
+                sleep 1;
+              done; while true; do
+                sleep 1;
+              done;
+          volumeMounts:
+            - name: varlog
+              mountPath: /var/log
+            - name: varlogconfig
+              mountPath: /varconfig/log
+      volumes:
+        - name: varlog
+          emptyDir: {}
+        - name: varlogconfig
+          emptyDir: {}
+      securityContext:
+        runAsUser: 1000