test: Flaky self-monitor metric outage tests (#1334)

kyma-project · Aug 9, 2024 · c1e5d6d · c1e5d6d
1 parent ccd9872
commit c1e5d6d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/test/integration/istio/metrics_self_monitor_outage_test.go b/test/integration/istio/metrics_self_monitor_outage_test.go
@@ -41,7 +41,7 @@ var _ = Describe(suite.ID(), Label(suite.LabelSelfMonitoringMetricsOutage), Orde
 
 		objs = append(objs,
 			&metricPipeline,
-			telemetrygen.NewDeployment(mockNs, telemetrygen.SignalTypeMetrics, telemetrygen.WithRate(500_000), telemetrygen.WithWorkers(5)).WithReplicas(2).K8sObject(),
+			telemetrygen.NewDeployment(mockNs, telemetrygen.SignalTypeMetrics, telemetrygen.WithRate(10_000_000), telemetrygen.WithWorkers(50), telemetrygen.WithInterval("30s")).WithReplicas(2).K8sObject(),
 		)
 
 		return objs

diff --git a/test/testkit/mocks/telemetrygen/telemetrygen.go b/test/testkit/mocks/telemetrygen/telemetrygen.go
@@ -91,6 +91,13 @@ func WithSpanSize(spanSize int) Option {
 	}
 }
 
+// WithInterval Reporting interval
+func WithInterval(duration string) Option {
+	return func(spec *corev1.PodSpec) {
+		spec.Containers[0].Args = append(spec.Containers[0].Args, "--interval")
+		spec.Containers[0].Args = append(spec.Containers[0].Args, fmt.Sprintf("%v", duration))
+	}
+}
 func NewPod(namespace string, signalType SignalType, opts ...Option) *kitk8s.Pod {
 	return kitk8s.NewPod(DefaultName, namespace).WithPodSpec(PodSpec(signalType, opts...)).WithLabel("app.kubernetes.io/name", DefaultName)
 }