Including eventing-kafka upgrade tests for source and channel

go.mod

@@ -41,7 +41,7 @@ replace (
 	k8s.io/client-go => k8s.io/client-go v0.19.7
 	k8s.io/code-generator => k8s.io/code-generator v0.19.7
 	k8s.io/kube-openapi => k8s.io/kube-openapi v0.0.0-20200805222855-6aeccd4b50c6
-	knative.dev/eventing => github.com/openshift/knative-eventing v0.99.1-0.20210607061742-4ca24dc7b424
-	knative.dev/eventing-kafka => github.com/openshift-knative/eventing-kafka v0.19.1-0.20210608134610-b6f1e2aed71e
+	knative.dev/eventing => github.com/openshift/knative-eventing v0.99.1-0.20210610143215-480365c6cb7c
+	knative.dev/eventing-kafka => github.com/openshift-knative/eventing-kafka v0.19.1-0.20210610191316-8ce9b2e6d6c5
 	knative.dev/serving => github.com/openshift/knative-serving v0.10.1-0.20210526160136-40b6f2a655b1
 )

test/lib.bash

@@ -198,12 +198,10 @@ function run_rolling_upgrade_tests {
   channels=messaging.knative.dev/v1beta1:KafkaChannel,messaging.knative.dev/v1:InMemoryChannel
 
   # Test configuration. See https://github.com/knative/eventing/tree/main/test/upgrade#probe-test-configuration
-  # TODO(ksuszyns): remove E2E_UPGRADE_TESTS_SERVING_SCALETOZERO when knative/operator#297 is fixed.
-  E2E_UPGRADE_TESTS_SERVING_SCALETOZERO=false \
-  E2E_UPGRADE_TESTS_SERVING_USE=true \
-  E2E_UPGRADE_TESTS_CONFIGMOUNTPOINT=/.config/wathola \
-  E2E_UPGRADE_TESTS_INTERVAL="50ms" \
-  E2E_UPGRADE_TESTS_FAILONERRORS=true \
+  # TODO(ksuszyns): remove EVENTING_UPGRADE_TESTS_SERVING_SCALETOZERO when knative/operator#297 is fixed.
+  EVENTING_UPGRADE_TESTS_SERVING_SCALETOZERO=false \
+  EVENTING_UPGRADE_TESTS_SERVING_USE=true \
+  EVENTING_UPGRADE_TESTS_CONFIGMOUNTPOINT=/.config/wathola \
   GO_TEST_VERBOSITY=standard-verbose \
   SYSTEM_NAMESPACE=knative-serving \
   go_test_e2e -tags=upgrade -timeout=30m \

test/upgrade/continual/channel-config.toml

@@ -0,0 +1 @@
+../../../vendor/knative.dev/eventing-kafka/test/upgrade/continual/channel-config.toml

test/upgrade/continual/source-config.toml

@@ -0,0 +1 @@
+../../../vendor/knative.dev/eventing-kafka/test/upgrade/continual/source-config.toml

test/upgrade/upgrade_test.go

@@ -23,6 +23,7 @@ import (
 
 	"github.com/openshift-knative/serverless-operator/test"
 	"github.com/openshift-knative/serverless-operator/test/upgrade/installation"
+	"knative.dev/eventing-kafka/test/upgrade/continual"
 
 	"go.uber.org/zap"
 	kafkaupgrade "knative.dev/eventing-kafka/test/upgrade"
@@ -32,7 +33,8 @@ import (
 	servingupgrade "knative.dev/serving/test/upgrade"
 )
 
-// FIXME: https://github.com/knative/eventing/issues/5176 `config.toml` in this directory is required
+// FIXME: https://github.com/knative/eventing/issues/5176 `*-config.toml` in
+//        this directory are required, so that kafkaupgrade tests will see them.
 
 func TestServerlessUpgrade(t *testing.T) {
 	ctx := test.SetupClusterAdmin(t)
@@ -42,14 +44,16 @@ func TestServerlessUpgrade(t *testing.T) {
 		Tests: pkgupgrade.Tests{
 			PreUpgrade:  preUpgradeTests(),
 			PostUpgrade: postUpgradeTests(ctx),
-			Continual: []pkgupgrade.BackgroundOperation{
-				servingupgrade.ProbeTest(),
-				servingupgrade.AutoscaleSustainingWithTBCTest(),
-				servingupgrade.AutoscaleSustainingTest(),
-				eventingupgrade.ContinualTest(),
-				kafkaupgrade.ChannelContinualTest(kafkaupgrade.ContinualTestOptions{}),
-				kafkaupgrade.SourceContinualTest(kafkaupgrade.ContinualTestOptions{}),
-			},
+			Continual: merge(
+				[]pkgupgrade.BackgroundOperation{
+					servingupgrade.ProbeTest(),
+					servingupgrade.AutoscaleSustainingWithTBCTest(),
+					servingupgrade.AutoscaleSustainingTest(),
+					eventingupgrade.ContinualTest(),
+				},
+				kafkaupgrade.ChannelContinualTests(continual.ChannelTestOptions{}),
+				kafkaupgrade.SourceContinualTests(continual.SourceTestOptions{}),
+			),
 		},
 		Installations: pkgupgrade.Installations{
 			UpgradeWith: []pkgupgrade.Operation{
@@ -89,6 +93,18 @@ func TestClusterUpgrade(t *testing.T) {
 	suite.Execute(cfg)
 }
 
+func merge(slices ...[]pkgupgrade.BackgroundOperation) []pkgupgrade.BackgroundOperation {
+	l := 0
+	for _, slice := range slices {
+		l += len(slice)
+	}
+	result := make([]pkgupgrade.BackgroundOperation, 0, l)
+	for _, slice := range slices {
+		result = append(result, slice...)
+	}
+	return result
+}
+
 func preUpgradeTests() []pkgupgrade.Operation {
 	tests := []pkgupgrade.Operation{
 		eventingupgrade.PreUpgradeTest(),