Skip to content

Commit

Permalink
fix: make sure to delay reconcile on all failures (#44)
Browse files Browse the repository at this point in the history
  • Loading branch information
diranged authored Nov 29, 2022
1 parent de38393 commit 1d4e6ac
Show file tree
Hide file tree
Showing 3 changed files with 24 additions and 8 deletions.
12 changes: 9 additions & 3 deletions controllers/exec_access_template_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,17 @@ func (r *ExecAccessTemplateReconciler) Reconcile(
// VERIFICATION: Make sure that the TargetRef is valid and points to an active controller
err = r.VerifyTargetRef(builder)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// VERIFICATION: Make sure the DefaultDuration and MaxDuration settings are valid
err = r.VerifyMiscSettings(builder)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// TODO:
Expand All @@ -96,7 +100,9 @@ func (r *ExecAccessTemplateReconciler) Reconcile(
// FINAL: Set Status.Ready state
err = r.setReadyStatus(ctx, resource)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}
return ctrl.Result{
RequeueAfter: time.Duration(r.ReconcililationInterval * int(time.Minute)),
Expand Down
8 changes: 6 additions & 2 deletions controllers/pod_access_request_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,9 @@ func (r *PodAccessRequestReconciler) Reconcile(
// VERIFICATION: Verifies the requested duration
err = r.verifyDuration(builder)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// VERIFICATION: Handle whether or not the access is expired at this point! If so, delete it.
Expand Down Expand Up @@ -143,7 +145,9 @@ func (r *PodAccessRequestReconciler) Reconcile(
// FINAL: Set Status.Ready state
err = r.setReadyStatus(ctx, resource)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// Exit Reconciliation Loop
Expand Down
12 changes: 9 additions & 3 deletions controllers/pod_access_template_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,17 @@ func (r *PodAccessTemplateReconciler) Reconcile(
// VERIFICATION: Make sure that the TargetRef is valid and points to an active controller
err = r.VerifyTargetRef(builder)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// VERIFICATION: Make sure the DefaultDuration and MaxDuration settings are valid
err = r.VerifyMiscSettings(builder)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}

// // TODO:
Expand All @@ -96,7 +100,9 @@ func (r *PodAccessTemplateReconciler) Reconcile(
// FINAL: Set Status.Ready state
err = r.setReadyStatus(ctx, resource)
if err != nil {
return ctrl.Result{}, err
return ctrl.Result{
RequeueAfter: time.Duration(time.Duration(ErrorReconciliationInterval) * time.Second),
}, err
}
return ctrl.Result{
RequeueAfter: time.Duration(r.ReconcililationInterval * int(time.Minute)),
Expand Down

0 comments on commit 1d4e6ac

Please sign in to comment.