From efbad8bd8d5697cde3aeac917e0a5c281c7ae4d1 Mon Sep 17 00:00:00 2001 From: Michael Sambol Date: Fri, 1 Nov 2024 08:56:20 -0700 Subject: [PATCH] chore(pipes-sources): update readme to use SqsTarget --- packages/@aws-cdk/aws-pipes-sources-alpha/README.md | 8 ++++---- .../aws-pipes-sources-alpha/rosetta/default.ts-fixture | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/README.md b/packages/@aws-cdk/aws-pipes-sources-alpha/README.md index 4ddfc822ae165..9291d3d3acb17 100644 --- a/packages/@aws-cdk/aws-pipes-sources-alpha/README.md +++ b/packages/@aws-cdk/aws-pipes-sources-alpha/README.md @@ -40,7 +40,7 @@ const pipeSource = new sources.SqsSource(sourceQueue); const pipe = new pipes.Pipe(this, 'Pipe', { source: pipeSource, - target: new SomeTarget(targetQueue) + target: new SqsTarget(targetQueue) }); ``` @@ -57,7 +57,7 @@ const pipeSource = new sources.SqsSource(sourceQueue, { const pipe = new pipes.Pipe(this, 'Pipe', { source: pipeSource, - target: new SomeTarget(targetQueue) + target: new SqsTarget(targetQueue) }); ``` @@ -75,7 +75,7 @@ const pipeSource = new sources.KinesisSource(sourceStream, { const pipe = new pipes.Pipe(this, 'Pipe', { source: pipeSource, - target: new SomeTarget(targetQueue) + target: new SqsTarget(targetQueue) }); ``` @@ -99,6 +99,6 @@ const pipeSource = new sources.DynamoDBSource(table, { const pipe = new pipes.Pipe(this, 'Pipe', { source: pipeSource, - target: new SomeTarget(targetQueue) + target: new SqsTarget(targetQueue) }); ``` diff --git a/packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture b/packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture index d0b11899ad633..9d10b863856f9 100644 --- a/packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture +++ b/packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture @@ -6,6 +6,7 @@ import * as ddb from 'aws-cdk-lib/aws-dynamodb'; import { Construct } from 'constructs'; import * as pipes from '@aws-cdk/aws-pipes-alpha'; import * as sources from '@aws-cdk/aws-pipes-sources-alpha'; +import { SqsTarget } from '@aws-cdk/aws-pipes-targets-alpha'; class SomeTarget implements pipes.ITarget { targetArn: string;