Make it able to bring your own OpenStack volume

Signed-off-by: Max Rantil <[email protected]>

Author: Max Rantil

hack/ci/cloud-init/controller.yaml.tpl

@@ -150,6 +150,9 @@
         openstack aggregate add host "$aggregateid" "$host"
     done
 
+    # Create volume types
+    openstack volume type create "test-volume-type" --description "Test volume type" --public
+
     # the flavors are created in a way that we can execute at least 2 e2e tests in parallel (overall we have 32 vCPUs)
     openstack flavor delete m1.tiny
     openstack flavor create --ram 512 --disk 1 --ephemeral 1 --vcpus 1 --public --id 1 m1.tiny --property hw_rng:allowed='True'

test/e2e/suites/e2e/e2e_test.go

@@ -898,16 +898,17 @@ func createTestVolumeType(e2eCtx *shared.E2EContext) {
 	volumeClient, err := openstack.NewBlockStorageV3(providerClient, gophercloud.EndpointOpts{Region: clientOpts.RegionName})
 	Expect(err).NotTo(HaveOccurred())
 
-	shared.Logf("Creating test volume type")
-	_, err = volumetypes.Create(volumeClient, &volumetypes.CreateOpts{
-		Name:        e2eCtx.E2EConfig.GetVariable(shared.OpenStackVolumeTypeAlt),
-		Description: "Test volume type",
-		IsPublic:    pointer.Bool(true),
-		ExtraSpecs:  map[string]string{},
-	}).Extract()
-	if capoerrors.IsConflict(err) {
-		shared.Logf("Volume type already exists. This may happen in development environments, but it is not expected in CI.")
-		return
+	volumeTypeName := e2eCtx.E2EConfig.GetVariable(shared.OpenStackVolumeTypeAlt)
+
+	shared.Logf("Checking if test volume type '%s' exists", volumeTypeName)
+	_, err = volumetypes.Get(volumeClient, volumeTypeName).Extract()
+
+	if err != nil {
+		if capoerrors.IsConflict(err) {
+			shared.Logf("Volume type already exists. This may happen in development environments, but it is not expected in CI.")
+			return
+		}
+		Expect(err).NotTo(HaveOccurred())
 	}
-	Expect(err).NotTo(HaveOccurred())
+	shared.Logf("Proceeding with volume type '%s'.", volumeTypeName)
 }