Add data download controller

changelogs/unreleased/6436-qiuming-best

@@ -0,0 +1 @@
+Add data download controller for data mover

pkg/builder/data_download_builder.go

@@ -0,0 +1,103 @@
+/*
+Copyright The Velero Contributors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package builder
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	velerov2alpha1api "github.com/vmware-tanzu/velero/pkg/apis/velero/v2alpha1"
+)
+
+// DataDownloadBuilder builds DataDownload objects
+type DataDownloadBuilder struct {
+	object *velerov2alpha1api.DataDownload
+}
+
+// ForDataDownload is the constructor for a DataDownloadBuilder.
+func ForDataDownload(ns, name string) *DataDownloadBuilder {
+	return &DataDownloadBuilder{
+		object: &velerov2alpha1api.DataDownload{
+			TypeMeta: metav1.TypeMeta{
+				APIVersion: velerov2alpha1api.SchemeGroupVersion.String(),
+				Kind:       "DataDownloadload",
+			},
+			ObjectMeta: metav1.ObjectMeta{
+				Namespace: ns,
+				Name:      name,
+			},
+		},
+	}
+}
+
+// Result returns the built DataDownload.
+func (d *DataDownloadBuilder) Result() *velerov2alpha1api.DataDownload {
+	return d.object
+}
+
+// BackupStorageLocation sets the DataDownload's backup storage location.
+func (d *DataDownloadBuilder) BackupStorageLocation(name string) *DataDownloadBuilder {
+	d.object.Spec.BackupStorageLocation = name
+	return d
+}
+
+// Phase sets the DataDownload's phase.
+func (d *DataDownloadBuilder) Phase(phase velerov2alpha1api.DataDownloadPhase) *DataDownloadBuilder {
+	d.object.Status.Phase = phase
+	return d
+}
+
+// SnapshotID sets the DataDownload's SnapshotID.
+func (d *DataDownloadBuilder) SnapshotID(id string) *DataDownloadBuilder {
+	d.object.Spec.SnapshotID = id
+	return d
+}
+
+// DataMover sets the DataDownload's DataMover.
+func (d *DataDownloadBuilder) DataMover(dataMover string) *DataDownloadBuilder {
+	d.object.Spec.DataMover = dataMover
+	return d
+}
+
+// SourceNamespace sets the DataDownload's SourceNamespace.
+func (d *DataDownloadBuilder) SourceNamespace(sourceNamespace string) *DataDownloadBuilder {
+	d.object.Spec.SourceNamespace = sourceNamespace
+	return d
+}
+
+// TargetVolume sets the DataDownload's TargetVolume.
+func (d *DataDownloadBuilder) TargetVolume(targetVolume velerov2alpha1api.TargetVolumeSpec) *DataDownloadBuilder {
+	d.object.Spec.TargetVolume = targetVolume
+	return d
+}
+
+// Cancel sets the DataDownload's Cancel.
+func (d *DataDownloadBuilder) Cancel(cancel bool) *DataDownloadBuilder {
+	d.object.Spec.Cancel = cancel
+	return d
+}
+
+// OperationTimeout sets the DataDownload's OperationTimeout.
+func (d *DataDownloadBuilder) OperationTimeout(timeout metav1.Duration) *DataDownloadBuilder {
+	d.object.Spec.OperationTimeout = timeout
+	return d
+}
+
+// DataMoverConfig sets the DataDownload's DataMoverConfig.
+func (d *DataDownloadBuilder) DataMoverConfig(config *map[string]string) *DataDownloadBuilder {
+	d.object.Spec.DataMoverConfig = *config
+	return d
+}

pkg/cmd/cli/nodeagent/server.go

@@ -260,6 +260,10 @@ func (s *nodeAgentServer) run() {
 		s.logger.WithError(err).Fatal("Unable to create the data upload controller")
 	}
 
+	if err = controller.NewDataDownloadReconciler(s.mgr.GetClient(), s.kubeClient, repoEnsurer, credentialGetter, s.nodeName, s.logger).SetupWithManager(s.mgr); err != nil {
+		s.logger.WithError(err).Fatal("Unable to create the data download controller")
+	}
+
 	s.logger.Info("Controllers starting...")
 
 	if err := s.mgr.Start(ctrl.SetupSignalHandler()); err != nil {