chore: max delay and timer

open-telemetry · Nov 8, 2024 · 713c655 · 713c655
1 parent c2d58a3
commit 713c655
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/testbed/tests/log_test.go b/testbed/tests/log_test.go
@@ -386,13 +386,16 @@ func TestMemoryLimiterHit(t *testing.T) {
 	otlpreceiver.WithTimeout(`
     timeout: 0s
 `)
-	processors := map[string]string{
-		"memory_limiter": `
+	processors := []ProcessorNameAndConfigBody{
+		{
+			Name: "memory_limiter",
+			Body: `
   memory_limiter:
     check_interval: 1s
     limit_mib: 300
     spike_limit_mib: 150
 `,
+		},
 	}
 	ScenarioMemoryLimiterHit(
 		t,
@@ -402,6 +405,7 @@ func TestMemoryLimiterHit(t *testing.T) {
 			DataItemsPerSecond: 100000,
 			ItemsPerBatch:      1000,
 			Parallel:           1,
+			MaxDelay:           20 * time.Second,
 		},
 		performanceResultsSummary, 100, processors)
 }
diff --git a/testbed/tests/scenarios.go b/testbed/tests/scenarios.go
@@ -559,7 +559,7 @@ func ScenarioMemoryLimiterHit(
 	loadOptions testbed.LoadOptions,
 	resultsSummary testbed.TestResultsSummary,
 	sleepTime int,
-	processors map[string]string,
+	processors []ProcessorNameAndConfigBody,
 ) {
 	resultDir, err := filepath.Abs(path.Join("results", t.Name()))
 	require.NoError(t, err)