IntegrationSource CRD (knative#8238)

* Add initial raw API types and controller/reconciler. Levering internally the container source for the handling of the kamelet workloads. the logic for applying the env-vars is a bit verbose, but can be improved. Tests/lifeccyle and some other improvements are still missing. but this works. Signed-off-by: Matthias Wessendorf <[email protected]> * adding reflection to make the mapping less verbose, and more flexible to extend... Signed-off-by: Matthias Wessendorf <[email protected]> * Add DDB Streams Signed-off-by: Matthias Wessendorf <[email protected]> * polish and add minimal tests Signed-off-by: Matthias Wessendorf <[email protected]> * Update pkg/apis/sources/v1alpha1/integration_lifecycle.go Co-authored-by: Pierangelo Di Pilato <[email protected]> * Update pkg/apis/sources/v1alpha1/integration_lifecycle.go Co-authored-by: Pierangelo Di Pilato <[email protected]> * Fix compiler warnings Signed-off-by: Matthias Wessendorf <[email protected]> * use other image coordinates Signed-off-by: Matthias Wessendorf <[email protected]> * first test for source Signed-off-by: Matthias Wessendorf <[email protected]> * Adding initial rekt test Signed-off-by: Matthias Wessendorf <[email protected]> * Adding SSL support and test for IntegrationSource Signed-off-by: Matthias Wessendorf <[email protected]> * Formatting fixes Signed-off-by: Matthias Wessendorf <[email protected]> * Disable OIDC tests for now Signed-off-by: Matthias Wessendorf <[email protected]> * use knative nightly images Signed-off-by: Matthias Wessendorf <[email protected]> * Fixing linters Signed-off-by: Matthias Wessendorf <[email protected]> * addressing comments, Part1 Signed-off-by: Matthias Wessendorf <[email protected]> --------- Signed-off-by: Matthias Wessendorf <[email protected]> Co-authored-by: Pierangelo Di Pilato <[email protected]>
matzew · Nov 6, 2024 · 68b5a79 · 68b5a79
1 parent 33d5b6a
commit 68b5a79
Show file tree

Hide file tree

Showing 61 changed files with 5,962 additions and 2 deletions.
diff --git a/cmd/controller/main.go b/cmd/controller/main.go
@@ -41,6 +41,7 @@ import (
 	"knative.dev/eventing/pkg/reconciler/channel"
 	"knative.dev/eventing/pkg/reconciler/containersource"
 	"knative.dev/eventing/pkg/reconciler/eventtype"
+	"knative.dev/eventing/pkg/reconciler/integrationsource"
 	"knative.dev/eventing/pkg/reconciler/parallel"
 	"knative.dev/eventing/pkg/reconciler/pingsource"
 	"knative.dev/eventing/pkg/reconciler/sequence"
@@ -104,6 +105,8 @@ func main() {
 		apiserversource.NewController,
 		pingsource.NewController,
 		containersource.NewController,
+		integrationsource.NewController,
+
 		// Sources CRD
 		sourcecrd.NewController,
 

diff --git a/cmd/webhook/main.go b/cmd/webhook/main.go
@@ -20,6 +20,8 @@ import (
 	"context"
 	"os"
 
+	sourcesv1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
+
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/kubernetes/scheme"
@@ -92,6 +94,8 @@ var ourTypes = map[schema.GroupVersionKind]resourcesemantics.GenericCRD{
 	messagingv1.SchemeGroupVersion.WithKind("Subscription"): &messagingv1.Subscription{},
 
 	// For group sources.knative.dev.
+	// v1alpha1
+	sourcesv1alpha1.SchemeGroupVersion.WithKind("IntegrationSource"): &sourcesv1alpha1.IntegrationSource{},
 	// v1beta2
 	sourcesv1beta2.SchemeGroupVersion.WithKind("PingSource"): &sourcesv1beta2.PingSource{},
 	// v1

diff --git a/config/300-integrationsource.yaml b/config/300-integrationsource.yaml
@@ -0,0 +1 @@
+core/resources/integrationsource.yaml
diff --git a/config/core/resources/integrationsource.yaml b/config/core/resources/integrationsource.yaml
diff --git a/config/core/roles/source-observer-clusterrole.yaml b/config/core/roles/source-observer-clusterrole.yaml
@@ -45,6 +45,7 @@ rules:
       - pingsources
       - sinkbindings
       - containersources
+      - integrationsources
     verbs:
       - get
       - list

diff --git a/config/core/roles/sources-controller-clusterroles.yaml b/config/core/roles/sources-controller-clusterroles.yaml
@@ -66,6 +66,9 @@ rules:
       - "containersources"
       - "containersources/status"
       - "containersources/finalizers"
+      - "integrationsources"
+      - "integrationsources/status"
+      - "integrationsources/finalizers"
     verbs:
       - "get"
       - "list"