Skip to content

Commit 07be7ea

Browse files
author
awstools
committed
feat(client-kinesis-analytics-v2): This release adds support for new ListApplicationOperations and DescribeApplicationOperation APIs. It adds a new configuration to enable system rollbacks, adds field ApplicationVersionCreateTimestamp for clarity and improves support for pagination for APIs.
1 parent 3520f1a commit 07be7ea

29 files changed

+1446
-37
lines changed

‎clients/client-kinesis-analytics-v2/README.md

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -343,6 +343,14 @@ DescribeApplication
343343

344344
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DescribeApplicationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationCommandOutput/)
345345

346+
</details>
347+
<details>
348+
<summary>
349+
DescribeApplicationOperation
350+
</summary>
351+
352+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DescribeApplicationOperationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationOperationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationOperationCommandOutput/)
353+
346354
</details>
347355
<details>
348356
<summary>
@@ -367,6 +375,14 @@ DiscoverInputSchema
367375

368376
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DiscoverInputSchemaCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DiscoverInputSchemaCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DiscoverInputSchemaCommandOutput/)
369377

378+
</details>
379+
<details>
380+
<summary>
381+
ListApplicationOperations
382+
</summary>
383+
384+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/ListApplicationOperationsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/ListApplicationOperationsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/ListApplicationOperationsCommandOutput/)
385+
370386
</details>
371387
<details>
372388
<summary>

‎clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2.ts

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,11 @@ import {
8787
DescribeApplicationCommandInput,
8888
DescribeApplicationCommandOutput,
8989
} from "./commands/DescribeApplicationCommand";
90+
import {
91+
DescribeApplicationOperationCommand,
92+
DescribeApplicationOperationCommandInput,
93+
DescribeApplicationOperationCommandOutput,
94+
} from "./commands/DescribeApplicationOperationCommand";
9095
import {
9196
DescribeApplicationSnapshotCommand,
9297
DescribeApplicationSnapshotCommandInput,
@@ -102,6 +107,11 @@ import {
102107
DiscoverInputSchemaCommandInput,
103108
DiscoverInputSchemaCommandOutput,
104109
} from "./commands/DiscoverInputSchemaCommand";
110+
import {
111+
ListApplicationOperationsCommand,
112+
ListApplicationOperationsCommandInput,
113+
ListApplicationOperationsCommandOutput,
114+
} from "./commands/ListApplicationOperationsCommand";
105115
import {
106116
ListApplicationsCommand,
107117
ListApplicationsCommandInput,
@@ -173,9 +183,11 @@ const commands = {
173183
DeleteApplicationSnapshotCommand,
174184
DeleteApplicationVpcConfigurationCommand,
175185
DescribeApplicationCommand,
186+
DescribeApplicationOperationCommand,
176187
DescribeApplicationSnapshotCommand,
177188
DescribeApplicationVersionCommand,
178189
DiscoverInputSchemaCommand,
190+
ListApplicationOperationsCommand,
179191
ListApplicationsCommand,
180192
ListApplicationSnapshotsCommand,
181193
ListApplicationVersionsCommand,
@@ -479,6 +491,23 @@ export interface KinesisAnalyticsV2 {
479491
cb: (err: any, data?: DescribeApplicationCommandOutput) => void
480492
): void;
481493

494+
/**
495+
* @see {@link DescribeApplicationOperationCommand}
496+
*/
497+
describeApplicationOperation(
498+
args: DescribeApplicationOperationCommandInput,
499+
options?: __HttpHandlerOptions
500+
): Promise<DescribeApplicationOperationCommandOutput>;
501+
describeApplicationOperation(
502+
args: DescribeApplicationOperationCommandInput,
503+
cb: (err: any, data?: DescribeApplicationOperationCommandOutput) => void
504+
): void;
505+
describeApplicationOperation(
506+
args: DescribeApplicationOperationCommandInput,
507+
options: __HttpHandlerOptions,
508+
cb: (err: any, data?: DescribeApplicationOperationCommandOutput) => void
509+
): void;
510+
482511
/**
483512
* @see {@link DescribeApplicationSnapshotCommand}
484513
*/
@@ -530,6 +559,23 @@ export interface KinesisAnalyticsV2 {
530559
cb: (err: any, data?: DiscoverInputSchemaCommandOutput) => void
531560
): void;
532561

562+
/**
563+
* @see {@link ListApplicationOperationsCommand}
564+
*/
565+
listApplicationOperations(
566+
args: ListApplicationOperationsCommandInput,
567+
options?: __HttpHandlerOptions
568+
): Promise<ListApplicationOperationsCommandOutput>;
569+
listApplicationOperations(
570+
args: ListApplicationOperationsCommandInput,
571+
cb: (err: any, data?: ListApplicationOperationsCommandOutput) => void
572+
): void;
573+
listApplicationOperations(
574+
args: ListApplicationOperationsCommandInput,
575+
options: __HttpHandlerOptions,
576+
cb: (err: any, data?: ListApplicationOperationsCommandOutput) => void
577+
): void;
578+
533579
/**
534580
* @see {@link ListApplicationsCommand}
535581
*/

‎clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2Client.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,10 @@ import {
115115
DescribeApplicationCommandInput,
116116
DescribeApplicationCommandOutput,
117117
} from "./commands/DescribeApplicationCommand";
118+
import {
119+
DescribeApplicationOperationCommandInput,
120+
DescribeApplicationOperationCommandOutput,
121+
} from "./commands/DescribeApplicationOperationCommand";
118122
import {
119123
DescribeApplicationSnapshotCommandInput,
120124
DescribeApplicationSnapshotCommandOutput,
@@ -127,6 +131,10 @@ import {
127131
DiscoverInputSchemaCommandInput,
128132
DiscoverInputSchemaCommandOutput,
129133
} from "./commands/DiscoverInputSchemaCommand";
134+
import {
135+
ListApplicationOperationsCommandInput,
136+
ListApplicationOperationsCommandOutput,
137+
} from "./commands/ListApplicationOperationsCommand";
130138
import { ListApplicationsCommandInput, ListApplicationsCommandOutput } from "./commands/ListApplicationsCommand";
131139
import {
132140
ListApplicationSnapshotsCommandInput,
@@ -185,9 +193,11 @@ export type ServiceInputTypes =
185193
| DeleteApplicationSnapshotCommandInput
186194
| DeleteApplicationVpcConfigurationCommandInput
187195
| DescribeApplicationCommandInput
196+
| DescribeApplicationOperationCommandInput
188197
| DescribeApplicationSnapshotCommandInput
189198
| DescribeApplicationVersionCommandInput
190199
| DiscoverInputSchemaCommandInput
200+
| ListApplicationOperationsCommandInput
191201
| ListApplicationSnapshotsCommandInput
192202
| ListApplicationVersionsCommandInput
193203
| ListApplicationsCommandInput
@@ -221,9 +231,11 @@ export type ServiceOutputTypes =
221231
| DeleteApplicationSnapshotCommandOutput
222232
| DeleteApplicationVpcConfigurationCommandOutput
223233
| DescribeApplicationCommandOutput
234+
| DescribeApplicationOperationCommandOutput
224235
| DescribeApplicationSnapshotCommandOutput
225236
| DescribeApplicationVersionCommandOutput
226237
| DiscoverInputSchemaCommandOutput
238+
| ListApplicationOperationsCommandOutput
227239
| ListApplicationSnapshotsCommandOutput
228240
| ListApplicationVersionsCommandOutput
229241
| ListApplicationsCommandOutput

‎clients/client-kinesis-analytics-v2/src/commands/AddApplicationCloudWatchLoggingOptionCommand.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ export interface AddApplicationCloudWatchLoggingOptionCommandOutput
6868
* // RoleARN: "STRING_VALUE",
6969
* // },
7070
* // ],
71+
* // OperationId: "STRING_VALUE",
7172
* // };
7273
*
7374
* ```

‎clients/client-kinesis-analytics-v2/src/commands/AddApplicationVpcConfigurationCommand.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ export interface AddApplicationVpcConfigurationCommandOutput
8383
* // "STRING_VALUE",
8484
* // ],
8585
* // },
86+
* // OperationId: "STRING_VALUE",
8687
* // };
8788
*
8889
* ```

‎clients/client-kinesis-analytics-v2/src/commands/CreateApplicationCommand.ts

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,9 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
182182
* ApplicationSnapshotConfiguration: { // ApplicationSnapshotConfiguration
183183
* SnapshotsEnabled: true || false, // required
184184
* },
185+
* ApplicationSystemRollbackConfiguration: { // ApplicationSystemRollbackConfiguration
186+
* RollbackEnabled: true || false, // required
187+
* },
185188
* VpcConfigurations: [ // VpcConfigurations
186189
* { // VpcConfiguration
187190
* SubnetIds: [ // SubnetIds // required
@@ -414,6 +417,9 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
414417
* // ApplicationSnapshotConfigurationDescription: { // ApplicationSnapshotConfigurationDescription
415418
* // SnapshotsEnabled: true || false, // required
416419
* // },
420+
* // ApplicationSystemRollbackConfigurationDescription: { // ApplicationSystemRollbackConfigurationDescription
421+
* // RollbackEnabled: true || false, // required
422+
* // },
417423
* // VpcConfigurationDescriptions: [ // VpcConfigurationDescriptions
418424
* // { // VpcConfigurationDescription
419425
* // VpcConfigurationId: "STRING_VALUE", // required
@@ -471,6 +477,7 @@ export interface CreateApplicationCommandOutput extends CreateApplicationRespons
471477
* // },
472478
* // ApplicationVersionUpdatedFrom: Number("long"),
473479
* // ApplicationVersionRolledBackFrom: Number("long"),
480+
* // ApplicationVersionCreateTimestamp: new Date("TIMESTAMP"),
474481
* // ConditionalToken: "STRING_VALUE",
475482
* // ApplicationVersionRolledBackTo: Number("long"),
476483
* // ApplicationMode: "STREAMING" || "INTERACTIVE",

‎clients/client-kinesis-analytics-v2/src/commands/CreateApplicationPresignedUrlCommand.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,13 +39,13 @@ export interface CreateApplicationPresignedUrlCommandOutput
3939
/**
4040
* <p>Creates and returns a URL that you can use to connect to
4141
* an application's extension.</p>
42-
* <p>The IAM role or user used to call this API defines the permissions to access the
42+
* <p>The IAM role or user used to call this API defines the permissions to access the
4343
* extension. After the presigned URL is created, no additional permission is required to access
4444
* this URL. IAM authorization policies for this API are also enforced for every HTTP request
4545
* that attempts to connect to the extension. </p>
46-
* <p>You control the amount of time that the URL will be valid using the <code>SessionExpirationDurationInSeconds</code>
46+
* <p>You control the amount of time that the URL will be valid using the <code>SessionExpirationDurationInSeconds</code>
4747
* parameter. If you do not provide this parameter, the returned URL is valid for twelve hours.</p>
48-
* <note>
48+
* <note>
4949
* <p>The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes
5050
* to be valid.
5151
* If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error.</p>

‎clients/client-kinesis-analytics-v2/src/commands/DeleteApplicationCloudWatchLoggingOptionCommand.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ export interface DeleteApplicationCloudWatchLoggingOptionCommandOutput
6666
* // RoleARN: "STRING_VALUE",
6767
* // },
6868
* // ],
69+
* // OperationId: "STRING_VALUE",
6970
* // };
7071
*
7172
* ```

‎clients/client-kinesis-analytics-v2/src/commands/DeleteApplicationVpcConfigurationCommand.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ export interface DeleteApplicationVpcConfigurationCommandOutput
5858
* // { // DeleteApplicationVpcConfigurationResponse
5959
* // ApplicationARN: "STRING_VALUE",
6060
* // ApplicationVersionId: Number("long"),
61+
* // OperationId: "STRING_VALUE",
6162
* // };
6263
*
6364
* ```

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationCommand.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,9 @@ export interface DescribeApplicationCommandOutput extends DescribeApplicationRes
222222
* // ApplicationSnapshotConfigurationDescription: { // ApplicationSnapshotConfigurationDescription
223223
* // SnapshotsEnabled: true || false, // required
224224
* // },
225+
* // ApplicationSystemRollbackConfigurationDescription: { // ApplicationSystemRollbackConfigurationDescription
226+
* // RollbackEnabled: true || false, // required
227+
* // },
225228
* // VpcConfigurationDescriptions: [ // VpcConfigurationDescriptions
226229
* // { // VpcConfigurationDescription
227230
* // VpcConfigurationId: "STRING_VALUE", // required
@@ -279,6 +282,7 @@ export interface DescribeApplicationCommandOutput extends DescribeApplicationRes
279282
* // },
280283
* // ApplicationVersionUpdatedFrom: Number("long"),
281284
* // ApplicationVersionRolledBackFrom: Number("long"),
285+
* // ApplicationVersionCreateTimestamp: new Date("TIMESTAMP"),
282286
* // ConditionalToken: "STRING_VALUE",
283287
* // ApplicationVersionRolledBackTo: Number("long"),
284288
* // ApplicationMode: "STREAMING" || "INTERACTIVE",

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationOperationCommand.ts

Lines changed: 117 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,117 @@
1+
// smithy-typescript generated code
2+
import { getEndpointPlugin } from "@smithy/middleware-endpoint";
3+
import { getSerdePlugin } from "@smithy/middleware-serde";
4+
import { Command as $Command } from "@smithy/smithy-client";
5+
import { MetadataBearer as __MetadataBearer } from "@smithy/types";
6+
7+
import { commonParams } from "../endpoint/EndpointParameters";
8+
import {
9+
KinesisAnalyticsV2ClientResolvedConfig,
10+
ServiceInputTypes,
11+
ServiceOutputTypes,
12+
} from "../KinesisAnalyticsV2Client";
13+
import { DescribeApplicationOperationRequest, DescribeApplicationOperationResponse } from "../models/models_0";
14+
import {
15+
de_DescribeApplicationOperationCommand,
16+
se_DescribeApplicationOperationCommand,
17+
} from "../protocols/Aws_json1_1";
18+
19+
/**
20+
* @public
21+
*/
22+
export type { __MetadataBearer };
23+
export { $Command };
24+
/**
25+
* @public
26+
*
27+
* The input for {@link DescribeApplicationOperationCommand}.
28+
*/
29+
export interface DescribeApplicationOperationCommandInput extends DescribeApplicationOperationRequest {}
30+
/**
31+
* @public
32+
*
33+
* The output of {@link DescribeApplicationOperationCommand}.
34+
*/
35+
export interface DescribeApplicationOperationCommandOutput
36+
extends DescribeApplicationOperationResponse,
37+
__MetadataBearer {}
38+
39+
/**
40+
* Returns information about a specific operation performed on a Managed Service for Apache Flink application
41+
* @example
42+
* Use a bare-bones client and the command you need to make an API call.
43+
* ```javascript
44+
* import { KinesisAnalyticsV2Client, DescribeApplicationOperationCommand } from "@aws-sdk/client-kinesis-analytics-v2"; // ES Modules import
45+
* // const { KinesisAnalyticsV2Client, DescribeApplicationOperationCommand } = require("@aws-sdk/client-kinesis-analytics-v2"); // CommonJS import
46+
* const client = new KinesisAnalyticsV2Client(config);
47+
* const input = { // DescribeApplicationOperationRequest
48+
* ApplicationName: "STRING_VALUE", // required
49+
* OperationId: "STRING_VALUE", // required
50+
* };
51+
* const command = new DescribeApplicationOperationCommand(input);
52+
* const response = await client.send(command);
53+
* // { // DescribeApplicationOperationResponse
54+
* // ApplicationOperationInfoDetails: { // ApplicationOperationInfoDetails
55+
* // Operation: "STRING_VALUE", // required
56+
* // StartTime: new Date("TIMESTAMP"), // required
57+
* // EndTime: new Date("TIMESTAMP"), // required
58+
* // OperationStatus: "IN_PROGRESS" || "CANCELLED" || "SUCCESSFUL" || "FAILED", // required
59+
* // ApplicationVersionChangeDetails: { // ApplicationVersionChangeDetails
60+
* // ApplicationVersionUpdatedFrom: Number("long"), // required
61+
* // ApplicationVersionUpdatedTo: Number("long"), // required
62+
* // },
63+
* // OperationFailureDetails: { // OperationFailureDetails
64+
* // RollbackOperationId: "STRING_VALUE",
65+
* // ErrorInfo: { // ErrorInfo
66+
* // ErrorString: "STRING_VALUE",
67+
* // },
68+
* // },
69+
* // },
70+
* // };
71+
*
72+
* ```
73+
*
74+
* @param DescribeApplicationOperationCommandInput - {@link DescribeApplicationOperationCommandInput}
75+
* @returns {@link DescribeApplicationOperationCommandOutput}
76+
* @see {@link DescribeApplicationOperationCommandInput} for command's `input` shape.
77+
* @see {@link DescribeApplicationOperationCommandOutput} for command's `response` shape.
78+
* @see {@link KinesisAnalyticsV2ClientResolvedConfig | config} for KinesisAnalyticsV2Client's `config` shape.
79+
*
80+
* @throws {@link InvalidArgumentException} (client fault)
81+
* <p>The specified input parameter value is not valid.</p>
82+
*
83+
* @throws {@link ResourceNotFoundException} (client fault)
84+
* <p>Specified application can't be found.</p>
85+
*
86+
* @throws {@link UnsupportedOperationException} (client fault)
87+
* <p>The request was rejected because a specified parameter is not supported or a specified resource is not valid for this
88+
* operation. </p>
89+
*
90+
* @throws {@link KinesisAnalyticsV2ServiceException}
91+
* <p>Base exception class for all service exceptions from KinesisAnalyticsV2 service.</p>
92+
*
93+
* @public
94+
*/
95+
export class DescribeApplicationOperationCommand extends $Command
96+
.classBuilder<
97+
DescribeApplicationOperationCommandInput,
98+
DescribeApplicationOperationCommandOutput,
99+
KinesisAnalyticsV2ClientResolvedConfig,
100+
ServiceInputTypes,
101+
ServiceOutputTypes
102+
>()
103+
.ep({
104+
...commonParams,
105+
})
106+
.m(function (this: any, Command: any, cs: any, config: KinesisAnalyticsV2ClientResolvedConfig, o: any) {
107+
return [
108+
getSerdePlugin(config, this.serialize, this.deserialize),
109+
getEndpointPlugin(config, Command.getEndpointParameterInstructions()),
110+
];
111+
})
112+
.s("KinesisAnalytics_20180523", "DescribeApplicationOperation", {})
113+
.n("KinesisAnalyticsV2Client", "DescribeApplicationOperationCommand")
114+
.f(void 0, void 0)
115+
.ser(se_DescribeApplicationOperationCommand)
116+
.de(de_DescribeApplicationOperationCommand)
117+
.build() {}

‎clients/client-kinesis-analytics-v2/src/commands/DescribeApplicationVersionCommand.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -223,6 +223,9 @@ export interface DescribeApplicationVersionCommandOutput extends DescribeApplica
223223
* // ApplicationSnapshotConfigurationDescription: { // ApplicationSnapshotConfigurationDescription
224224
* // SnapshotsEnabled: true || false, // required
225225
* // },
226+
* // ApplicationSystemRollbackConfigurationDescription: { // ApplicationSystemRollbackConfigurationDescription
227+
* // RollbackEnabled: true || false, // required
228+
* // },
226229
* // VpcConfigurationDescriptions: [ // VpcConfigurationDescriptions
227230
* // { // VpcConfigurationDescription
228231
* // VpcConfigurationId: "STRING_VALUE", // required
@@ -280,6 +283,7 @@ export interface DescribeApplicationVersionCommandOutput extends DescribeApplica
280283
* // },
281284
* // ApplicationVersionUpdatedFrom: Number("long"),
282285
* // ApplicationVersionRolledBackFrom: Number("long"),
286+
* // ApplicationVersionCreateTimestamp: new Date("TIMESTAMP"),
283287
* // ConditionalToken: "STRING_VALUE",
284288
* // ApplicationVersionRolledBackTo: Number("long"),
285289
* // ApplicationMode: "STREAMING" || "INTERACTIVE",

0 commit comments

Comments
 (0)