Skip to content

Commit fbb977a

Browse files
chore(controller): Make controller logic consistent
Signed-off-by: Mathieu Cesbron <[email protected]>
1 parent 74a6eb6 commit fbb977a

3 files changed

+29
-31
lines changed

controllers/certificate_lifecycle_controller.go

+15-14
Original file line numberDiff line numberDiff line change
@@ -35,28 +35,29 @@ type CertificateLifecycle struct {
3535
}
3636

3737
func (s *CertificateLifecycle) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error) {
38-
logger := log.FromContext(ctx)
38+
log := log.FromContext(ctx)
3939

40-
logger.Info("starting CertificateLifecycle handling")
40+
log.Info("starting CertificateLifecycle handling")
4141

4242
secret := corev1.Secret{}
43-
if err := s.client.Get(ctx, request.NamespacedName, &secret); err != nil {
44-
if k8serrors.IsNotFound(err) {
45-
logger.Info("resource may have been deleted, skipping")
46-
47-
return reconcile.Result{}, nil
48-
}
43+
err := s.client.Get(ctx, request.NamespacedName, &secret)
44+
if k8serrors.IsNotFound(err) {
45+
log.Info("resource have been deleted, skipping")
46+
return reconcile.Result{}, nil
47+
}
48+
if err != nil {
49+
log.Error(err, "cannot retrieve the required resource")
50+
return reconcile.Result{}, err
4951
}
5052

5153
checkType, ok := secret.GetLabels()[constants.ControllerLabelResource]
5254
if !ok {
53-
logger.Info("missing controller label, shouldn't happen")
55+
log.Info("missing controller label, shouldn't happen")
5456

5557
return reconcile.Result{}, nil
5658
}
5759

5860
var crt *x509.Certificate
59-
var err error
6061

6162
switch checkType {
6263
case "x509":
@@ -68,15 +69,15 @@ func (s *CertificateLifecycle) Reconcile(ctx context.Context, request reconcile.
6869
}
6970

7071
if err != nil {
71-
logger.Error(err, "skipping reconciliation")
72+
log.Error(err, "skipping reconciliation")
7273

7374
return reconcile.Result{}, nil
7475
}
7576

7677
deadline := time.Now().AddDate(0, 0, 1)
7778

7879
if deadline.After(crt.NotAfter) {
79-
logger.Info("certificate near expiration, must be rotated")
80+
log.Info("certificate near expiration, must be rotated")
8081

8182
s.Channel <- event.GenericEvent{Object: &kamajiv1alpha1.TenantControlPlane{
8283
ObjectMeta: metav1.ObjectMeta{
@@ -85,14 +86,14 @@ func (s *CertificateLifecycle) Reconcile(ctx context.Context, request reconcile.
8586
},
8687
}}
8788

88-
logger.Info("certificate rotation triggered")
89+
log.Info("certificate rotation triggered")
8990

9091
return reconcile.Result{}, nil
9192
}
9293

9394
after := crt.NotAfter.Sub(deadline)
9495

95-
logger.Info("certificate is still valid, enqueuing back", "after", after.String())
96+
log.Info("certificate is still valid, enqueuing back", "after", after.String())
9697

9798
return reconcile.Result{Requeue: true, RequeueAfter: after}, nil
9899
}

controllers/datastore_controller.go

+7-7
Original file line numberDiff line numberDiff line change
@@ -39,13 +39,13 @@ func (r *DataStore) Reconcile(ctx context.Context, request reconcile.Request) (r
3939
log := log.FromContext(ctx)
4040

4141
ds := &kamajiv1alpha1.DataStore{}
42-
if err := r.Client.Get(ctx, request.NamespacedName, ds); err != nil {
43-
if k8serrors.IsNotFound(err) {
44-
return reconcile.Result{}, nil
45-
}
46-
47-
log.Error(err, "unable to retrieve the request")
48-
42+
err := r.Client.Get(ctx, request.NamespacedName, ds)
43+
if k8serrors.IsNotFound(err) {
44+
log.Info("resource have been deleted, skipping")
45+
return reconcile.Result{}, nil
46+
}
47+
if err != nil {
48+
log.Error(err, "cannot retrieve the required resource")
4949
return reconcile.Result{}, err
5050
}
5151

controllers/tenantcontrolplane_controller.go

+7-10
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import (
1515
batchv1 "k8s.io/api/batch/v1"
1616
corev1 "k8s.io/api/core/v1"
1717
networkingv1 "k8s.io/api/networking/v1"
18-
apimachineryerrors "k8s.io/apimachinery/pkg/api/errors"
18+
k8serrors "k8s.io/apimachinery/pkg/api/errors"
1919
k8stypes "k8s.io/apimachinery/pkg/types"
2020
"k8s.io/client-go/util/workqueue"
2121
"k8s.io/utils/clock"
@@ -84,16 +84,13 @@ func (r *TenantControlPlaneReconciler) Reconcile(ctx context.Context, req ctrl.R
8484
defer cancelFn()
8585

8686
tenantControlPlane, err := r.getTenantControlPlane(ctx, req.NamespacedName)()
87+
if k8serrors.IsNotFound(err) {
88+
log.Info("resource have been deleted, skipping")
89+
return reconcile.Result{}, nil
90+
}
8791
if err != nil {
88-
if apimachineryerrors.IsNotFound(err) {
89-
log.Info("resource may have been deleted, skipping")
90-
91-
return ctrl.Result{}, nil
92-
}
93-
94-
log.Error(err, "cannot retrieve the required instance")
95-
96-
return ctrl.Result{}, err
92+
log.Error(err, "cannot retrieve the required resource")
93+
return reconcile.Result{}, err
9794
}
9895

9996
releaser, err := mutex.Acquire(r.mutexSpec(tenantControlPlane))

0 commit comments

Comments
 (0)