kola: add KubeVirt platform support

Add a new "kubevirt" platform to kola for testing CoreOS on KubeVirt VMs.
This enables end-to-end testing of afterburn's KubeVirt metadata provider,
supporting both ConfigDrive and NoCloud cloud-init types.

Platform implementation:
- API wrapper using controller-runtime client + kubevirt.io/api types
  (lightweight alternative to kubevirt.io/client-go)
- SSH access via WebSocket port-forward through the KubeVirt API server
  (no virtctl binary dependency)
- containerDisk support for FCOS images (cosa already builds these)
- Per-test CloudInitType and NetworkData via MachineOptions

External test framework:
- Detect network_data.json in test dir -> ConfigDrive cloud-init type
- Detect network-config in test dir -> NoCloud cloud-init type
- File naming follows real-world conventions (OpenStack / cloud-init)
- Error if both files present in the same test directory
- Silently ignored on platforms that don't support network data

New CLI flags:
  --kubevirt-kubeconfig, --kubevirt-namespace, --kubevirt-image,
  --kubevirt-cloud-init-type, --kubevirt-memory, --kubevirt-cpus

New tests:
  fcos.metadata.kubevirt.configdrive
  fcos.metadata.kubevirt.nocloud

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: qinqon

mantle/cmd/kola/options.go

@@ -40,7 +40,7 @@ var (
 	kolaPlatform      string
 	kolaParallelArg   string
 	kolaArchitectures = []string{"amd64"}
-	kolaPlatforms     = []string{"aws", "azure", "do", "esx", "gcp", "openstack", "qemu", "qemu-iso"}
+	kolaPlatforms     = []string{"aws", "azure", "do", "esx", "gcp", "kubevirt", "openstack", "qemu", "qemu-iso"}
 	kolaDistros       = []string{"fcos", "rhcos", "scos"}
 )
 
@@ -140,6 +140,14 @@ func init() {
 	sv(&kola.OpenStackOptions.Domain, "openstack-domain", "", "OpenStack domain ID")
 	sv(&kola.OpenStackOptions.FloatingIPNetwork, "openstack-floating-ip-network", "", "OpenStack network to use when creating a floating IP")
 
+	// kubevirt-specific options
+	sv(&kola.KubeVirtOptions.Kubeconfig, "kubevirt-kubeconfig", "", "Path to kubeconfig (default: in-cluster or ~/.kube/config)")
+	sv(&kola.KubeVirtOptions.Namespace, "kubevirt-namespace", "default", "Kubernetes namespace for VMs")
+	sv(&kola.KubeVirtOptions.Image, "kubevirt-image", "", "Container disk image pull spec")
+	sv(&kola.KubeVirtOptions.CloudInitType, "kubevirt-cloud-init-type", "configdrive", "Cloud-init type: configdrive or nocloud")
+	sv(&kola.KubeVirtOptions.Memory, "kubevirt-memory", "2Gi", "VM memory")
+	root.PersistentFlags().Uint32Var(&kola.KubeVirtOptions.CPUs, "kubevirt-cpus", 2, "VM CPUs")
+
 	// QEMU-specific options
 	sv(&kola.QEMUOptions.Firmware, "qemu-firmware", "", "Boot firmware: bios,uefi,uefi-secure (default bios)")
 	sv(&kola.QEMUOptions.DiskImage, "qemu-image", "", "path to CoreOS disk image")

mantle/kola/harness.go

@@ -45,13 +45,15 @@ import (
 	doapi "github.com/coreos/coreos-assembler/mantle/platform/api/do"
 	esxapi "github.com/coreos/coreos-assembler/mantle/platform/api/esx"
 	gcloudapi "github.com/coreos/coreos-assembler/mantle/platform/api/gcloud"
+	kubevirtapi "github.com/coreos/coreos-assembler/mantle/platform/api/kubevirt"
 	openstackapi "github.com/coreos/coreos-assembler/mantle/platform/api/openstack"
 	"github.com/coreos/coreos-assembler/mantle/platform/conf"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/aws"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/azure"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/do"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/esx"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/gcloud"
+	"github.com/coreos/coreos-assembler/mantle/platform/machine/kubevirt"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/openstack"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/qemu"
 	"github.com/coreos/coreos-assembler/mantle/platform/machine/qemuiso"
@@ -113,6 +115,7 @@ var (
 	DOOptions        = doapi.Options{Options: &Options}        // glue to set platform options from main
 	ESXOptions       = esxapi.Options{Options: &Options}       // glue to set platform options from main
 	GCPOptions       = gcloudapi.Options{Options: &Options}    // glue to set platform options from main
+	KubeVirtOptions  = kubevirtapi.Options{Options: &Options}  // glue to set platform options from main
 	OpenStackOptions = openstackapi.Options{Options: &Options} // glue to set platform options from main
 	QEMUOptions      = qemu.Options{Options: &Options}         // glue to set platform options from main
 	QEMUIsoOptions   = qemuiso.Options{Options: &Options}      // glue to set platform options from main
@@ -310,6 +313,8 @@ func NewFlight(pltfrm string) (flight platform.Flight, err error) {
 		flight, err = esx.NewFlight(&ESXOptions)
 	case "gcp":
 		flight, err = gcloud.NewFlight(&GCPOptions)
+	case "kubevirt":
+		flight, err = kubevirt.NewFlight(&KubeVirtOptions)
 	case "openstack":
 		flight, err = openstack.NewFlight(&OpenStackOptions)
 	case "qemu":
@@ -1164,7 +1169,7 @@ func runExternalTest(c cluster.TestCluster, mach platform.Machine, testNum int)
 	}
 }
 
-func registerExternalTest(testname, executable, dependencydir string, userdata *conf.UserData, baseMeta externalTestMeta) error {
+func registerExternalTest(testname, executable, dependencydir string, userdata *conf.UserData, baseMeta externalTestMeta, networkData, cloudInitType string) error {
 	targetMeta, err := metadataFromTestBinary(executable)
 	if err != nil {
 		return errors.Wrapf(err, "Parsing metadata from %s", executable)
@@ -1250,6 +1255,8 @@ ExecStart=%s
 		InstanceType:              targetMeta.InstanceType,
 		NonExclusive:              !targetMeta.Exclusive,
 		Conflicts:                 targetMeta.Conflicts,
+		CloudInitType:             cloudInitType,
+		NetworkData:               networkData,
 
 		Run: func(c cluster.TestCluster) {
 			mach := c.Machines()[0]
@@ -1337,6 +1344,8 @@ func patternMatchesTests(pattern string, tests map[string]*register.Test) (bool,
 // registerTestDir parses one test directory and registers it as a test
 func registerTestDir(dir, testprefix string, children []os.DirEntry) error {
 	var dependencydir string
+	var networkData string
+	var cloudInitType string
 	var meta externalTestMeta
 	userdata := conf.EmptyIgnition()
 	executables := []string{}
@@ -1381,6 +1390,26 @@ func registerTestDir(dir, testprefix string, children []os.DirEntry) error {
 			if err := dec.Decode(&meta); err != nil {
 				return errors.Wrapf(err, "parsing %s", fpath)
 			}
+		} else if isreg && c.Name() == "network_data.json" {
+			if cloudInitType != "" {
+				return fmt.Errorf("found both network_data.json and network-config in %s; use only one", dir)
+			}
+			v, err := os.ReadFile(filepath.Join(dir, c.Name()))
+			if err != nil {
+				return errors.Wrapf(err, "reading %s", c.Name())
+			}
+			networkData = string(v)
+			cloudInitType = "configdrive"
+		} else if isreg && c.Name() == "network-config" {
+			if cloudInitType != "" {
+				return fmt.Errorf("found both network_data.json and network-config in %s; use only one", dir)
+			}
+			v, err := os.ReadFile(filepath.Join(dir, c.Name()))
+			if err != nil {
+				return errors.Wrapf(err, "reading %s", c.Name())
+			}
+			networkData = string(v)
+			cloudInitType = "nocloud"
 		} else if c.IsDir() && c.Name() == kolaExtBinDataName {
 			dependencydir = filepath.Join(dir, c.Name())
 		} else if c.Mode()&os.ModeSymlink != 0 && c.Name() == kolaExtBinDataName {
@@ -1427,7 +1456,7 @@ func registerTestDir(dir, testprefix string, children []os.DirEntry) error {
 			continue
 		}
 
-		err := registerExternalTest(testname, executable, dependencydir, userdata, meta)
+		err := registerExternalTest(testname, executable, dependencydir, userdata, meta, networkData, cloudInitType)
 		if err != nil {
 			return err
 		}
@@ -1870,6 +1899,8 @@ func runTest(h *harness.H, t *register.Test, pltfrm string, flight platform.Flig
 			AppendFirstbootKernelArgs: t.AppendFirstbootKernelArgs,
 			SkipStartMachine:          true,
 			InstanceType:              t.InstanceType,
+			CloudInitType:             t.CloudInitType,
+			NetworkData:               t.NetworkData,
 		}
 
 		if testSecureBoot(t) {

mantle/kola/register/register.go

@@ -128,6 +128,15 @@ type Test struct {
 	// If provided, this test will be run on the target instance type.
 	// This overrides the instance type set with `kola run`
 	InstanceType string
+
+	// CloudInitType specifies the cloud-init volume type (kubevirt-only):
+	// "configdrive" or "nocloud". Auto-detected from network data filename:
+	// network_data.json -> configdrive, network-config -> nocloud.
+	CloudInitType string
+
+	// NetworkData is network configuration passed to the cloud-init volume
+	// (kubevirt-only). Format depends on CloudInitType.
+	NetworkData string
 }
 
 // Registered tests that run as part of `kola run` live here. Mapping of names

mantle/kola/tests/metadata/contents.go

@@ -19,11 +19,11 @@ import (
 
 	"github.com/coreos/coreos-assembler/mantle/kola/cluster"
 	"github.com/coreos/coreos-assembler/mantle/kola/register"
+	"github.com/coreos/coreos-assembler/mantle/platform"
 	"github.com/coreos/coreos-assembler/mantle/platform/conf"
 )
 
-func init() {
-	enableMetadataService := conf.Ignition(`{
+var enableMetadataService = conf.Ignition(`{
 		"ignition": {"version": "3.0.0"},
 		"systemd": {
 			"units": [{
@@ -37,6 +37,8 @@ func init() {
 		}
 	}`)
 
+func init() {
+
 	register.RegisterTest(&register.Test{
 		Name:        "fcos.metadata.aws",
 		Description: "Verify the metadata on AWS.",
@@ -56,6 +58,24 @@ func init() {
 		UserData:    enableMetadataService,
 		Distros:     []string{"fcos"},
 	})
+
+	register.RegisterTest(&register.Test{
+		Name:        "fcos.metadata.kubevirt.configdrive",
+		Description: "Verify afterburn metadata on KubeVirt with ConfigDrive.",
+		Run:         verifyKubeVirtConfigDrive,
+		ClusterSize: 0,
+		Platforms:   []string{"kubevirt"},
+		Distros:     []string{"fcos"},
+	})
+
+	register.RegisterTest(&register.Test{
+		Name:        "fcos.metadata.kubevirt.nocloud",
+		Description: "Verify afterburn metadata on KubeVirt with NoCloud.",
+		Run:         verifyKubeVirtNoCloud,
+		ClusterSize: 0,
+		Platforms:   []string{"kubevirt"},
+		Distros:     []string{"fcos"},
+	})
 }
 
 func verifyAWS(c cluster.TestCluster) {
@@ -68,6 +88,28 @@ func verifyAzure(c cluster.TestCluster) {
 	// which is required for AFTERBURN_AZURE_IPV4_VIRTUAL to be present
 }
 
+func verifyKubeVirtConfigDrive(c cluster.TestCluster) {
+	opts := platform.MachineOptions{
+		CloudInitType: "configdrive",
+	}
+	_, err := c.NewMachineWithOptions(enableMetadataService, opts)
+	if err != nil {
+		c.Fatalf("Unable to create machine: %v", err)
+	}
+	verify(c, "AFTERBURN_KUBEVIRT_INSTANCE_ID", "AFTERBURN_KUBEVIRT_HOSTNAME")
+}
+
+func verifyKubeVirtNoCloud(c cluster.TestCluster) {
+	opts := platform.MachineOptions{
+		CloudInitType: "nocloud",
+	}
+	_, err := c.NewMachineWithOptions(enableMetadataService, opts)
+	if err != nil {
+		c.Fatalf("Unable to create machine: %v", err)
+	}
+	verify(c, "AFTERBURN_KUBEVIRT_INSTANCE_ID", "AFTERBURN_KUBEVIRT_HOSTNAME")
+}
+
 func verify(c cluster.TestCluster, keys ...string) {
 	m := c.Machines()[0]