cloud output: add logging of stages

grafana · May 13, 2022 · 9db5af6 · 9db5af6
1 parent 0a72b7c
commit 9db5af6
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 0 deletions.
diff --git a/controllers/k6_create.go b/controllers/k6_create.go
@@ -25,6 +25,7 @@ func CreateJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6Reco
 		return res, err
 	}
 
+	log.Info("Changing stage of K6 status to created")
 	k6.Status.Stage = "created"
 	if err = r.Client.Status().Update(ctx, k6); err != nil {
 		log.Error(err, "Could not update status of custom resource")

diff --git a/controllers/k6_finish.go b/controllers/k6_finish.go
@@ -77,6 +77,7 @@ func FinishJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6Reco
 		}
 	}
 
+	log.Info("Changing stage of K6 status to finished")
 	k6.Status.Stage = "finished"
 	if err = r.Client.Status().Update(ctx, k6); err != nil {
 		log.Error(err, "Could not update status of custom resource")

diff --git a/controllers/k6_initialize.go b/controllers/k6_initialize.go
@@ -35,6 +35,7 @@ var (
 func InitializeJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6Reconciler) (res ctrl.Result, err error) {
 	log.Info("Initialize test")
 
+	log.Info("Changing stage of K6 status to initialization")
 	k6.Status.Stage = "initialization"
 	if err = r.Client.Status().Update(ctx, k6); err != nil {
 		log.Error(err, "Could not update status of custom resource")
@@ -190,6 +191,7 @@ func InitializeJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6
 		return
 	}
 
+	log.Info("Changing stage of K6 status to initialized")
 	k6.Status.Stage = "initialized"
 	if err = r.Client.Status().Update(ctx, k6); err != nil {
 		log.Error(err, "Could not update status of custom resource")

diff --git a/controllers/k6_start.go b/controllers/k6_start.go
@@ -96,6 +96,7 @@ func StartJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6Recon
 		return ctrl.Result{}, err
 	}
 
+	log.Info("Changing stage of K6 status to started")
 	k6.Status.Stage = "started"
 	if err = r.Client.Status().Update(ctx, k6); err != nil {
 		log.Error(err, "Could not update status of custom resource")