forklift: introduce forklift controller

Signed-off-by: Benny Zlotnik <bzlotnik@redhat.com>
kubevirt · Nov 23, 2023 · c0397fe · c0397fe
1 parent 283fb96
commit c0397fe
Show file tree

Hide file tree

Showing 5 changed files with 763 additions and 0 deletions.
diff --git a/cmd/cdi-controller/BUILD.bazel b/cmd/cdi-controller/BUILD.bazel
@@ -16,6 +16,7 @@ go_library(
         "//pkg/util/cert/fetcher:go_default_library",
         "//pkg/util/cert/generator:go_default_library",
         "//staging/src/kubevirt.io/containerized-data-importer-api/pkg/apis/core/v1beta1:go_default_library",
+        "//staging/src/kubevirt.io/containerized-data-importer-api/pkg/apis/forklift/v1beta1:go_default_library",
         "//vendor/github.com/kelseyhightower/envconfig:go_default_library",
         "//vendor/github.com/kubernetes-csi/external-snapshotter/client/v6/apis/volumesnapshot/v1:go_default_library",
         "//vendor/github.com/openshift/api/config/v1:go_default_library",

diff --git a/cmd/cdi-controller/controller.go b/cmd/cdi-controller/controller.go
@@ -33,6 +33,8 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/metrics"
 
 	cdiv1 "kubevirt.io/containerized-data-importer-api/pkg/apis/core/v1beta1"
+	forklift "kubevirt.io/containerized-data-importer-api/pkg/apis/forklift/v1beta1"
+
 	"kubevirt.io/containerized-data-importer/pkg/common"
 	"kubevirt.io/containerized-data-importer/pkg/controller"
 	dvc "kubevirt.io/containerized-data-importer/pkg/controller/datavolume"
@@ -66,6 +68,7 @@ var (
 		cdiv1.AddToScheme,
 		extv1.AddToScheme,
 		snapshotv1.AddToScheme,
+		forklift.AddToScheme,
 		imagev1.Install,
 		ocpconfigv1.Install,
 		routev1.Install,
@@ -285,6 +288,10 @@ func start() {
 		klog.Errorf("Unable to setup clone populator: %v", err)
 		os.Exit(1)
 	}
+	if _, err := populators.NewForkliftPopulator(ctx, mgr, log, importerImage, installerLabels); err != nil {
+		klog.Errorf("Unable to setup forklift populator: %v", err)
+		os.Exit(1)
+	}
 
 	klog.V(1).Infoln("created cdi controllers")
 

diff --git a/pkg/controller/populators/BUILD.bazel b/pkg/controller/populators/BUILD.bazel
@@ -4,6 +4,7 @@ go_library(
     name = "go_default_library",
     srcs = [
         "clone-populator.go",
+        "forklift-populator.go",
         "import-populator.go",
         "populator-base.go",
         "upload-populator.go",
@@ -18,6 +19,7 @@ go_library(
         "//pkg/feature-gates:go_default_library",
         "//pkg/util:go_default_library",
         "//staging/src/kubevirt.io/containerized-data-importer-api/pkg/apis/core/v1beta1:go_default_library",
+        "//staging/src/kubevirt.io/containerized-data-importer-api/pkg/apis/forklift/v1beta1:go_default_library",
         "//vendor/github.com/go-logr/logr:go_default_library",
         "//vendor/github.com/pkg/errors:go_default_library",
         "//vendor/k8s.io/api/core/v1:go_default_library",