feat(client-kafka): Amazon MSK has introduced new versions of ListClu…

…sterOperations and DescribeClusterOperation APIs. These v2 APIs provide information and insights into the ongoing operations of both MSK Provisioned and MSK Serverless clusters.
aws · Jul 28, 2023 · 57e3fc5 · 57e3fc5
1 parent 2ccf087
commit 57e3fc5
Show file tree

Hide file tree

Showing 11 changed files with 1,603 additions and 0 deletions.
diff --git a/clients/client-kafka/README.md b/clients/client-kafka/README.md
@@ -298,6 +298,14 @@ DescribeClusterOperation
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/describeclusteroperationcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeclusteroperationcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeclusteroperationcommandoutput.html)
 
+</details>
+<details>
+<summary>
+DescribeClusterOperationV2
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/describeclusteroperationv2command.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeclusteroperationv2commandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeclusteroperationv2commandoutput.html)
+
 </details>
 <details>
 <summary>
@@ -370,6 +378,14 @@ ListClusterOperations
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/listclusteroperationscommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listclusteroperationscommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listclusteroperationscommandoutput.html)
 
+</details>
+<details>
+<summary>
+ListClusterOperationsV2
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/listclusteroperationsv2command.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listclusteroperationsv2commandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listclusteroperationsv2commandoutput.html)
+
 </details>
 <details>
 <summary>

diff --git a/clients/client-kafka/src/Kafka.ts b/clients/client-kafka/src/Kafka.ts
@@ -62,6 +62,11 @@ import {
  DescribeClusterOperationCommandInput,
  DescribeClusterOperationCommandOutput,
 } from "./commands/DescribeClusterOperationCommand";
+import {
+ DescribeClusterOperationV2Command,
+ DescribeClusterOperationV2CommandInput,
+ DescribeClusterOperationV2CommandOutput,
+} from "./commands/DescribeClusterOperationV2Command";
 import {
  DescribeClusterV2Command,
  DescribeClusterV2CommandInput,
@@ -107,6 +112,11 @@ import {
  ListClusterOperationsCommandInput,
  ListClusterOperationsCommandOutput,
 } from "./commands/ListClusterOperationsCommand";
+import {
+ ListClusterOperationsV2Command,
+ ListClusterOperationsV2CommandInput,
+ ListClusterOperationsV2CommandOutput,
+} from "./commands/ListClusterOperationsV2Command";
 import {
  ListClustersCommand,
  ListClustersCommandInput,
@@ -234,6 +244,7 @@ const commands = {
  DeleteVpcConnectionCommand,
  DescribeClusterCommand,
  DescribeClusterOperationCommand,
+ DescribeClusterOperationV2Command,
  DescribeClusterV2Command,
  DescribeConfigurationCommand,
  DescribeConfigurationRevisionCommand,
@@ -243,6 +254,7 @@ const commands = {
  GetCompatibleKafkaVersionsCommand,
  ListClientVpcConnectionsCommand,
  ListClusterOperationsCommand,
+ ListClusterOperationsV2Command,
  ListClustersCommand,
  ListClustersV2Command,
  ListConfigurationRevisionsCommand,
@@ -456,6 +468,23 @@ export interface Kafka {
  cb: (err: any, data?: DescribeClusterOperationCommandOutput) => void
  ): void;
 
+ /**
+ * @see {@link DescribeClusterOperationV2Command}
+ */
+ describeClusterOperationV2(
+ args: DescribeClusterOperationV2CommandInput,
+ options?: __HttpHandlerOptions
+ ): Promise<DescribeClusterOperationV2CommandOutput>;
+ describeClusterOperationV2(
+ args: DescribeClusterOperationV2CommandInput,
+ cb: (err: any, data?: DescribeClusterOperationV2CommandOutput) => void
+ ): void;
+ describeClusterOperationV2(
+ args: DescribeClusterOperationV2CommandInput,
+ options: __HttpHandlerOptions,
+ cb: (err: any, data?: DescribeClusterOperationV2CommandOutput) => void
+ ): void;
+
  /**
  * @see {@link DescribeClusterV2Command}
  */
@@ -609,6 +638,23 @@ export interface Kafka {
  cb: (err: any, data?: ListClusterOperationsCommandOutput) => void
  ): void;
 
+ /**
+ * @see {@link ListClusterOperationsV2Command}
+ */
+ listClusterOperationsV2(
+ args: ListClusterOperationsV2CommandInput,
+ options?: __HttpHandlerOptions
+ ): Promise<ListClusterOperationsV2CommandOutput>;
+ listClusterOperationsV2(
+ args: ListClusterOperationsV2CommandInput,
+ cb: (err: any, data?: ListClusterOperationsV2CommandOutput) => void
+ ): void;
+ listClusterOperationsV2(
+ args: ListClusterOperationsV2CommandInput,
+ options: __HttpHandlerOptions,
+ cb: (err: any, data?: ListClusterOperationsV2CommandOutput) => void
+ ): void;
+
  /**
  * @see {@link ListClustersCommand}
  */

diff --git a/clients/client-kafka/src/KafkaClient.ts b/clients/client-kafka/src/KafkaClient.ts
@@ -85,6 +85,10 @@ import {
  DescribeClusterOperationCommandInput,
  DescribeClusterOperationCommandOutput,
 } from "./commands/DescribeClusterOperationCommand";
+import {
+ DescribeClusterOperationV2CommandInput,
+ DescribeClusterOperationV2CommandOutput,
+} from "./commands/DescribeClusterOperationV2Command";
 import { DescribeClusterV2CommandInput, DescribeClusterV2CommandOutput } from "./commands/DescribeClusterV2Command";
 import {
  DescribeConfigurationCommandInput,
@@ -115,6 +119,10 @@ import {
  ListClusterOperationsCommandInput,
  ListClusterOperationsCommandOutput,
 } from "./commands/ListClusterOperationsCommand";
+import {
+ ListClusterOperationsV2CommandInput,
+ ListClusterOperationsV2CommandOutput,
+} from "./commands/ListClusterOperationsV2Command";
 import { ListClustersCommandInput, ListClustersCommandOutput } from "./commands/ListClustersCommand";
 import { ListClustersV2CommandInput, ListClustersV2CommandOutput } from "./commands/ListClustersV2Command";
 import {
@@ -186,6 +194,7 @@ export type ServiceInputTypes =
  | DeleteVpcConnectionCommandInput
  | DescribeClusterCommandInput
  | DescribeClusterOperationCommandInput
+ | DescribeClusterOperationV2CommandInput
  | DescribeClusterV2CommandInput
  | DescribeConfigurationCommandInput
  | DescribeConfigurationRevisionCommandInput
@@ -195,6 +204,7 @@ export type ServiceInputTypes =
  | GetCompatibleKafkaVersionsCommandInput
  | ListClientVpcConnectionsCommandInput
  | ListClusterOperationsCommandInput
+ | ListClusterOperationsV2CommandInput
  | ListClustersCommandInput
  | ListClustersV2CommandInput
  | ListConfigurationRevisionsCommandInput
@@ -236,6 +246,7 @@ export type ServiceOutputTypes =
  | DeleteVpcConnectionCommandOutput
  | DescribeClusterCommandOutput
  | DescribeClusterOperationCommandOutput
+ | DescribeClusterOperationV2CommandOutput
  | DescribeClusterV2CommandOutput
  | DescribeConfigurationCommandOutput
  | DescribeConfigurationRevisionCommandOutput
@@ -245,6 +256,7 @@ export type ServiceOutputTypes =
  | GetCompatibleKafkaVersionsCommandOutput
  | ListClientVpcConnectionsCommandOutput
  | ListClusterOperationsCommandOutput
+ | ListClusterOperationsV2CommandOutput
  | ListClustersCommandOutput
  | ListClustersV2CommandOutput
  | ListConfigurationRevisionsCommandOutput