Import populator

cmd/cdi-controller/BUILD.bazel

@@ -9,6 +9,7 @@ go_library(
         "//pkg/common:go_default_library",
         "//pkg/controller:go_default_library",
         "//pkg/controller/datavolume:go_default_library",
+        "//pkg/controller/populators:go_default_library",
         "//pkg/controller/transfer:go_default_library",
         "//pkg/util:go_default_library",
         "//pkg/util/cert:go_default_library",

cmd/cdi-controller/controller.go

@@ -35,6 +35,7 @@ import (
 	"kubevirt.io/containerized-data-importer/pkg/common"
 	"kubevirt.io/containerized-data-importer/pkg/controller"
 	dvc "kubevirt.io/containerized-data-importer/pkg/controller/datavolume"
+	"kubevirt.io/containerized-data-importer/pkg/controller/populators"
 	"kubevirt.io/containerized-data-importer/pkg/controller/transfer"
 	"kubevirt.io/containerized-data-importer/pkg/util"
 	"kubevirt.io/containerized-data-importer/pkg/util/cert"
@@ -266,6 +267,15 @@ func start() {
 		klog.Errorf("Unable to setup datasource controller: %v", err)
 		os.Exit(1)
 	}
+	// Populator controllers and indexes
+	if err := populators.CreateCommonPopulatorIndexes(mgr); err != nil {
+		klog.Errorf("Unable to create common populator indexes: %v", err)
+		os.Exit(1)
+	}
+	if _, err := populators.NewImportPopulator(ctx, mgr, log, installerLabels); err != nil {
+		klog.Errorf("Unable to setup import populator: %v", err)
+		os.Exit(1)
+	}
 
 	klog.V(1).Infoln("created cdi controllers")
 

pkg/client/clientset/versioned/typed/core/v1beta1/BUILD.bazel

@@ -13,6 +13,7 @@ go_library(
         "generated_expansion.go",
         "objecttransfer.go",
         "storageprofile.go",
+        "volumeimportsource.go",
     ],
     importpath = "kubevirt.io/containerized-data-importer/pkg/client/clientset/versioned/typed/core/v1beta1",
     visibility = ["//visibility:public"],

pkg/client/clientset/versioned/typed/core/v1beta1/fake/BUILD.bazel

@@ -12,6 +12,7 @@ go_library(
         "fake_datavolume.go",
         "fake_objecttransfer.go",
         "fake_storageprofile.go",
+        "fake_volumeimportsource.go",
     ],
     importpath = "kubevirt.io/containerized-data-importer/pkg/client/clientset/versioned/typed/core/v1beta1/fake",
     visibility = ["//visibility:public"],