Skip to content

Commit d2200cd

Browse files
committed
feat: improve logging
1 parent a6fba69 commit d2200cd

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

controllers/database_controller.go

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -48,12 +48,13 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
4848
return ctrl.Result{}, nil
4949
}
5050
// Error reading the object - requeue the request.
51-
log.Error(err, "Failed to get Database")
51+
log.Error(err, "Failed to get database resource")
5252
return ctrl.Result{}, err
5353
}
5454

5555
db, err := r.getDatabaseConnection(ctx, database.Spec.Type)
5656
if err != nil {
57+
log.Error(err, "Failed to detect and open database connection")
5758
return ctrl.Result{}, err
5859
}
5960

@@ -63,6 +64,7 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
6364

6465
hasDatabase, err := db.HasDatabase(ctx, database.Spec.Database)
6566
if err != nil {
67+
log.Error(err, "Couldn't check if database exists")
6668
return ctrl.Result{}, err
6769
}
6870

@@ -71,12 +73,14 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
7173

7274
err = db.CreateDatabase(ctx, database.Spec.Database)
7375
if err != nil {
76+
log.Error(err, "Can't create database")
7477
return ctrl.Result{}, err
7578
}
7679
}
7780

7881
hasDatabaseUserWithAccess, err := db.HasDatabaseUserWithAccess(ctx, database.Spec.Username, database.Spec.Database)
7982
if err != nil {
83+
log.Error(err, "Can't check if user has access to database")
8084
return ctrl.Result{}, err
8185
}
8286

@@ -85,6 +89,7 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
8589

8690
err = db.CreateDatabaseUser(ctx, database.Spec.Username, database.Spec.Password, database.Spec.Database)
8791
if err != nil {
92+
log.Error(err, "Can't create database user with access to database")
8893
return ctrl.Result{}, err
8994
}
9095
}
@@ -100,6 +105,7 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
100105
// finalization logic fails, don't remove the finalizer so
101106
// that we can retry during the next reconciliation.
102107
if err := r.finalizeDatabase(ctx, log, database); err != nil {
108+
log.Error(err, "Can't create finalizer for database")
103109
return ctrl.Result{}, err
104110
}
105111

@@ -108,6 +114,7 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
108114
controllerutil.RemoveFinalizer(database, databaseFinalizer)
109115
err := r.Update(ctx, database)
110116
if err != nil {
117+
log.Error(err, "Can't remove finalizers of database")
111118
return ctrl.Result{}, err
112119
}
113120
}
@@ -116,7 +123,8 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
116123

117124
// Add finalizer for this CR
118125
if !contains(database.GetFinalizers(), databaseFinalizer) {
119-
if err := r.addFinalizer(log, database); err != nil {
126+
if err := r.addFinalizer(ctx, log, database); err != nil {
127+
log.Error(err, "Can't add finalizer to this custom-resource (database)")
120128
return ctrl.Result{}, err
121129
}
122130
}
@@ -205,12 +213,12 @@ func (r *DatabaseReconciler) finalizeDatabase(ctx context.Context, log logr.Logg
205213
return nil
206214
}
207215

208-
func (r *DatabaseReconciler) addFinalizer(log logr.Logger, m *anbratengithubiov1alpha1.Database) error {
216+
func (r *DatabaseReconciler) addFinalizer(ctx context.Context, log logr.Logger, m *anbratengithubiov1alpha1.Database) error {
209217
log.Info("Adding Finalizer for the database")
210218
controllerutil.AddFinalizer(m, databaseFinalizer)
211219

212220
// Update CR
213-
err := r.Update(context.TODO(), m)
221+
err := r.Update(ctx, m)
214222
if err != nil {
215223
log.Error(err, "Failed to update database with finalizer")
216224
return err

0 commit comments

Comments
 (0)