add node name data mover CR

Signed-off-by: Lyndon-Li <lyonghui@vmware.com>

config/crd/v2alpha1/bases/velero.io_datadownloads.yaml

@@ -41,6 +41,10 @@ spec:
       jsonPath: .metadata.creationTimestamp
       name: Age
       type: date
+    - description: Name of the node where the DataDownload is processed
+      jsonPath: .status.node
+      name: Node
+      type: string
     name: v2alpha1
     schema:
       openAPIV3Schema:
@@ -132,6 +136,9 @@ spec:
               message:
                 description: Message is a message about the DataDownload's status.
                 type: string
+              node:
+                description: Node is name of the node where the DataDownload is processed.
+                type: string
               phase:
                 description: Phase is the current state of the DataDownload.
                 enum:

config/crd/v2alpha1/bases/velero.io_datauploads.yaml

@@ -42,6 +42,10 @@ spec:
       jsonPath: .metadata.creationTimestamp
       name: Age
       type: date
+    - description: Name of the node where the DataUpload is processed
+      jsonPath: .status.node
+      name: Node
+      type: string
     name: v2alpha1
     schema:
       openAPIV3Schema:
@@ -147,6 +151,9 @@ spec:
               message:
                 description: Message is a message about the DataUpload's status.
                 type: string
+              node:
+                description: Node is name of the node where the DataUpload is processed.
+                type: string
               path:
                 description: Path is the full path of the snapshot volume being backed
                   up.

pkg/apis/velero/v2alpha1/data_download_types.go

@@ -111,6 +111,10 @@ type DataDownloadStatus struct {
 	// about the restore operation.
 	// +optional
 	Progress shared.DataMoveOperationProgress `json:"progress,omitempty"`
+
+	// Node is name of the node where the DataDownload is processed.
+	// +optional
+	Node string `json:"node,omitempty"`
 }
 
 // TODO(2.0) After converting all resources to use the runtime-controller client, the genclient and k8s:deepcopy markers will no longer be needed and should be removed.
@@ -125,6 +129,7 @@ type DataDownloadStatus struct {
 // +kubebuilder:printcolumn:name="Total Bytes",type="integer",format="int64",JSONPath=".status.progress.totalBytes",description="Total bytes"
 // +kubebuilder:printcolumn:name="Storage Location",type="string",JSONPath=".spec.backupStorageLocation",description="Name of the Backup Storage Location where the backup data is stored"
 // +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="Time duration since this DataDownload was created"
+// +kubebuilder:printcolumn:name="Node",type="string",JSONPath=".status.node",description="Name of the node where the DataDownload is processed"
 
 type DataDownload struct {
 	metav1.TypeMeta `json:",inline"`

pkg/apis/velero/v2alpha1/data_upload_types.go

@@ -140,6 +140,10 @@ type DataUploadStatus struct {
 	// about the backup operation.
 	// +optional
 	Progress shared.DataMoveOperationProgress `json:"progress,omitempty"`
+
+	// Node is name of the node where the DataUpload is processed.
+	// +optional
+	Node string `json:"node,omitempty"`
 }
 
 // TODO(2.0) After converting all resources to use the runttime-controller client,
@@ -155,6 +159,7 @@ type DataUploadStatus struct {
 // +kubebuilder:printcolumn:name="Total Bytes",type="integer",format="int64",JSONPath=".status.progress.totalBytes",description="Total bytes"
 // +kubebuilder:printcolumn:name="Storage Location",type="string",JSONPath=".spec.backupStorageLocation",description="Name of the Backup Storage Location where this backup should be stored"
 // +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="Time duration since this DataUpload was created"
+// +kubebuilder:printcolumn:name="Node",type="string",JSONPath=".status.node",description="Name of the node where the DataUpload is processed"
 
 type DataUpload struct {
 	metav1.TypeMeta `json:",inline"`

pkg/controller/data_download_controller.go

@@ -400,7 +400,7 @@ func (r *DataDownloadReconciler) findSnapshotRestoreForPod(podObj client.Object)
 	requests := make([]reconcile.Request, 1)
 
 	r.logger.WithField("Restore pod", pod.Name).Infof("Preparing data download %s", dd.Name)
-	err = r.patchDataDownload(context.Background(), dd, prepareDataDownload)
+	err = r.patchDataDownload(context.Background(), dd, r.prepareDataDownload)
 	if err != nil {
 		r.logger.WithField("Restore pod", pod.Name).WithError(err).Error("unable to patch data download")
 		return []reconcile.Request{}
@@ -426,8 +426,9 @@ func (r *DataDownloadReconciler) patchDataDownload(ctx context.Context, req *vel
 	return nil
 }
 
-func prepareDataDownload(ssb *velerov2alpha1api.DataDownload) {
+func (r *DataDownloadReconciler) prepareDataDownload(ssb *velerov2alpha1api.DataDownload) {
 	ssb.Status.Phase = velerov2alpha1api.DataDownloadPhasePrepared
+	ssb.Status.Node = r.nodeName
 }
 
 func (r *DataDownloadReconciler) errorOut(ctx context.Context, dd *velerov2alpha1api.DataDownload, err error, msg string, log logrus.FieldLogger) (ctrl.Result, error) {

pkg/controller/data_upload_controller.go

@@ -416,7 +416,7 @@ func (r *DataUploadReconciler) findDataUploadForPod(podObj client.Object) []reco
 	}
 
 	r.logger.WithField("Backup pod", pod.Name).Infof("Preparing dataupload %s", du.Name)
-	if err := r.patchDataUpload(context.Background(), du, prepareDataUpload); err != nil {
+	if err := r.patchDataUpload(context.Background(), du, r.prepareDataUpload); err != nil {
 		r.logger.WithField("Backup pod", pod.Name).WithError(err).Error("failed to patch dataupload")
 		return []reconcile.Request{}
 	}
@@ -440,8 +440,9 @@ func (r *DataUploadReconciler) patchDataUpload(ctx context.Context, req *velerov
 	return nil
 }
 
-func prepareDataUpload(du *velerov2alpha1api.DataUpload) {
+func (r *DataUploadReconciler) prepareDataUpload(du *velerov2alpha1api.DataUpload) {
 	du.Status.Phase = velerov2alpha1api.DataUploadPhasePrepared
+	du.Status.Node = r.nodeName
 }
 
 func (r *DataUploadReconciler) errorOut(ctx context.Context, du *velerov2alpha1api.DataUpload, err error, msg string, log logrus.FieldLogger) (ctrl.Result, error) {