feat(client-kafkaconnect): Adds support for tagging, with new TagResource, 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.

Author: awstools

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>

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}
    */

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;
 
 /**

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);

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);

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",
  * // };
  *
  * ```