Merge branch 'main' into event_invoke_config_alias

Author: Vandita2020

apis/v1alpha1/event_source_mapping.go

@@ -128,6 +128,11 @@ resources:
           resource: Broker
           path: Status.BrokerID
           service_name: mq
+      EventSourceARN:
+        references:
+          resource: Cluster
+          path: Status.ACKResourceMetadata.ARN
+          service_name: kafka
       UUID:
         is_primary_key: true
       FunctionName:

apis/v1alpha1/generator.yaml

@@ -90,6 +90,19 @@ spec:
                   Streaming for Apache Kafka – The ARN of the cluster. \n * Amazon
                   MQ – The ARN of the broker."
                 type: string
+              eventSourceRef:
+                description: "AWSResourceReferenceWrapper provides a wrapper around
+                  *AWSResourceReference type to provide more user friendly syntax
+                  for references using 'from' field Ex: APIIDRef: \n from: name: my-api"
+                properties:
+                  from:
+                    description: AWSResourceReference provides all the values necessary
+                      to reference another k8s resource for finding the identifier(Id/ARN/Name)
+                    properties:
+                      name:
+                        type: string
+                    type: object
+                type: object
               filterCriteria:
                 description: An object that defines the filter criteria that determine
                   whether Lambda should process an event. For more information, see

apis/v1alpha1/zz_generated.deepcopy.go

@@ -59,6 +59,20 @@ rules:
   verbs:
   - get
   - list
+- apiGroups:
+  - kafka.services.k8s.aws
+  resources:
+  - clusters
+  verbs:
+  - get
+  - list
+- apiGroups:
+  - kafka.services.k8s.aws
+  resources:
+  - clusters/status
+  verbs:
+  - get
+  - list
 - apiGroups:
   - kms.services.k8s.aws
   resources:

cmd/controller/main.go

@@ -128,6 +128,11 @@ resources:
           resource: Broker
           path: Status.BrokerID
           service_name: mq
+      EventSourceARN:
+        references:
+          resource: Cluster
+          path: Status.ACKResourceMetadata.ARN
+          service_name: kafka
       UUID:
         is_primary_key: true
       FunctionName:

config/crd/bases/lambda.services.k8s.aws_eventsourcemappings.yaml

@@ -4,6 +4,7 @@ go 1.19
 
 require (
 	github.com/aws-controllers-k8s/ec2-controller v0.0.21
+	github.com/aws-controllers-k8s/kafka-controller v0.0.0-20230615185632-102279061de1
 	github.com/aws-controllers-k8s/kms-controller v0.1.2
 	github.com/aws-controllers-k8s/mq-controller v0.0.22
 	github.com/aws-controllers-k8s/runtime v0.26.0

config/rbac/cluster-role-controller.yaml

@@ -40,6 +40,8 @@ github.com/alecthomas/units v0.0.0-20190717042225-c3de453c63f4/go.mod h1:ybxpYRF
 github.com/alecthomas/units v0.0.0-20190924025748-f65c72e2690d/go.mod h1:rBZYJk541a8SKzHPHnH3zbiI+7dagKZ0cgpgrD7Fyho=
 github.com/aws-controllers-k8s/ec2-controller v0.0.21 h1:5O7/9aED2Tl9OT0TL2rWrc1Ix5V1UxYEgDKAhvFhPJQ=
 github.com/aws-controllers-k8s/ec2-controller v0.0.21/go.mod h1:OMsmJeJ3iQZ1sJgs3hqnjBRnJ3hmTzJUO38W5rxnB5M=
+github.com/aws-controllers-k8s/kafka-controller v0.0.0-20230615185632-102279061de1 h1:NvmtIsm6fVoGUOvMfevONJETf+PtRWAiD3XzZBtQ2WA=
+github.com/aws-controllers-k8s/kafka-controller v0.0.0-20230615185632-102279061de1/go.mod h1:BHW00DFtXtugpsyn0nN0YdP32xmCN5p3lIJYP+Y0iVY=
 github.com/aws-controllers-k8s/kms-controller v0.1.2 h1:9lb98jspqOpFpmIFHOJ6pRnOkC8kDEPIgTAb5QnVGZo=
 github.com/aws-controllers-k8s/kms-controller v0.1.2/go.mod h1:6CoV0UMFd03EUF9dXgOTTScGdBhJzsWn9W0dw2n0kA4=
 github.com/aws-controllers-k8s/mq-controller v0.0.22 h1:XxFSQL9yaaiiuZ6E/fh/+Y9C+3DG2c5oXWG/4ZNwd1w=

generator.yaml

@@ -90,6 +90,19 @@ spec:
                   Streaming for Apache Kafka – The ARN of the cluster. \n - Amazon
                   MQ – The ARN of the broker."
                 type: string
+              eventSourceRef:
+                description: "AWSResourceReferenceWrapper provides a wrapper around
+                  *AWSResourceReference type to provide more user friendly syntax
+                  for references using 'from' field Ex: APIIDRef: \n from: name: my-api"
+                properties:
+                  from:
+                    description: AWSResourceReference provides all the values necessary
+                      to reference another k8s resource for finding the identifier(Id/ARN/Name)
+                    properties:
+                      name:
+                        type: string
+                    type: object
+                type: object
               filterCriteria:
                 description: An object that defines the filter criteria that determine
                   whether Lambda should process an event. For more information, see

go.mod

@@ -74,6 +74,20 @@ rules:
   verbs:
   - get
   - list
+- apiGroups:
+  - kafka.services.k8s.aws
+  resources:
+  - clusters
+  verbs:
+  - get
+  - list
+- apiGroups:
+  - kafka.services.k8s.aws
+  resources:
+  - clusters/status
+  verbs:
+  - get
+  - list
 - apiGroups:
   - kms.services.k8s.aws
   resources: