feat: Introduce CloudEvents to KEDA

apis/keda/v1alpha1/cloudevents_types.go

@@ -0,0 +1,71 @@
+/*
+Copyright 2021 The KEDA Authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// CloudEvent defines how a trigger can authenticate globally
+// +genclient
+// +kubebuilder:resource:path=cloudevents,scope=Namespaced
+// +kubebuilder:subresource:status
+type CloudEvent struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec CloudEventSpec `json:"spec"`
+}
+
+// +kubebuilder:object:root=true
+
+// CloudEventList is a list of CloudEvent resources
+type CloudEventList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+	Items           []CloudEvent `json:"items"`
+}
+
+// CloudEvent
+type CloudEventSpec struct {
+	// +optional
+	ClusterName string `json:"clusterName,omitempty"`
+
+	// +optional
+	AzureEventGrid *AzureEventGridSpec `json:"azureEventGrid,omitempty"`
+}
+
+type AzureEventGridSpec struct {
+	EndPoint string `json:"endPoint"`
+
+	Key string `json:"key"`
+
+	TopicName string `json:"topicName"`
+
+	SubscriptionName string `json:"subscriptionName"`
+}
+
+func init() {
+	SchemeBuilder.Register(&CloudEvent{}, &CloudEventList{})
+}
+
+// GenerateIdentifier returns identifier for the object in for "kind.namespace.name"
+func (t *CloudEvent) GenerateIdentifier() string {
+	return GenerateIdentifier("CloudEvent", t.Namespace, t.Name)
+}

cmd/operator/main.go

@@ -40,6 +40,7 @@ import (
 	kedav1alpha1 "github.com/kedacore/keda/v2/apis/keda/v1alpha1"
 	kedacontrollers "github.com/kedacore/keda/v2/controllers/keda"
 	"github.com/kedacore/keda/v2/pkg/certificates"
+	"github.com/kedacore/keda/v2/pkg/eventemitter"
 	"github.com/kedacore/keda/v2/pkg/k8s"
 	"github.com/kedacore/keda/v2/pkg/metricsservice"
 	"github.com/kedacore/keda/v2/pkg/scaling"
@@ -178,6 +179,7 @@ func main() {
 
 	globalHTTPTimeout := time.Duration(globalHTTPTimeoutMS) * time.Millisecond
 	eventRecorder := mgr.GetEventRecorderFor("keda-operator")
+	eventEmitter := eventemitter.NewEventEmitter(mgr.GetClient(), eventRecorder)
 
 	kubeClientset, err := kubernetes.NewForConfig(cfg)
 	if err != nil {
@@ -208,6 +210,7 @@ func main() {
 		Recorder:     eventRecorder,
 		ScaleClient:  scaleClient,
 		ScaleHandler: scaledHandler,
+		EventEmitter: *eventEmitter,
 	}).SetupWithManager(mgr, controller.Options{
 		MaxConcurrentReconciles: scaledObjectMaxReconciles,
 	}); err != nil {
@@ -241,6 +244,13 @@ func main() {
 		setupLog.Error(err, "unable to create controller", "controller", "ClusterTriggerAuthentication")
 		os.Exit(1)
 	}
+	if err = (&kedacontrollers.CloudEventsReconciler{
+		Client:       mgr.GetClient(),
+		EventEmitter: *eventEmitter,
+	}).SetupWithManager(mgr); err != nil {
+		setupLog.Error(err, "unable to create controller", "controller", "CloudEvents")
+		os.Exit(1)
+	}
 	//+kubebuilder:scaffold:builder
 
 	if err := mgr.AddHealthzCheck("healthz", healthz.Ping); err != nil {

config/crd/bases/keda.sh_cloudevents.yaml

@@ -0,0 +1,62 @@
+---
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  annotations:
+    controller-gen.kubebuilder.io/version: v0.12.0
+  name: cloudevents.keda.sh
+spec:
+  group: keda.sh
+  names:
+    kind: CloudEvent
+    listKind: CloudEventList
+    plural: cloudevents
+    singular: cloudevent
+  scope: Namespaced
+  versions:
+  - name: v1alpha1
+    schema:
+      openAPIV3Schema:
+        description: CloudEvent defines how a trigger can authenticate globally
+        properties:
+          apiVersion:
+            description: 'APIVersion defines the versioned schema of this representation
+              of an object. Servers should convert recognized schemas to the latest
+              internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources'
+            type: string
+          kind:
+            description: 'Kind is a string value representing the REST resource this
+              object represents. Servers may infer this from the endpoint the client
+              submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+            type: string
+          metadata:
+            type: object
+          spec:
+            description: CloudEvent
+            properties:
+              azureEventGrid:
+                properties:
+                  endPoint:
+                    type: string
+                  key:
+                    type: string
+                  subscriptionName:
+                    type: string
+                  topicName:
+                    type: string
+                required:
+                - endPoint
+                - key
+                - subscriptionName
+                - topicName
+                type: object
+              clusterName:
+                type: string
+            type: object
+        required:
+        - spec
+        type: object
+    served: true
+    storage: true
+    subresources:
+      status: {}

config/crd/kustomization.yaml

@@ -6,6 +6,7 @@ resources:
 - bases/keda.sh_scaledjobs.yaml
 - bases/keda.sh_triggerauthentications.yaml
 - bases/keda.sh_clustertriggerauthentications.yaml
+- bases/keda.sh_cloudevents.yaml
 # +kubebuilder:scaffold:crdkustomizeresource
 
 ## ScaledJob CRD needs to be patched because for some usecases (details in the patch file)

config/rbac/role.yaml

@@ -88,6 +88,13 @@ rules:
   - leases
   verbs:
   - '*'
+- apiGroups:
+  - keda.sh
+  resources:
+  - cloudevents
+  - cloudevents/status
+  verbs:
+  - '*'
 - apiGroups:
   - keda.sh
   resources:

config/samples/keda_v1alpha1_cloudevents.yaml

@@ -0,0 +1,12 @@
+apiVersion: keda.sh/v1alpha1
+kind: CloudEvent
+metadata:
+  name: cloudevents-sample
+  namespace: keda
+spec:
+  clusterName: cluster-sample
+  azureEventGrid: 
+    endPoint: https://eventgridtestnamespace.eastus-1.eventgrid.azure.net/
+    key: FXZBmVucowoeM/Kl0zNeDJHoyOZO+sXB+IeeE7S6aSg=
+    topicName: testtopicone
+    subscriptionName: 66a7fcba-dac3-46d8-b509-202f305618c8