Validate IG RootVolumeType

pkg/apis/kops/validation/instancegroup.go

@@ -209,6 +209,10 @@ func CrossValidateInstanceGroup(g *kops.InstanceGroup, cluster *kops.Cluster) fi
 		}
 	}
 
+	if g.Spec.RootVolumeType != nil && kops.CloudProviderID(cluster.Spec.CloudProvider) == kops.CloudProviderAWS {
+		allErrs = append(allErrs, IsValidValue(field.NewPath("spec", "rootVolumeType"), g.Spec.RootVolumeType, []string{"gp2", "io1"})...)
+	}
+
 	return allErrs
 }
 

pkg/apis/kops/validation/instancegroup_test.go

@@ -179,3 +179,45 @@ func TestValidMasterInstanceGroup(t *testing.T) {
 	}
 
 }
+
+func TestValidBootDevice(t *testing.T) {
+
+	cluster := &kops.Cluster{
+		Spec: kops.ClusterSpec{
+			CloudProvider: "aws",
+		},
+	}
+	grid := []struct {
+		volumeType string
+		expected   []string
+	}{
+		{
+			volumeType: "gp2",
+		},
+		{
+			volumeType: "io1",
+		},
+		{
+			volumeType: "st1",
+			expected:   []string{"Unsupported value::spec.rootVolumeType"},
+		},
+		{
+			volumeType: "sc1",
+			expected:   []string{"Unsupported value::spec.rootVolumeType"},
+		},
+	}
+
+	for _, g := range grid {
+		ig := &kops.InstanceGroup{
+			ObjectMeta: v1.ObjectMeta{
+				Name: "some-ig",
+			},
+			Spec: kops.InstanceGroupSpec{
+				Role:           "Node",
+				RootVolumeType: fi.String(g.volumeType),
+			},
+		}
+		errs := CrossValidateInstanceGroup(ig, cluster)
+		testErrors(t, g.volumeType, errs, g.expected)
+	}
+}