feat(api): deprecate IntegrationPlatform

This is a prerequisite for next gen architecture of Camel K, where we aim to simplify the API.
From now on, the configuration which was previously part of the IntegrationPlatform custom resource, has to be configured as environment variable on the operator.

Ref #6454

Author: squakez

.github/workflows/common.yml

@@ -82,6 +82,35 @@ jobs:
       run: |
         DO_TEST_PREBUILD=false GOTESTFMT="-json 2>&1 | gotestfmt" make test-common
 
+  # This job will replace the previous one when we've settled any possible issue
+  # with IntegrationPlatform deprecation
+  common-platformless:
+    runs-on: ubuntu-latest
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v4
+      with:
+        persist-credentials: false
+        submodules: recursive
+
+    - name: Infra setting
+      uses: ./.github/actions/infra-setting
+
+    - name: Install operator
+      shell: bash
+      run: |
+        kubectl create ns camel-k
+        kubectl apply -k install/overlays/kubernetes/descoped/ --server-side --force-conflicts
+        kubectl wait --for=condition=available deployment/camel-k-operator -n camel-k --timeout=60s
+        # Install Apache Kamelets catalog
+        curl -sL "https://repo1.maven.org/maven2/org/apache/camel/kamelets/camel-kamelets/4.18.1/camel-kamelets-4.18.1.jar" > /tmp/camel-kamelets.jar
+        unzip /tmp/camel-kamelets.jar && kubectl apply -f /tmp/kamelets
+
+    - name: Run test
+      shell: bash
+      run: |
+        DO_TEST_PREBUILD=false GOTESTFMT="-json 2>&1 | gotestfmt" make test-common
+
   advanced:
     runs-on: ubuntu-latest
     steps:

build/Dockerfile

@@ -39,7 +39,7 @@ RUN tar -xC ${MVNW_DIR} -f ${MVNW_DIR}mvnw.tar \
 # Used by mvnw to download maven dist into it
 ENV MAVEN_USER_HOME="${MAVEN_HOME}"
 # Install a default mvnw distribution at build time
-RUN ${MVNW_DIR}/mvnw --version
+RUN ${MVNW_DIR}mvnw --version
 
 ADD build/_maven_output ${MVN_REPO}
 # Fix https://github.com/moby/moby/issues/37965
@@ -56,7 +56,7 @@ USER 1001:0
 
 ADD build/_output/bin/kamel-${IMAGE_ARCH} /usr/local/bin/kamel
 
-FROM golang:1.22 AS go
+FROM golang:1.25 AS go
 
 RUN go install github.com/go-delve/delve/cmd/dlv@latest
 

docs/modules/ROOT/partials/apis/camel-k-crds.adoc

@@ -2975,6 +2975,8 @@ the maximum amount of parallel running pipelines started by this operator instan
 
 IntegrationPlatformCluster is the kind of orchestration cluster the platform is installed into.
 
+Deprecated: no longer in use.
+
 
 [#_camel_apache_org_v1_IntegrationPlatformCondition]
 === IntegrationPlatformCondition

e2e/advanced/platform_traits_test.go

@@ -32,6 +32,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 
 	. "github.com/apache/camel-k/v2/e2e/support"
+	v1 "github.com/apache/camel-k/v2/pkg/apis/camel/v1"
 	"github.com/apache/camel-k/v2/pkg/util/defaults"
 	. "github.com/onsi/gomega"
 )
@@ -73,6 +74,8 @@ func TestHelmInstallation(t *testing.T) {
 		g.Expect(operatorPod.Spec.Containers[0].SecurityContext.SeccompProfile).To(Equal(DefaultOperatorSecurityContext().SeccompProfile))
 		g.Expect(operatorPod.Spec.Containers[0].SecurityContext.AllowPrivilegeEscalation).To(Equal(DefaultOperatorSecurityContext().AllowPrivilegeEscalation))
 
+		g.Eventually(PlatformPhase(t, ctx, ns)).Should(Equal(v1.IntegrationPlatformPhaseReady))
+
 		// Test a simple route
 		t.Run("simple route", func(t *testing.T) {
 			g.Expect(KamelRunWithID(t, ctx, operatorID, ns, "files/yaml.yaml").Execute()).To(Succeed())

e2e/install/helm/setup_test.go

@@ -31,6 +31,7 @@ import (
 	"sync"
 	"testing"
 
+	v1 "github.com/apache/camel-k/v2/pkg/apis/camel/v1"
 	. "github.com/onsi/gomega"
 	"github.com/onsi/gomega/gexec"
 	. "github.com/onsi/gomega/gstruct"
@@ -104,8 +105,9 @@ func InstallOperatorWithConf(t *testing.T, ctx context.Context, g *WithT, ns, op
 	ExpectExecSucceed(t, g,
 		Make(t, makeRule, args...),
 	)
-	// Let's make sure the operator has been deployed
+	// Let's make sure the operator has been deployed and the platform ready
 	g.Eventually(OperatorPod(t, ctx, ns)).ShouldNot(BeNil())
+	g.Eventually(PlatformPhase(t, ctx, ns)).Should(Equal(v1.IntegrationPlatformPhaseReady))
 }
 
 // UninstallOperator will delete operator resources from namespace (keeps CRDs).

e2e/support/test_util.go

@@ -63,6 +63,12 @@ spec:
               value: {{ .Values.operator.logLevel }}
             - name: OPERATOR_NAME
               value: camel-k
+            # NOTE: this value must be changed properly with a real
+            # container registry value. In development Minikube environment
+            # you can use constant "MINIKUBE" to dynamically look and load the
+            # registry add-on which has to be installed previously on the cluster.
+            - name: REGISTRY_ADDRESS
+              value: MINIKUBE
             - name: POD_NAME
               valueFrom:
                 fieldRef:

helm/camel-k/templates/operator-deployment.yaml

@@ -50,17 +50,6 @@ func (in *RuntimeSpec) CapabilityDependencies(capability string) []MavenArtifact
 	return deps
 }
 
-// TraitProfileByName returns the trait profile corresponding to the given name (case insensitive).
-func TraitProfileByName(name string) TraitProfile {
-	for _, p := range AllTraitProfiles {
-		if strings.EqualFold(name, string(p)) {
-			return p
-		}
-	}
-
-	return ""
-}
-
 // Equal checks if the profile is equal to the given profile (case insensitive).
 func (p TraitProfile) Equal(other TraitProfile) bool {
 	return strings.EqualFold(string(p), string(other))
@@ -289,3 +278,23 @@ func (s *SourceSpec) InferLanguage() Language {
 
 	return ""
 }
+
+// Validate checks if the strategy is supported.
+func (b BuildStrategy) Validate() error {
+	switch b {
+	case BuildStrategyRoutine, BuildStrategyPod:
+		return nil
+	default:
+		return fmt.Errorf("invalid BuildStrategy: %q", b)
+	}
+}
+
+// Validate checks if the strategy is supported.
+func (b BuildOrderStrategy) Validate() error {
+	switch b {
+	case BuildOrderStrategyDependencies, BuildOrderStrategyFIFO, BuildOrderStrategySequential:
+		return nil
+	default:
+		return fmt.Errorf("invalid BuildStrategy: %q", b)
+	}
+}

pkg/apis/camel/v1/common_types_support.go

@@ -190,3 +190,52 @@ func TestDecodeValueSourceInvalid(t *testing.T) {
 	}
 
 }
+
+func TestBuildStrategy_Validate(t *testing.T) {
+	tests := []struct {
+		name      string
+		input     BuildStrategy
+		wantError bool
+	}{
+		{"valid routine", BuildStrategyRoutine, false},
+		{"valid pod", BuildStrategyPod, false},
+		{"invalid strategy", BuildStrategy("wrong"), true},
+		{"empty strategy", BuildStrategy(""), true},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			err := tt.input.Validate()
+			if tt.wantError {
+				assert.Error(t, err)
+			} else {
+				assert.NoError(t, err)
+			}
+		})
+	}
+}
+
+func TestBuildOrderStrategy_Validate(t *testing.T) {
+	tests := []struct {
+		name      string
+		input     BuildOrderStrategy
+		wantError bool
+	}{
+		{"valid dependencies", BuildOrderStrategyDependencies, false},
+		{"valid fifo", BuildOrderStrategyFIFO, false},
+		{"valid sequential", BuildOrderStrategySequential, false},
+		{"invalid strategy", BuildOrderStrategy("wrong"), true},
+		{"empty strategy", BuildOrderStrategy(""), true},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			err := tt.input.Validate()
+			if tt.wantError {
+				assert.Error(t, err)
+			} else {
+				assert.NoError(t, err)
+			}
+		})
+	}
+}

pkg/apis/camel/v1/common_types_support_test.go

@@ -283,17 +283,6 @@ func (in *Integration) SetOperatorID(operatorID string) {
 	SetAnnotation(&in.ObjectMeta, OperatorIDAnnotation, operatorID)
 }
 
-func (in *Integration) SetIntegrationPlatform(platform *IntegrationPlatform) {
-	cs := corev1.ConditionTrue
-
-	if platform.Status.Phase != IntegrationPlatformPhaseReady {
-		cs = corev1.ConditionFalse
-	}
-
-	in.Status.SetCondition(IntegrationConditionPlatformAvailable, cs, IntegrationConditionPlatformAvailableReason, platform.Namespace+"/"+platform.Name)
-	in.Status.Platform = platform.Name
-}
-
 func (in *Integration) SetIntegrationKit(kit *IntegrationKit) {
 	if kit == nil {
 		in.Status.IntegrationKit = nil
@@ -328,15 +317,18 @@ func (in *Integration) SetIntegrationKit(kit *IntegrationKit) {
 	in.Status.Image = image
 }
 
-func (in *Integration) GetIntegrationKitNamespace(p *IntegrationPlatform) string {
+// GetIntegrationKitNamespace returns the namespace of the kit. You must provide a fallback platform
+// namespace where the new Kit is going to be created (ie, the older IntegrationPlatform namespace) or
+// the operator namespace.
+func (in *Integration) GetIntegrationKitNamespace(platformNamespace string) string {
 	if in.Status.IntegrationKit != nil && in.Status.IntegrationKit.Namespace != "" {
 		return in.Status.IntegrationKit.Namespace
 	}
 	if in.Spec.IntegrationKit != nil && in.Spec.IntegrationKit.Namespace != "" {
 		return in.Spec.IntegrationKit.Namespace
 	}
-	if p != nil {
-		return p.Namespace
+	if platformNamespace != "" {
+		return platformNamespace
 	}
 
 	return in.Namespace