bucket: Replace GetInterval() with GetRequeueAfter()
Signed-off-by: Sunny <darkowlzz@protonmail.com>
This commit is contained in:
parent
1e6f4d9a70
commit
66a074778d
|
@ -171,10 +171,10 @@ func (r *BucketReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
|
||||||
|
|
||||||
log.Info(fmt.Sprintf("Reconciliation finished in %s, next run in %s",
|
log.Info(fmt.Sprintf("Reconciliation finished in %s, next run in %s",
|
||||||
time.Since(start).String(),
|
time.Since(start).String(),
|
||||||
bucket.GetInterval().Duration.String(),
|
bucket.GetRequeueAfter().String(),
|
||||||
))
|
))
|
||||||
|
|
||||||
return ctrl.Result{RequeueAfter: bucket.GetInterval().Duration}, nil
|
return ctrl.Result{RequeueAfter: bucket.GetRequeueAfter()}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *BucketReconciler) reconcile(ctx context.Context, bucket sourcev1.Bucket) (sourcev1.Bucket, error) {
|
func (r *BucketReconciler) reconcile(ctx context.Context, bucket sourcev1.Bucket) (sourcev1.Bucket, error) {
|
||||||
|
|
Loading…
Reference in New Issue