Upload populator

cmd/cdi-controller/controller.go

@@ -276,6 +276,10 @@ func start() {
 		klog.Errorf("Unable to setup import populator: %v", err)
 		os.Exit(1)
 	}
+	if _, err := populators.NewUploadPopulator(ctx, mgr, log, installerLabels); err != nil {
+		klog.Errorf("Unable to setup upload populator: %v", err)
+		os.Exit(1)
+	}
 
 	klog.V(1).Infoln("created cdi controllers")
 

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

@@ -14,6 +14,7 @@ go_library(
         "objecttransfer.go",
         "storageprofile.go",
         "volumeimportsource.go",
+        "volumeuploadsource.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

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