Skip to content

Commit 2be6625

Browse files
author
awstools
committed
feat(client-dynamodb): This release adds support for including ApproximateCreationDateTimePrecision configurations in EnableKinesisStreamingDestination API, adds the same as an optional field in the response of DescribeKinesisStreamingDestination, and adds support for a new UpdateKinesisStreamingDestination API.
1 parent a8ed592 commit 2be6625

11 files changed

+550
-10
lines changed

clients/client-dynamodb/README.md

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -619,6 +619,14 @@ UpdateItem
619619

620620
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/dynamodb/command/UpdateItemCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-dynamodb/Interface/UpdateItemCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-dynamodb/Interface/UpdateItemCommandOutput/)
621621

622+
</details>
623+
<details>
624+
<summary>
625+
UpdateKinesisStreamingDestination
626+
</summary>
627+
628+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/dynamodb/command/UpdateKinesisStreamingDestinationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-dynamodb/Interface/UpdateKinesisStreamingDestinationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-dynamodb/Interface/UpdateKinesisStreamingDestinationCommandOutput/)
629+
622630
</details>
623631
<details>
624632
<summary>

clients/client-dynamodb/src/DynamoDB.ts

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,11 @@ import {
196196
UpdateGlobalTableSettingsCommandOutput,
197197
} from "./commands/UpdateGlobalTableSettingsCommand";
198198
import { UpdateItemCommand, UpdateItemCommandInput, UpdateItemCommandOutput } from "./commands/UpdateItemCommand";
199+
import {
200+
UpdateKinesisStreamingDestinationCommand,
201+
UpdateKinesisStreamingDestinationCommandInput,
202+
UpdateKinesisStreamingDestinationCommandOutput,
203+
} from "./commands/UpdateKinesisStreamingDestinationCommand";
199204
import { UpdateTableCommand, UpdateTableCommandInput, UpdateTableCommandOutput } from "./commands/UpdateTableCommand";
200205
import {
201206
UpdateTableReplicaAutoScalingCommand,
@@ -260,6 +265,7 @@ const commands = {
260265
UpdateGlobalTableCommand,
261266
UpdateGlobalTableSettingsCommand,
262267
UpdateItemCommand,
268+
UpdateKinesisStreamingDestinationCommand,
263269
UpdateTableCommand,
264270
UpdateTableReplicaAutoScalingCommand,
265271
UpdateTimeToLiveCommand,
@@ -983,6 +989,23 @@ export interface DynamoDB {
983989
cb: (err: any, data?: UpdateItemCommandOutput) => void
984990
): void;
985991

992+
/**
993+
* @see {@link UpdateKinesisStreamingDestinationCommand}
994+
*/
995+
updateKinesisStreamingDestination(
996+
args: UpdateKinesisStreamingDestinationCommandInput,
997+
options?: __HttpHandlerOptions
998+
): Promise<UpdateKinesisStreamingDestinationCommandOutput>;
999+
updateKinesisStreamingDestination(
1000+
args: UpdateKinesisStreamingDestinationCommandInput,
1001+
cb: (err: any, data?: UpdateKinesisStreamingDestinationCommandOutput) => void
1002+
): void;
1003+
updateKinesisStreamingDestination(
1004+
args: UpdateKinesisStreamingDestinationCommandInput,
1005+
options: __HttpHandlerOptions,
1006+
cb: (err: any, data?: UpdateKinesisStreamingDestinationCommandOutput) => void
1007+
): void;
1008+
9861009
/**
9871010
* @see {@link UpdateTableCommand}
9881011
*/

clients/client-dynamodb/src/DynamoDBClient.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,10 @@ import {
160160
UpdateGlobalTableSettingsCommandOutput,
161161
} from "./commands/UpdateGlobalTableSettingsCommand";
162162
import { UpdateItemCommandInput, UpdateItemCommandOutput } from "./commands/UpdateItemCommand";
163+
import {
164+
UpdateKinesisStreamingDestinationCommandInput,
165+
UpdateKinesisStreamingDestinationCommandOutput,
166+
} from "./commands/UpdateKinesisStreamingDestinationCommand";
163167
import { UpdateTableCommandInput, UpdateTableCommandOutput } from "./commands/UpdateTableCommand";
164168
import {
165169
UpdateTableReplicaAutoScalingCommandInput,
@@ -231,6 +235,7 @@ export type ServiceInputTypes =
231235
| UpdateGlobalTableCommandInput
232236
| UpdateGlobalTableSettingsCommandInput
233237
| UpdateItemCommandInput
238+
| UpdateKinesisStreamingDestinationCommandInput
234239
| UpdateTableCommandInput
235240
| UpdateTableReplicaAutoScalingCommandInput
236241
| UpdateTimeToLiveCommandInput;
@@ -289,6 +294,7 @@ export type ServiceOutputTypes =
289294
| UpdateGlobalTableCommandOutput
290295
| UpdateGlobalTableSettingsCommandOutput
291296
| UpdateItemCommandOutput
297+
| UpdateKinesisStreamingDestinationCommandOutput
292298
| UpdateTableCommandOutput
293299
| UpdateTableReplicaAutoScalingCommandOutput
294300
| UpdateTimeToLiveCommandOutput;

clients/client-dynamodb/src/commands/DescribeKinesisStreamingDestinationCommand.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,9 @@ export interface DescribeKinesisStreamingDestinationCommandOutput
5353
* // KinesisDataStreamDestinations: [ // KinesisDataStreamDestinations
5454
* // { // KinesisDataStreamDestination
5555
* // StreamArn: "STRING_VALUE",
56-
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED",
56+
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED" || "UPDATING",
5757
* // DestinationStatusDescription: "STRING_VALUE",
58+
* // ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
5859
* // },
5960
* // ],
6061
* // };

clients/client-dynamodb/src/commands/DisableKinesisStreamingDestinationCommand.ts

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,13 +44,19 @@ export interface DisableKinesisStreamingDestinationCommandOutput
4444
* const input = { // KinesisStreamingDestinationInput
4545
* TableName: "STRING_VALUE", // required
4646
* StreamArn: "STRING_VALUE", // required
47+
* EnableKinesisStreamingConfiguration: { // EnableKinesisStreamingConfiguration
48+
* ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
49+
* },
4750
* };
4851
* const command = new DisableKinesisStreamingDestinationCommand(input);
4952
* const response = await client.send(command);
5053
* // { // KinesisStreamingDestinationOutput
5154
* // TableName: "STRING_VALUE",
5255
* // StreamArn: "STRING_VALUE",
53-
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED",
56+
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED" || "UPDATING",
57+
* // EnableKinesisStreamingConfiguration: { // EnableKinesisStreamingConfiguration
58+
* // ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
59+
* // },
5460
* // };
5561
*
5662
* ```

clients/client-dynamodb/src/commands/EnableKinesisStreamingDestinationCommand.ts

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,13 +46,19 @@ export interface EnableKinesisStreamingDestinationCommandOutput
4646
* const input = { // KinesisStreamingDestinationInput
4747
* TableName: "STRING_VALUE", // required
4848
* StreamArn: "STRING_VALUE", // required
49+
* EnableKinesisStreamingConfiguration: { // EnableKinesisStreamingConfiguration
50+
* ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
51+
* },
4952
* };
5053
* const command = new EnableKinesisStreamingDestinationCommand(input);
5154
* const response = await client.send(command);
5255
* // { // KinesisStreamingDestinationOutput
5356
* // TableName: "STRING_VALUE",
5457
* // StreamArn: "STRING_VALUE",
55-
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED",
58+
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED" || "UPDATING",
59+
* // EnableKinesisStreamingConfiguration: { // EnableKinesisStreamingConfiguration
60+
* // ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
61+
* // },
5662
* // };
5763
*
5864
* ```
Lines changed: 125 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,125 @@
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 { DynamoDBClientResolvedConfig, ServiceInputTypes, ServiceOutputTypes } from "../DynamoDBClient";
8+
import { commonParams } from "../endpoint/EndpointParameters";
9+
import { UpdateKinesisStreamingDestinationInput, UpdateKinesisStreamingDestinationOutput } from "../models/models_0";
10+
import {
11+
de_UpdateKinesisStreamingDestinationCommand,
12+
se_UpdateKinesisStreamingDestinationCommand,
13+
} from "../protocols/Aws_json1_0";
14+
15+
/**
16+
* @public
17+
*/
18+
export { __MetadataBearer, $Command };
19+
/**
20+
* @public
21+
*
22+
* The input for {@link UpdateKinesisStreamingDestinationCommand}.
23+
*/
24+
export interface UpdateKinesisStreamingDestinationCommandInput extends UpdateKinesisStreamingDestinationInput {}
25+
/**
26+
* @public
27+
*
28+
* The output of {@link UpdateKinesisStreamingDestinationCommand}.
29+
*/
30+
export interface UpdateKinesisStreamingDestinationCommandOutput
31+
extends UpdateKinesisStreamingDestinationOutput,
32+
__MetadataBearer {}
33+
34+
/**
35+
* @public
36+
* <p>The command to update the Kinesis stream destination.</p>
37+
* @example
38+
* Use a bare-bones client and the command you need to make an API call.
39+
* ```javascript
40+
* import { DynamoDBClient, UpdateKinesisStreamingDestinationCommand } from "@aws-sdk/client-dynamodb"; // ES Modules import
41+
* // const { DynamoDBClient, UpdateKinesisStreamingDestinationCommand } = require("@aws-sdk/client-dynamodb"); // CommonJS import
42+
* const client = new DynamoDBClient(config);
43+
* const input = { // UpdateKinesisStreamingDestinationInput
44+
* TableName: "STRING_VALUE", // required
45+
* StreamArn: "STRING_VALUE", // required
46+
* UpdateKinesisStreamingConfiguration: { // UpdateKinesisStreamingConfiguration
47+
* ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
48+
* },
49+
* };
50+
* const command = new UpdateKinesisStreamingDestinationCommand(input);
51+
* const response = await client.send(command);
52+
* // { // UpdateKinesisStreamingDestinationOutput
53+
* // TableName: "STRING_VALUE",
54+
* // StreamArn: "STRING_VALUE",
55+
* // DestinationStatus: "ENABLING" || "ACTIVE" || "DISABLING" || "DISABLED" || "ENABLE_FAILED" || "UPDATING",
56+
* // UpdateKinesisStreamingConfiguration: { // UpdateKinesisStreamingConfiguration
57+
* // ApproximateCreationDateTimePrecision: "MILLISECOND" || "MICROSECOND",
58+
* // },
59+
* // };
60+
*
61+
* ```
62+
*
63+
* @param UpdateKinesisStreamingDestinationCommandInput - {@link UpdateKinesisStreamingDestinationCommandInput}
64+
* @returns {@link UpdateKinesisStreamingDestinationCommandOutput}
65+
* @see {@link UpdateKinesisStreamingDestinationCommandInput} for command's `input` shape.
66+
* @see {@link UpdateKinesisStreamingDestinationCommandOutput} for command's `response` shape.
67+
* @see {@link DynamoDBClientResolvedConfig | config} for DynamoDBClient's `config` shape.
68+
*
69+
* @throws {@link InternalServerError} (server fault)
70+
* <p>An error occurred on the server side.</p>
71+
*
72+
* @throws {@link InvalidEndpointException} (client fault)
73+
*
74+
* @throws {@link LimitExceededException} (client fault)
75+
* <p>There is no limit to the number of daily on-demand backups that can be taken. </p>
76+
* <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations
77+
* include <code>CreateTable</code>, <code>UpdateTable</code>,
78+
* <code>DeleteTable</code>,<code>UpdateTimeToLive</code>,
79+
* <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>. </p>
80+
* <p>When you are creating a table with one or more secondary
81+
* indexes, you can have up to 250 such requests running at a time. However, if the table or
82+
* index specifications are complex, then DynamoDB might temporarily reduce the number
83+
* of concurrent operations.</p>
84+
* <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p>
85+
* <p>There is a soft account quota of 2,500 tables.</p>
86+
* <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p>
87+
* <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding
88+
* this limit may result in request throttling.</p>
89+
*
90+
* @throws {@link ResourceInUseException} (client fault)
91+
* <p>The operation conflicts with the resource's availability. For example, you
92+
* attempted to recreate an existing table, or tried to delete a table currently in the
93+
* <code>CREATING</code> state.</p>
94+
*
95+
* @throws {@link ResourceNotFoundException} (client fault)
96+
* <p>The operation tried to access a nonexistent table or index. The resource might not
97+
* be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
98+
*
99+
* @throws {@link DynamoDBServiceException}
100+
* <p>Base exception class for all service exceptions from DynamoDB service.</p>
101+
*
102+
*/
103+
export class UpdateKinesisStreamingDestinationCommand extends $Command
104+
.classBuilder<
105+
UpdateKinesisStreamingDestinationCommandInput,
106+
UpdateKinesisStreamingDestinationCommandOutput,
107+
DynamoDBClientResolvedConfig,
108+
ServiceInputTypes,
109+
ServiceOutputTypes
110+
>()
111+
.ep({
112+
...commonParams,
113+
})
114+
.m(function (this: any, Command: any, cs: any, config: DynamoDBClientResolvedConfig, o: any) {
115+
return [
116+
getSerdePlugin(config, this.serialize, this.deserialize),
117+
getEndpointPlugin(config, Command.getEndpointParameterInstructions()),
118+
];
119+
})
120+
.s("DynamoDB_20120810", "UpdateKinesisStreamingDestination", {})
121+
.n("DynamoDBClient", "UpdateKinesisStreamingDestinationCommand")
122+
.f(void 0, void 0)
123+
.ser(se_UpdateKinesisStreamingDestinationCommand)
124+
.de(de_UpdateKinesisStreamingDestinationCommand)
125+
.build() {}

clients/client-dynamodb/src/commands/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ export * from "./UpdateContributorInsightsCommand";
4949
export * from "./UpdateGlobalTableCommand";
5050
export * from "./UpdateGlobalTableSettingsCommand";
5151
export * from "./UpdateItemCommand";
52+
export * from "./UpdateKinesisStreamingDestinationCommand";
5253
export * from "./UpdateTableCommand";
5354
export * from "./UpdateTableReplicaAutoScalingCommand";
5455
export * from "./UpdateTimeToLiveCommand";

0 commit comments

Comments
 (0)