clone populator

only supports PVC source now

snapshot coming soon

Signed-off-by: Michael Henriksen <mhenriks@redhat.com>

cluster-sync/clean.sh

@@ -44,6 +44,13 @@ _kubectl get dataimportcron --all-namespaces -o=custom-columns=NAME:.metadata.na
     _kubectl patch dataimportcron $name -n $namespace --type=json -p '[{ "op": "remove", "path": "/metadata/finalizers" }]'
 done
 
+_kubectl get pvc --all-namespaces -o=custom-columns=NAME:.metadata.name,NAMESPACE:.metadata.namespace,FINALIZERS:.metadata.finalizers --no-headers | grep cdi.kubevirt.io/clonePopulator | while read p; do
+    arr=($p)
+    name="${arr[0]}"
+    namespace="${arr[1]}"
+    _kubectl patch pvc $name -n $namespace --type=json -p '[{ "op": "remove", "path": "/metadata/finalizers" }]'
+done
+
 if [ -f "${OPERATOR_CR_MANIFEST}" ]; then
 	echo "Cleaning CR object ..."
     if _kubectl get crd cdis.cdi.kubevirt.io ; then

cmd/cdi-controller/controller.go

@@ -280,6 +280,10 @@ func start() {
 		klog.Errorf("Unable to setup upload populator: %v", err)
 		os.Exit(1)
 	}
+	if _, err := populators.NewClonePopulator(ctx, mgr, log, clonerImage, pullPolicy, 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",
+        "volumeclonesource.go",
         "volumeimportsource.go",
         "volumeuploadsource.go",
     ],

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_volumeclonesource.go",
         "fake_volumeimportsource.go",
         "fake_volumeuploadsource.go",
     ],