Add resource reference for Amazon MQ broker in Lambda controller EventSourceMapping resource

Author: Vandita2020

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2022-10-25T17:58:30Z"
-  build_hash: 9727031b415481d9ac28bb94cac9f1e73336401d
+  build_date: "2022-11-04T20:58:55Z"
+  build_hash: 560c702f71f3f9041b97417e84076d12721d9629
   go_version: go1.19
-  version: v0.19.3-9-g9727031
-api_directory_checksum: e2da75eafa3ab7fe7cc4c8c26ba01e495e31d494
+  version: v0.19.3-9-g560c702
+api_directory_checksum: d8e4f928367bfe35852ffcd9fdf53610f7a3de50
 api_version: v1alpha1
 aws_sdk_go_version: v1.44.93
 generator_config_info:
-  file_checksum: 1328b65627cf7280ef4df6c1b0435653e99fe62f
+  file_checksum: 18aef4974f374781b15ed07cb11be4f7d0dab0f5
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

apis/v1alpha1/event_source_mapping.go

@@ -97,6 +97,11 @@ resources:
       ignore: true
   EventSourceMapping:
     fields:
+      AmazonManagedKafkaEventSourceConfig:
+        references:
+          resource: Broker
+          path: Status.BrokerID
+          service_name: mq
       UUID:
         is_primary_key: true
       FunctionName:

apis/v1alpha1/generator.yaml

@@ -43,6 +43,19 @@ spec:
                   consumerGroupID:
                     type: string
                 type: object
+              amazonManagedKafkaEventSourceConfigRef:
+                description: 'AWSResourceReferenceWrapper provides a wrapper around
+                  *AWSResourceReference type to provide more user friendly syntax
+                  for references using ''from'' field Ex: APIIDRef: 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
               batchSize:
                 description: "The maximum number of records in each batch that Lambda
                   pulls from your stream or queue and sends to your function. Lambda

apis/v1alpha1/zz_generated.deepcopy.go

@@ -173,6 +173,20 @@ rules:
   - get
   - patch
   - update
+- apiGroups:
+  - mq.services.k8s.aws
+  resources:
+  - brokers
+  verbs:
+  - get
+  - list
+- apiGroups:
+  - mq.services.k8s.aws
+  resources:
+  - brokers/status
+  verbs:
+  - get
+  - list
 - apiGroups:
   - s3.services.k8s.aws
   resources:

cmd/controller/main.go

@@ -97,6 +97,11 @@ resources:
       ignore: true
   EventSourceMapping:
     fields:
+      AmazonManagedKafkaEventSourceConfig:
+        references:
+          resource: Broker
+          path: Status.BrokerID
+          service_name: mq
       UUID:
         is_primary_key: true
       FunctionName:

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

@@ -5,6 +5,7 @@ go 1.17
 require (
 	github.com/aws-controllers-k8s/ec2-controller v0.0.21
 	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.20.1
 	github.com/aws-controllers-k8s/s3-controller v0.1.5
 	github.com/aws/aws-sdk-go v1.44.93

config/rbac/cluster-role-controller.yaml

@@ -68,6 +68,8 @@ github.com/aws-controllers-k8s/ec2-controller v0.0.21 h1:5O7/9aED2Tl9OT0TL2rWrc1
 github.com/aws-controllers-k8s/ec2-controller v0.0.21/go.mod h1:OMsmJeJ3iQZ1sJgs3hqnjBRnJ3hmTzJUO38W5rxnB5M=
 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=
+github.com/aws-controllers-k8s/mq-controller v0.0.22/go.mod h1:p+YVFjpwlgRC+1cPeCabk1xTB1hTCU+RwYtFzrTnJmE=
 github.com/aws-controllers-k8s/runtime v0.20.0/go.mod h1:oA8ML1/LL3chPn26P6SzBNu1CUI2nekB+PTqykNs0qU=
 github.com/aws-controllers-k8s/runtime v0.20.1 h1:L/Huf1shRahx5BqJBCSS5u+vYg3f0Rotsq1jutORpdI=
 github.com/aws-controllers-k8s/runtime v0.20.1/go.mod h1:k7z4qlf6aK1Kzd4ff49wzcyhDKHjWaUpqxrwgl4uS1o=

generator.yaml

@@ -43,6 +43,19 @@ spec:
                   consumerGroupID:
                     type: string
                 type: object
+              amazonManagedKafkaEventSourceConfigRef:
+                description: 'AWSResourceReferenceWrapper provides a wrapper around
+                  *AWSResourceReference type to provide more user friendly syntax
+                  for references using ''from'' field Ex: APIIDRef: 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
               batchSize:
                 description: "The maximum number of records in each batch that Lambda
                   pulls from your stream or queue and sends to your function. Lambda

go.mod

@@ -180,6 +180,20 @@ rules:
   - get
   - patch
   - update
+- apiGroups:
+  - mq.services.k8s.aws
+  resources:
+  - brokers
+  verbs:
+  - get
+  - list
+- apiGroups:
+  - mq.services.k8s.aws
+  resources:
+  - brokers/status
+  verbs:
+  - get
+  - list
 - apiGroups:
   - s3.services.k8s.aws
   resources: