forked from kubernetes-sigs/aws-load-balancer-controller
/
reconcile.go
28 lines (23 loc) · 827 Bytes
/
reconcile.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
package runtime
import (
"github.com/go-logr/logr"
"github.com/pkg/errors"
ctrl "sigs.k8s.io/controller-runtime"
)
// HandleReconcileError will handle errors from reconcile handlers, which respects runtime errors.
func HandleReconcileError(err error, log logr.Logger) (ctrl.Result, error) {
if err == nil {
return ctrl.Result{}, nil
}
var requeueNeededAfter *RequeueNeededAfter
if errors.As(err, &requeueNeededAfter) {
log.V(1).Info("requeue after", "duration", requeueNeededAfter.Duration(), "reason", requeueNeededAfter.Reason())
return ctrl.Result{RequeueAfter: requeueNeededAfter.Duration()}, nil
}
var requeueNeeded *RequeueNeeded
if errors.As(err, &requeueNeeded) {
log.V(1).Info("requeue", "reason", requeueNeeded.Reason())
return ctrl.Result{Requeue: true}, nil
}
return ctrl.Result{}, err
}