feat(client-firehose): For AppendOnly streams, Firehose will automati…

…cally scale to match your throughput.
aws · Jan 28, 2025 · 446f685 · 446f685
1 parent e6f9df1
commit 446f685
Show file tree

Hide file tree

Showing 6 changed files with 433 additions and 193 deletions.
diff --git a/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts b/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts
@@ -108,6 +108,9 @@ export interface CreateDeliveryStreamCommandOutput extends CreateDeliveryStreamO
  * const input = { // CreateDeliveryStreamInput
  *   DeliveryStreamName: "STRING_VALUE", // required
  *   DeliveryStreamType: "DirectPut" || "KinesisStreamAsSource" || "MSKAsSource" || "DatabaseAsSource",
+ *   DirectPutSourceConfiguration: { // DirectPutSourceConfiguration
+ *     ThroughputHintInMBs: Number("int"), // required
+ *   },
  *   KinesisStreamSourceConfiguration: { // KinesisStreamSourceConfiguration
  *     KinesisStreamARN: "STRING_VALUE", // required
  *     RoleARN: "STRING_VALUE", // required
@@ -610,6 +613,7 @@ export interface CreateDeliveryStreamCommandOutput extends CreateDeliveryStreamO
  *       DurationInSeconds: Number("int"),
  *     },
  *     RoleARN: "STRING_VALUE", // required
+ *     AppendOnly: true || false,
  *     CatalogConfiguration: { // CatalogConfiguration
  *       CatalogARN: "STRING_VALUE",
  *       WarehouseLocation: "STRING_VALUE",

diff --git a/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts b/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts
@@ -75,6 +75,9 @@ export interface DescribeDeliveryStreamCommandOutput extends DescribeDeliveryStr
  * //     CreateTimestamp: new Date("TIMESTAMP"),
  * //     LastUpdateTimestamp: new Date("TIMESTAMP"),
  * //     Source: { // SourceDescription
+ * //       DirectPutSourceDescription: { // DirectPutSourceDescription
+ * //         ThroughputHintInMBs: Number("int"),
+ * //       },
  * //       KinesisStreamSourceDescription: { // KinesisStreamSourceDescription
  * //         KinesisStreamARN: "STRING_VALUE",
  * //         RoleARN: "STRING_VALUE",
@@ -626,6 +629,7 @@ export interface DescribeDeliveryStreamCommandOutput extends DescribeDeliveryStr
  * //             DurationInSeconds: Number("int"),
  * //           },
  * //           RoleARN: "STRING_VALUE",
+ * //           AppendOnly: true || false,
  * //           CatalogConfiguration: { // CatalogConfiguration
  * //             CatalogARN: "STRING_VALUE",
  * //             WarehouseLocation: "STRING_VALUE",

diff --git a/clients/client-firehose/src/commands/UpdateDestinationCommand.ts b/clients/client-firehose/src/commands/UpdateDestinationCommand.ts
@@ -511,6 +511,7 @@ export interface UpdateDestinationCommandOutput extends UpdateDestinationOutput,
  *       DurationInSeconds: Number("int"),
  *     },
  *     RoleARN: "STRING_VALUE",
+ *     AppendOnly: true || false,
  *     CatalogConfiguration: { // CatalogConfiguration
  *       CatalogARN: "STRING_VALUE",
  *       WarehouseLocation: "STRING_VALUE",