From c70be168ef42ee853e75034468ec3d2c2d5ff876 Mon Sep 17 00:00:00 2001 From: awssdkgo Date: Mon, 26 Feb 2024 19:31:39 +0000 Subject: [PATCH] Release v1.50.26 (2024-02-26) === ### Service Client Updates * `service/apigateway`: Updates service documentation * Documentation updates for Amazon API Gateway. * `service/drs`: Updates service API and documentation * `service/kafkaconnect`: Updates service API and documentation * `service/rds`: Updates service API, documentation, waiters, paginators, and examples * This release adds support for gp3 data volumes for Multi-AZ DB Clusters. --- CHANGELOG.md | 11 + aws/version.go | 2 +- models/apis/apigateway/2015-07-09/docs-2.json | 6 +- .../2015-07-09/endpoint-rule-set-1.json | 40 +- models/apis/drs/2020-02-26/api-2.json | 42 +- models/apis/drs/2020-02-26/docs-2.json | 37 + .../apis/kafkaconnect/2021-09-14/api-2.json | 215 +++- .../apis/kafkaconnect/2021-09-14/docs-2.json | 97 +- .../2021-09-14/endpoint-rule-set-1.json | 40 +- models/apis/rds/2014-10-31/api-2.json | 9 +- models/apis/rds/2014-10-31/docs-2.json | 5 +- service/apigateway/api.go | 7 +- service/drs/api.go | 100 ++ service/kafkaconnect/api.go | 939 +++++++++++++++++- .../kafkaconnectiface/interface.go | 16 + service/rds/api.go | 42 +- 16 files changed, 1501 insertions(+), 107 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 96b3a85ce0..21938943b5 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,14 @@ +Release v1.50.26 (2024-02-26) +=== + +### Service Client Updates +* `service/apigateway`: Updates service documentation + * Documentation updates for Amazon API Gateway. +* `service/drs`: Updates service API and documentation +* `service/kafkaconnect`: Updates service API and documentation +* `service/rds`: Updates service API, documentation, waiters, paginators, and examples + * This release adds support for gp3 data volumes for Multi-AZ DB Clusters. + Release v1.50.25 (2024-02-23) === diff --git a/aws/version.go b/aws/version.go index e026795755..ed0729d446 100644 --- a/aws/version.go +++ b/aws/version.go @@ -5,4 +5,4 @@ package aws const SDKName = "aws-sdk-go" // SDKVersion is the version of this SDK -const SDKVersion = "1.50.25" +const SDKVersion = "1.50.26" diff --git a/models/apis/apigateway/2015-07-09/docs-2.json b/models/apis/apigateway/2015-07-09/docs-2.json index c11169fc46..b9b87327e5 100644 --- a/models/apis/apigateway/2015-07-09/docs-2.json +++ b/models/apis/apigateway/2015-07-09/docs-2.json @@ -114,7 +114,7 @@ "UpdateIntegrationResponse": "

Represents an update integration response.

", "UpdateMethod": "

Updates an existing Method resource.

", "UpdateMethodResponse": "

Updates an existing MethodResponse resource.

", - "UpdateModel": "

Changes information about a model.

", + "UpdateModel": "

Changes information about a model. The maximum size of the model is 400 KB.

", "UpdateRequestValidator": "

Updates a RequestValidator of a given RestApi.

", "UpdateResource": "

Changes information about a Resource resource.

", "UpdateRestApi": "

Changes information about the specified API.

", @@ -245,7 +245,7 @@ "RequestValidator$validateRequestParameters": "

A Boolean flag to indicate whether to validate request parameters (true) or not (false).

", "RestApi$disableExecuteApiEndpoint": "

Specifies whether clients can invoke your API by using the default execute-api endpoint. By default, clients can invoke your API with the default https://{api_id}.execute-api.{region}.amazonaws.com endpoint. To require that clients use a custom domain name to invoke your API, disable the default endpoint.

", "SdkConfigurationProperty$required": "

A boolean flag of an SdkType configuration property to indicate if the associated SDK configuration property is required (true) or not (false).

", - "Stage$cacheClusterEnabled": "

Specifies whether a cache cluster is enabled for the stage.

", + "Stage$cacheClusterEnabled": "

Specifies whether a cache cluster is enabled for the stage. To activate a method-level cache, set CachingEnabled to true for a method.

", "Stage$tracingEnabled": "

Specifies whether active tracing with X-ray is enabled for the Stage.

", "TlsConfig$insecureSkipVerification": "

Specifies whether or not API Gateway skips verification that the certificate for an integration endpoint is issued by a supported certificate authority. This isn’t recommended, but it enables you to use certificates that are signed by private certificate authorities, or certificates that are self-signed. If enabled, API Gateway still performs basic certificate validation, which includes checking the certificate's expiration date, hostname, and presence of a root certificate authority. Supported only for HTTP and HTTP_PROXY integrations.

Enabling insecureSkipVerification isn't recommended, especially for integrations with public HTTPS endpoints. If you enable insecureSkipVerification, you increase the risk of man-in-the-middle attacks.

" } @@ -1583,7 +1583,7 @@ "CreateModelRequest$restApiId": "

The RestApi identifier under which the Model will be created.

", "CreateModelRequest$name": "

The name of the model. Must be alphanumeric.

", "CreateModelRequest$description": "

The description of the model.

", - "CreateModelRequest$schema": "

The schema for the model. For application/json models, this should be JSON schema draft 4 model.

", + "CreateModelRequest$schema": "

The schema for the model. For application/json models, this should be JSON schema draft 4 model. The maximum size of the model is 400 KB.

", "CreateModelRequest$contentType": "

The content-type for the model.

", "CreateRequestValidatorRequest$restApiId": "

The string identifier of the associated RestApi.

", "CreateRequestValidatorRequest$name": "

The name of the to-be-created RequestValidator.

", diff --git a/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json b/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json index 6180415235..c8acc7bd13 100644 --- a/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json +++ b/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json @@ -40,7 +40,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -83,7 +82,8 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -96,7 +96,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -110,7 +109,6 @@ "assign": "PartitionResult" } ], - "type": "tree", "rules": [ { "conditions": [ @@ -133,7 +131,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -168,7 +165,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -179,14 +175,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "FIPS and DualStack are enabled, but this partition does not support one or both", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -200,14 +198,12 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ { "fn": "booleanEquals", "argv": [ - true, { "fn": "getAttr", "argv": [ @@ -216,11 +212,11 @@ }, "supportsFIPS" ] - } + }, + true ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -231,14 +227,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "FIPS is enabled but this partition does not support FIPS", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -252,7 +250,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -272,7 +269,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -283,14 +279,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "DualStack is enabled but this partition does not support DualStack", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [], @@ -301,9 +299,11 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" } - ] + ], + "type": "tree" }, { "conditions": [], diff --git a/models/apis/drs/2020-02-26/api-2.json b/models/apis/drs/2020-02-26/api-2.json index f82267b234..a6bd6bc41f 100644 --- a/models/apis/drs/2020-02-26/api-2.json +++ b/models/apis/drs/2020-02-26/api-2.json @@ -1006,6 +1006,7 @@ "forceUefi":{"shape":"Boolean"}, "rootVolumeName":{"shape":"LargeBoundedString"}, "volumeToConversionMap":{"shape":"VolumeToConversionMap"}, + "volumeToProductCodes":{"shape":"VolumeToProductCodes"}, "volumeToVolumeSize":{"shape":"VolumeToSizeMap"} } }, @@ -1148,7 +1149,8 @@ "deviceName":{"shape":"BoundedString"}, "replicatedStorageBytes":{"shape":"PositiveInteger"}, "rescannedStorageBytes":{"shape":"PositiveInteger"}, - "totalStorageBytes":{"shape":"PositiveInteger"} + "totalStorageBytes":{"shape":"PositiveInteger"}, + "volumeStatus":{"shape":"VolumeStatus"} } }, "DataReplicationInfoReplicatedDisks":{ @@ -2280,6 +2282,30 @@ "type":"long", "min":0 }, + "ProductCode":{ + "type":"structure", + "members":{ + "productCodeId":{"shape":"ProductCodeId"}, + "productCodeMode":{"shape":"ProductCodeMode"} + } + }, + "ProductCodeId":{ + "type":"string", + "max":25, + "min":25, + "pattern":"^([A-Za-z0-9])+$" + }, + "ProductCodeMode":{ + "type":"string", + "enum":[ + "ENABLED", + "DISABLED" + ] + }, + "ProductCodes":{ + "type":"list", + "member":{"shape":"ProductCode"} + }, "PutLaunchActionRequest":{ "type":"structure", "required":[ @@ -3271,11 +3297,25 @@ "other" ] }, + "VolumeStatus":{ + "type":"string", + "enum":[ + "REGULAR", + "CONTAINS_MARKETPLACE_PRODUCT_CODES", + "MISSING_VOLUME_ATTRIBUTES", + "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE" + ] + }, "VolumeToConversionMap":{ "type":"map", "key":{"shape":"LargeBoundedString"}, "value":{"shape":"ConversionMap"} }, + "VolumeToProductCodes":{ + "type":"map", + "key":{"shape":"LargeBoundedString"}, + "value":{"shape":"ProductCodes"} + }, "VolumeToSizeMap":{ "type":"map", "key":{"shape":"LargeBoundedString"}, diff --git a/models/apis/drs/2020-02-26/docs-2.json b/models/apis/drs/2020-02-26/docs-2.json index 9fa9577e08..db3db46a70 100644 --- a/models/apis/drs/2020-02-26/docs-2.json +++ b/models/apis/drs/2020-02-26/docs-2.json @@ -885,6 +885,7 @@ "ValidationExceptionField$message": "

Validate exception field message.

", "ValidationExceptionField$name": "

Validate exception field name.

", "VolumeToConversionMap$key": null, + "VolumeToProductCodes$key": null, "VolumeToSizeMap$key": null } }, @@ -1334,6 +1335,30 @@ "VolumeToSizeMap$value": null } }, + "ProductCode": { + "base": "

Properties of a product code associated with a volume.

", + "refs": { + "ProductCodes$member": null + } + }, + "ProductCodeId": { + "base": null, + "refs": { + "ProductCode$productCodeId": "

Id of a product code associated with a volume.

" + } + }, + "ProductCodeMode": { + "base": null, + "refs": { + "ProductCode$productCodeMode": "

Mode of a product code associated with a volume.

" + } + }, + "ProductCodes": { + "base": null, + "refs": { + "VolumeToProductCodes$value": null + } + }, "PutLaunchActionRequest": { "base": null, "refs": { @@ -2054,12 +2079,24 @@ "ValidationException$reason": "

Validation exception reason.

" } }, + "VolumeStatus": { + "base": null, + "refs": { + "DataReplicationInfoReplicatedDisk$volumeStatus": "

The status of the volume.

" + } + }, "VolumeToConversionMap": { "base": null, "refs": { "ConversionProperties$volumeToConversionMap": "

A mapping between the volumes being converted and the converted snapshot ids

" } }, + "VolumeToProductCodes": { + "base": null, + "refs": { + "ConversionProperties$volumeToProductCodes": "

A mapping between the volumes being converted and the product codes associated with them

" + } + }, "VolumeToSizeMap": { "base": null, "refs": { diff --git a/models/apis/kafkaconnect/2021-09-14/api-2.json b/models/apis/kafkaconnect/2021-09-14/api-2.json index 8632fb1dd4..62234e4f0c 100644 --- a/models/apis/kafkaconnect/2021-09-14/api-2.json +++ b/models/apis/kafkaconnect/2021-09-14/api-2.json @@ -113,6 +113,26 @@ ], "idempotent":true }, + "DeleteWorkerConfiguration":{ + "name":"DeleteWorkerConfiguration", + "http":{ + "method":"DELETE", + "requestUri":"/v1/worker-configurations/{workerConfigurationArn}", + "responseCode":200 + }, + "input":{"shape":"DeleteWorkerConfigurationRequest"}, + "output":{"shape":"DeleteWorkerConfigurationResponse"}, + "errors":[ + {"shape":"NotFoundException"}, + {"shape":"BadRequestException"}, + {"shape":"ForbiddenException"}, + {"shape":"ServiceUnavailableException"}, + {"shape":"TooManyRequestsException"}, + {"shape":"UnauthorizedException"}, + {"shape":"InternalServerErrorException"} + ], + "idempotent":true + }, "DescribeConnector":{ "name":"DescribeConnector", "http":{ @@ -208,6 +228,25 @@ {"shape":"InternalServerErrorException"} ] }, + "ListTagsForResource":{ + "name":"ListTagsForResource", + "http":{ + "method":"GET", + "requestUri":"/v1/tags/{resourceArn}", + "responseCode":200 + }, + "input":{"shape":"ListTagsForResourceRequest"}, + "output":{"shape":"ListTagsForResourceResponse"}, + "errors":[ + {"shape":"NotFoundException"}, + {"shape":"BadRequestException"}, + {"shape":"ForbiddenException"}, + {"shape":"ServiceUnavailableException"}, + {"shape":"TooManyRequestsException"}, + {"shape":"UnauthorizedException"}, + {"shape":"InternalServerErrorException"} + ] + }, "ListWorkerConfigurations":{ "name":"ListWorkerConfigurations", "http":{ @@ -227,6 +266,47 @@ {"shape":"InternalServerErrorException"} ] }, + "TagResource":{ + "name":"TagResource", + "http":{ + "method":"POST", + "requestUri":"/v1/tags/{resourceArn}", + "responseCode":200 + }, + "input":{"shape":"TagResourceRequest"}, + "output":{"shape":"TagResourceResponse"}, + "errors":[ + {"shape":"NotFoundException"}, + {"shape":"ConflictException"}, + {"shape":"BadRequestException"}, + {"shape":"ForbiddenException"}, + {"shape":"ServiceUnavailableException"}, + {"shape":"TooManyRequestsException"}, + {"shape":"UnauthorizedException"}, + {"shape":"InternalServerErrorException"} + ], + "idempotent":true + }, + "UntagResource":{ + "name":"UntagResource", + "http":{ + "method":"DELETE", + "requestUri":"/v1/tags/{resourceArn}", + "responseCode":200 + }, + "input":{"shape":"UntagResourceRequest"}, + "output":{"shape":"UntagResourceResponse"}, + "errors":[ + {"shape":"NotFoundException"}, + {"shape":"BadRequestException"}, + {"shape":"ForbiddenException"}, + {"shape":"ServiceUnavailableException"}, + {"shape":"TooManyRequestsException"}, + {"shape":"UnauthorizedException"}, + {"shape":"InternalServerErrorException"} + ], + "idempotent":true + }, "UpdateConnector":{ "name":"UpdateConnector", "http":{ @@ -422,6 +502,7 @@ "logDelivery":{"shape":"LogDelivery"}, "plugins":{"shape":"__listOfPlugin"}, "serviceExecutionRoleArn":{"shape":"__string"}, + "tags":{"shape":"Tags"}, "workerConfiguration":{"shape":"WorkerConfiguration"} } }, @@ -444,7 +525,8 @@ "contentType":{"shape":"CustomPluginContentType"}, "description":{"shape":"__stringMax1024"}, "location":{"shape":"CustomPluginLocation"}, - "name":{"shape":"__stringMin1Max128"} + "name":{"shape":"__stringMin1Max128"}, + "tags":{"shape":"Tags"} } }, "CreateCustomPluginResponse":{ @@ -465,7 +547,8 @@ "members":{ "description":{"shape":"__stringMax1024"}, "name":{"shape":"__stringMin1Max128"}, - "propertiesFileContent":{"shape":"__sensitiveString"} + "propertiesFileContent":{"shape":"__sensitiveString"}, + "tags":{"shape":"Tags"} } }, "CreateWorkerConfigurationResponse":{ @@ -474,7 +557,8 @@ "creationTime":{"shape":"__timestampIso8601"}, "latestRevision":{"shape":"WorkerConfigurationRevisionSummary"}, "name":{"shape":"__string"}, - "workerConfigurationArn":{"shape":"__string"} + "workerConfigurationArn":{"shape":"__string"}, + "workerConfigurationState":{"shape":"WorkerConfigurationState"} } }, "CustomPlugin":{ @@ -596,6 +680,24 @@ "customPluginState":{"shape":"CustomPluginState"} } }, + "DeleteWorkerConfigurationRequest":{ + "type":"structure", + "required":["workerConfigurationArn"], + "members":{ + "workerConfigurationArn":{ + "shape":"__string", + "location":"uri", + "locationName":"workerConfigurationArn" + } + } + }, + "DeleteWorkerConfigurationResponse":{ + "type":"structure", + "members":{ + "workerConfigurationArn":{"shape":"__string"}, + "workerConfigurationState":{"shape":"WorkerConfigurationState"} + } + }, "DescribeConnectorRequest":{ "type":"structure", "required":["connectorArn"], @@ -670,7 +772,8 @@ "description":{"shape":"__string"}, "latestRevision":{"shape":"WorkerConfigurationRevisionDescription"}, "name":{"shape":"__string"}, - "workerConfigurationArn":{"shape":"__string"} + "workerConfigurationArn":{"shape":"__string"}, + "workerConfigurationState":{"shape":"WorkerConfigurationState"} } }, "FirehoseLogDelivery":{ @@ -796,6 +899,11 @@ "location":"querystring", "locationName":"maxResults" }, + "namePrefix":{ + "shape":"__string", + "location":"querystring", + "locationName":"namePrefix" + }, "nextToken":{ "shape":"__string", "location":"querystring", @@ -810,6 +918,23 @@ "nextToken":{"shape":"__string"} } }, + "ListTagsForResourceRequest":{ + "type":"structure", + "required":["resourceArn"], + "members":{ + "resourceArn":{ + "shape":"__string", + "location":"uri", + "locationName":"resourceArn" + } + } + }, + "ListTagsForResourceResponse":{ + "type":"structure", + "members":{ + "tags":{"shape":"Tags"} + } + }, "ListWorkerConfigurationsRequest":{ "type":"structure", "members":{ @@ -818,6 +943,11 @@ "location":"querystring", "locationName":"maxResults" }, + "namePrefix":{ + "shape":"__string", + "location":"querystring", + "locationName":"namePrefix" + }, "nextToken":{ "shape":"__string", "location":"querystring", @@ -996,6 +1126,49 @@ "message":{"shape":"__string"} } }, + "TagKey":{ + "type":"string", + "max":128, + "min":1 + }, + "TagKeyList":{ + "type":"list", + "member":{"shape":"TagKey"}, + "max":200, + "min":0 + }, + "TagResourceRequest":{ + "type":"structure", + "required":[ + "resourceArn", + "tags" + ], + "members":{ + "resourceArn":{ + "shape":"__string", + "location":"uri", + "locationName":"resourceArn" + }, + "tags":{"shape":"Tags"} + } + }, + "TagResourceResponse":{ + "type":"structure", + "members":{ + } + }, + "TagValue":{ + "type":"string", + "max":256, + "min":0 + }, + "Tags":{ + "type":"map", + "key":{"shape":"TagKey"}, + "value":{"shape":"TagValue"}, + "max":200, + "min":0 + }, "TooManyRequestsException":{ "type":"structure", "members":{ @@ -1018,6 +1191,30 @@ }, "exception":true }, + "UntagResourceRequest":{ + "type":"structure", + "required":[ + "resourceArn", + "tagKeys" + ], + "members":{ + "resourceArn":{ + "shape":"__string", + "location":"uri", + "locationName":"resourceArn" + }, + "tagKeys":{ + "shape":"TagKeyList", + "location":"querystring", + "locationName":"tagKeys" + } + } + }, + "UntagResourceResponse":{ + "type":"structure", + "members":{ + } + }, "UpdateConnectorRequest":{ "type":"structure", "required":[ @@ -1096,6 +1293,13 @@ "revision":{"shape":"__long"} } }, + "WorkerConfigurationState":{ + "type":"string", + "enum":[ + "ACTIVE", + "DELETING" + ] + }, "WorkerConfigurationSummary":{ "type":"structure", "members":{ @@ -1103,7 +1307,8 @@ "description":{"shape":"__string"}, "latestRevision":{"shape":"WorkerConfigurationRevisionSummary"}, "name":{"shape":"__string"}, - "workerConfigurationArn":{"shape":"__string"} + "workerConfigurationArn":{"shape":"__string"}, + "workerConfigurationState":{"shape":"WorkerConfigurationState"} } }, "WorkerLogDelivery":{ diff --git a/models/apis/kafkaconnect/2021-09-14/docs-2.json b/models/apis/kafkaconnect/2021-09-14/docs-2.json index ba34514197..65668e761f 100644 --- a/models/apis/kafkaconnect/2021-09-14/docs-2.json +++ b/models/apis/kafkaconnect/2021-09-14/docs-2.json @@ -2,17 +2,21 @@ "version": "2.0", "service": "

", "operations": { - "CreateConnector": "

Creates a connector using the specified properties.

", + "CreateConnector": "

Creates a connector using the specified properties.

", "CreateCustomPlugin": "

Creates a custom plugin using the specified properties.

", "CreateWorkerConfiguration": "

Creates a worker configuration using the specified properties.

", "DeleteConnector": "

Deletes the specified connector.

", "DeleteCustomPlugin": "

Deletes a custom plugin.

", + "DeleteWorkerConfiguration": "

Deletes the specified worker configuration.

", "DescribeConnector": "

Returns summary information about the connector.

", "DescribeCustomPlugin": "

A summary description of the custom plugin.

", "DescribeWorkerConfiguration": "

Returns information about a worker configuration.

", "ListConnectors": "

Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors.

", "ListCustomPlugins": "

Returns a list of all of the custom plugins in this account and Region.

", + "ListTagsForResource": "

Lists all the tags attached to the specified resource.

", "ListWorkerConfigurations": "

Returns a list of all of the worker configurations in this account and Region.

", + "TagResource": "

Attaches tags to the specified resource.

", + "UntagResource": "

Removes tags from the specified resource.

", "UpdateConnector": "

Updates the specified connector.

" }, "shapes": { @@ -134,7 +138,7 @@ } }, "CustomPlugin": { - "base": "

A plugin is an AWS resource that contains the code that defines a connector's logic.

", + "base": "

A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic.

", "refs": { "Plugin$customPlugin": "

Details about a custom plugin.

" } @@ -212,6 +216,16 @@ "refs": { } }, + "DeleteWorkerConfigurationRequest": { + "base": null, + "refs": { + } + }, + "DeleteWorkerConfigurationResponse": { + "base": null, + "refs": { + } + }, "DescribeConnectorRequest": { "base": null, "refs": { @@ -337,6 +351,16 @@ "refs": { } }, + "ListTagsForResourceRequest": { + "base": null, + "refs": { + } + }, + "ListTagsForResourceResponse": { + "base": null, + "refs": { + } + }, "ListWorkerConfigurationsRequest": { "base": null, "refs": { @@ -374,7 +398,7 @@ } }, "Plugin": { - "base": "

A plugin is an AWS resource that contains the code that defines your connector logic.

", + "base": "

A plugin is an Amazon Web Services resource that contains the code that defines your connector logic.

", "refs": { "__listOfPlugin$member": null } @@ -475,6 +499,45 @@ "DescribeCustomPluginResponse$stateDescription": "

Details about the state of a custom plugin.

" } }, + "TagKey": { + "base": null, + "refs": { + "TagKeyList$member": null, + "Tags$key": null + } + }, + "TagKeyList": { + "base": null, + "refs": { + "UntagResourceRequest$tagKeys": "

The keys of the tags that you want to remove from the resource.

" + } + }, + "TagResourceRequest": { + "base": null, + "refs": { + } + }, + "TagResourceResponse": { + "base": null, + "refs": { + } + }, + "TagValue": { + "base": null, + "refs": { + "Tags$value": null + } + }, + "Tags": { + "base": null, + "refs": { + "CreateConnectorRequest$tags": "

The tags you want to attach to the connector.

", + "CreateCustomPluginRequest$tags": "

The tags you want to attach to the custom plugin.

", + "CreateWorkerConfigurationRequest$tags": "

The tags you want to attach to the worker configuration.

", + "ListTagsForResourceResponse$tags": "

Lists the tags attached to the specified resource in the corresponding request.

", + "TagResourceRequest$tags": "

The tags that you want to attach to the resource.

" + } + }, "TooManyRequestsException": { "base": "

HTTP Status Code 429: Limit exceeded. Resource limit reached.

", "refs": { @@ -485,6 +548,16 @@ "refs": { } }, + "UntagResourceRequest": { + "base": null, + "refs": { + } + }, + "UntagResourceResponse": { + "base": null, + "refs": { + } + }, "UpdateConnectorRequest": { "base": null, "refs": { @@ -533,6 +606,15 @@ "WorkerConfigurationSummary$latestRevision": "

The latest revision of a worker configuration.

" } }, + "WorkerConfigurationState": { + "base": null, + "refs": { + "CreateWorkerConfigurationResponse$workerConfigurationState": "

The state of the worker configuration.

", + "DeleteWorkerConfigurationResponse$workerConfigurationState": "

The state of the worker configuration.

", + "DescribeWorkerConfigurationResponse$workerConfigurationState": "

The state of the worker configuration.

", + "WorkerConfigurationSummary$workerConfigurationState": "

The state of the worker configuration.

" + } + }, "WorkerConfigurationSummary": { "base": "

The summary of a worker configuration.

", "refs": { @@ -618,7 +700,7 @@ "__listOfPlugin": { "base": null, "refs": { - "CreateConnectorRequest$plugins": "

Specifies which plugins to use for the connector.

" + "CreateConnectorRequest$plugins": "

Amazon MSK Connect does not currently support specifying multiple plugins as a list. To use more than one plugin for your connector, you can create a single custom plugin using a ZIP file that bundles multiple plugins together.

Specifies which plugin to use for the connector. You must specify a single-element list containing one customPlugin object.

" } }, "__listOfPluginDescription": { @@ -711,6 +793,8 @@ "DeleteConnectorResponse$connectorArn": "

The Amazon Resource Name (ARN) of the connector that you requested to delete.

", "DeleteCustomPluginRequest$customPluginArn": "

The Amazon Resource Name (ARN) of the custom plugin that you want to delete.

", "DeleteCustomPluginResponse$customPluginArn": "

The Amazon Resource Name (ARN) of the custom plugin that you requested to delete.

", + "DeleteWorkerConfigurationRequest$workerConfigurationArn": "

The Amazon Resource Name (ARN) of the worker configuration that you want to delete.

", + "DeleteWorkerConfigurationResponse$workerConfigurationArn": "

The Amazon Resource Name (ARN) of the worker configuration that you requested to delete.

", "DescribeConnectorRequest$connectorArn": "

The Amazon Resource Name (ARN) of the connector that you want to describe.

", "DescribeConnectorResponse$connectorArn": "

The Amazon Resource Name (ARN) of the connector.

", "DescribeConnectorResponse$connectorDescription": "

A summary description of the connector.

", @@ -733,8 +817,11 @@ "ListConnectorsRequest$connectorNamePrefix": "

The name prefix that you want to use to search for and list connectors.

", "ListConnectorsRequest$nextToken": "

If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

", "ListConnectorsResponse$nextToken": "

If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where it left off.

", + "ListCustomPluginsRequest$namePrefix": "

Lists custom plugin names that start with the specified text string.

", "ListCustomPluginsRequest$nextToken": "

If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

", "ListCustomPluginsResponse$nextToken": "

If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

", + "ListTagsForResourceRequest$resourceArn": "

The Amazon Resource Name (ARN) of the resource for which you want to list all attached tags.

", + "ListWorkerConfigurationsRequest$namePrefix": "

Lists worker configuration names that start with the specified text string.

", "ListWorkerConfigurationsRequest$nextToken": "

If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

", "ListWorkerConfigurationsResponse$nextToken": "

If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

", "NotFoundException$message": null, @@ -751,8 +838,10 @@ "ServiceUnavailableException$message": null, "StateDescription$code": "

A code that describes the state of a resource.

", "StateDescription$message": "

A message that describes the state of a resource.

", + "TagResourceRequest$resourceArn": "

The Amazon Resource Name (ARN) of the resource to which you want to attach tags.

", "TooManyRequestsException$message": null, "UnauthorizedException$message": null, + "UntagResourceRequest$resourceArn": "

The Amazon Resource Name (ARN) of the resource from which you want to remove tags.

", "UpdateConnectorRequest$connectorArn": "

The Amazon Resource Name (ARN) of the connector that you want to update.

", "UpdateConnectorRequest$currentVersion": "

The current version of the connector that you want to update.

", "UpdateConnectorResponse$connectorArn": "

The Amazon Resource Name (ARN) of the connector.

", diff --git a/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json b/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json index c5b90d3def..545020b141 100644 --- a/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json +++ b/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json @@ -40,7 +40,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -83,7 +82,8 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -96,7 +96,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -110,7 +109,6 @@ "assign": "PartitionResult" } ], - "type": "tree", "rules": [ { "conditions": [ @@ -133,7 +131,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -168,7 +165,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -179,14 +175,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "FIPS and DualStack are enabled, but this partition does not support one or both", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -200,14 +198,12 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ { "fn": "booleanEquals", "argv": [ - true, { "fn": "getAttr", "argv": [ @@ -216,11 +212,11 @@ }, "supportsFIPS" ] - } + }, + true ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -231,14 +227,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "FIPS is enabled but this partition does not support FIPS", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [ @@ -252,7 +250,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [ @@ -272,7 +269,6 @@ ] } ], - "type": "tree", "rules": [ { "conditions": [], @@ -283,14 +279,16 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" }, { "conditions": [], "error": "DualStack is enabled but this partition does not support DualStack", "type": "error" } - ] + ], + "type": "tree" }, { "conditions": [], @@ -301,9 +299,11 @@ }, "type": "endpoint" } - ] + ], + "type": "tree" } - ] + ], + "type": "tree" }, { "conditions": [], diff --git a/models/apis/rds/2014-10-31/api-2.json b/models/apis/rds/2014-10-31/api-2.json index 3755b4ad45..f28d4dc888 100644 --- a/models/apis/rds/2014-10-31/api-2.json +++ b/models/apis/rds/2014-10-31/api-2.json @@ -4147,7 +4147,8 @@ "IOOptimizedNextAllowedModificationTime":{"shape":"TStamp"}, "LocalWriteForwardingStatus":{"shape":"LocalWriteForwardingStatus"}, "AwsBackupRecoveryPointArn":{"shape":"String"}, - "LimitlessDatabase":{"shape":"LimitlessDatabase"} + "LimitlessDatabase":{"shape":"LimitlessDatabase"}, + "StorageThroughput":{"shape":"IntegerOptional"} }, "wrapper":true }, @@ -4188,7 +4189,8 @@ "KmsKeyId":{"shape":"String"}, "StorageType":{"shape":"String"}, "Iops":{"shape":"IntegerOptional"}, - "AwsBackupRecoveryPointArn":{"shape":"String"} + "AwsBackupRecoveryPointArn":{"shape":"String"}, + "StorageThroughput":{"shape":"IntegerOptional"} }, "wrapper":true }, @@ -4532,7 +4534,8 @@ "TagList":{"shape":"TagList"}, "DBSystemId":{"shape":"String"}, "StorageType":{"shape":"String"}, - "DbClusterResourceId":{"shape":"String"} + "DbClusterResourceId":{"shape":"String"}, + "StorageThroughput":{"shape":"IntegerOptional"} }, "wrapper":true }, diff --git a/models/apis/rds/2014-10-31/docs-2.json b/models/apis/rds/2014-10-31/docs-2.json index e0570d41b7..a9e7b65dcb 100644 --- a/models/apis/rds/2014-10-31/docs-2.json +++ b/models/apis/rds/2014-10-31/docs-2.json @@ -3012,12 +3012,15 @@ "DBCluster$Iops": "

The Provisioned IOPS (I/O operations per second) value.

This setting is only for non-Aurora Multi-AZ DB clusters.

", "DBCluster$MonitoringInterval": "

The interval, in seconds, between points when Enhanced Monitoring metrics are collected for the DB cluster.

This setting is only for non-Aurora Multi-AZ DB clusters.

", "DBCluster$PerformanceInsightsRetentionPeriod": "

The number of days to retain Performance Insights data.

This setting is only for non-Aurora Multi-AZ DB clusters.

Valid Values:

Default: 7 days

", + "DBCluster$StorageThroughput": "

The storage throughput for the DB cluster. The throughput is automatically set based on the IOPS that you provision, and is not configurable.

This setting is only for non-Aurora Multi-AZ DB clusters.

", "DBClusterAutomatedBackup$BackupRetentionPeriod": "

The retention period for the automated backups.

", "DBClusterAutomatedBackup$Iops": "

The IOPS (I/O operations per second) value for the automated backup.

This setting is only for non-Aurora Multi-AZ DB clusters.

", + "DBClusterAutomatedBackup$StorageThroughput": "

The storage throughput for the automated backup. The throughput is automatically set based on the IOPS that you provision, and is not configurable.

This setting is only for non-Aurora Multi-AZ DB clusters.

", "DBClusterCapacityInfo$PendingCapacity": "

A value that specifies the capacity that the DB cluster scales to next.

", "DBClusterCapacityInfo$CurrentCapacity": "

The current capacity of the DB cluster.

", "DBClusterCapacityInfo$SecondsBeforeTimeout": "

The number of seconds before a call to ModifyCurrentDBClusterCapacity times out.

", "DBClusterMember$PromotionTier": "

A value that specifies the order in which an Aurora Replica is promoted to the primary instance after a failure of the existing primary instance. For more information, see Fault Tolerance for an Aurora DB Cluster in the Amazon Aurora User Guide.

", + "DBClusterSnapshot$StorageThroughput": "

The storage throughput for the DB cluster snapshot. The throughput is automatically set based on the IOPS that you provision, and is not configurable.

This setting is only for non-Aurora Multi-AZ DB clusters.

", "DBInstance$Iops": "

The Provisioned IOPS (I/O operations per second) value for the DB instance.

", "DBInstance$MonitoringInterval": "

The interval, in seconds, between points when Enhanced Monitoring metrics are collected for the DB instance.

", "DBInstance$PromotionTier": "

The order of priority in which an Aurora Replica is promoted to the primary instance after a failure of the existing primary instance. For more information, see Fault Tolerance for an Aurora DB Cluster in the Amazon Aurora User Guide.

", @@ -5553,7 +5556,7 @@ "RestoreDBInstanceFromDBSnapshotMessage$CustomIamInstanceProfile": "

The instance profile associated with the underlying Amazon EC2 instance of an RDS Custom DB instance. The instance profile must meet the following requirements:

For the list of permissions required for the IAM role, see Configure IAM and your VPC in the Amazon RDS User Guide.

This setting is required for RDS Custom.

", "RestoreDBInstanceFromDBSnapshotMessage$BackupTarget": "

Specifies where automated backups and manual snapshots are stored for the restored DB instance.

Possible values are outposts (Amazon Web Services Outposts) and region (Amazon Web Services Region). The default is region.

For more information, see Working with Amazon RDS on Amazon Web Services Outposts in the Amazon RDS User Guide.

", "RestoreDBInstanceFromDBSnapshotMessage$NetworkType": "

The network type of the DB instance.

Valid Values:

The network type is determined by the DBSubnetGroup specified for the DB instance. A DBSubnetGroup can support only the IPv4 protocol or the IPv4 and the IPv6 protocols (DUAL).

For more information, see Working with a DB instance in a VPC in the Amazon RDS User Guide.

", - "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "

The identifier for the RDS for MySQL Multi-AZ DB cluster snapshot to restore from.

For more information on Multi-AZ DB clusters, see Multi-AZ DB cluster deployments in the Amazon RDS User Guide.

Constraints:

", + "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "

The identifier for the Multi-AZ DB cluster snapshot to restore from.

For more information on Multi-AZ DB clusters, see Multi-AZ DB cluster deployments in the Amazon RDS User Guide.

Constraints:

", "RestoreDBInstanceFromS3Message$DBName": "

The name of the database to create when the DB instance is created. Follow the naming rules specified in CreateDBInstance.

", "RestoreDBInstanceFromS3Message$DBInstanceIdentifier": "

The DB instance identifier. This parameter is stored as a lowercase string.

Constraints:

Example: mydbinstance

", "RestoreDBInstanceFromS3Message$DBInstanceClass": "

The compute and memory capacity of the DB instance, for example db.m4.large. Not all DB instance classes are available in all Amazon Web Services Regions, or for all database engines. For the full list of DB instance classes, and availability for your engine, see DB Instance Class in the Amazon RDS User Guide.

Importing from Amazon S3 isn't supported on the db.t2.micro DB instance class.

", diff --git a/service/apigateway/api.go b/service/apigateway/api.go index 2cf3cc0791..5a83e95b66 100644 --- a/service/apigateway/api.go +++ b/service/apigateway/api.go @@ -10817,7 +10817,7 @@ func (c *APIGateway) UpdateModelRequest(input *UpdateModelInput) (req *request.R // UpdateModel API operation for Amazon API Gateway. // -// Changes information about a model. +// Changes information about a model. The maximum size of the model is 400 KB. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about @@ -13133,7 +13133,7 @@ type CreateModelInput struct { RestApiId *string `location:"uri" locationName:"restapi_id" type:"string" required:"true"` // The schema for the model. For application/json models, this should be JSON - // schema draft 4 model. + // schema draft 4 model. The maximum size of the model is 400 KB. Schema *string `locationName:"schema" type:"string"` } @@ -23479,7 +23479,8 @@ type Stage struct { // Settings for logging access in this stage. AccessLogSettings *AccessLogSettings `locationName:"accessLogSettings" type:"structure"` - // Specifies whether a cache cluster is enabled for the stage. + // Specifies whether a cache cluster is enabled for the stage. To activate a + // method-level cache, set CachingEnabled to true for a method. CacheClusterEnabled *bool `locationName:"cacheClusterEnabled" type:"boolean"` // The stage's cache capacity in GB. For more information about choosing a cache diff --git a/service/drs/api.go b/service/drs/api.go index 0ccf0ad980..488e459cd2 100644 --- a/service/drs/api.go +++ b/service/drs/api.go @@ -5713,6 +5713,10 @@ type ConversionProperties struct { // ids VolumeToConversionMap map[string]map[string]*string `locationName:"volumeToConversionMap" type:"map"` + // A mapping between the volumes being converted and the product codes associated + // with them + VolumeToProductCodes map[string][]*ProductCode `locationName:"volumeToProductCodes" type:"map"` + // A mapping between the volumes and their sizes VolumeToVolumeSize map[string]*int64 `locationName:"volumeToVolumeSize" type:"map"` } @@ -5759,6 +5763,12 @@ func (s *ConversionProperties) SetVolumeToConversionMap(v map[string]map[string] return s } +// SetVolumeToProductCodes sets the VolumeToProductCodes field's value. +func (s *ConversionProperties) SetVolumeToProductCodes(v map[string][]*ProductCode) *ConversionProperties { + s.VolumeToProductCodes = v + return s +} + // SetVolumeToVolumeSize sets the VolumeToVolumeSize field's value. func (s *ConversionProperties) SetVolumeToVolumeSize(v map[string]*int64) *ConversionProperties { s.VolumeToVolumeSize = v @@ -6729,6 +6739,9 @@ type DataReplicationInfoReplicatedDisk struct { // The total amount of data to be replicated in bytes. TotalStorageBytes *int64 `locationName:"totalStorageBytes" type:"long"` + + // The status of the volume. + VolumeStatus *string `locationName:"volumeStatus" type:"string" enum:"VolumeStatus"` } // String returns the string representation. @@ -6779,6 +6792,12 @@ func (s *DataReplicationInfoReplicatedDisk) SetTotalStorageBytes(v int64) *DataR return s } +// SetVolumeStatus sets the VolumeStatus field's value. +func (s *DataReplicationInfoReplicatedDisk) SetVolumeStatus(v string) *DataReplicationInfoReplicatedDisk { + s.VolumeStatus = &v + return s +} + // Data replication initiation. type DataReplicationInitiation struct { _ struct{} `type:"structure"` @@ -11266,6 +11285,47 @@ func (s *ParticipatingServer) SetSourceServerID(v string) *ParticipatingServer { return s } +// Properties of a product code associated with a volume. +type ProductCode struct { + _ struct{} `type:"structure"` + + // Id of a product code associated with a volume. + ProductCodeId *string `locationName:"productCodeId" min:"25" type:"string"` + + // Mode of a product code associated with a volume. + ProductCodeMode *string `locationName:"productCodeMode" type:"string" enum:"ProductCodeMode"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ProductCode) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ProductCode) GoString() string { + return s.String() +} + +// SetProductCodeId sets the ProductCodeId field's value. +func (s *ProductCode) SetProductCodeId(v string) *ProductCode { + s.ProductCodeId = &v + return s +} + +// SetProductCodeMode sets the ProductCodeMode field's value. +func (s *ProductCode) SetProductCodeMode(v string) *ProductCode { + s.ProductCodeMode = &v + return s +} + type PutLaunchActionInput struct { _ struct{} `type:"structure"` @@ -17195,6 +17255,22 @@ func PITPolicyRuleUnits_Values() []string { } } +const ( + // ProductCodeModeEnabled is a ProductCodeMode enum value + ProductCodeModeEnabled = "ENABLED" + + // ProductCodeModeDisabled is a ProductCodeMode enum value + ProductCodeModeDisabled = "DISABLED" +) + +// ProductCodeMode_Values returns all elements of the ProductCodeMode enum +func ProductCodeMode_Values() []string { + return []string{ + ProductCodeModeEnabled, + ProductCodeModeDisabled, + } +} + const ( // RecoveryInstanceDataReplicationInitiationStepNameLinkFailbackClientWithRecoveryInstance is a RecoveryInstanceDataReplicationInitiationStepName enum value RecoveryInstanceDataReplicationInitiationStepNameLinkFailbackClientWithRecoveryInstance = "LINK_FAILBACK_CLIENT_WITH_RECOVERY_INSTANCE" @@ -17596,3 +17672,27 @@ func ValidationExceptionReason_Values() []string { ValidationExceptionReasonOther, } } + +const ( + // VolumeStatusRegular is a VolumeStatus enum value + VolumeStatusRegular = "REGULAR" + + // VolumeStatusContainsMarketplaceProductCodes is a VolumeStatus enum value + VolumeStatusContainsMarketplaceProductCodes = "CONTAINS_MARKETPLACE_PRODUCT_CODES" + + // VolumeStatusMissingVolumeAttributes is a VolumeStatus enum value + VolumeStatusMissingVolumeAttributes = "MISSING_VOLUME_ATTRIBUTES" + + // VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable is a VolumeStatus enum value + VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable = "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE" +) + +// VolumeStatus_Values returns all elements of the VolumeStatus enum +func VolumeStatus_Values() []string { + return []string{ + VolumeStatusRegular, + VolumeStatusContainsMarketplaceProductCodes, + VolumeStatusMissingVolumeAttributes, + VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable, + } +} diff --git a/service/kafkaconnect/api.go b/service/kafkaconnect/api.go index fa8aae783d..52490377ac 100644 --- a/service/kafkaconnect/api.go +++ b/service/kafkaconnect/api.go @@ -10,6 +10,7 @@ import ( "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/private/protocol" + "github.com/aws/aws-sdk-go/private/protocol/restjson" ) const opCreateConnector = "CreateConnector" @@ -539,6 +540,109 @@ func (c *KafkaConnect) DeleteCustomPluginWithContext(ctx aws.Context, input *Del return out, req.Send() } +const opDeleteWorkerConfiguration = "DeleteWorkerConfiguration" + +// DeleteWorkerConfigurationRequest generates a "aws/request.Request" representing the +// client's request for the DeleteWorkerConfiguration operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See DeleteWorkerConfiguration for more information on using the DeleteWorkerConfiguration +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// // Example sending a request using the DeleteWorkerConfigurationRequest method. +// req, resp := client.DeleteWorkerConfigurationRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration +func (c *KafkaConnect) DeleteWorkerConfigurationRequest(input *DeleteWorkerConfigurationInput) (req *request.Request, output *DeleteWorkerConfigurationOutput) { + op := &request.Operation{ + Name: opDeleteWorkerConfiguration, + HTTPMethod: "DELETE", + HTTPPath: "/v1/worker-configurations/{workerConfigurationArn}", + } + + if input == nil { + input = &DeleteWorkerConfigurationInput{} + } + + output = &DeleteWorkerConfigurationOutput{} + req = c.newRequest(op, input, output) + return +} + +// DeleteWorkerConfiguration API operation for Managed Streaming for Kafka Connect. +// +// Deletes the specified worker configuration. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for Managed Streaming for Kafka Connect's +// API operation DeleteWorkerConfiguration for usage and error information. +// +// Returned Error Types: +// +// - NotFoundException +// HTTP Status Code 404: Resource not found due to incorrect input. Correct +// your request and then retry it. +// +// - BadRequestException +// HTTP Status Code 400: Bad request due to incorrect input. Correct your request +// and then retry it. +// +// - ForbiddenException +// HTTP Status Code 403: Access forbidden. Correct your credentials and then +// retry your request. +// +// - ServiceUnavailableException +// HTTP Status Code 503: Service Unavailable. Retrying your request in some +// time might resolve the issue. +// +// - TooManyRequestsException +// HTTP Status Code 429: Limit exceeded. Resource limit reached. +// +// - UnauthorizedException +// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't +// be validated. +// +// - InternalServerErrorException +// HTTP Status Code 500: Unexpected internal server error. Retrying your request +// might resolve the issue. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration +func (c *KafkaConnect) DeleteWorkerConfiguration(input *DeleteWorkerConfigurationInput) (*DeleteWorkerConfigurationOutput, error) { + req, out := c.DeleteWorkerConfigurationRequest(input) + return out, req.Send() +} + +// DeleteWorkerConfigurationWithContext is the same as DeleteWorkerConfiguration with the addition of +// the ability to pass a context and additional request options. +// +// See DeleteWorkerConfiguration for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *KafkaConnect) DeleteWorkerConfigurationWithContext(ctx aws.Context, input *DeleteWorkerConfigurationInput, opts ...request.Option) (*DeleteWorkerConfigurationOutput, error) { + req, out := c.DeleteWorkerConfigurationRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opDescribeConnector = "DescribeConnector" // DescribeConnectorRequest generates a "aws/request.Request" representing the @@ -1170,6 +1274,109 @@ func (c *KafkaConnect) ListCustomPluginsPagesWithContext(ctx aws.Context, input return p.Err() } +const opListTagsForResource = "ListTagsForResource" + +// ListTagsForResourceRequest generates a "aws/request.Request" representing the +// client's request for the ListTagsForResource operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See ListTagsForResource for more information on using the ListTagsForResource +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// // Example sending a request using the ListTagsForResourceRequest method. +// req, resp := client.ListTagsForResourceRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource +func (c *KafkaConnect) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) { + op := &request.Operation{ + Name: opListTagsForResource, + HTTPMethod: "GET", + HTTPPath: "/v1/tags/{resourceArn}", + } + + if input == nil { + input = &ListTagsForResourceInput{} + } + + output = &ListTagsForResourceOutput{} + req = c.newRequest(op, input, output) + return +} + +// ListTagsForResource API operation for Managed Streaming for Kafka Connect. +// +// Lists all the tags attached to the specified resource. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for Managed Streaming for Kafka Connect's +// API operation ListTagsForResource for usage and error information. +// +// Returned Error Types: +// +// - NotFoundException +// HTTP Status Code 404: Resource not found due to incorrect input. Correct +// your request and then retry it. +// +// - BadRequestException +// HTTP Status Code 400: Bad request due to incorrect input. Correct your request +// and then retry it. +// +// - ForbiddenException +// HTTP Status Code 403: Access forbidden. Correct your credentials and then +// retry your request. +// +// - ServiceUnavailableException +// HTTP Status Code 503: Service Unavailable. Retrying your request in some +// time might resolve the issue. +// +// - TooManyRequestsException +// HTTP Status Code 429: Limit exceeded. Resource limit reached. +// +// - UnauthorizedException +// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't +// be validated. +// +// - InternalServerErrorException +// HTTP Status Code 500: Unexpected internal server error. Retrying your request +// might resolve the issue. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource +func (c *KafkaConnect) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) { + req, out := c.ListTagsForResourceRequest(input) + return out, req.Send() +} + +// ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of +// the ability to pass a context and additional request options. +// +// See ListTagsForResource for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *KafkaConnect) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) { + req, out := c.ListTagsForResourceRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opListWorkerConfigurations = "ListWorkerConfigurations" // ListWorkerConfigurationsRequest generates a "aws/request.Request" representing the @@ -1330,6 +1537,218 @@ func (c *KafkaConnect) ListWorkerConfigurationsPagesWithContext(ctx aws.Context, return p.Err() } +const opTagResource = "TagResource" + +// TagResourceRequest generates a "aws/request.Request" representing the +// client's request for the TagResource operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See TagResource for more information on using the TagResource +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// // Example sending a request using the TagResourceRequest method. +// req, resp := client.TagResourceRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource +func (c *KafkaConnect) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) { + op := &request.Operation{ + Name: opTagResource, + HTTPMethod: "POST", + HTTPPath: "/v1/tags/{resourceArn}", + } + + if input == nil { + input = &TagResourceInput{} + } + + output = &TagResourceOutput{} + req = c.newRequest(op, input, output) + req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) + return +} + +// TagResource API operation for Managed Streaming for Kafka Connect. +// +// Attaches tags to the specified resource. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for Managed Streaming for Kafka Connect's +// API operation TagResource for usage and error information. +// +// Returned Error Types: +// +// - NotFoundException +// HTTP Status Code 404: Resource not found due to incorrect input. Correct +// your request and then retry it. +// +// - ConflictException +// HTTP Status Code 409: Conflict. A resource with this name already exists. +// Retry your request with another name. +// +// - BadRequestException +// HTTP Status Code 400: Bad request due to incorrect input. Correct your request +// and then retry it. +// +// - ForbiddenException +// HTTP Status Code 403: Access forbidden. Correct your credentials and then +// retry your request. +// +// - ServiceUnavailableException +// HTTP Status Code 503: Service Unavailable. Retrying your request in some +// time might resolve the issue. +// +// - TooManyRequestsException +// HTTP Status Code 429: Limit exceeded. Resource limit reached. +// +// - UnauthorizedException +// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't +// be validated. +// +// - InternalServerErrorException +// HTTP Status Code 500: Unexpected internal server error. Retrying your request +// might resolve the issue. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource +func (c *KafkaConnect) TagResource(input *TagResourceInput) (*TagResourceOutput, error) { + req, out := c.TagResourceRequest(input) + return out, req.Send() +} + +// TagResourceWithContext is the same as TagResource with the addition of +// the ability to pass a context and additional request options. +// +// See TagResource for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *KafkaConnect) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) { + req, out := c.TagResourceRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + +const opUntagResource = "UntagResource" + +// UntagResourceRequest generates a "aws/request.Request" representing the +// client's request for the UntagResource operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See UntagResource for more information on using the UntagResource +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// // Example sending a request using the UntagResourceRequest method. +// req, resp := client.UntagResourceRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource +func (c *KafkaConnect) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) { + op := &request.Operation{ + Name: opUntagResource, + HTTPMethod: "DELETE", + HTTPPath: "/v1/tags/{resourceArn}", + } + + if input == nil { + input = &UntagResourceInput{} + } + + output = &UntagResourceOutput{} + req = c.newRequest(op, input, output) + req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) + return +} + +// UntagResource API operation for Managed Streaming for Kafka Connect. +// +// Removes tags from the specified resource. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for Managed Streaming for Kafka Connect's +// API operation UntagResource for usage and error information. +// +// Returned Error Types: +// +// - NotFoundException +// HTTP Status Code 404: Resource not found due to incorrect input. Correct +// your request and then retry it. +// +// - BadRequestException +// HTTP Status Code 400: Bad request due to incorrect input. Correct your request +// and then retry it. +// +// - ForbiddenException +// HTTP Status Code 403: Access forbidden. Correct your credentials and then +// retry your request. +// +// - ServiceUnavailableException +// HTTP Status Code 503: Service Unavailable. Retrying your request in some +// time might resolve the issue. +// +// - TooManyRequestsException +// HTTP Status Code 429: Limit exceeded. Resource limit reached. +// +// - UnauthorizedException +// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't +// be validated. +// +// - InternalServerErrorException +// HTTP Status Code 500: Unexpected internal server error. Retrying your request +// might resolve the issue. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource +func (c *KafkaConnect) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) { + req, out := c.UntagResourceRequest(input) + return out, req.Send() +} + +// UntagResourceWithContext is the same as UntagResource with the addition of +// the ability to pass a context and additional request options. +// +// See UntagResource for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *KafkaConnect) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) { + req, out := c.UntagResourceRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opUpdateConnector = "UpdateConnector" // UpdateConnectorRequest generates a "aws/request.Request" representing the @@ -2450,7 +2869,13 @@ type CreateConnectorInput struct { // Details about log delivery. LogDelivery *LogDelivery `locationName:"logDelivery" type:"structure"` - // Specifies which plugins to use for the connector. + // + // Amazon MSK Connect does not currently support specifying multiple plugins + // as a list. To use more than one plugin for your connector, you can create + // a single custom plugin using a ZIP file that bundles multiple plugins together. + // + // Specifies which plugin to use for the connector. You must specify a single-element + // list containing one customPlugin object. // // Plugins is a required field Plugins []*Plugin `locationName:"plugins" type:"list" required:"true"` @@ -2464,6 +2889,9 @@ type CreateConnectorInput struct { // ServiceExecutionRoleArn is a required field ServiceExecutionRoleArn *string `locationName:"serviceExecutionRoleArn" type:"string" required:"true"` + // The tags you want to attach to the connector. + Tags map[string]*string `locationName:"tags" type:"map"` + // Specifies which worker configuration to use with the connector. WorkerConfiguration *WorkerConfiguration `locationName:"workerConfiguration" type:"structure"` } @@ -2632,6 +3060,12 @@ func (s *CreateConnectorInput) SetServiceExecutionRoleArn(v string) *CreateConne return s } +// SetTags sets the Tags field's value. +func (s *CreateConnectorInput) SetTags(v map[string]*string) *CreateConnectorInput { + s.Tags = v + return s +} + // SetWorkerConfiguration sets the WorkerConfiguration field's value. func (s *CreateConnectorInput) SetWorkerConfiguration(v *WorkerConfiguration) *CreateConnectorInput { s.WorkerConfiguration = v @@ -2707,6 +3141,9 @@ type CreateCustomPluginInput struct { // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The tags you want to attach to the custom plugin. + Tags map[string]*string `locationName:"tags" type:"map"` } // String returns the string representation. @@ -2778,6 +3215,12 @@ func (s *CreateCustomPluginInput) SetName(v string) *CreateCustomPluginInput { return s } +// SetTags sets the Tags field's value. +func (s *CreateCustomPluginInput) SetTags(v map[string]*string) *CreateCustomPluginInput { + s.Tags = v + return s +} + type CreateCustomPluginOutput struct { _ struct{} `type:"structure"` @@ -2855,6 +3298,9 @@ type CreateWorkerConfigurationInput struct { // // PropertiesFileContent is a required field PropertiesFileContent *string `locationName:"propertiesFileContent" type:"string" required:"true" sensitive:"true"` + + // The tags you want to attach to the worker configuration. + Tags map[string]*string `locationName:"tags" type:"map"` } // String returns the string representation. @@ -2912,6 +3358,12 @@ func (s *CreateWorkerConfigurationInput) SetPropertiesFileContent(v string) *Cre return s } +// SetTags sets the Tags field's value. +func (s *CreateWorkerConfigurationInput) SetTags(v map[string]*string) *CreateWorkerConfigurationInput { + s.Tags = v + return s +} + type CreateWorkerConfigurationOutput struct { _ struct{} `type:"structure"` @@ -2926,6 +3378,9 @@ type CreateWorkerConfigurationOutput struct { // The Amazon Resource Name (ARN) that Amazon assigned to the worker configuration. WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"` + + // The state of the worker configuration. + WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"` } // String returns the string representation. @@ -2970,8 +3425,14 @@ func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *C return s } -// A plugin is an AWS resource that contains the code that defines a connector's -// logic. +// SetWorkerConfigurationState sets the WorkerConfigurationState field's value. +func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *CreateWorkerConfigurationOutput { + s.WorkerConfigurationState = &v + return s +} + +// A plugin is an Amazon Web Services resource that contains the code that defines +// a connector's logic. type CustomPlugin struct { _ struct{} `type:"structure"` @@ -3441,29 +3902,120 @@ func (s DeleteConnectorOutput) String() string { // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". -func (s DeleteConnectorOutput) GoString() string { +func (s DeleteConnectorOutput) GoString() string { + return s.String() +} + +// SetConnectorArn sets the ConnectorArn field's value. +func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput { + s.ConnectorArn = &v + return s +} + +// SetConnectorState sets the ConnectorState field's value. +func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput { + s.ConnectorState = &v + return s +} + +type DeleteCustomPluginInput struct { + _ struct{} `type:"structure" nopayload:"true"` + + // The Amazon Resource Name (ARN) of the custom plugin that you want to delete. + // + // CustomPluginArn is a required field + CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteCustomPluginInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteCustomPluginInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DeleteCustomPluginInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DeleteCustomPluginInput"} + if s.CustomPluginArn == nil { + invalidParams.Add(request.NewErrParamRequired("CustomPluginArn")) + } + if s.CustomPluginArn != nil && len(*s.CustomPluginArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("CustomPluginArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetCustomPluginArn sets the CustomPluginArn field's value. +func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput { + s.CustomPluginArn = &v + return s +} + +type DeleteCustomPluginOutput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the custom plugin that you requested to + // delete. + CustomPluginArn *string `locationName:"customPluginArn" type:"string"` + + // The state of the custom plugin. + CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteCustomPluginOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteCustomPluginOutput) GoString() string { return s.String() } -// SetConnectorArn sets the ConnectorArn field's value. -func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput { - s.ConnectorArn = &v +// SetCustomPluginArn sets the CustomPluginArn field's value. +func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput { + s.CustomPluginArn = &v return s } -// SetConnectorState sets the ConnectorState field's value. -func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput { - s.ConnectorState = &v +// SetCustomPluginState sets the CustomPluginState field's value. +func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput { + s.CustomPluginState = &v return s } -type DeleteCustomPluginInput struct { +type DeleteWorkerConfigurationInput struct { _ struct{} `type:"structure" nopayload:"true"` - // The Amazon Resource Name (ARN) of the custom plugin that you want to delete. + // The Amazon Resource Name (ARN) of the worker configuration that you want + // to delete. // - // CustomPluginArn is a required field - CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"` + // WorkerConfigurationArn is a required field + WorkerConfigurationArn *string `location:"uri" locationName:"workerConfigurationArn" type:"string" required:"true"` } // String returns the string representation. @@ -3471,7 +4023,7 @@ type DeleteCustomPluginInput struct { // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". -func (s DeleteCustomPluginInput) String() string { +func (s DeleteWorkerConfigurationInput) String() string { return awsutil.Prettify(s) } @@ -3480,18 +4032,18 @@ func (s DeleteCustomPluginInput) String() string { // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". -func (s DeleteCustomPluginInput) GoString() string { +func (s DeleteWorkerConfigurationInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. -func (s *DeleteCustomPluginInput) Validate() error { - invalidParams := request.ErrInvalidParams{Context: "DeleteCustomPluginInput"} - if s.CustomPluginArn == nil { - invalidParams.Add(request.NewErrParamRequired("CustomPluginArn")) +func (s *DeleteWorkerConfigurationInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DeleteWorkerConfigurationInput"} + if s.WorkerConfigurationArn == nil { + invalidParams.Add(request.NewErrParamRequired("WorkerConfigurationArn")) } - if s.CustomPluginArn != nil && len(*s.CustomPluginArn) < 1 { - invalidParams.Add(request.NewErrParamMinLen("CustomPluginArn", 1)) + if s.WorkerConfigurationArn != nil && len(*s.WorkerConfigurationArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("WorkerConfigurationArn", 1)) } if invalidParams.Len() > 0 { @@ -3500,21 +4052,21 @@ func (s *DeleteCustomPluginInput) Validate() error { return nil } -// SetCustomPluginArn sets the CustomPluginArn field's value. -func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput { - s.CustomPluginArn = &v +// SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value. +func (s *DeleteWorkerConfigurationInput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationInput { + s.WorkerConfigurationArn = &v return s } -type DeleteCustomPluginOutput struct { +type DeleteWorkerConfigurationOutput struct { _ struct{} `type:"structure"` - // The Amazon Resource Name (ARN) of the custom plugin that you requested to - // delete. - CustomPluginArn *string `locationName:"customPluginArn" type:"string"` + // The Amazon Resource Name (ARN) of the worker configuration that you requested + // to delete. + WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"` - // The state of the custom plugin. - CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"` + // The state of the worker configuration. + WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"` } // String returns the string representation. @@ -3522,7 +4074,7 @@ type DeleteCustomPluginOutput struct { // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". -func (s DeleteCustomPluginOutput) String() string { +func (s DeleteWorkerConfigurationOutput) String() string { return awsutil.Prettify(s) } @@ -3531,19 +4083,19 @@ func (s DeleteCustomPluginOutput) String() string { // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". -func (s DeleteCustomPluginOutput) GoString() string { +func (s DeleteWorkerConfigurationOutput) GoString() string { return s.String() } -// SetCustomPluginArn sets the CustomPluginArn field's value. -func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput { - s.CustomPluginArn = &v +// SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value. +func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationOutput { + s.WorkerConfigurationArn = &v return s } -// SetCustomPluginState sets the CustomPluginState field's value. -func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput { - s.CustomPluginState = &v +// SetWorkerConfigurationState sets the WorkerConfigurationState field's value. +func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DeleteWorkerConfigurationOutput { + s.WorkerConfigurationState = &v return s } @@ -3981,6 +4533,9 @@ type DescribeWorkerConfigurationOutput struct { // The Amazon Resource Name (ARN) of the custom configuration. WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"` + + // The state of the worker configuration. + WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"` } // String returns the string representation. @@ -4031,6 +4586,12 @@ func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) return s } +// SetWorkerConfigurationState sets the WorkerConfigurationState field's value. +func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DescribeWorkerConfigurationOutput { + s.WorkerConfigurationState = &v + return s +} + // The settings for delivering logs to Amazon Kinesis Data Firehose. type FirehoseLogDelivery struct { _ struct{} `type:"structure"` @@ -4619,6 +5180,9 @@ type ListCustomPluginsInput struct { // The maximum number of custom plugins to list in one response. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` + // Lists custom plugin names that start with the specified text string. + NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"` + // If the response of a ListCustomPlugins operation is truncated, it will include // a NextToken. Send this NextToken in a subsequent request to continue listing // from where the previous operation left off. @@ -4662,6 +5226,12 @@ func (s *ListCustomPluginsInput) SetMaxResults(v int64) *ListCustomPluginsInput return s } +// SetNamePrefix sets the NamePrefix field's value. +func (s *ListCustomPluginsInput) SetNamePrefix(v string) *ListCustomPluginsInput { + s.NamePrefix = &v + return s +} + // SetNextToken sets the NextToken field's value. func (s *ListCustomPluginsInput) SetNextToken(v string) *ListCustomPluginsInput { s.NextToken = &v @@ -4710,12 +5280,96 @@ func (s *ListCustomPluginsOutput) SetNextToken(v string) *ListCustomPluginsOutpu return s } +type ListTagsForResourceInput struct { + _ struct{} `type:"structure" nopayload:"true"` + + // The Amazon Resource Name (ARN) of the resource for which you want to list + // all attached tags. + // + // ResourceArn is a required field + ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListTagsForResourceInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListTagsForResourceInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListTagsForResourceInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListTagsForResourceInput"} + if s.ResourceArn == nil { + invalidParams.Add(request.NewErrParamRequired("ResourceArn")) + } + if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetResourceArn sets the ResourceArn field's value. +func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput { + s.ResourceArn = &v + return s +} + +type ListTagsForResourceOutput struct { + _ struct{} `type:"structure"` + + // Lists the tags attached to the specified resource in the corresponding request. + Tags map[string]*string `locationName:"tags" type:"map"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListTagsForResourceOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListTagsForResourceOutput) GoString() string { + return s.String() +} + +// SetTags sets the Tags field's value. +func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput { + s.Tags = v + return s +} + type ListWorkerConfigurationsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of worker configurations to list in one response. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` + // Lists worker configuration names that start with the specified text string. + NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"` + // If the response of a ListWorkerConfigurations operation is truncated, it // will include a NextToken. Send this NextToken in a subsequent request to // continue listing from where the previous operation left off. @@ -4759,6 +5413,12 @@ func (s *ListWorkerConfigurationsInput) SetMaxResults(v int64) *ListWorkerConfig return s } +// SetNamePrefix sets the NamePrefix field's value. +func (s *ListWorkerConfigurationsInput) SetNamePrefix(v string) *ListWorkerConfigurationsInput { + s.NamePrefix = &v + return s +} + // SetNextToken sets the NextToken field's value. func (s *ListWorkerConfigurationsInput) SetNextToken(v string) *ListWorkerConfigurationsInput { s.NextToken = &v @@ -4958,8 +5618,8 @@ func (s *NotFoundException) RequestID() string { return s.RespMetadata.RequestID } -// A plugin is an AWS resource that contains the code that defines your connector -// logic. +// A plugin is an Amazon Web Services resource that contains the code that defines +// your connector logic. type Plugin struct { _ struct{} `type:"structure"` @@ -5832,6 +6492,92 @@ func (s *StateDescription) SetMessage(v string) *StateDescription { return s } +type TagResourceInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the resource to which you want to attach + // tags. + // + // ResourceArn is a required field + ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` + + // The tags that you want to attach to the resource. + // + // Tags is a required field + Tags map[string]*string `locationName:"tags" type:"map" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s TagResourceInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s TagResourceInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *TagResourceInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "TagResourceInput"} + if s.ResourceArn == nil { + invalidParams.Add(request.NewErrParamRequired("ResourceArn")) + } + if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) + } + if s.Tags == nil { + invalidParams.Add(request.NewErrParamRequired("Tags")) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetResourceArn sets the ResourceArn field's value. +func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput { + s.ResourceArn = &v + return s +} + +// SetTags sets the Tags field's value. +func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput { + s.Tags = v + return s +} + +type TagResourceOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s TagResourceOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s TagResourceOutput) GoString() string { + return s.String() +} + // HTTP Status Code 429: Limit exceeded. Resource limit reached. type TooManyRequestsException struct { _ struct{} `type:"structure"` @@ -5961,6 +6707,92 @@ func (s *UnauthorizedException) RequestID() string { return s.RespMetadata.RequestID } +type UntagResourceInput struct { + _ struct{} `type:"structure" nopayload:"true"` + + // The Amazon Resource Name (ARN) of the resource from which you want to remove + // tags. + // + // ResourceArn is a required field + ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` + + // The keys of the tags that you want to remove from the resource. + // + // TagKeys is a required field + TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s UntagResourceInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s UntagResourceInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *UntagResourceInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "UntagResourceInput"} + if s.ResourceArn == nil { + invalidParams.Add(request.NewErrParamRequired("ResourceArn")) + } + if s.ResourceArn != nil && len(*s.ResourceArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1)) + } + if s.TagKeys == nil { + invalidParams.Add(request.NewErrParamRequired("TagKeys")) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetResourceArn sets the ResourceArn field's value. +func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput { + s.ResourceArn = &v + return s +} + +// SetTagKeys sets the TagKeys field's value. +func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput { + s.TagKeys = v + return s +} + +type UntagResourceOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s UntagResourceOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s UntagResourceOutput) GoString() string { + return s.String() +} + type UpdateConnectorInput struct { _ struct{} `type:"structure"` @@ -6417,6 +7249,9 @@ type WorkerConfigurationSummary struct { // The Amazon Resource Name (ARN) of the worker configuration. WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"` + + // The state of the worker configuration. + WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"` } // String returns the string representation. @@ -6467,6 +7302,12 @@ func (s *WorkerConfigurationSummary) SetWorkerConfigurationArn(v string) *Worker return s } +// SetWorkerConfigurationState sets the WorkerConfigurationState field's value. +func (s *WorkerConfigurationSummary) SetWorkerConfigurationState(v string) *WorkerConfigurationSummary { + s.WorkerConfigurationState = &v + return s +} + // Workers can send worker logs to different destination types. This configuration // specifies the details of these destinations. type WorkerLogDelivery struct { @@ -6701,3 +7542,19 @@ func KafkaClusterEncryptionInTransitType_Values() []string { KafkaClusterEncryptionInTransitTypeTls, } } + +const ( + // WorkerConfigurationStateActive is a WorkerConfigurationState enum value + WorkerConfigurationStateActive = "ACTIVE" + + // WorkerConfigurationStateDeleting is a WorkerConfigurationState enum value + WorkerConfigurationStateDeleting = "DELETING" +) + +// WorkerConfigurationState_Values returns all elements of the WorkerConfigurationState enum +func WorkerConfigurationState_Values() []string { + return []string{ + WorkerConfigurationStateActive, + WorkerConfigurationStateDeleting, + } +} diff --git a/service/kafkaconnect/kafkaconnectiface/interface.go b/service/kafkaconnect/kafkaconnectiface/interface.go index 74343840d3..94f080afec 100644 --- a/service/kafkaconnect/kafkaconnectiface/interface.go +++ b/service/kafkaconnect/kafkaconnectiface/interface.go @@ -80,6 +80,10 @@ type KafkaConnectAPI interface { DeleteCustomPluginWithContext(aws.Context, *kafkaconnect.DeleteCustomPluginInput, ...request.Option) (*kafkaconnect.DeleteCustomPluginOutput, error) DeleteCustomPluginRequest(*kafkaconnect.DeleteCustomPluginInput) (*request.Request, *kafkaconnect.DeleteCustomPluginOutput) + DeleteWorkerConfiguration(*kafkaconnect.DeleteWorkerConfigurationInput) (*kafkaconnect.DeleteWorkerConfigurationOutput, error) + DeleteWorkerConfigurationWithContext(aws.Context, *kafkaconnect.DeleteWorkerConfigurationInput, ...request.Option) (*kafkaconnect.DeleteWorkerConfigurationOutput, error) + DeleteWorkerConfigurationRequest(*kafkaconnect.DeleteWorkerConfigurationInput) (*request.Request, *kafkaconnect.DeleteWorkerConfigurationOutput) + DescribeConnector(*kafkaconnect.DescribeConnectorInput) (*kafkaconnect.DescribeConnectorOutput, error) DescribeConnectorWithContext(aws.Context, *kafkaconnect.DescribeConnectorInput, ...request.Option) (*kafkaconnect.DescribeConnectorOutput, error) DescribeConnectorRequest(*kafkaconnect.DescribeConnectorInput) (*request.Request, *kafkaconnect.DescribeConnectorOutput) @@ -106,6 +110,10 @@ type KafkaConnectAPI interface { ListCustomPluginsPages(*kafkaconnect.ListCustomPluginsInput, func(*kafkaconnect.ListCustomPluginsOutput, bool) bool) error ListCustomPluginsPagesWithContext(aws.Context, *kafkaconnect.ListCustomPluginsInput, func(*kafkaconnect.ListCustomPluginsOutput, bool) bool, ...request.Option) error + ListTagsForResource(*kafkaconnect.ListTagsForResourceInput) (*kafkaconnect.ListTagsForResourceOutput, error) + ListTagsForResourceWithContext(aws.Context, *kafkaconnect.ListTagsForResourceInput, ...request.Option) (*kafkaconnect.ListTagsForResourceOutput, error) + ListTagsForResourceRequest(*kafkaconnect.ListTagsForResourceInput) (*request.Request, *kafkaconnect.ListTagsForResourceOutput) + ListWorkerConfigurations(*kafkaconnect.ListWorkerConfigurationsInput) (*kafkaconnect.ListWorkerConfigurationsOutput, error) ListWorkerConfigurationsWithContext(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, ...request.Option) (*kafkaconnect.ListWorkerConfigurationsOutput, error) ListWorkerConfigurationsRequest(*kafkaconnect.ListWorkerConfigurationsInput) (*request.Request, *kafkaconnect.ListWorkerConfigurationsOutput) @@ -113,6 +121,14 @@ type KafkaConnectAPI interface { ListWorkerConfigurationsPages(*kafkaconnect.ListWorkerConfigurationsInput, func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool) error ListWorkerConfigurationsPagesWithContext(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool, ...request.Option) error + TagResource(*kafkaconnect.TagResourceInput) (*kafkaconnect.TagResourceOutput, error) + TagResourceWithContext(aws.Context, *kafkaconnect.TagResourceInput, ...request.Option) (*kafkaconnect.TagResourceOutput, error) + TagResourceRequest(*kafkaconnect.TagResourceInput) (*request.Request, *kafkaconnect.TagResourceOutput) + + UntagResource(*kafkaconnect.UntagResourceInput) (*kafkaconnect.UntagResourceOutput, error) + UntagResourceWithContext(aws.Context, *kafkaconnect.UntagResourceInput, ...request.Option) (*kafkaconnect.UntagResourceOutput, error) + UntagResourceRequest(*kafkaconnect.UntagResourceInput) (*request.Request, *kafkaconnect.UntagResourceOutput) + UpdateConnector(*kafkaconnect.UpdateConnectorInput) (*kafkaconnect.UpdateConnectorOutput, error) UpdateConnectorWithContext(aws.Context, *kafkaconnect.UpdateConnectorInput, ...request.Option) (*kafkaconnect.UpdateConnectorOutput, error) UpdateConnectorRequest(*kafkaconnect.UpdateConnectorInput) (*request.Request, *kafkaconnect.UpdateConnectorOutput) diff --git a/service/rds/api.go b/service/rds/api.go index 079d2f5324..3924ac6a89 100644 --- a/service/rds/api.go +++ b/service/rds/api.go @@ -28152,6 +28152,12 @@ type DBCluster struct { // Indicates whether the DB cluster is encrypted. StorageEncrypted *bool `type:"boolean"` + // The storage throughput for the DB cluster. The throughput is automatically + // set based on the IOPS that you provision, and is not configurable. + // + // This setting is only for non-Aurora Multi-AZ DB clusters. + StorageThroughput *int64 `type:"integer"` + // The storage type associated with the DB cluster. StorageType *string `type:"string"` @@ -28625,6 +28631,12 @@ func (s *DBCluster) SetStorageEncrypted(v bool) *DBCluster { return s } +// SetStorageThroughput sets the StorageThroughput field's value. +func (s *DBCluster) SetStorageThroughput(v int64) *DBCluster { + s.StorageThroughput = &v + return s +} + // SetStorageType sets the StorageType field's value. func (s *DBCluster) SetStorageType(v string) *DBCluster { s.StorageType = &v @@ -28735,6 +28747,12 @@ type DBClusterAutomatedBackup struct { // Indicates whether the source DB cluster is encrypted. StorageEncrypted *bool `type:"boolean"` + // The storage throughput for the automated backup. The throughput is automatically + // set based on the IOPS that you provision, and is not configurable. + // + // This setting is only for non-Aurora Multi-AZ DB clusters. + StorageThroughput *int64 `type:"integer"` + // The storage type associated with the DB cluster. // // This setting is only for non-Aurora Multi-AZ DB clusters. @@ -28894,6 +28912,12 @@ func (s *DBClusterAutomatedBackup) SetStorageEncrypted(v bool) *DBClusterAutomat return s } +// SetStorageThroughput sets the StorageThroughput field's value. +func (s *DBClusterAutomatedBackup) SetStorageThroughput(v int64) *DBClusterAutomatedBackup { + s.StorageThroughput = &v + return s +} + // SetStorageType sets the StorageType field's value. func (s *DBClusterAutomatedBackup) SetStorageType(v string) *DBClusterAutomatedBackup { s.StorageType = &v @@ -29403,6 +29427,12 @@ type DBClusterSnapshot struct { // Indicates whether the DB cluster snapshot is encrypted. StorageEncrypted *bool `type:"boolean"` + // The storage throughput for the DB cluster snapshot. The throughput is automatically + // set based on the IOPS that you provision, and is not configurable. + // + // This setting is only for non-Aurora Multi-AZ DB clusters. + StorageThroughput *int64 `type:"integer"` + // The storage type associated with the DB cluster snapshot. // // This setting is only for Aurora DB clusters. @@ -29566,6 +29596,12 @@ func (s *DBClusterSnapshot) SetStorageEncrypted(v bool) *DBClusterSnapshot { return s } +// SetStorageThroughput sets the StorageThroughput field's value. +func (s *DBClusterSnapshot) SetStorageThroughput(v int64) *DBClusterSnapshot { + s.StorageThroughput = &v + return s +} + // SetStorageType sets the StorageType field's value. func (s *DBClusterSnapshot) SetStorageType(v string) *DBClusterSnapshot { s.StorageType = &v @@ -56787,8 +56823,7 @@ type RestoreDBInstanceFromDBSnapshotInput struct { // This setting is required for RDS Custom. CustomIamInstanceProfile *string `type:"string"` - // The identifier for the RDS for MySQL Multi-AZ DB cluster snapshot to restore - // from. + // The identifier for the Multi-AZ DB cluster snapshot to restore from. // // For more information on Multi-AZ DB clusters, see Multi-AZ DB cluster deployments // (https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html) @@ -56806,9 +56841,6 @@ type RestoreDBInstanceFromDBSnapshotInput struct { // the DBClusterSnapshotIdentifier must be the ARN of the shared snapshot. // // * Can't be the identifier of an Aurora DB cluster snapshot. - // - // * Can't be the identifier of an RDS for PostgreSQL Multi-AZ DB cluster - // snapshot. DBClusterSnapshotIdentifier *string `type:"string"` // The compute and memory capacity of the Amazon RDS DB instance, for example