Add data download controller

Signed-off-by: Ming <mqiu@vmware.com>

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 {