fix readme, update int test

aws · Mar 16, 2024 · 3960068 · 3960068
1 parent ac8f444
commit 3960068
Show file tree

Hide file tree

Showing 8 changed files with 57 additions and 43 deletions.
diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/README.md b/packages/@aws-cdk/aws-pipes-sources-alpha/README.md
@@ -66,11 +66,13 @@ const pipe = new pipes.Pipe(this, 'Pipe', {
 A Kinesis stream can be used as a source for a pipe. The stream will be polled for new messages and the messages will be sent to the pipe.
 
 ```ts
+import * as kinesis from 'aws-cdk-lib/aws-kinesis';
+
 declare const sourceStream: kinesis.Stream;
 declare const targetQueue: sqs.Queue;
 
 const pipeSource = new sources.KinesisSource(sourceStream, {
-  startingPosition: StartingPosition.LATEST,
+  startingPosition: sources.StartingPosition.LATEST,
 });
 
 const pipe = new pipes.Pipe(this, 'Pipe', {

diff --git a/...ces-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-sources-kinesis-stream.assets.json b/...ces-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-sources-kinesis-stream.assets.json
diff --git a/...s-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-sources-kinesis-stream.template.json b/...s-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-sources-kinesis-stream.template.json
@@ -1,6 +1,6 @@
 {
  "Resources": {
-  "SourceKinesisStream2376424EB": {
+  "SourceKinesisStreamD9B33274": {
    "Type": "AWS::Kinesis::Stream",
    "Properties": {
     "RetentionPeriodHours": 24,
@@ -60,7 +60,7 @@
        "Effect": "Allow",
        "Resource": {
         "Fn::GetAtt": [
-         "SourceKinesisStream2376424EB",
+         "SourceKinesisStreamD9B33274",
          "Arn"
         ]
        }
@@ -101,7 +101,7 @@
     },
     "Source": {
      "Fn::GetAtt": [
-      "SourceKinesisStream2376424EB",
+      "SourceKinesisStreamD9B33274",
       "Arn"
      ]
     },
@@ -143,15 +143,15 @@
   }
  },
  "Outputs": {
-  "ExportsOutputFnGetAttSourceKinesisStream2376424EBArnEEBEE728": {
+  "ExportsOutputFnGetAttSourceKinesisStreamD9B33274Arn1A7BEAA1": {
    "Value": {
     "Fn::GetAtt": [
-     "SourceKinesisStream2376424EB",
+     "SourceKinesisStreamD9B33274",
      "Arn"
     ]
    },
    "Export": {
-    "Name": "aws-cdk-pipes-sources-kinesis-stream:ExportsOutputFnGetAttSourceKinesisStream2376424EBArnEEBEE728"
+    "Name": "aws-cdk-pipes-sources-kinesis-stream:ExportsOutputFnGetAttSourceKinesisStreamD9B33274Arn1A7BEAA1"
    }
   },
   "ExportsOutputRefTargetQueue08AD2B3C0C69AE0E": {

diff --git a/...teg.kinesis.js.snapshot/integtestpipesourcesqsDefaultTestDeployAssertD36A35C2.assets.json b/...teg.kinesis.js.snapshot/integtestpipesourcesqsDefaultTestDeployAssertD36A35C2.assets.json
diff --git a/...g.kinesis.js.snapshot/integtestpipesourcesqsDefaultTestDeployAssertD36A35C2.template.json b/...g.kinesis.js.snapshot/integtestpipesourcesqsDefaultTestDeployAssertD36A35C2.template.json
diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.js.snapshot/manifest.json b/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.js.snapshot/manifest.json
diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.js.snapshot/tree.json b/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.js.snapshot/tree.json
diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.ts b/packages/@aws-cdk/aws-pipes-sources-alpha/test/integ.kinesis.ts
@@ -6,7 +6,7 @@ import { KinesisSource, StartingPosition } from '../lib';
 
 const app = new cdk.App();
 const stack = new cdk.Stack(app, 'aws-cdk-pipes-sources-kinesis-stream');
-const sourceKinesisStream = new cdk.aws_kinesis.Stream(stack, 'SourceKinesisStream2');
+const sourceKinesisStream = new cdk.aws_kinesis.Stream(stack, 'SourceKinesisStream');
 const targetQueue = new cdk.aws_sqs.Queue(stack, 'TargetQueue');
 
 class TestTarget implements ITarget {