Initial Kubevirt provider implementation

Signed-off-by: Marko Mudrinić <[email protected]>

pkg/apis/kubeone/helpers.go

@@ -241,6 +241,8 @@ func (p CloudProviderSpec) CloudProviderName() string {
 		return "gce"
 	case p.Hetzner != nil:
 		return "hetzner"
+	case p.Kubevirt != nil:
+		return "kubevirt"
 	case p.Nutanix != nil:
 		return "nutanix"
 	case p.Openstack != nil:

pkg/apis/kubeone/types.go

@@ -398,6 +398,9 @@ type CloudProviderSpec struct {
 	// Hetzner
 	Hetzner *HetznerSpec `json:"hetzner,omitempty"`
 
+	// Kubevirt
+	Kubevirt *KubevirtSpec `json:"kubevirt,omitempty"`
+
 	// Nutanix
 	Nutanix *NutanixSpec `json:"nutanix,omitempty"`
 
@@ -435,6 +438,9 @@ type HetznerSpec struct {
 	NetworkID string `json:"networkID,omitempty"`
 }
 
+// KubevirtSpec defines the Kubevirt provider
+type KubevirtSpec struct{}
+
 // NutanixSpec defines the Nutanix provider
 type NutanixSpec struct{}
 

pkg/apis/kubeone/v1beta2/defaults.go

@@ -88,9 +88,10 @@ func SetDefaults_CloudProvider(obj *KubeOneCluster) {
 	// if kubernetes version is 1.29+
 	// and cloud provider is configured
 	if gteKube129Condition.Check(actualVer) && obj.CloudProvider.None == nil {
-		// and cloud provider is NOT VMwareCloudDirector, to prevent kubelet --cloud-provider=external situation where
-		// there will be no CCM (VMwareCloudDirector have no CCM) to initialize the Node
-		if obj.CloudProvider.VMwareCloudDirector == nil {
+		// and cloud provider is NOT Kubevirt and NOT VMwareCloudDirector,
+		// to prevent kubelet --cloud-provider=external situation where
+		// there will be no CCM to initialize the Node
+		if obj.CloudProvider.Kubevirt == nil && obj.CloudProvider.VMwareCloudDirector == nil {
 			obj.CloudProvider.External = true
 		}
 	}

pkg/apis/kubeone/v1beta2/helpers.go

@@ -38,6 +38,8 @@ func SetCloudProvider(cp *CloudProviderSpec, name string) error {
 		cp.GCE = &GCESpec{}
 	case "hetzner":
 		cp.Hetzner = &HetznerSpec{}
+	case "kubevirt":
+		cp.Kubevirt = &KubevirtSpec{}
 	case "nutanix":
 		cp.Nutanix = &NutanixSpec{}
 	case "openstack":
@@ -69,6 +71,8 @@ func (cps *CloudProviderSpec) Name() string {
 		return "gce"
 	case cps.Hetzner != nil:
 		return "hetzner"
+	case cps.Kubevirt != nil:
+		return "kubevirt"
 	case cps.Nutanix != nil:
 		return "nutanix"
 	case cps.Openstack != nil:

pkg/apis/kubeone/v1beta2/types.go

@@ -403,6 +403,9 @@ type CloudProviderSpec struct {
 	// Hetzner
 	Hetzner *HetznerSpec `json:"hetzner,omitempty"`
 
+	// Kubevirt
+	Kubevirt *KubevirtSpec `json:"kubevirt,omitempty"`
+
 	// Nutanix
 	Nutanix *NutanixSpec `json:"nutanix,omitempty"`
 
@@ -440,6 +443,9 @@ type HetznerSpec struct {
 	NetworkID string `json:"networkID,omitempty"`
 }
 
+// KubevirtSpec defines the Kubevirt provider
+type KubevirtSpec struct{}
+
 // NutanixSpec defines the Nutanix provider
 type NutanixSpec struct{}
 

pkg/apis/kubeone/v1beta3/defaults.go

@@ -88,9 +88,10 @@ func SetDefaults_CloudProvider(obj *KubeOneCluster) {
 	// if kubernetes version is 1.29+
 	// and cloud provider is configured
 	if gteKube129Condition.Check(actualVer) && obj.CloudProvider.None == nil {
-		// and cloud provider is NOT VMwareCloudDirector, to prevent kubelet --cloud-provider=external situation where
-		// there will be no CCM (VMwareCloudDirector have no CCM) to initialize the Node
-		if obj.CloudProvider.VMwareCloudDirector == nil {
+		// and cloud provider is NOT VMwareCloudDirector and NOT Kubevirt,
+		// to prevent kubelet --cloud-provider=external situation where
+		// there will be no CCM to initialize the Node
+		if obj.CloudProvider.Kubevirt == nil && obj.CloudProvider.VMwareCloudDirector == nil {
 			obj.CloudProvider.External = true
 		}
 	}

pkg/apis/kubeone/v1beta3/helpers.go

@@ -38,6 +38,8 @@ func SetCloudProvider(cp *CloudProviderSpec, name string) error {
 		cp.GCE = &GCESpec{}
 	case "hetzner":
 		cp.Hetzner = &HetznerSpec{}
+	case "kubevirt":
+		cp.Kubevirt = &KubevirtSpec{}
 	case "nutanix":
 		cp.Nutanix = &NutanixSpec{}
 	case "openstack":
@@ -69,6 +71,8 @@ func (cps *CloudProviderSpec) Name() string {
 		return "gce"
 	case cps.Hetzner != nil:
 		return "hetzner"
+	case cps.Kubevirt != nil:
+		return "kubevirt"
 	case cps.Nutanix != nil:
 		return "nutanix"
 	case cps.Openstack != nil:

pkg/apis/kubeone/v1beta3/types.go

@@ -395,6 +395,9 @@ type CloudProviderSpec struct {
 	// Hetzner
 	Hetzner *HetznerSpec `json:"hetzner,omitempty"`
 
+	// Kubevirt
+	Kubevirt *KubevirtSpec `json:"kubevirt,omitempty"`
+
 	// Nutanix
 	Nutanix *NutanixSpec `json:"nutanix,omitempty"`
 
@@ -432,6 +435,9 @@ type HetznerSpec struct {
 	NetworkID string `json:"networkID,omitempty"`
 }
 
+// KubevirtSpec defines the Kubevirt provider
+type KubevirtSpec struct{}
+
 // NutanixSpec defines the Nutanix provider
 type NutanixSpec struct{}
 

pkg/apis/kubeone/validation/validation.go

@@ -200,6 +200,15 @@ func ValidateCloudProviderSpec(providerSpec kubeoneapi.CloudProviderSpec, networ
 		}
 		providerFound = true
 	}
+	if providerSpec.Kubevirt != nil {
+		if providerFound {
+			allErrs = append(allErrs, field.Forbidden(fldPath.Child("kubevirt"), "only one provider can be used at the same time"))
+		}
+		providerFound = true
+		if providerSpec.External {
+			allErrs = append(allErrs, field.Forbidden(fldPath.Child("external"), "external cloud provider is not supported for Kubevirt clusters"))
+		}
+	}
 	if providerSpec.Nutanix != nil {
 		if providerFound {
 			allErrs = append(allErrs, field.Forbidden(fldPath.Child("nutanix"), "only one provider can be used at the same time"))

pkg/apis/kubeone/validation/validation_test.go

@@ -509,6 +509,13 @@ func TestValidateCloudProviderSpec(t *testing.T) {
 			},
 			expectedError: false,
 		},
+		{
+			name: "valid Kubevirt provider config",
+			providerConfig: kubeoneapi.CloudProviderSpec{
+				Kubevirt: &kubeoneapi.KubevirtSpec{},
+			},
+			expectedError: false,
+		},
 		{
 			name: "valid Nutanix provider config",
 			providerConfig: kubeoneapi.CloudProviderSpec{