Merge pull request #857 from haarchri/kinesis

Implements Kinesis Stream

Author: Aaron Eaton

Makefile

@@ -7,7 +7,7 @@ PROJECT_REPO := github.com/crossplane/$(PROJECT_NAME)
 PLATFORMS ?= linux_amd64 linux_arm64
 
 CODE_GENERATOR_COMMIT ?= 285d87b66b62fbfb859986ddf74c9f9b6ae743fb
-GENERATED_SERVICES="apigatewayv2,athena,cloudfront,cloudwatchlogs,dynamodb,elbv2,ec2,efs,glue,iot,kafka,kms,lambda,mq,rds,secretsmanager,servicediscovery,sfn,transfer,ram"
+GENERATED_SERVICES="apigatewayv2,athena,cloudfront,cloudwatchlogs,dynamodb,elbv2,ec2,efs,glue,iot,kafka,kinesis,kms,lambda,mq,rds,secretsmanager,servicediscovery,sfn,transfer,ram"
 
 # kind-related versions
 KIND_VERSION ?= v0.11.1

apis/aws.go

@@ -48,6 +48,7 @@ import (
 	iamv1beta1 "github.com/crossplane/provider-aws/apis/iam/v1beta1"
 	iotv1alpha1 "github.com/crossplane/provider-aws/apis/iot/v1alpha1"
 	kafkav1alpha1 "github.com/crossplane/provider-aws/apis/kafka/v1alpha1"
+	kinesisv1alpha1 "github.com/crossplane/provider-aws/apis/kinesis/v1alpha1"
 	kmsv1alpha1 "github.com/crossplane/provider-aws/apis/kms/v1alpha1"
 	lambdav1alpha1 "github.com/crossplane/provider-aws/apis/lambda/v1alpha1"
 	mqv1alpha1 "github.com/crossplane/provider-aws/apis/mq/v1alpha1"
@@ -117,6 +118,7 @@ func init() {
 		iotv1alpha1.SchemeBuilder.AddToScheme,
 		athenav1alpha1.SchemeBuilder.AddToScheme,
 		ramv1alpha1.SchemeBuilder.AddToScheme,
+		kinesisv1alpha1.SchemeBuilder.AddToScheme,
 	)
 }
 

apis/kinesis/v1alpha1/custom_types.go

@@ -0,0 +1,78 @@
+/*
+Copyright 2021 The Crossplane 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 (
+	xpv1 "github.com/crossplane/crossplane-runtime/apis/common/v1"
+)
+
+// CustomStreamParameters contains the additional fields for StreamParameters.
+type CustomStreamParameters struct {
+	// The retention period of the stream, in hours.
+	// Default: 24 hours
+	RetentionPeriodHours *int64 `json:"retentionPeriodHours,omitempty"`
+
+	// +optional
+	// +crossplane:generate:reference:type=github.com/crossplane/provider-aws/apis/kms/v1alpha1.Key
+	// +crossplane:generate:reference:extractor=github.com/crossplane/provider-aws/apis/kms/v1alpha1.KMSKeyARN()
+	KMSKeyARN *string `json:"kmsKeyARN,omitempty"`
+
+	KMSKeyARNRef *xpv1.Reference `json:"kmsKeyARNRef,omitempty"`
+
+	KMSKeyARNSelector *xpv1.Selector `json:"kmsKeyARNSelector,omitempty"`
+
+	// List of shard-level metrics.
+	//
+	// The following are the valid shard-level metrics. The value "ALL" enhances
+	// every metric.
+	//
+	//    * IncomingBytes
+	//
+	//    * IncomingRecords
+	//
+	//    * OutgoingBytes
+	//
+	//    * OutgoingRecords
+	//
+	//    * WriteProvisionedThroughputExceeded
+	//
+	//    * ReadProvisionedThroughputExceeded
+	//
+	//    * IteratorAgeMilliseconds
+	//
+	//    * ALL
+	//
+	// For more information, see Monitoring the Amazon Kinesis Data Streams Service
+	// with Amazon CloudWatch (https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html)
+	// in the Amazon Kinesis Data Streams Developer Guide.
+	EnhancedMetrics []*EnhancedMetrics `json:"enhancedMetrics,omitempty"`
+
+	Tags []CustomTag `json:"tags,omitempty"`
+
+	// If this parameter is unset (null) or if you set it to false, and the stream
+	// has registered consumers, the call to DeleteStream fails with a ResourceInUseException.
+	EnforceConsumerDeletion *bool `json:"enforceConsumerDeletion,omitempty"`
+}
+
+// CustomTag contains the additional fields for Tag.
+type CustomTag struct {
+	// A unique identifier for the tag.
+	Key string `json:"key"`
+
+	// An optional string, typically used to describe or define the tag.
+	Value string `json:"value,omitempty"`
+}

apis/kinesis/v1alpha1/generator-config.yaml

@@ -0,0 +1,50 @@
+ignore:
+  field_paths:
+    - CreateStreamInput.StreamName
+resources:
+  Stream:
+    fields:
+      StreamStatus:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.StreamStatus
+      StreamARN:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.StreamARN
+      Shards:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.Shards
+      RetentionPeriodHours:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.RetentionPeriodHours
+      KeyId:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.KeyId
+      HasMoreShards:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.HasMoreShards
+      EnhancedMonitoring:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.EnhancedMonitoring
+      EncryptionType:
+        is_read_only: true
+        from:
+          operation: DescribeStream
+          path: StreamDescription.EncryptionType
+    exceptions:
+      errors:
+        404:
+          code: ResourceNotFoundException