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 21, 2023 · 5f45cec · 5f45cec
1 parent 97ada38
commit 5f45cec
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,15 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
 			if ts != nil {
 				lastSyncTime := metav1.NewTime(ts.AsTime())
 				instance.Status.LastSyncTime = &lastSyncTime
+				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
@@ -219,8 +219,12 @@ func (rs *ReplicationServer) GetVolumeReplicationInfo(
 	if lastsynctime == nil {
 		klog.Errorf("Failed to get last sync time: %v", lastsynctime)
 	}
+	lastsyncduration := resp.GetLastSyncDuration()
+	lastsyncbytes := resp.GetLastSyncBytes()
 
 	return &proto.GetVolumeReplicationInfoResponse{
-		LastSyncTime: lastsynctime,
+		LastSyncTime:     lastsynctime,
+		LastSyncDuration: lastsyncduration,
+		LastSyncBytes:    lastsyncbytes,
 	}, nil
 }