Extended tests

knative-extensions · Jul 31, 2023 · df7e11c · df7e11c
1 parent 03fbc5c
commit df7e11c
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/pkg/reconciler/broker/resources/dispatcher_test.go b/pkg/reconciler/broker/resources/dispatcher_test.go
@@ -73,6 +73,7 @@ func TestMakeDispatcherDeployment(t *testing.T) {
 			BackoffDelay:  ptr.String("PT20S"),
 			BackoffPolicy: &linear,
 		},
+		DLX: true,
 	}
 
 	got := MakeDispatcherDeployment(args)
@@ -190,6 +191,9 @@ func TestMakeDispatcherDeployment(t *testing.T) {
 						}, {
 							Name:  "SUBSCRIBER_CACERTS",
 							Value: "test.cacert",
+						}, {
+							Name:  "DLX",
+							Value: "true",
 						}},
 						Ports: []corev1.ContainerPort{{
 							Name:          "http-metrics",

diff --git a/pkg/reconciler/trigger/resources/dispatcher_test.go b/pkg/reconciler/trigger/resources/dispatcher_test.go
@@ -88,6 +88,16 @@ func TestMakeDispatcherDeployment(t *testing.T) {
 				withEnv(corev1.EnvVar{Name: "POD_NAME", Value: "testtrigger-dlx-dispatcher"}),
 				withDefaultResourceRequirements(),
 			),
+		}, {
+			name: "with dlx name",
+			args: dispatcherArgs(withDLXName("dlx-name")),
+			want: deployment(
+				deploymentNamed("testtrigger-dispatcher"),
+				withEnv(corev1.EnvVar{Name: "PARALLELISM", Value: "1"}),
+				withEnv(corev1.EnvVar{Name: "DLX_NAME", Value: "dlx-name"}),
+				withEnv(corev1.EnvVar{Name: "POD_NAME", Value: "testtrigger-dispatcher"}),
+				withDefaultResourceRequirements(),
+			),
 		},
 		{
 			name: "with parallelism",
@@ -311,6 +321,12 @@ func withDLX(args *DispatcherArgs) {
 	args.DLX = true
 }
 
+func withDLXName(name string) func(*DispatcherArgs) {
+	return func(args *DispatcherArgs) {
+		args.DLXName = name
+	}
+}
+
 func withParallelism(c string) func(*DispatcherArgs) {
 	return func(args *DispatcherArgs) {
 		if args.Trigger.ObjectMeta.Annotations == nil {