Added vSphere provisioning mode support to data disks

Author: vr4manta

pkg/controller/vsphere/reconciler.go

@@ -1245,18 +1245,34 @@ func createDataDisks(s *machineScope, devices object.VirtualDeviceList) ([]types
 	for i, dataDisk := range s.providerSpec.DataDisks {
 		klog.V(2).InfoS("Adding disk", "name", dataDisk.Name, "spec", dataDisk)
 
+		backing := &types.VirtualDiskFlatVer2BackingInfo{
+			DiskMode: string(types.VirtualDiskModePersistent),
+			VirtualDeviceFileBackingInfo: types.VirtualDeviceFileBackingInfo{
+				FileName: "",
+			},
+		}
+
+		// Set provisioning type for the new data disk.
+		// Currently, if ThinProvisioned is not set, GOVC will set default to false.  We may want to change this behavior
+		// to match what template image OS disk has configured to make them match if not set.
+		switch dataDisk.ProvisioningMode {
+		case machinev1.ProvisioningModeThin:
+			backing.ThinProvisioned = types.NewBool(true)
+		case machinev1.ProvisioningModeThick:
+			backing.ThinProvisioned = types.NewBool(false)
+		case machinev1.ProvisioningModeEagerlyZeroed:
+			backing.ThinProvisioned = types.NewBool(false)
+			backing.EagerlyScrub = types.NewBool(true)
+		default:
+			klog.V(2).Infof("No provisioning type detected.  Leaving configuration empty.")
+		}
+
 		dev := &types.VirtualDisk{
 			VirtualDevice: types.VirtualDevice{
 				// Key needs to be unique and cannot match another new disk being added.  So we'll use the index as an
 				// input to NewKey.  NewKey() will always return same value since our new devices are not part of devices yet.
-				Key: devices.NewKey() - int32(i),
-				Backing: &types.VirtualDiskFlatVer2BackingInfo{
-					DiskMode:        string(types.VirtualDiskModePersistent),
-					ThinProvisioned: types.NewBool(true),
-					VirtualDeviceFileBackingInfo: types.VirtualDeviceFileBackingInfo{
-						FileName: "",
-					},
-				},
+				Key:           devices.NewKey() - int32(i),
+				Backing:       backing,
 				ControllerKey: controller.GetVirtualController().Key,
 			},
 			CapacityInKB: int64(dataDisk.SizeGiB) * 1024 * 1024,

pkg/webhooks/machine_webhook.go

@@ -131,6 +131,13 @@ var (
 
 	// vSphereDataDiskNamePattern is used to validate the name of a data disk
 	vSphereDataDiskNamePattern = regexp.MustCompile(`^[a-zA-Z0-9]([-_a-zA-Z0-9]*[a-zA-Z0-9])?$`)
+
+	// validProvisioningModes lists all valid data disk provisioning modes
+	validProvisioningModes = []machinev1beta1.ProvisioningMode{
+		machinev1beta1.ProvisioningModeThin,
+		machinev1beta1.ProvisioningModeThick,
+		machinev1beta1.ProvisioningModeEagerlyZeroed,
+	}
 )
 
 const (
@@ -1569,6 +1576,17 @@ func validateVSphereDataDisks(dataDisks []machinev1beta1.VSphereDisk) field.Erro
 		if disk.SizeGiB > maxVSphereDataDiskSize {
 			errs = append(errs, field.Invalid(diskPath.Child("sizeGiB"), disk.SizeGiB, fmt.Sprintf("data disk size (GiB) must not exceed %d", maxVSphereDataDiskSize)))
 		}
+
+		// Validate provisioning modes
+		if len(disk.ProvisioningMode) > 0 {
+			validModesSet := sets.NewString()
+			for _, m := range validProvisioningModes {
+				validModesSet.Insert(string(m))
+			}
+			if !validModesSet.Has(string(disk.ProvisioningMode)) {
+				errs = append(errs, field.NotSupported(diskPath, disk.ProvisioningMode, validModesSet.List()))
+			}
+		}
 	}
 
 	return errs

pkg/webhooks/machine_webhook_test.go

@@ -4432,6 +4432,43 @@ func TestValidateVSphereProviderSpec(t *testing.T) {
 			}(),
 			expectedError: "providerSpec.disks[0].name: Invalid value: \"Bad #Name\": data disk name must consist only of alphanumeric characters, hyphens and underscores, and must start and end with an alphanumeric character.",
 		},
+		{
+			testCase: "with data disk configured with provisioning mode",
+			modifySpec: func(p *machinev1beta1.VSphereMachineProviderSpec) {
+				p.DataDisks = []machinev1beta1.VSphereDisk{
+					{
+						Name:             "Disk1",
+						SizeGiB:          10,
+						ProvisioningMode: machinev1beta1.ProvisioningModeThin,
+					},
+				}
+			},
+			expectedOk: true,
+			featureGatesEnabled: func() map[string]bool {
+				fg := make(map[string]bool)
+				fg[string(features.FeatureGateVSphereMultiDisk)] = true
+				return fg
+			}(),
+		},
+		{
+			testCase: "with data disk configured with invalid provisioning mode",
+			modifySpec: func(p *machinev1beta1.VSphereMachineProviderSpec) {
+				p.DataDisks = []machinev1beta1.VSphereDisk{
+					{
+						Name:             "Disk1",
+						SizeGiB:          10,
+						ProvisioningMode: "Fat",
+					},
+				}
+			},
+			expectedOk: false,
+			featureGatesEnabled: func() map[string]bool {
+				fg := make(map[string]bool)
+				fg[string(features.FeatureGateVSphereMultiDisk)] = true
+				return fg
+			}(),
+			expectedError: "providerSpec.disks[0]: Unsupported value: \"Fat\": supported values: \"EagerlyZeroed\", \"Thick\", \"Thin\"",
+		},
 	}
 
 	secret := &corev1.Secret{