Validating labels of k8s resources in functional tests

radius-project · Sep 21, 2023 · ba1a043 · ba1a043
1 parent 1e8b6d9
commit ba1a043
Show file tree

Hide file tree

Showing 26 changed files with 264 additions and 195 deletions.
diff --git a/test/functional/daprrp/resources/dapr_pubsub_test.go b/test/functional/daprrp/resources/dapr_pubsub_test.go
@@ -56,14 +56,11 @@ func Test_DaprPubSubBroker_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "dpsb-manual-app-ctnr"),
-						validation.NewK8sPodForResource(name, "dpsb-manual-redis").
-							ValidateLabels(false),
-						validation.NewK8sServiceForResource(name, "dpsb-manual-redis").
-							ValidateLabels(false),
-
-						validation.NewDaprComponent(name, "dpsb-manual").
-							ValidateLabels(false),
+						validation.NewK8sPodForResource("dpsb-manual-app-ctnr").
+							AddRadiusLabels(name, "dpsb-manual-app-ctnr"),
+						validation.NewK8sPodForResource("dpsb-manual-redis"),
+						validation.NewK8sServiceForResource("dpsb-manual-redis"),
+						validation.NewDaprComponent("dpsb-manual"),
 					},
 				},
 			},
@@ -113,11 +110,8 @@ func Test_DaprPubSubBroker_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "dpsb-recipe-ctnr").
-							ValidateLabels(false),
-
-						validation.NewDaprComponent(name, "dpsb-recipe").
-							ValidateLabels(false),
+						validation.NewK8sPodForResource("dpsb-recipe-ctnr"),
+						validation.NewDaprComponent("dpsb-recipe"),
 					},
 				},
 			},

diff --git a/test/functional/daprrp/resources/dapr_secretstore_test.go b/test/functional/daprrp/resources/dapr_secretstore_test.go
@@ -55,11 +55,10 @@ func Test_DaprSecretStore_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "gnrc-scs-ctnr"),
+						validation.NewK8sPodForResource("gnrc-scs-ctnr").
+							AddRadiusLabels(name, "gnrc-scs-ctnr"),
 
-						// Not sure why we skip validating the labels
-						validation.NewDaprComponent(name, "gnrc-scs-manual").
-							ValidateLabels(false),
+						validation.NewDaprComponent("gnrc-scs-manual"),
 					},
 				},
 			},
@@ -104,11 +103,8 @@ func Test_DaprSecretStore_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "gnrc-scs-ctnr-recipe").
-							ValidateLabels(false),
-
-						validation.NewDaprComponent(name, "gnrc-scs-recipe").
-							ValidateLabels(false),
+						validation.NewK8sPodForResource("gnrc-scs-ctnr-recipe"),
+						validation.NewDaprComponent("gnrc-scs-recipe"),
 					},
 				},
 			},

diff --git a/test/functional/daprrp/resources/dapr_serviceinvocation_test.go b/test/functional/daprrp/resources/dapr_serviceinvocation_test.go
@@ -54,8 +54,10 @@ func Test_DaprServiceInvocation(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "dapr-frontend"),
-						validation.NewK8sPodForResource(name, "dapr-backend"),
+						validation.NewK8sPodForResource("dapr-frontend").
+							AddRadiusLabels(name, "dapr-frontend"),
+						validation.NewK8sPodForResource("dapr-backend").
+							AddRadiusLabels(name, "dapr-backend"),
 					},
 				},
 			},

diff --git a/test/functional/daprrp/resources/dapr_statestore_test.go b/test/functional/daprrp/resources/dapr_statestore_test.go
@@ -56,16 +56,13 @@ func Test_DaprStateStore_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "dapr-sts-manual-ctnr"),
+						validation.NewK8sPodForResource("dapr-sts-manual-ctnr").
+							AddRadiusLabels(name, "dapr-sts-manual-ctnr"),
 
 						// Deployed as supporting resources using Kubernetes Bicep extensibility.
-						validation.NewK8sPodForResource(name, "dapr-sts-manual-redis").
-							ValidateLabels(false),
-						validation.NewK8sServiceForResource(name, "dapr-sts-manual-redis").
-							ValidateLabels(false),
-
-						validation.NewDaprComponent(name, "dapr-sts-manual").
-							ValidateLabels(false),
+						validation.NewK8sPodForResource("dapr-sts-manual-redis"),
+						validation.NewK8sServiceForResource("dapr-sts-manual-redis"),
+						validation.NewDaprComponent("dapr-sts-manual"),
 					},
 				},
 			},
@@ -115,11 +112,8 @@ func Test_DaprStateStore_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "dapr-sts-recipe-ctnr").
-							ValidateLabels(false),
-
-						validation.NewDaprComponent(name, "dapr-sts-recipe").
-							ValidateLabels(false),
+						validation.NewK8sPodForResource("dapr-sts-recipe-ctnr"),
+						validation.NewDaprComponent("dapr-sts-recipe"),
 					},
 				},
 			},

diff --git a/test/functional/datastoresrp/resources/microsoftsql_test.go b/test/functional/datastoresrp/resources/microsoftsql_test.go
@@ -68,7 +68,8 @@ func Test_MicrosoftSQL_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mssql-app-ctnr"),
+						validation.NewK8sPodForResource("mssql-app-ctnr").
+							AddRadiusLabels(name, "mssql-app-ctnr"),
 					},
 				},
 			},

diff --git a/test/functional/datastoresrp/resources/mongodb_test.go b/test/functional/datastoresrp/resources/mongodb_test.go
@@ -66,9 +66,9 @@ func Test_MongoDB_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mdb-us-app-ctnr").ValidateLabels(false),
-						validation.NewK8sPodForResource(name, "mdb-us-ctnr").ValidateLabels(false),
-						validation.NewK8sServiceForResource(name, "mdb-us-rte").ValidateLabels(false),
+						validation.NewK8sPodForResource("mdb-us-app-ctnr"),
+						validation.NewK8sPodForResource("mdb-us-ctnr"),
+						validation.NewK8sServiceForResource("mdb-us-rte"),
 					},
 				},
 			},
@@ -114,7 +114,7 @@ func Test_MongoDB_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mongodb-app-ctnr").ValidateLabels(false),
+						validation.NewK8sPodForResource("mongodb-app-ctnr"),
 					},
 				},
 			},
@@ -170,7 +170,7 @@ func Test_MongoDB_RecipeParameters(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mdb-param-ctnr").ValidateLabels(false),
+						validation.NewK8sPodForResource("mdb-param-ctnr"),
 					},
 				},
 			},
@@ -225,7 +225,7 @@ func Test_MongoDB_Recipe_ContextParameter(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mdb-ctx-ctnr").ValidateLabels(false),
+						validation.NewK8sPodForResource("mdb-ctx-ctnr"),
 					},
 				},
 			},

diff --git a/test/functional/datastoresrp/resources/redis_test.go b/test/functional/datastoresrp/resources/redis_test.go
@@ -64,9 +64,12 @@ func Test_Redis_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "rds-app-ctnr"),
-						validation.NewK8sPodForResource(name, "rds-ctnr"),
-						validation.NewK8sServiceForResource(name, "rds-rte"),
+						validation.NewK8sPodForResource("rds-app-ctnr").
+							AddRadiusLabels(name, "rds-app-ctnr"),
+						validation.NewK8sPodForResource("rds-ctnr").
+							AddRadiusLabels(name, "rds-ctnr"),
+						validation.NewK8sServiceForResource("rds-rte").
+							AddRadiusLabels(name, "rds-rte"),
 					},
 				},
 			},

diff --git a/test/functional/datastoresrp/resources/sql_test.go b/test/functional/datastoresrp/resources/sql_test.go
@@ -69,9 +69,12 @@ func Test_SQLDatabase_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "sql-app-ctnr"),
-						validation.NewK8sPodForResource(name, "sql-ctnr"),
-						validation.NewK8sServiceForResource(name, "sql-rte"),
+						validation.NewK8sPodForResource("sql-app-ctnr").
+							AddRadiusLabels(name, "sql-app-ctnr"),
+						validation.NewK8sPodForResource("sql-ctnr").
+							AddRadiusLabels(name, "sql-ctnr"),
+						validation.NewK8sServiceForResource("sql-rte").
+							AddRadiusLabels(name, "sql-rte"),
 					},
 				},
 			},
@@ -112,8 +115,8 @@ func Test_SQLDatabase_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "sql-recipe-app-ctnr").ValidateLabels(false),
-						validation.NewK8sPodForResource(name, "sql-recipe-resource").ValidateLabels(false),
+						validation.NewK8sPodForResource("sql-recipe-app-ctnr"),
+						validation.NewK8sPodForResource("sql-recipe-resource"),
 					},
 				},
 			},

diff --git a/test/functional/messagingrp/resources/rabbitmq_test.go b/test/functional/messagingrp/resources/rabbitmq_test.go
@@ -64,9 +64,12 @@ func Test_RabbitMQ_Manual(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "rmq-app-ctnr"),
-						validation.NewK8sPodForResource(name, "rmq-ctnr"),
-						validation.NewK8sServiceForResource(name, "rmq-rte"),
+						validation.NewK8sPodForResource("rmq-app-ctnr").
+							AddRadiusLabels(name, "rmq-app-ctnr"),
+						validation.NewK8sPodForResource("rmq-ctnr").
+							AddRadiusLabels(name, "rmq-ctnr"),
+						validation.NewK8sServiceForResource("rmq-rte").
+							AddRadiusLabels(name, "rmq-rte"),
 					},
 				},
 			},
@@ -104,8 +107,8 @@ func Test_RabbitMQ_Recipe(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "rmq-recipe-app-ctnr").ValidateLabels(false),
-						validation.NewK8sPodForResource(name, "rmq-recipe-resource").ValidateLabels(false),
+						validation.NewK8sPodForResource("rmq-recipe-app-ctnr"),
+						validation.NewK8sPodForResource("rmq-recipe-resource"),
 					},
 				},
 			},

diff --git a/test/functional/samples/tutorial_test.go b/test/functional/samples/tutorial_test.go
@@ -110,7 +110,8 @@ func Test_FirstApplicationSample(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(appName, "demo"),
+						validation.NewK8sPodForResource("demo").
+							AddRadiusLabels(appName, "demo"),
 					},
 				},
 			},

diff --git a/test/functional/shared/cli/cli_test.go b/test/functional/shared/cli/cli_test.go
@@ -441,8 +441,10 @@ func Test_CLI(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					"default-kubernetes-cli": {
-						validation.NewK8sPodForResource(name, "containera"),
-						validation.NewK8sPodForResource(name, "containerb"),
+						validation.NewK8sPodForResource("containera").
+							AddRadiusLabels(name, "containera"),
+						validation.NewK8sPodForResource("containerb").
+							AddRadiusLabels(name, "containerb"),
 					},
 				},
 			},
@@ -481,8 +483,10 @@ func Test_CLI_JSON(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					"default-kubernetes-cli-json": {
-						validation.NewK8sPodForResource(name, "containera-json"),
-						validation.NewK8sPodForResource(name, "containerb-json"),
+						validation.NewK8sPodForResource("containera-json").
+							AddRadiusLabels(name, "containera-json"),
+						validation.NewK8sPodForResource("containerb-json").
+							AddRadiusLabels(name, "containerb-json"),
 					},
 				},
 			},
@@ -521,8 +525,10 @@ func Test_CLI_Delete(t *testing.T) {
 		validation.ValidateObjectsRunning(ctx, t, options.K8sClient, options.DynamicClient, validation.K8sObjectSet{
 			Namespaces: map[string][]validation.K8sObject{
 				"default-kubernetes-cli-with-resources": {
-					validation.NewK8sPodForResource(appName, "containera-app-with-resources"),
-					validation.NewK8sPodForResource(appName, "containerb-app-with-resources"),
+					validation.NewK8sPodForResource("containera-app-with-resources").
+						AddRadiusLabels(appName, "containera-app-with-resources"),
+					validation.NewK8sPodForResource("containerb-app-with-resources").
+						AddRadiusLabels(appName, "containerb-app-with-resources"),
 				},
 			},
 		})
@@ -555,8 +561,10 @@ func Test_CLI_Delete(t *testing.T) {
 		validation.ValidateObjectsRunning(ctx, t, options.K8sClient, options.DynamicClient, validation.K8sObjectSet{
 			Namespaces: map[string][]validation.K8sObject{
 				"default-kubernetes-cli-with-resources": {
-					validation.NewK8sPodForResource(appName, "containera-app-with-resources"),
-					validation.NewK8sPodForResource(appName, "containerb-app-with-resources"),
+					validation.NewK8sPodForResource("containera-app-with-resources").
+						AddRadiusLabels(appName, "containera-app-with-resources"),
+					validation.NewK8sPodForResource("containerb-app-with-resources").
+						AddRadiusLabels(appName, "containerb-app-with-resources"),
 				},
 			},
 		})
@@ -615,8 +623,10 @@ func Test_CLI_DeploymentParameters(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					"default-kubernetes-cli-params": {
-						validation.NewK8sPodForResource(name, "containerc"),
-						validation.NewK8sPodForResource(name, "containerd"),
+						validation.NewK8sPodForResource("containerc").
+							AddRadiusLabels(name, "containerc"),
+						validation.NewK8sPodForResource("containerd").
+							AddRadiusLabels(name, "containerd"),
 					},
 				},
 			},

diff --git a/test/functional/shared/mechanics/mechanics_test.go b/test/functional/shared/mechanics/mechanics_test.go
@@ -82,7 +82,8 @@ func Test_RedeployWithAnotherResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicsa"),
+						validation.NewK8sPodForResource("mechanicsa").
+							AddRadiusLabels(name, "mechanicsa"),
 					},
 				},
 			},
@@ -110,8 +111,10 @@ func Test_RedeployWithAnotherResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicsb"),
-						validation.NewK8sPodForResource(name, "mechanicsc"),
+						validation.NewK8sPodForResource("mechanicsb").
+							AddRadiusLabels(name, "mechanicsb"),
+						validation.NewK8sPodForResource("mechanicsc").
+							AddRadiusLabels(name, "mechanicsc"),
 					},
 				},
 			},
@@ -145,7 +148,8 @@ func Test_RedeployWithUpdatedResourceUpdatesResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicsd"),
+						validation.NewK8sPodForResource("mechanicsd").
+							AddRadiusLabels(name, "mechanicsd"),
 					},
 				},
 			},
@@ -168,7 +172,8 @@ func Test_RedeployWithUpdatedResourceUpdatesResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicsd"),
+						validation.NewK8sPodForResource("mechanicsd").
+							AddRadiusLabels(name, "mechanicsd"),
 					},
 				},
 			},
@@ -215,7 +220,8 @@ func Test_RedeployWithTwoSeparateResourcesKeepsResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicse"),
+						validation.NewK8sPodForResource("mechanicse").
+							AddRadiusLabels(name, "mechanicse"),
 					},
 				},
 			},
@@ -243,8 +249,10 @@ func Test_RedeployWithTwoSeparateResourcesKeepsResource(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicse"),
-						validation.NewK8sPodForResource(name, "mechanicsf"),
+						validation.NewK8sPodForResource("mechanicse").
+							AddRadiusLabels(name, "mechanicse"),
+						validation.NewK8sPodForResource("mechanicsf").
+							AddRadiusLabels(name, "mechanicsf"),
 					},
 				},
 			},
@@ -293,8 +301,10 @@ func Test_CommunicationCycle(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, "mechanicsg"),
-						validation.NewK8sPodForResource(name, "cyclea"),
+						validation.NewK8sPodForResource("mechanicsg").
+							AddRadiusLabels(name, "mechanicsg"),
+						validation.NewK8sPodForResource("cyclea").
+							AddRadiusLabels(name, "cyclea"),
 					},
 				},
 			},

diff --git a/test/functional/shared/resources/azure_connections_test.go b/test/functional/shared/resources/azure_connections_test.go
@@ -56,7 +56,8 @@ func Test_AzureConnections(t *testing.T) {
 			K8sObjects: &validation.K8sObjectSet{
 				Namespaces: map[string][]validation.K8sObject{
 					appNamespace: {
-						validation.NewK8sPodForResource(name, containerResourceName),
+						validation.NewK8sPodForResource(containerResourceName).
+							AddRadiusLabels(name, containerResourceName),
 					},
 				},
 			},