Merge branch 'main' into asyncworker-logging

radius-project · Mar 27, 2024 · ba3b3b5 · ba3b3b5
2 parents 5d98555 + f863351
commit ba3b3b5
Show file tree

Hide file tree

Showing 174 changed files with 617 additions and 579 deletions.
diff --git a/.github/workflows/functional-test.yaml b/.github/workflows/functional-test.yaml
@@ -211,7 +211,7 @@ jobs:
             * Dapr: ${{ env.DAPR_VER }}
             * Azure KeyVault CSI driver: ${{ env.AZURE_KEYVAULT_CSI_DRIVER_VER }}
             * Azure Workload identity webhook: ${{ env.AZURE_WORKLOAD_IDENTITY_WEBHOOK_VER }}
-            * Bicep recipe location `${{ env.BICEP_RECIPE_REGISTRY }}/test/functional/shared/recipes/<name>:${{ env.REL_VERSION }}`
+            * Bicep recipe location `${{ env.BICEP_RECIPE_REGISTRY }}/test/testrecipes/test-bicep-recipes/<name>:${{ env.REL_VERSION }}`
             * Terraform recipe location `${{ env.TF_RECIPE_MODULE_SERVER_URL }}/<name>.zip` (in cluster)
             * applications-rp test image location: `${{ env.CONTAINER_REGISTRY }}/applications-rp:${{ env.REL_VERSION }}`
             * controller test image location: `${{ env.CONTAINER_REGISTRY }}/controller:${{ env.REL_VERSION }}`

diff --git a/.github/workflows/long-running-azure.yaml b/.github/workflows/long-running-azure.yaml
@@ -197,7 +197,7 @@ jobs:
           <summary> Click here to see the list of tools in the current test run</summary>
 
           * gotestsum ${{ env.GOTESTSUM_VER }}
-          * Bicep recipe location `${{ env.BICEP_RECIPE_REGISTRY }}/test/functional/shared/recipes/<name>:${{ steps.gen-id.outputs.REL_VERSION }}`
+          * Bicep recipe location `${{ env.BICEP_RECIPE_REGISTRY }}/test/testrecipes/test-bicep-recipes/<name>:${{ steps.gen-id.outputs.REL_VERSION }}`
           * Terraform recipe location `${{ env.TF_RECIPE_MODULE_SERVER_URL }}/<name>.zip` (in cluster)
           * applications-rp test image location: `${{ env.CONTAINER_REGISTRY }}/applications-rp:${{ steps.gen-id.outputs.REL_VERSION }}`
           * controller test image location: `${{ env.CONTAINER_REGISTRY }}/controller:${{ steps.gen-id.outputs.REL_VERSION }}`

diff --git a/.github/workflows/retry-functional-test.yaml b/.github/workflows/retry-functional-test.yaml
@@ -23,8 +23,8 @@ permissions:
 
 on:
   schedule:
-    # Run every 20 minutes
-    - cron: "*/20 * * * *"
+    # Run every 2 hours
+    - cron: "0 */2 * * *"
 
 env:
   # Go version

diff --git a/build/recipes.mk b/build/recipes.mk
@@ -27,20 +27,20 @@ TERRAFORM_MODULE_CONFIGMAP_NAME=tf-module-server-content
 publish-test-bicep-recipes: ## Publishes test recipes to <BICEP_RECIPE_REGISTRY> with version <BICEP_RECIPE_TAG_VERSION>
 	@if [ -z "$(BICEP_RECIPE_REGISTRY)" ]; then echo "Error: BICEP_RECIPE_REGISTRY must be set to a valid OCI registry"; exit 1; fi
 
-	@echo "$(ARROW) Publishing Bicep test recipes from ./test/functional/shared/resources/testdata/recipes/test-bicep-recipes..."
+	@echo "$(ARROW) Publishing Bicep test recipes from ./test/testrecipes/test-bicep-recipes..."
 	./.github/scripts/publish-recipes.sh \
-		./test/functional/shared/resources/testdata/recipes/test-bicep-recipes \
-		${BICEP_RECIPE_REGISTRY}/test/functional/shared/recipes \
+		./test/testrecipes/test-bicep-recipes \
+		${BICEP_RECIPE_REGISTRY}/test/testrecipes/test-bicep-recipes \
 		${BICEP_RECIPE_TAG_VERSION}
 
 .PHONY: publish-test-terraform-recipes
 publish-test-terraform-recipes: ## Publishes test terraform recipes to the current Kubernetes cluster
 	@echo "$(ARROW) Creating Kubernetes namespace $(TERRAFORM_MODULE_SERVER_NAMESPACE)..."
 	kubectl create namespace $(TERRAFORM_MODULE_SERVER_NAMESPACE) --dry-run=client -o yaml | kubectl apply -f -
 
-	@echo "$(ARROW) Publishing Terraform test recipes from ./test/functional/shared/resources/testdata/recipes/test-terraform-recipes..."
+	@echo "$(ARROW) Publishing Terraform test recipes from ./test/testrecipes/test-terraform-recipes..."
 	./.github/scripts/publish-test-terraform-recipes.py \
-		./test/functional/shared/resources/testdata/recipes/test-terraform-recipes \
+		./test/testrecipes/test-terraform-recipes \
 		$(TERRAFORM_MODULE_SERVER_NAMESPACE) \
 		$(TERRAFORM_MODULE_CONFIGMAP_NAME)
 

diff --git a/build/test.mk b/build/test.mk
@@ -74,8 +74,13 @@ test-functional-kubernetes: test-functional-kubernetes-noncloud ## Runs all Kube
 test-functional-kubernetes-noncloud: ## Runs Kubernetes functional tests that do not require cloud resources
 	CGO_ENABLED=1 $(GOTEST_TOOL) ./test/functional-portable/kubernetes/noncloud/... -timeout ${TEST_TIMEOUT} -v -parallel 5 $(GOTEST_OPTS)
 
-test-functional-shared: ## Runs shared functional tests
-	CGO_ENABLED=1 $(GOTEST_TOOL) ./test/functional/shared/... -timeout ${TEST_TIMEOUT} -v -parallel 10 $(GOTEST_OPTS)
+test-functional-shared: test-functional-corerp-noncloud test-functional-corerp-cloud ## Runs all Core RP functional tests (both cloud and non-cloud)
+
+test-functional-corerp-noncloud: ## Runs corerp functional tests that do not require cloud resources
+	CGO_ENABLED=1 $(GOTEST_TOOL) ./test/functional-portable/corerp/noncloud/... -timeout ${TEST_TIMEOUT} -v -parallel 10 $(GOTEST_OPTS)
+
+test-functional-corerp-cloud: ## Runs corerp functional tests that require cloud resources
+	CGO_ENABLED=1 $(GOTEST_TOOL) ./test/functional-portable/corerp/cloud/... -timeout ${TEST_TIMEOUT} -v -parallel 10 $(GOTEST_OPTS)
 
 test-functional-msgrp: test-functional-msgrp-noncloud ## Runs all Messaging RP functional tests (both cloud and non-cloud)
 

diff --git a/...tributing/contributing-code/contributing-code-tests/tests-naming-conventions.md b/...tributing/contributing-code/contributing-code-tests/tests-naming-conventions.md
@@ -1,5 +1,5 @@
 # Radius functional test naming conventions
-Today, the [functional tests](https://github.com/radius-project/radius/tree/main/test/functional/shared/resources) use some abbreviations to make sure that the resource labels will not exceed 63 characters (application + resource name). Here are a list of some of the abbreviations and patterns:
+Today, the [functional tests](https://github.com/radius-project/radius/tree/main/test/functional-portable/corerp/resources) use some abbreviations to make sure that the resource labels will not exceed 63 characters (application + resource name). Here are a list of some of the abbreviations and patterns:
 
 |Keyword|Abbreviation|
 |-|-|

diff --git a/test/functional-portable/cli/noncloud/cli_test.go b/test/functional-portable/cli/noncloud/cli_test.go
@@ -44,8 +44,9 @@ import (
 	"github.com/radius-project/radius/pkg/corerp/api/v20231001preview"
 	"github.com/radius-project/radius/pkg/ucp/resources"
 	"github.com/radius-project/radius/pkg/version"
-	"github.com/radius-project/radius/test/functional/shared"
+
 	"github.com/radius-project/radius/test/radcli"
+	"github.com/radius-project/radius/test/rp"
 	"github.com/radius-project/radius/test/step"
 	"github.com/radius-project/radius/test/testcontext"
 	"github.com/radius-project/radius/test/testutil"
@@ -59,21 +60,21 @@ const (
 	retries = 10
 )
 
-func verifyRecipeCLI(ctx context.Context, t *testing.T, test shared.RPTest) {
-	options := shared.NewRPTestOptions(t)
+func verifyRecipeCLI(ctx context.Context, t *testing.T, test rp.RPTest) {
+	options := rp.NewRPTestOptions(t)
 	cli := radcli.NewCLI(t, options.ConfigFilePath)
 	envName := test.Steps[0].RPResources.Resources[0].Name
 	registry := strings.TrimPrefix(testutil.GetBicepRecipeRegistry(), "registry=")
 	version := strings.TrimPrefix(testutil.GetBicepRecipeVersion(), "version=")
 	resourceType := "Applications.Datastores/redisCaches"
-	file := "../../../functional/shared/resources/testdata/recipes/test-bicep-recipes/corerp-redis-recipe.bicep"
+	file := "../../../testrecipes/test-bicep-recipes/corerp-redis-recipe.bicep"
 	target := fmt.Sprintf("br:ghcr.io/radius-project/dev/test-bicep-recipes/redis-recipe:%s", generateUniqueTag())
 
 	recipeName := "recipeName"
 	recipeTemplate := fmt.Sprintf("%s/recipes/local-dev/rediscaches:%s", registry, version)
 
 	bicepRecipe := "recipe1"
-	bicepRecipeTemplate := fmt.Sprintf("%s/test/functional/shared/recipes/corerp-redis-recipe:%s", registry, version)
+	bicepRecipeTemplate := fmt.Sprintf("%s/test/testrecipes/test-bicep-recipes/corerp-redis-recipe:%s", registry, version)
 	templateKindBicep := "bicep"
 
 	terraformRecipe := "recipe2"
@@ -155,8 +156,8 @@ func verifyRecipeCLI(ctx context.Context, t *testing.T, test shared.RPTest) {
 	})
 }
 
-func verifyCLIBasics(ctx context.Context, t *testing.T, test shared.RPTest) {
-	options := shared.NewRPTestOptions(t)
+func verifyCLIBasics(ctx context.Context, t *testing.T, test rp.RPTest) {
+	options := rp.NewRPTestOptions(t)
 	cli := radcli.NewCLI(t, options.ConfigFilePath)
 	appName := test.Name
 	containerName := "containerA"
@@ -280,7 +281,7 @@ func Test_Run_Logger(t *testing.T) {
 	// Will be used to cancel `rad run`
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
-	options := shared.NewRPTestOptions(t)
+	options := rp.NewRPTestOptions(t)
 
 	template := "testdata/corerp-kubernetes-cli-run.bicep"
 	applicationName := "cli-run-logger"
@@ -354,7 +355,7 @@ func Test_Run_Portforward(t *testing.T) {
 	// Will be used to cancel `rad run`
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
-	options := shared.NewRPTestOptions(t)
+	options := rp.NewRPTestOptions(t)
 
 	template := "testdata/corerp-kubernetes-cli-run-portforward.bicep"
 	applicationName := "cli-run-portforward"
@@ -453,7 +454,7 @@ func Test_CLI(t *testing.T) {
 	template := "testdata/corerp-kubernetes-cli.bicep"
 	name := "kubernetes-cli"
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor: step.NewDeployExecutor(template, testutil.GetMagpieImage()),
 			RPResources: &validation.RPResourceSet{
@@ -493,7 +494,7 @@ func Test_CLI_JSON(t *testing.T) {
 	template := "testdata/corerp-kubernetes-cli.json"
 	name := "kubernetes-cli-json"
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor: step.NewDeployExecutor(template, testutil.GetMagpieImage()),
 			RPResources: &validation.RPResourceSet{
@@ -533,7 +534,7 @@ func Test_CLI_Delete(t *testing.T) {
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
 
-	options := shared.NewRPTestOptions(t)
+	options := rp.NewRPTestOptions(t)
 	appName := "kubernetes-cli-with-resources"
 	appNameUnassociatedResources := "kubernetes-cli-with-unassociated-resources"
 	appNameEmptyResources := "kubernetes-cli-empty-resources"
@@ -631,7 +632,7 @@ func Test_CLI_DeploymentParameters(t *testing.T) {
 	// corerp-kubernetes-cli-parameters.parameters.json uses ghcr.io/radius-project/dev as a registry parameter.
 	// Use the specified tag only if the test uses ghcr.io/radius-project/dev registry. Otherwise, use latest tag.
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor: step.NewDeployExecutor(template, "@"+parameterFilePath, testutil.GetMagpieTag()),
 			RPResources: &validation.RPResourceSet{
@@ -670,7 +671,7 @@ func Test_CLI_version(t *testing.T) {
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
 
-	options := shared.NewTestOptions(t)
+	options := rp.NewTestOptions(t)
 	cli := radcli.NewCLI(t, options.ConfigFilePath)
 
 	output, err := cli.Version(ctx)
@@ -691,7 +692,7 @@ func Test_CLI_Only_version(t *testing.T) {
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
 
-	options := shared.NewTestOptions(t)
+	options := rp.NewTestOptions(t)
 	cli := radcli.NewCLI(t, options.ConfigFilePath)
 
 	output, err := cli.CliVersion(ctx)
@@ -709,7 +710,7 @@ func Test_RecipeCommands(t *testing.T) {
 	template := "testdata/corerp-resources-recipe-env.bicep"
 	name := "corerp-resources-recipe-env"
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor: step.NewDeployExecutor(template, testutil.GetBicepRecipeRegistry(), testutil.GetBicepRecipeVersion()),
 			RPResources: &validation.RPResourceSet{
@@ -735,7 +736,7 @@ func Test_DevRecipes(t *testing.T) {
 	ctx, cancel := testcontext.NewWithCancel(t)
 	t.Cleanup(cancel)
 
-	options := shared.NewTestOptions(t)
+	options := rp.NewTestOptions(t)
 	cli := radcli.NewCLI(t, options.ConfigFilePath)
 
 	envName := "test-dev-recipes"
@@ -797,7 +798,7 @@ func GetAvailablePort() (int, error) {
 
 // DeleteAppWithoutDeletingResources creates a client to delete an application without deleting its resources and returns
 // an error if one occurs.
-func DeleteAppWithoutDeletingResources(t *testing.T, ctx context.Context, options shared.RPTestOptions, applicationName string) error {
+func DeleteAppWithoutDeletingResources(t *testing.T, ctx context.Context, options rp.RPTestOptions, applicationName string) error {
 	client := options.ManagementClient
 	require.IsType(t, client, &clients.UCPApplicationsManagementClient{})
 	appManagementClient := client.(*clients.UCPApplicationsManagementClient)

diff --git a/test/functional-portable/cli/noncloud/testdata/corerp-resources-recipe-env.bicep b/test/functional-portable/cli/noncloud/testdata/corerp-resources-recipe-env.bicep
@@ -20,7 +20,7 @@ resource env 'Applications.Core/environments@2023-10-01-preview' = {
       'Applications.Datastores/redisCaches':{
         recipe1: {
           templateKind: 'bicep'
-          templatePath: '${registry}/test/functional/shared/recipes/corerp-redis-recipe:${version}'
+          templatePath: '${registry}/test/testrecipes/test-bicep-recipes/corerp-redis-recipe:${version}'
         }
         recipe2: {
           templateKind: 'terraform'

diff --git a/...al/shared/mechanics/aws_mechanics_test.go → ...erp/cloud/mechanics/aws_mechanics_test.go b/...al/shared/mechanics/aws_mechanics_test.go → ...erp/cloud/mechanics/aws_mechanics_test.go
@@ -21,7 +21,7 @@ import (
 	"testing"
 
 	"github.com/google/uuid"
-	"github.com/radius-project/radius/test/functional/shared"
+	"github.com/radius-project/radius/test/rp"
 	"github.com/radius-project/radius/test/step"
 	"github.com/radius-project/radius/test/testutil"
 	"github.com/radius-project/radius/test/validation"
@@ -32,7 +32,7 @@ func Test_AWSRedeployWithUpdatedResourceUpdatesResource(t *testing.T) {
 	name := "radiusfunctionaltestbucket-" + uuid.New().String()
 	creationTimestamp := testutil.GetCreationTimestamp()
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor:                               step.NewDeployExecutor(fmt.Sprintf(templateFmt, 1), "bucketName="+name, "creationTimestamp="+creationTimestamp),
 			SkipKubernetesOutputResourceValidation: true,
@@ -89,5 +89,7 @@ func Test_AWSRedeployWithUpdatedResourceUpdatesResource(t *testing.T) {
 			},
 		},
 	})
+
+	test.RequiredFeatures = []rp.RequiredFeature{rp.FeatureAWS}
 	test.Test(t)
 }
diff --git a/...hcreateandwritepropertyupdate.step1.bicep → ...hcreateandwritepropertyupdate.step1.bicep b/...hcreateandwritepropertyupdate.step1.bicep → ...hcreateandwritepropertyupdate.step1.bicep
diff --git a/...hcreateandwritepropertyupdate.step2.bicep → ...hcreateandwritepropertyupdate.step2.bicep b/...hcreateandwritepropertyupdate.step2.bicep → ...hcreateandwritepropertyupdate.step2.bicep
diff --git a/...-redeploy-withupdatedresource.step1.bicep → ...-redeploy-withupdatedresource.step1.bicep b/...-redeploy-withupdatedresource.step1.bicep → ...-redeploy-withupdatedresource.step1.bicep
diff --git a/...-redeploy-withupdatedresource.step2.bicep → ...-redeploy-withupdatedresource.step2.bicep b/...-redeploy-withupdatedresource.step2.bicep → ...-redeploy-withupdatedresource.step2.bicep
diff --git a/...ces/aws_multi_identifier_resource_test.go → ...ces/aws_multi_identifier_resource_test.go b/...ces/aws_multi_identifier_resource_test.go → ...ces/aws_multi_identifier_resource_test.go
@@ -22,7 +22,7 @@ import (
 	"time"
 
 	"github.com/google/uuid"
-	"github.com/radius-project/radius/test/functional/shared"
+	"github.com/radius-project/radius/test/rp"
 	"github.com/radius-project/radius/test/step"
 	"github.com/radius-project/radius/test/validation"
 )
@@ -34,7 +34,7 @@ func Test_AWS_MultiIdentifier_Resource(t *testing.T) {
 	testName := "ms" + uuid.New().String()
 	creationTimestamp := fmt.Sprintf("%d", time.Now().Unix())
 
-	test := shared.NewRPTest(t, testName, []shared.TestStep{
+	test := rp.NewRPTest(t, testName, []rp.TestStep{
 		{
 			Executor:                               step.NewDeployExecutor(template, "filterName="+filterName, "logGroupName="+logGroupName, "creationTimestamp="+creationTimestamp),
 			SkipKubernetesOutputResourceValidation: true,
@@ -64,5 +64,6 @@ func Test_AWS_MultiIdentifier_Resource(t *testing.T) {
 		},
 	})
 
+	test.RequiredFeatures = []rp.RequiredFeature{rp.FeatureAWS}
 	test.Test(t)
 }
diff --git a/...al/shared/resources/aws_s3_bucket_test.go → ...erp/cloud/resources/aws_s3_bucket_test.go b/...al/shared/resources/aws_s3_bucket_test.go → ...erp/cloud/resources/aws_s3_bucket_test.go
@@ -19,7 +19,7 @@ package resource_test
 import (
 	"testing"
 
-	"github.com/radius-project/radius/test/functional/shared"
+	"github.com/radius-project/radius/test/rp"
 	"github.com/radius-project/radius/test/step"
 	"github.com/radius-project/radius/test/testutil"
 	"github.com/radius-project/radius/test/validation"
@@ -30,7 +30,7 @@ func Test_AWS_S3Bucket(t *testing.T) {
 	name := testutil.GenerateS3BucketName()
 	creationTimestamp := testutil.GetCreationTimestamp()
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor:                               step.NewDeployExecutor(template, "bucketName="+name, "creationTimestamp="+creationTimestamp),
 			SkipKubernetesOutputResourceValidation: true,
@@ -60,6 +60,7 @@ func Test_AWS_S3Bucket(t *testing.T) {
 		},
 	})
 
+	test.RequiredFeatures = []rp.RequiredFeature{rp.FeatureAWS}
 	test.Test(t)
 }
 
@@ -69,7 +70,7 @@ func Test_AWS_S3Bucket_Existing(t *testing.T) {
 	name := testutil.GenerateS3BucketName()
 	creationTimestamp := testutil.GetCreationTimestamp()
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor:                               step.NewDeployExecutor(template, "bucketName="+name, "creationTimestamp="+creationTimestamp),
 			SkipKubernetesOutputResourceValidation: true,
@@ -129,6 +130,6 @@ func Test_AWS_S3Bucket_Existing(t *testing.T) {
 		},
 	})
 
-	test.RequiredFeatures = []shared.RequiredFeature{shared.FeatureAWS}
+	test.RequiredFeatures = []rp.RequiredFeature{rp.FeatureAWS}
 	test.Test(t)
 }
diff --git a/...hared/resources/azure_connections_test.go → ...cloud/resources/azure_connections_test.go b/...hared/resources/azure_connections_test.go → ...cloud/resources/azure_connections_test.go
@@ -20,7 +20,7 @@ import (
 	"os"
 	"testing"
 
-	"github.com/radius-project/radius/test/functional/shared"
+	"github.com/radius-project/radius/test/rp"
 	"github.com/radius-project/radius/test/step"
 	"github.com/radius-project/radius/test/testutil"
 	"github.com/radius-project/radius/test/validation"
@@ -37,7 +37,7 @@ func Test_AzureConnections(t *testing.T) {
 	cosmosmongodbresourceid := "cosmosmongodbresourceid=" + os.Getenv("AZURE_COSMOS_MONGODB_ACCOUNT_ID")
 	appNamespace := "default-corerp-azure-connection-database-service"
 
-	test := shared.NewRPTest(t, name, []shared.TestStep{
+	test := rp.NewRPTest(t, name, []rp.TestStep{
 		{
 			Executor: step.NewDeployExecutor(template, testutil.GetMagpieImage(), cosmosmongodbresourceid),
 			RPResources: &validation.RPResourceSet{
@@ -63,6 +63,6 @@ func Test_AzureConnections(t *testing.T) {
 		},
 	})
 
-	test.RequiredFeatures = []shared.RequiredFeature{shared.FeatureAzure}
+	test.RequiredFeatures = []rp.RequiredFeature{rp.FeatureAzure}
 	test.Test(t)
 }