Enable status subresource for integration

deploy/crd-integration.yaml

@@ -8,6 +8,8 @@ spec:
   group: camel.apache.org
   scope: Namespaced
   version: v1alpha1
+  subresources:
+    status: {}
   names:
     kind: Integration
     listKind: IntegrationList

pkg/controller/integration/build_context.go

@@ -66,7 +66,7 @@ func (action *buildContextAction) Handle(ctx context.Context, integration *v1alp
 				// with a context
 				target := integration.DeepCopy()
 				target.Status.Context = ""
-				return action.client.Update(ctx, target)
+				return action.client.Status().Update(ctx, target)
 			}
 		}
 
@@ -83,7 +83,7 @@ func (action *buildContextAction) Handle(ctx context.Context, integration *v1alp
 
 			logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-			return action.client.Update(ctx, target)
+			return action.client.Status().Update(ctx, target)
 		}
 
 		if ictx.Status.Phase == v1alpha1.IntegrationContextPhaseReady {
@@ -104,14 +104,14 @@ func (action *buildContextAction) Handle(ctx context.Context, integration *v1alp
 
 			logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-			return action.client.Update(ctx, target)
+			return action.client.Status().Update(ctx, target)
 		}
 
 		if integration.Status.Context == "" {
 			// We need to set the context
 			target := integration.DeepCopy()
 			target.Status.Context = ictx.Name
-			return action.client.Update(ctx, target)
+			return action.client.Status().Update(ctx, target)
 		}
 
 		return nil
@@ -145,5 +145,5 @@ func (action *buildContextAction) Handle(ctx context.Context, integration *v1alp
 	target := integration.DeepCopy()
 	target.Status.Context = platformCtxName
 
-	return action.client.Update(ctx, target)
+	return action.client.Status().Update(ctx, target)
 }

pkg/controller/integration/build_image.go

@@ -146,7 +146,7 @@ func (action *buildImageAction) handleBuildStateChange(ctx context.Context, res
 
 		logrus.Infof("Integration %s transitioning to state %s, reason: %s", target.Name, target.Status.Phase, res.Error.Error())
 
-		return action.client.Update(ctx, target)
+		return action.client.Status().Update(ctx, target)
 	case builder.StatusCompleted:
 		target.Status.Phase = v1alpha1.IntegrationPhaseDeploying
 		if res.PublicImage != "" {
@@ -164,7 +164,7 @@ func (action *buildImageAction) handleBuildStateChange(ctx context.Context, res
 
 		logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-		if err := action.client.Update(ctx, target); err != nil {
+		if err := action.client.Status().Update(ctx, target); err != nil {
 			return err
 		}
 	}

pkg/controller/integration/build_image_failure_recovery.go

@@ -68,7 +68,7 @@ func (action *errorRecoveryAction) Handle(ctx context.Context, integration *v1al
 
 		logrus.Infof("Max recovery attempt reached for integration %s, transition to phase %s", integration.Name, string(target.Status.Phase))
 
-		return action.client.Update(ctx, target)
+		return action.client.Status().Update(ctx, target)
 	}
 
 	if integration.Status.Failure != nil {
@@ -97,7 +97,7 @@ func (action *errorRecoveryAction) Handle(ctx context.Context, integration *v1al
 			target.Status.Failure.Recovery.AttemptMax,
 		)
 
-		return action.client.Update(ctx, target)
+		return action.client.Status().Update(ctx, target)
 	}
 
 	return nil

pkg/controller/integration/deploy.go

@@ -75,5 +75,5 @@ func (action *deployAction) Handle(ctx context.Context, integration *v1alpha1.In
 	target.Status.Phase = v1alpha1.IntegrationPhaseRunning
 	logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-	return action.client.Update(ctx, target)
+	return action.client.Status().Update(ctx, target)
 }

pkg/controller/integration/initialize.go

@@ -62,7 +62,7 @@ func (action *initializeAction) Handle(ctx context.Context, integration *v1alpha
 
 			logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-			return action.client.Update(ctx, target)
+			return action.client.Status().Update(ctx, target)
 		}
 
 		return nil
@@ -74,15 +74,15 @@ func (action *initializeAction) Handle(ctx context.Context, integration *v1alpha
 	}
 
 	//
-	// restore phase to initial phase ase traits are not aware of
+	// restore phase to initial phase as traits are not aware of
 	// WaitingForPlatform phase
 	//
 	if integration.Status.Phase == v1alpha1.IntegrationPhaseWaitingForPlatform {
 		target := integration.DeepCopy()
 		target.Status.Phase = v1alpha1.IntegrationPhaseInitial
 		target.Status.Digest = dgst
 
-		return action.client.Update(ctx, target)
+		return action.client.Status().Update(ctx, target)
 	}
 
 	// better not changing the spec section of the target because it may be used for comparison by a
@@ -109,5 +109,5 @@ func (action *initializeAction) Handle(ctx context.Context, integration *v1alpha
 
 	logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-	return action.client.Update(ctx, target)
+	return action.client.Status().Update(ctx, target)
 }

pkg/controller/integration/monitor.go

@@ -59,7 +59,7 @@ func (action *monitorAction) Handle(ctx context.Context, integration *v1alpha1.I
 
 		logrus.Info("Integration ", target.Name, " transitioning to state ", target.Status.Phase)
 
-		return action.client.Update(ctx, target)
+		return action.client.Status().Update(ctx, target)
 	}
 
 	// TODO check also if deployment matches (e.g. replicas)