replication: update reconcile logic

This commit updates the reconcile logic to get more info and update the volrep status. Signed-off-by: yati1998 <[email protected]>
csi-addons · Jun 22, 2023 · 9711c1f · 9711c1f
1 parent 0294ccd
commit 9711c1f
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/controllers/replication.storage/volumereplication_controller.go b/controllers/replication.storage/volumereplication_controller.go
@@ -380,6 +380,17 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
 			if ts != nil {
 				lastSyncTime := metav1.NewTime(ts.AsTime())
 				instance.Status.LastSyncTime = &lastSyncTime
+				instance.Status.LastSyncDuration = nil
+				instance.Status.LastSyncBytes = nil
+				td := info.GetLastSyncDuration()
+				if td != nil {
+					lastSyncDuration := metav1.Duration{Duration: td.AsDuration()}
+					instance.Status.LastSyncDuration = &lastSyncDuration
+				}
+				tb := info.GetLastSyncBytes()
+				if tb != 0 {
+					instance.Status.LastSyncBytes = &tb
+				}
 			}
 			requeueForInfo = true
 		} else if !util.IsUnimplementedError(err) {

diff --git a/internal/sidecar/service/volumereplication.go b/internal/sidecar/service/volumereplication.go
@@ -221,6 +221,8 @@ func (rs *ReplicationServer) GetVolumeReplicationInfo(
 	}
 
 	return &proto.GetVolumeReplicationInfoResponse{
-		LastSyncTime: lastsynctime,
+		LastSyncTime:     lastsynctime,
+		LastSyncDuration: resp.GetLastSyncDuration(),
+		LastSyncBytes:    resp.GetLastSyncBytes(),
 	}, nil
 }