Adding KinesisStreamInput interface to take optional timestmap

aws · Oct 19, 2024 · fb7e41b · fb7e41b
1 parent ae47336
commit fb7e41b
Show file tree

Hide file tree

Showing 11 changed files with 859 additions and 28 deletions.
diff --git a/...amework-integ/test/aws-dynamodb/test/integ.dynamodb-v2.kinesis-stream.js.snapshot/cdk.out b/...amework-integ/test/aws-dynamodb/test/integ.dynamodb-v2.kinesis-stream.js.snapshot/cdk.out
diff --git a/...integ.dynamodb-v2.kinesis-stream.js.snapshot/global-table-kinesis-stream-test.assets.json b/...integ.dynamodb-v2.kinesis-stream.js.snapshot/global-table-kinesis-stream-test.assets.json
diff --git a/...teg.dynamodb-v2.kinesis-stream.js.snapshot/global-table-kinesis-stream-test.template.json b/...teg.dynamodb-v2.kinesis-stream.js.snapshot/global-table-kinesis-stream-test.template.json
@@ -0,0 +1,200 @@
+{
+ "Resources": {
+  "Stream790BDEE4": {
+   "Type": "AWS::Kinesis::Stream",
+   "Properties": {
+    "RetentionPeriodHours": 24,
+    "ShardCount": 1,
+    "StreamEncryption": {
+     "Fn::If": [
+      "AwsCdkKinesisEncryptedStreamsUnsupportedRegions",
+      {
+       "Ref": "AWS::NoValue"
+      },
+      {
+       "EncryptionType": "KMS",
+       "KeyId": "alias/aws/kinesis"
+      }
+     ]
+    }
+   },
+   "UpdateReplacePolicy": "Retain",
+   "DeletionPolicy": "Retain"
+  },
+  "KinesisStream1AE0A3437": {
+   "Type": "AWS::Kinesis::Stream",
+   "Properties": {
+    "RetentionPeriodHours": 24,
+    "ShardCount": 1,
+    "StreamEncryption": {
+     "Fn::If": [
+      "AwsCdkKinesisEncryptedStreamsUnsupportedRegions",
+      {
+       "Ref": "AWS::NoValue"
+      },
+      {
+       "EncryptionType": "KMS",
+       "KeyId": "alias/aws/kinesis"
+      }
+     ]
+    }
+   },
+   "UpdateReplacePolicy": "Retain",
+   "DeletionPolicy": "Retain"
+  },
+  "TableCD117FA1": {
+   "Type": "AWS::DynamoDB::GlobalTable",
+   "Properties": {
+    "AttributeDefinitions": [
+     {
+      "AttributeName": "hashKey",
+      "AttributeType": "S"
+     }
+    ],
+    "BillingMode": "PAY_PER_REQUEST",
+    "KeySchema": [
+     {
+      "AttributeName": "hashKey",
+      "KeyType": "HASH"
+     }
+    ],
+    "Replicas": [
+     {
+      "KinesisStreamSpecification": {
+       "StreamArn": {
+        "Fn::GetAtt": [
+         "Stream790BDEE4",
+         "Arn"
+        ]
+       }
+      },
+      "Region": "eu-west-1"
+     }
+    ]
+   },
+   "UpdateReplacePolicy": "Delete",
+   "DeletionPolicy": "Delete"
+  },
+  "Table2DBDCD1F7": {
+   "Type": "AWS::DynamoDB::GlobalTable",
+   "Properties": {
+    "AttributeDefinitions": [
+     {
+      "AttributeName": "hashKey",
+      "AttributeType": "S"
+     }
+    ],
+    "BillingMode": "PAY_PER_REQUEST",
+    "KeySchema": [
+     {
+      "AttributeName": "hashKey",
+      "KeyType": "HASH"
+     }
+    ],
+    "Replicas": [
+     {
+      "Region": "us-east-1"
+     },
+     {
+      "KinesisStreamSpecification": {
+       "ApproximateCreationDateTimePrecision": "MILLISECOND",
+       "StreamArn": {
+        "Fn::GetAtt": [
+         "KinesisStream1AE0A3437",
+         "Arn"
+        ]
+       }
+      },
+      "Region": "eu-west-1"
+     }
+    ],
+    "StreamSpecification": {
+     "StreamViewType": "NEW_AND_OLD_IMAGES"
+    }
+   },
+   "UpdateReplacePolicy": "Delete",
+   "DeletionPolicy": "Delete"
+  },
+  "Table3D174A7C6": {
+   "Type": "AWS::DynamoDB::GlobalTable",
+   "Properties": {
+    "AttributeDefinitions": [
+     {
+      "AttributeName": "hashKey",
+      "AttributeType": "S"
+     }
+    ],
+    "BillingMode": "PAY_PER_REQUEST",
+    "KeySchema": [
+     {
+      "AttributeName": "hashKey",
+      "KeyType": "HASH"
+     }
+    ],
+    "Replicas": [
+     {
+      "Region": "eu-west-1"
+     }
+    ]
+   },
+   "UpdateReplacePolicy": "Delete",
+   "DeletionPolicy": "Delete"
+  }
+ },
+ "Conditions": {
+  "AwsCdkKinesisEncryptedStreamsUnsupportedRegions": {
+   "Fn::Or": [
+    {
+     "Fn::Equals": [
+      {
+       "Ref": "AWS::Region"
+      },
+      "cn-north-1"
+     ]
+    },
+    {
+     "Fn::Equals": [
+      {
+       "Ref": "AWS::Region"
+      },
+      "cn-northwest-1"
+     ]
+    }
+   ]
+  }
+ },
+ "Parameters": {
+  "BootstrapVersion": {
+   "Type": "AWS::SSM::Parameter::Value<String>",
+   "Default": "/cdk-bootstrap/hnb659fds/version",
+   "Description": "Version of the CDK Bootstrap resources in this environment, automatically retrieved from SSM Parameter Store. [cdk:skip]"
+  }
+ },
+ "Rules": {
+  "CheckBootstrapVersion": {
+   "Assertions": [
+    {
+     "Assert": {
+      "Fn::Not": [
+       {
+        "Fn::Contains": [
+         [
+          "1",
+          "2",
+          "3",
+          "4",
+          "5"
+         ],
+         {
+          "Ref": "BootstrapVersion"
+         }
+        ]
+       }
+      ]
+     },
+     "AssertDescription": "CDK bootstrap stack version 6 required. Please run 'cdk bootstrap' with a recent version of the CDK CLI."
+    }
+   ]
+  }
+ }
+}
diff --git a/...is-stream.js.snapshot/globaltablekinesisstreamDefaultTestDeployAssert1282D084.assets.json b/...is-stream.js.snapshot/globaltablekinesisstreamDefaultTestDeployAssert1282D084.assets.json
diff --git a/...-stream.js.snapshot/globaltablekinesisstreamDefaultTestDeployAssert1282D084.template.json b/...-stream.js.snapshot/globaltablekinesisstreamDefaultTestDeployAssert1282D084.template.json
diff --git a/...work-integ/test/aws-dynamodb/test/integ.dynamodb-v2.kinesis-stream.js.snapshot/integ.json b/...work-integ/test/aws-dynamodb/test/integ.dynamodb-v2.kinesis-stream.js.snapshot/integ.json