(ctx context.Context, client client.Client, drPolicy *rmn.DRPolicy)
| 683 | duration := d.getRequeueDuration() |
| 684 | log.Info(fmt.Sprintf("Requeing after %v", duration)) |
| 685 | |
| 686 | return reconcile.Result{RequeueAfter: duration}, nil |
| 687 | } |
| 688 | |
| 689 | if requeue { |
| 690 | log.Info("Requeing...") |
| 691 | |
| 692 | return ctrl.Result{Requeue: true}, nil |
| 693 | } |
| 694 | |
| 695 | // Last status update time AFTER processing |
| 696 | var afterProcessing metav1.Time |
| 697 | if d.instance.Status.LastUpdateTime != nil { |
| 698 | afterProcessing = *d.instance.Status.LastUpdateTime |
| 699 | } |
| 700 | |
| 701 | requeueTimeDuration := r.getStatusCheckDelay(beforeProcessing, afterProcessing) |
| 702 | log.Info("Requeue time", "duration", requeueTimeDuration) |
| 703 | |
| 704 | return ctrl.Result{RequeueAfter: requeueTimeDuration}, nil |
no test coverage detected