Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

WIP: Integration sink and source: all together #8254

Open
wants to merge 19 commits into
base: main
Choose a base branch
from
Open

WIP: Integration sink and source: all together #8254

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
9e15cc1
Add initial raw API types and controller/reconciler. Levering interna…
matzew Sep 20, 2024
5a433d7
adding reflection to make the mapping less verbose, and more flexible…
matzew Sep 26, 2024
05b37eb
Add DDB Streams
matzew Sep 27, 2024
a71a652
polish and add minimal tests
matzew Oct 10, 2024
1169796
Update pkg/apis/sources/v1alpha1/integration_lifecycle.go
matzew Oct 11, 2024
ce209c8
Update pkg/apis/sources/v1alpha1/integration_lifecycle.go
matzew Oct 11, 2024
bfcaf02
Fix compiler warnings
matzew Oct 11, 2024
e114ee5
use other image coordinates
matzew Oct 14, 2024
1d4cc75
first test for source
matzew Oct 16, 2024
96df997
Adding initial rekt test
matzew Oct 16, 2024
91c0828
First Sink
matzew Oct 1, 2024
687be52
Updates on sink
matzew Oct 8, 2024
6d0b777
starting common types for source
matzew Oct 8, 2024
6be04c4
starting common types for sink
matzew Oct 8, 2024
ebbcba6
some code share and refactorings
matzew Oct 9, 2024
8c5ecf9
some fixes
matzew Oct 10, 2024
c21a9a5
use other image coordinates
matzew Oct 14, 2024
ad4a9d2
Align sources w/ common API
matzew Oct 14, 2024
7ea017f
Add missing api and tests for sink and run codegen
matzew Oct 14, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions cmd/controller/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
/*

Check failure on line 1 in cmd/controller/main.go

View workflow job for this annotation

GitHub Actions / style / Golang / Auto-format and Check 

Please run goimports.
diff --git a/cmd/controller/main.go b/cmd/controller/main.go
index bfca7ca..03dd21d 100644
--- a/cmd/controller/main.go
+++ b/cmd/controller/main.go
@@ -21,13 +21,14 @@ import (
 	// _ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
 
 	"errors"
-	integrationSink "knative.dev/eventing/pkg/reconciler/integration/sink"
-	integrationSource "knative.dev/eventing/pkg/reconciler/integration/source"
 	"log"
 	"net/http"
 	"os"
 	"time"
 
+	integrationSink "knative.dev/eventing/pkg/reconciler/integration/sink"
+	integrationSource "knative.dev/eventing/pkg/reconciler/integration/source"
+
 	"knative.dev/pkg/injection/sharedmain"
 
 	filteredFactory "knative.dev/pkg/client/injection/kube/informers/factory/filtered"
Copyright 2019 The Knative Authors

Licensed under the Apache License, Version 2.0 (the "License");
Expand All @@ -21,6 +21,8 @@
// _ "k8s.io/client-go/plugin/pkg/client/auth/gcp"

"errors"
integrationSink "knative.dev/eventing/pkg/reconciler/integration/sink"
integrationSource "knative.dev/eventing/pkg/reconciler/integration/source"
"log"
"net/http"
"os"
Expand Down Expand Up @@ -104,11 +106,14 @@
apiserversource.NewController,
pingsource.NewController,
containersource.NewController,
integrationSource.NewController,

// Sources CRD
sourcecrd.NewController,

// Sinks
jobsink.NewController,
integrationSink.NewController,

// Sugar
sugarnamespace.NewController,
Expand Down
6 changes: 5 additions & 1 deletion cmd/webhook/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
/*

Check failure on line 1 in cmd/webhook/main.go

View workflow job for this annotation

GitHub Actions / style / Golang / Auto-format and Check 

Please run goimports.
diff --git a/cmd/webhook/main.go b/cmd/webhook/main.go
index fddd03f..76dc703 100644
--- a/cmd/webhook/main.go
+++ b/cmd/webhook/main.go
@@ -18,9 +18,10 @@ package main
 
 import (
 	"context"
-	sourcesv1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
 	"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"
Copyright 2018 The Knative Authors

Licensed under the Apache License, Version 2.0 (the "License");
Expand All @@ -18,6 +18,7 @@

import (
"context"
sourcesv1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
"os"

"k8s.io/apimachinery/pkg/runtime/schema"
Expand Down Expand Up @@ -92,6 +93,8 @@
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
Expand All @@ -102,7 +105,8 @@

// For group sinks.knative.dev.
// v1alpha1
sinksv1alpha1.SchemeGroupVersion.WithKind("JobSink"): &sinksv1alpha1.JobSink{},
sinksv1alpha1.SchemeGroupVersion.WithKind("JobSink"): &sinksv1alpha1.JobSink{},
sinksv1alpha1.SchemeGroupVersion.WithKind("IntegrationSink"): &sinksv1alpha1.IntegrationSink{},

// For group flows.knative.dev
// v1
Expand Down
1 change: 1 addition & 0 deletions config/300-integrationsink.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
core/resources/integrationsink.yaml
1 change: 1 addition & 0 deletions config/300-integrationsource.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
core/resources/integrationsource.yaml
423 changes: 423 additions & 0 deletions config/core/resources/integrationsink.yaml
View file
Open in desktop

Large diffs are not rendered by default.

447 changes: 447 additions & 0 deletions config/core/resources/integrationsource.yaml
View file
Open in desktop

Large diffs are not rendered by default.

3 changes: 3 additions & 0 deletions config/core/roles/controller-clusterroles.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -113,6 +113,8 @@ rules:
resources:
- "jobsinks"
- "jobsinks/status"
- "integrationsinks"
- "integrationsinks/status"
verbs:
- "get"
- "list"
Expand All @@ -135,6 +137,7 @@ rules:
- "sinks.knative.dev"
resources:
- "jobsinks/finalizers"
- "integrationsinks/finalizers"
verbs:
- "update"

Expand Down
1 change: 1 addition & 0 deletions config/core/roles/source-observer-clusterrole.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ rules:
- pingsources
- sinkbindings
- containersources
- integrationsources
verbs:
- get
- list
Expand Down
3 changes: 3 additions & 0 deletions config/core/roles/sources-controller-clusterroles.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,9 @@ rules:
- "containersources"
- "containersources/status"
- "containersources/finalizers"
- "integrationsources"
- "integrationsources/status"
- "integrationsources/finalizers"
verbs:
- "get"
- "list"
Expand Down
Loading
Loading