feat(client-kafkaconnect): Adds support for tagging, with new TagReso…

…urce, UntagResource and ListTagsForResource APIs to manage tags and updates to existing APIs to allow tag on create. This release also adds support for the new DeleteWorkerConfiguration API.
aws · Feb 26, 2024 · 2a94d42 · 2a94d42
1 parent f0fac71
commit 2a94d42
Show file tree

Hide file tree

Showing 17 changed files with 1,345 additions and 12 deletions.
diff --git a/clients/client-kafkaconnect/README.md b/clients/client-kafkaconnect/README.md
@@ -242,6 +242,14 @@ DeleteCustomPlugin
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/DeleteCustomPluginCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/DeleteCustomPluginCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/DeleteCustomPluginCommandOutput/)
 
+</details>
+<details>
+<summary>
+DeleteWorkerConfiguration
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/DeleteWorkerConfigurationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/DeleteWorkerConfigurationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/DeleteWorkerConfigurationCommandOutput/)
+
 </details>
 <details>
 <summary>
@@ -282,6 +290,14 @@ ListCustomPlugins
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/ListCustomPluginsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListCustomPluginsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListCustomPluginsCommandOutput/)
 
+</details>
+<details>
+<summary>
+ListTagsForResource
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/ListTagsForResourceCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListTagsForResourceCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListTagsForResourceCommandOutput/)
+
 </details>
 <details>
 <summary>
@@ -290,6 +306,22 @@ ListWorkerConfigurations
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/ListWorkerConfigurationsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListWorkerConfigurationsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/ListWorkerConfigurationsCommandOutput/)
 
+</details>
+<details>
+<summary>
+TagResource
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/TagResourceCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/TagResourceCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/TagResourceCommandOutput/)
+
+</details>
+<details>
+<summary>
+UntagResource
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kafkaconnect/command/UntagResourceCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/UntagResourceCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kafkaconnect/Interface/UntagResourceCommandOutput/)
+
 </details>
 <details>
 <summary>

diff --git a/clients/client-kafkaconnect/src/KafkaConnect.ts b/clients/client-kafkaconnect/src/KafkaConnect.ts
@@ -27,6 +27,11 @@ import {
   DeleteCustomPluginCommandInput,
   DeleteCustomPluginCommandOutput,
 } from "./commands/DeleteCustomPluginCommand";
+import {
+  DeleteWorkerConfigurationCommand,
+  DeleteWorkerConfigurationCommandInput,
+  DeleteWorkerConfigurationCommandOutput,
+} from "./commands/DeleteWorkerConfigurationCommand";
 import {
   DescribeConnectorCommand,
   DescribeConnectorCommandInput,
@@ -52,11 +57,22 @@ import {
   ListCustomPluginsCommandInput,
   ListCustomPluginsCommandOutput,
 } from "./commands/ListCustomPluginsCommand";
+import {
+  ListTagsForResourceCommand,
+  ListTagsForResourceCommandInput,
+  ListTagsForResourceCommandOutput,
+} from "./commands/ListTagsForResourceCommand";
 import {
   ListWorkerConfigurationsCommand,
   ListWorkerConfigurationsCommandInput,
   ListWorkerConfigurationsCommandOutput,
 } from "./commands/ListWorkerConfigurationsCommand";
+import { TagResourceCommand, TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand";
+import {
+  UntagResourceCommand,
+  UntagResourceCommandInput,
+  UntagResourceCommandOutput,
+} from "./commands/UntagResourceCommand";
 import {
   UpdateConnectorCommand,
   UpdateConnectorCommandInput,
@@ -70,12 +86,16 @@ const commands = {
   CreateWorkerConfigurationCommand,
   DeleteConnectorCommand,
   DeleteCustomPluginCommand,
+  DeleteWorkerConfigurationCommand,
   DescribeConnectorCommand,
   DescribeCustomPluginCommand,
   DescribeWorkerConfigurationCommand,
   ListConnectorsCommand,
   ListCustomPluginsCommand,
+  ListTagsForResourceCommand,
   ListWorkerConfigurationsCommand,
+  TagResourceCommand,
+  UntagResourceCommand,
   UpdateConnectorCommand,
 };
 
@@ -159,6 +179,23 @@ export interface KafkaConnect {
     cb: (err: any, data?: DeleteCustomPluginCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link DeleteWorkerConfigurationCommand}
+   */
+  deleteWorkerConfiguration(
+    args: DeleteWorkerConfigurationCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<DeleteWorkerConfigurationCommandOutput>;
+  deleteWorkerConfiguration(
+    args: DeleteWorkerConfigurationCommandInput,
+    cb: (err: any, data?: DeleteWorkerConfigurationCommandOutput) => void
+  ): void;
+  deleteWorkerConfiguration(
+    args: DeleteWorkerConfigurationCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: DeleteWorkerConfigurationCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link DescribeConnectorCommand}
    */
@@ -241,6 +278,23 @@ export interface KafkaConnect {
     cb: (err: any, data?: ListCustomPluginsCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link ListTagsForResourceCommand}
+   */
+  listTagsForResource(
+    args: ListTagsForResourceCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<ListTagsForResourceCommandOutput>;
+  listTagsForResource(
+    args: ListTagsForResourceCommandInput,
+    cb: (err: any, data?: ListTagsForResourceCommandOutput) => void
+  ): void;
+  listTagsForResource(
+    args: ListTagsForResourceCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: ListTagsForResourceCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link ListWorkerConfigurationsCommand}
    */
@@ -258,6 +312,28 @@ export interface KafkaConnect {
     cb: (err: any, data?: ListWorkerConfigurationsCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link TagResourceCommand}
+   */
+  tagResource(args: TagResourceCommandInput, options?: __HttpHandlerOptions): Promise<TagResourceCommandOutput>;
+  tagResource(args: TagResourceCommandInput, cb: (err: any, data?: TagResourceCommandOutput) => void): void;
+  tagResource(
+    args: TagResourceCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: TagResourceCommandOutput) => void
+  ): void;
+
+  /**
+   * @see {@link UntagResourceCommand}
+   */
+  untagResource(args: UntagResourceCommandInput, options?: __HttpHandlerOptions): Promise<UntagResourceCommandOutput>;
+  untagResource(args: UntagResourceCommandInput, cb: (err: any, data?: UntagResourceCommandOutput) => void): void;
+  untagResource(
+    args: UntagResourceCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: UntagResourceCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link UpdateConnectorCommand}
    */

diff --git a/clients/client-kafkaconnect/src/KafkaConnectClient.ts b/clients/client-kafkaconnect/src/KafkaConnectClient.ts
@@ -61,6 +61,10 @@ import {
 } from "./commands/CreateWorkerConfigurationCommand";
 import { DeleteConnectorCommandInput, DeleteConnectorCommandOutput } from "./commands/DeleteConnectorCommand";
 import { DeleteCustomPluginCommandInput, DeleteCustomPluginCommandOutput } from "./commands/DeleteCustomPluginCommand";
+import {
+  DeleteWorkerConfigurationCommandInput,
+  DeleteWorkerConfigurationCommandOutput,
+} from "./commands/DeleteWorkerConfigurationCommand";
 import { DescribeConnectorCommandInput, DescribeConnectorCommandOutput } from "./commands/DescribeConnectorCommand";
 import {
   DescribeCustomPluginCommandInput,
@@ -72,10 +76,16 @@ import {
 } from "./commands/DescribeWorkerConfigurationCommand";
 import { ListConnectorsCommandInput, ListConnectorsCommandOutput } from "./commands/ListConnectorsCommand";
 import { ListCustomPluginsCommandInput, ListCustomPluginsCommandOutput } from "./commands/ListCustomPluginsCommand";
+import {
+  ListTagsForResourceCommandInput,
+  ListTagsForResourceCommandOutput,
+} from "./commands/ListTagsForResourceCommand";
 import {
   ListWorkerConfigurationsCommandInput,
   ListWorkerConfigurationsCommandOutput,
 } from "./commands/ListWorkerConfigurationsCommand";
+import { TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand";
+import { UntagResourceCommandInput, UntagResourceCommandOutput } from "./commands/UntagResourceCommand";
 import { UpdateConnectorCommandInput, UpdateConnectorCommandOutput } from "./commands/UpdateConnectorCommand";
 import {
   ClientInputEndpointParameters,
@@ -97,12 +107,16 @@ export type ServiceInputTypes =
   | CreateWorkerConfigurationCommandInput
   | DeleteConnectorCommandInput
   | DeleteCustomPluginCommandInput
+  | DeleteWorkerConfigurationCommandInput
   | DescribeConnectorCommandInput
   | DescribeCustomPluginCommandInput
   | DescribeWorkerConfigurationCommandInput
   | ListConnectorsCommandInput
   | ListCustomPluginsCommandInput
+  | ListTagsForResourceCommandInput
   | ListWorkerConfigurationsCommandInput
+  | TagResourceCommandInput
+  | UntagResourceCommandInput
   | UpdateConnectorCommandInput;
 
 /**
@@ -114,12 +128,16 @@ export type ServiceOutputTypes =
   | CreateWorkerConfigurationCommandOutput
   | DeleteConnectorCommandOutput
   | DeleteCustomPluginCommandOutput
+  | DeleteWorkerConfigurationCommandOutput
   | DescribeConnectorCommandOutput
   | DescribeCustomPluginCommandOutput
   | DescribeWorkerConfigurationCommandOutput
   | ListConnectorsCommandOutput
   | ListCustomPluginsCommandOutput
+  | ListTagsForResourceCommandOutput
   | ListWorkerConfigurationsCommandOutput
+  | TagResourceCommandOutput
+  | UntagResourceCommandOutput
   | UpdateConnectorCommandOutput;
 
 /**

diff --git a/clients/client-kafkaconnect/src/commands/CreateConnectorCommand.ts b/clients/client-kafkaconnect/src/commands/CreateConnectorCommand.ts
@@ -32,7 +32,7 @@ export interface CreateConnectorCommandOutput extends CreateConnectorResponse, _
 
 /**
  * @public
- * <p>Creates a connector using the specified properties.</p>
+ * <p>Creates a connector using the specified properties. </p>
  * @example
  * Use a bare-bones client and the command you need to make an API call.
  * ```javascript
@@ -112,6 +112,9 @@ export interface CreateConnectorCommandOutput extends CreateConnectorResponse, _
  *     revision: Number("long"), // required
  *     workerConfigurationArn: "STRING_VALUE", // required
  *   },
+ *   tags: { // Tags
+ *     "<keys>": "STRING_VALUE",
+ *   },
  * };
  * const command = new CreateConnectorCommand(input);
  * const response = await client.send(command);

diff --git a/clients/client-kafkaconnect/src/commands/CreateCustomPluginCommand.ts b/clients/client-kafkaconnect/src/commands/CreateCustomPluginCommand.ts
@@ -46,6 +46,9 @@ export interface CreateCustomPluginCommandOutput extends CreateCustomPluginRespo
  *     },
  *   },
  *   name: "STRING_VALUE", // required
+ *   tags: { // Tags
+ *     "<keys>": "STRING_VALUE",
+ *   },
  * };
  * const command = new CreateCustomPluginCommand(input);
  * const response = await client.send(command);

diff --git a/clients/client-kafkaconnect/src/commands/CreateWorkerConfigurationCommand.ts b/clients/client-kafkaconnect/src/commands/CreateWorkerConfigurationCommand.ts
@@ -43,6 +43,9 @@ export interface CreateWorkerConfigurationCommandOutput extends CreateWorkerConf
  *   description: "STRING_VALUE",
  *   name: "STRING_VALUE", // required
  *   propertiesFileContent: "STRING_VALUE", // required
+ *   tags: { // Tags
+ *     "<keys>": "STRING_VALUE",
+ *   },
  * };
  * const command = new CreateWorkerConfigurationCommand(input);
  * const response = await client.send(command);
@@ -55,6 +58,7 @@ export interface CreateWorkerConfigurationCommandOutput extends CreateWorkerConf
  * //   },
  * //   name: "STRING_VALUE",
  * //   workerConfigurationArn: "STRING_VALUE",
+ * //   workerConfigurationState: "STRING_VALUE",
  * // };
  *
  * ```