Skip to content

Commit eda41e0

Browse files
authored
test: Adds shared stream instance support for acceptance tests (#3490)
* test: Exposes stream instance management for test infrastructure cleanup * test: Adds shared stream instance support for acceptance tests * refactor: consolidate stream connection test files and add connection name parameter * refactor: consolidate stream connection test cases and improve data source checks * refactor: consolidate stream connection test files and improve test organization * fix: create separate stream instance for sample stream connection tests and add sample connection to default stream instance * test: Support re-using stream instance in streamprocessor tests * refactor: add ConfigStateChecks and extract pluralConfigStateChecks helper function in stream processor tests to allow plural checks when tests are run in parallel * docs: add documentation for ProjectIDExecutionWithStreamInstance test helper * docs: improve comments and rename variables in stream-related test files * refactor: update pagination comment and improve stream instance check logic
1 parent 86d712e commit eda41e0

11 files changed

+359
-439
lines changed

internal/service/streamconnection/data_source_stream_connection_test.go

Lines changed: 0 additions & 98 deletions
This file was deleted.

internal/service/streamconnection/data_source_stream_connections_test.go

Lines changed: 0 additions & 88 deletions
This file was deleted.

internal/service/streamconnection/resource_stream_connection_migration_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,10 @@ import (
99

1010
func TestMigStreamRSStreamConnection_kafkaPlaintext(t *testing.T) {
1111
mig.SkipIfVersionBelow(t, "1.16.0") // when reached GA
12-
mig.CreateAndRunTest(t, testCaseKafkaPlaintext(t))
12+
mig.CreateAndRunTest(t, testCaseKafkaPlaintext(t, "-mig"))
1313
}
1414

1515
func TestMigStreamRSStreamConnection_cluster(t *testing.T) {
1616
mig.SkipIfVersionBelow(t, "1.16.0") // when reached GA
17-
mig.CreateAndRunTest(t, testCaseCluster(t))
17+
mig.CreateAndRunTest(t, testCaseCluster(t, "-mig"))
1818
}

0 commit comments

Comments
 (0)