diff --git a/apis/apigateway/2015-07-09/docs-2.json b/apis/apigateway/2015-07-09/docs-2.json
index c11169fc467..b9b87327e54 100644
--- a/apis/apigateway/2015-07-09/docs-2.json
+++ b/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/apis/apigateway/2015-07-09/endpoint-rule-set-1.json b/apis/apigateway/2015-07-09/endpoint-rule-set-1.json
index 61804152356..c8acc7bd13a 100644
--- a/apis/apigateway/2015-07-09/endpoint-rule-set-1.json
+++ b/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/apis/drs/2020-02-26/api-2.json b/apis/drs/2020-02-26/api-2.json
index f82267b2347..a6bd6bc41fc 100644
--- a/apis/drs/2020-02-26/api-2.json
+++ b/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/apis/drs/2020-02-26/docs-2.json b/apis/drs/2020-02-26/docs-2.json
index 9fa9577e088..db3db46a702 100644
--- a/apis/drs/2020-02-26/docs-2.json
+++ b/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/apis/kafkaconnect/2021-09-14/api-2.json b/apis/kafkaconnect/2021-09-14/api-2.json
index 8632fb1dd48..62234e4f0c4 100644
--- a/apis/kafkaconnect/2021-09-14/api-2.json
+++ b/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/apis/kafkaconnect/2021-09-14/docs-2.json b/apis/kafkaconnect/2021-09-14/docs-2.json
index ba345141973..65668e761f1 100644
--- a/apis/kafkaconnect/2021-09-14/docs-2.json
+++ b/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/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json b/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json
index c5b90d3def0..545020b141c 100644
--- a/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json
+++ b/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/apis/rds/2014-10-31/api-2.json b/apis/rds/2014-10-31/api-2.json
index 3755b4ad451..f28d4dc8881 100644
--- a/apis/rds/2014-10-31/api-2.json
+++ b/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/apis/rds/2014-10-31/docs-2.json b/apis/rds/2014-10-31/docs-2.json
index e0570d41b75..a9e7b65dcb6 100644
--- a/apis/rds/2014-10-31/docs-2.json
+++ b/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:
-
7
-
month * 31, where month is a number of months from 1-23. Examples: 93
(3 months * 31), 341
(11 months * 31), 589
(19 months * 31)
-
731
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:
-
The profile must exist in your account.
-
The profile must have an IAM role that Amazon EC2 has permissions to assume.
-
The instance profile name and the associated IAM role name must start with the prefix AWSRDSCustom
.
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:
-
Must match the identifier of an existing Multi-AZ DB cluster snapshot.
-
Can't be specified when DBSnapshotIdentifier
is specified.
-
Must be specified when DBSnapshotIdentifier
isn't specified.
-
If you are restoring from a shared manual Multi-AZ DB cluster snapshot, 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.
",
+ "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:
-
Must match the identifier of an existing Multi-AZ DB cluster snapshot.
-
Can't be specified when DBSnapshotIdentifier
is specified.
-
Must be specified when DBSnapshotIdentifier
isn't specified.
-
If you are restoring from a shared manual Multi-AZ DB cluster snapshot, the DBClusterSnapshotIdentifier
must be the ARN of the shared snapshot.
-
Can't be the identifier of an Aurora DB cluster snapshot.
",
"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:
-
Must contain from 1 to 63 letters, numbers, or hyphens.
-
First character must be a letter.
-
Can't end with a hyphen or contain two consecutive hyphens.
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/gems/aws-sdk-apigateway/CHANGELOG.md b/gems/aws-sdk-apigateway/CHANGELOG.md
index 55b39532819..929f351c4e5 100644
--- a/gems/aws-sdk-apigateway/CHANGELOG.md
+++ b/gems/aws-sdk-apigateway/CHANGELOG.md
@@ -1,6 +1,11 @@
Unreleased Changes
------------------
+1.92.0 (2024-02-26)
+------------------
+
+* Feature - Documentation updates for Amazon API Gateway.
+
1.91.0 (2024-01-26)
------------------
diff --git a/gems/aws-sdk-apigateway/VERSION b/gems/aws-sdk-apigateway/VERSION
index 6979a6c0661..7f229af9647 100644
--- a/gems/aws-sdk-apigateway/VERSION
+++ b/gems/aws-sdk-apigateway/VERSION
@@ -1 +1 @@
-1.91.0
+1.92.0
diff --git a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway.rb b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway.rb
index 2f27760882e..71c470e7e24 100644
--- a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway.rb
+++ b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway.rb
@@ -52,6 +52,6 @@
# @!group service
module Aws::APIGateway
- GEM_VERSION = '1.91.0'
+ GEM_VERSION = '1.92.0'
end
diff --git a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/client.rb b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/client.rb
index 94f9bc5e906..59e01cfb548 100644
--- a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/client.rb
+++ b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/client.rb
@@ -992,7 +992,7 @@ def create_domain_name(params = {}, options = {})
#
# @option params [String] :schema
# The schema for the model. For `application/json` models, this should
- # be JSON schema draft 4 model.
+ # be JSON schema draft 4 model. The maximum size of the model is 400 KB.
#
# @option params [required, String] :content_type
# The content-type for the model.
@@ -6494,7 +6494,8 @@ def update_method_response(params = {}, options = {})
req.send_request(options)
end
- # Changes information about a model.
+ # Changes information about a model. The maximum size of the model is
+ # 400 KB.
#
# @option params [required, String] :rest_api_id
# The string identifier of the associated RestApi.
@@ -7060,7 +7061,7 @@ def build_request(operation_name, params = {})
params: params,
config: config)
context[:gem_name] = 'aws-sdk-apigateway'
- context[:gem_version] = '1.91.0'
+ context[:gem_version] = '1.92.0'
Seahorse::Client::Request.new(handlers, context)
end
diff --git a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/endpoint_provider.rb b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/endpoint_provider.rb
index 42bd2e1eb6c..7a897c58c5f 100644
--- a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/endpoint_provider.rb
+++ b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/endpoint_provider.rb
@@ -32,7 +32,7 @@ def resolve_endpoint(parameters)
raise ArgumentError, "FIPS and DualStack are enabled, but this partition does not support one or both"
end
if Aws::Endpoints::Matchers.boolean_equals?(use_fips, true)
- if Aws::Endpoints::Matchers.boolean_equals?(true, Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"))
+ if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
return Aws::Endpoints::Endpoint.new(url: "https://apigateway-fips.#{region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
diff --git a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/types.rb b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/types.rb
index 71d6c67ffcc..ad9f04af8e1 100644
--- a/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/types.rb
+++ b/gems/aws-sdk-apigateway/lib/aws-sdk-apigateway/types.rb
@@ -890,7 +890,8 @@ class CreateDomainNameRequest < Struct.new(
#
# @!attribute [rw] schema
# The schema for the model. For `application/json` models, this should
- # be JSON schema draft 4 model.
+ # be JSON schema draft 4 model. The maximum size of the model is 400
+ # KB.
# @return [String]
#
# @!attribute [rw] content_type
@@ -4735,7 +4736,9 @@ class ServiceUnavailableException < Struct.new(
# @return [String]
#
# @!attribute [rw] cache_cluster_enabled
- # 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.
# @return [Boolean]
#
# @!attribute [rw] cache_cluster_size
diff --git a/gems/aws-sdk-drs/CHANGELOG.md b/gems/aws-sdk-drs/CHANGELOG.md
index c9cd4f708a2..7c5b40b9e75 100644
--- a/gems/aws-sdk-drs/CHANGELOG.md
+++ b/gems/aws-sdk-drs/CHANGELOG.md
@@ -1,6 +1,11 @@
Unreleased Changes
------------------
+1.29.0 (2024-02-26)
+------------------
+
+* Feature - Added volume status to DescribeSourceServer replicated volumes.
+
1.28.0 (2024-01-26)
------------------
diff --git a/gems/aws-sdk-drs/VERSION b/gems/aws-sdk-drs/VERSION
index cfc730712d5..5e57fb89558 100644
--- a/gems/aws-sdk-drs/VERSION
+++ b/gems/aws-sdk-drs/VERSION
@@ -1 +1 @@
-1.28.0
+1.29.0
diff --git a/gems/aws-sdk-drs/lib/aws-sdk-drs.rb b/gems/aws-sdk-drs/lib/aws-sdk-drs.rb
index f28145c9105..e6d3ba5c89e 100644
--- a/gems/aws-sdk-drs/lib/aws-sdk-drs.rb
+++ b/gems/aws-sdk-drs/lib/aws-sdk-drs.rb
@@ -52,6 +52,6 @@
# @!group service
module Aws::Drs
- GEM_VERSION = '1.28.0'
+ GEM_VERSION = '1.29.0'
end
diff --git a/gems/aws-sdk-drs/lib/aws-sdk-drs/client.rb b/gems/aws-sdk-drs/lib/aws-sdk-drs/client.rb
index 235528de816..9a6f52f496d 100644
--- a/gems/aws-sdk-drs/lib/aws-sdk-drs/client.rb
+++ b/gems/aws-sdk-drs/lib/aws-sdk-drs/client.rb
@@ -498,6 +498,7 @@ def associate_source_network_stack(params = {}, options = {})
# resp.source_server.data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.source_server.data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.source_server.data_replication_info.staging_availability_zone #=> String
# resp.source_server.last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.source_server.life_cycle.added_to_service_date_time #=> String
@@ -1013,6 +1014,10 @@ def delete_source_server(params = {}, options = {})
# resp.items[0].event_data.conversion_properties.volume_to_conversion_map #=> Hash
# resp.items[0].event_data.conversion_properties.volume_to_conversion_map["LargeBoundedString"] #=> Hash
# resp.items[0].event_data.conversion_properties.volume_to_conversion_map["LargeBoundedString"]["EbsSnapshot"] #=> String
+ # resp.items[0].event_data.conversion_properties.volume_to_product_codes #=> Hash
+ # resp.items[0].event_data.conversion_properties.volume_to_product_codes["LargeBoundedString"] #=> Array
+ # resp.items[0].event_data.conversion_properties.volume_to_product_codes["LargeBoundedString"][0].product_code_id #=> String
+ # resp.items[0].event_data.conversion_properties.volume_to_product_codes["LargeBoundedString"][0].product_code_mode #=> String, one of "ENABLED", "DISABLED"
# resp.items[0].event_data.conversion_properties.volume_to_volume_size #=> Hash
# resp.items[0].event_data.conversion_properties.volume_to_volume_size["LargeBoundedString"] #=> Integer
# resp.items[0].event_data.conversion_server_id #=> String
@@ -1508,6 +1513,7 @@ def describe_source_networks(params = {}, options = {})
# resp.items[0].data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.items[0].data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.items[0].data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.items[0].data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.items[0].data_replication_info.staging_availability_zone #=> String
# resp.items[0].last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.items[0].life_cycle.added_to_service_date_time #=> String
@@ -1658,6 +1664,7 @@ def disconnect_recovery_instance(params = {}, options = {})
# resp.data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.data_replication_info.staging_availability_zone #=> String
# resp.last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.life_cycle.added_to_service_date_time #=> String
@@ -2234,6 +2241,7 @@ def put_launch_action(params = {}, options = {})
# resp.data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.data_replication_info.staging_availability_zone #=> String
# resp.last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.life_cycle.added_to_service_date_time #=> String
@@ -2506,6 +2514,7 @@ def start_recovery(params = {}, options = {})
# resp.source_server.data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.source_server.data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.source_server.data_replication_info.staging_availability_zone #=> String
# resp.source_server.last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.source_server.life_cycle.added_to_service_date_time #=> String
@@ -2742,6 +2751,7 @@ def stop_failback(params = {}, options = {})
# resp.source_server.data_replication_info.replicated_disks[0].replicated_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].rescanned_storage_bytes #=> Integer
# resp.source_server.data_replication_info.replicated_disks[0].total_storage_bytes #=> Integer
+ # resp.source_server.data_replication_info.replicated_disks[0].volume_status #=> String, one of "REGULAR", "CONTAINS_MARKETPLACE_PRODUCT_CODES", "MISSING_VOLUME_ATTRIBUTES", "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
# resp.source_server.data_replication_info.staging_availability_zone #=> String
# resp.source_server.last_launch_result #=> String, one of "NOT_STARTED", "PENDING", "SUCCEEDED", "FAILED"
# resp.source_server.life_cycle.added_to_service_date_time #=> String
@@ -3481,7 +3491,7 @@ def build_request(operation_name, params = {})
params: params,
config: config)
context[:gem_name] = 'aws-sdk-drs'
- context[:gem_version] = '1.28.0'
+ context[:gem_version] = '1.29.0'
Seahorse::Client::Request.new(handlers, context)
end
diff --git a/gems/aws-sdk-drs/lib/aws-sdk-drs/client_api.rb b/gems/aws-sdk-drs/lib/aws-sdk-drs/client_api.rb
index 9d904d2e1e7..867f6e39459 100644
--- a/gems/aws-sdk-drs/lib/aws-sdk-drs/client_api.rb
+++ b/gems/aws-sdk-drs/lib/aws-sdk-drs/client_api.rb
@@ -189,6 +189,10 @@ module ClientApi
ParticipatingServer = Shapes::StructureShape.new(name: 'ParticipatingServer')
ParticipatingServers = Shapes::ListShape.new(name: 'ParticipatingServers')
PositiveInteger = Shapes::IntegerShape.new(name: 'PositiveInteger')
+ ProductCode = Shapes::StructureShape.new(name: 'ProductCode')
+ ProductCodeId = Shapes::StringShape.new(name: 'ProductCodeId')
+ ProductCodeMode = Shapes::StringShape.new(name: 'ProductCodeMode')
+ ProductCodes = Shapes::ListShape.new(name: 'ProductCodes')
PutLaunchActionRequest = Shapes::StructureShape.new(name: 'PutLaunchActionRequest')
PutLaunchActionResponse = Shapes::StructureShape.new(name: 'PutLaunchActionResponse')
RecoveryInstance = Shapes::StructureShape.new(name: 'RecoveryInstance')
@@ -296,7 +300,9 @@ module ClientApi
ValidationExceptionField = Shapes::StructureShape.new(name: 'ValidationExceptionField')
ValidationExceptionFieldList = Shapes::ListShape.new(name: 'ValidationExceptionFieldList')
ValidationExceptionReason = Shapes::StringShape.new(name: 'ValidationExceptionReason')
+ VolumeStatus = Shapes::StringShape.new(name: 'VolumeStatus')
VolumeToConversionMap = Shapes::MapShape.new(name: 'VolumeToConversionMap')
+ VolumeToProductCodes = Shapes::MapShape.new(name: 'VolumeToProductCodes')
VolumeToSizeMap = Shapes::MapShape.new(name: 'VolumeToSizeMap')
VpcID = Shapes::StringShape.new(name: 'VpcID')
@@ -335,6 +341,7 @@ module ClientApi
ConversionProperties.add_member(:force_uefi, Shapes::ShapeRef.new(shape: Boolean, location_name: "forceUefi"))
ConversionProperties.add_member(:root_volume_name, Shapes::ShapeRef.new(shape: LargeBoundedString, location_name: "rootVolumeName"))
ConversionProperties.add_member(:volume_to_conversion_map, Shapes::ShapeRef.new(shape: VolumeToConversionMap, location_name: "volumeToConversionMap"))
+ ConversionProperties.add_member(:volume_to_product_codes, Shapes::ShapeRef.new(shape: VolumeToProductCodes, location_name: "volumeToProductCodes"))
ConversionProperties.add_member(:volume_to_volume_size, Shapes::ShapeRef.new(shape: VolumeToSizeMap, location_name: "volumeToVolumeSize"))
ConversionProperties.struct_class = Types::ConversionProperties
@@ -405,6 +412,7 @@ module ClientApi
DataReplicationInfoReplicatedDisk.add_member(:replicated_storage_bytes, Shapes::ShapeRef.new(shape: PositiveInteger, location_name: "replicatedStorageBytes"))
DataReplicationInfoReplicatedDisk.add_member(:rescanned_storage_bytes, Shapes::ShapeRef.new(shape: PositiveInteger, location_name: "rescannedStorageBytes"))
DataReplicationInfoReplicatedDisk.add_member(:total_storage_bytes, Shapes::ShapeRef.new(shape: PositiveInteger, location_name: "totalStorageBytes"))
+ DataReplicationInfoReplicatedDisk.add_member(:volume_status, Shapes::ShapeRef.new(shape: VolumeStatus, location_name: "volumeStatus"))
DataReplicationInfoReplicatedDisk.struct_class = Types::DataReplicationInfoReplicatedDisk
DataReplicationInfoReplicatedDisks.member = Shapes::ShapeRef.new(shape: DataReplicationInfoReplicatedDisk)
@@ -807,6 +815,12 @@ module ClientApi
ParticipatingServers.member = Shapes::ShapeRef.new(shape: ParticipatingServer)
+ ProductCode.add_member(:product_code_id, Shapes::ShapeRef.new(shape: ProductCodeId, location_name: "productCodeId"))
+ ProductCode.add_member(:product_code_mode, Shapes::ShapeRef.new(shape: ProductCodeMode, location_name: "productCodeMode"))
+ ProductCode.struct_class = Types::ProductCode
+
+ ProductCodes.member = Shapes::ShapeRef.new(shape: ProductCode)
+
PutLaunchActionRequest.add_member(:action_code, Shapes::ShapeRef.new(shape: SsmDocumentName, required: true, location_name: "actionCode"))
PutLaunchActionRequest.add_member(:action_id, Shapes::ShapeRef.new(shape: LaunchActionId, required: true, location_name: "actionId"))
PutLaunchActionRequest.add_member(:action_version, Shapes::ShapeRef.new(shape: LaunchActionVersion, required: true, location_name: "actionVersion"))
@@ -1252,6 +1266,9 @@ module ClientApi
VolumeToConversionMap.key = Shapes::ShapeRef.new(shape: LargeBoundedString)
VolumeToConversionMap.value = Shapes::ShapeRef.new(shape: ConversionMap)
+ VolumeToProductCodes.key = Shapes::ShapeRef.new(shape: LargeBoundedString)
+ VolumeToProductCodes.value = Shapes::ShapeRef.new(shape: ProductCodes)
+
VolumeToSizeMap.key = Shapes::ShapeRef.new(shape: LargeBoundedString)
VolumeToSizeMap.value = Shapes::ShapeRef.new(shape: PositiveInteger)
diff --git a/gems/aws-sdk-drs/lib/aws-sdk-drs/types.rb b/gems/aws-sdk-drs/lib/aws-sdk-drs/types.rb
index edfd7b81f6d..829f1c2db0d 100644
--- a/gems/aws-sdk-drs/lib/aws-sdk-drs/types.rb
+++ b/gems/aws-sdk-drs/lib/aws-sdk-drs/types.rb
@@ -136,6 +136,11 @@ class ConflictException < Struct.new(
# snapshot ids
# @return [Hash>]
#
+ # @!attribute [rw] volume_to_product_codes
+ # A mapping between the volumes being converted and the product codes
+ # associated with them
+ # @return [Hash>]
+ #
# @!attribute [rw] volume_to_volume_size
# A mapping between the volumes and their sizes
# @return [Hash]
@@ -147,6 +152,7 @@ class ConversionProperties < Struct.new(
:force_uefi,
:root_volume_name,
:volume_to_conversion_map,
+ :volume_to_product_codes,
:volume_to_volume_size)
SENSITIVE = []
include Aws::Structure
@@ -463,6 +469,10 @@ class DataReplicationInfo < Struct.new(
# The total amount of data to be replicated in bytes.
# @return [Integer]
#
+ # @!attribute [rw] volume_status
+ # The status of the volume.
+ # @return [String]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/drs-2020-02-26/DataReplicationInfoReplicatedDisk AWS API Documentation
#
class DataReplicationInfoReplicatedDisk < Struct.new(
@@ -470,7 +480,8 @@ class DataReplicationInfoReplicatedDisk < Struct.new(
:device_name,
:replicated_storage_bytes,
:rescanned_storage_bytes,
- :total_storage_bytes)
+ :total_storage_bytes,
+ :volume_status)
SENSITIVE = []
include Aws::Structure
end
@@ -2089,6 +2100,25 @@ class ParticipatingServer < Struct.new(
include Aws::Structure
end
+ # Properties of a product code associated with a volume.
+ #
+ # @!attribute [rw] product_code_id
+ # Id of a product code associated with a volume.
+ # @return [String]
+ #
+ # @!attribute [rw] product_code_mode
+ # Mode of a product code associated with a volume.
+ # @return [String]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/drs-2020-02-26/ProductCode AWS API Documentation
+ #
+ class ProductCode < Struct.new(
+ :product_code_id,
+ :product_code_mode)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
# @!attribute [rw] action_code
# Launch action code.
# @return [String]
diff --git a/gems/aws-sdk-drs/sig/types.rbs b/gems/aws-sdk-drs/sig/types.rbs
index 614fc56bcf9..c0fb6ca56bd 100644
--- a/gems/aws-sdk-drs/sig/types.rbs
+++ b/gems/aws-sdk-drs/sig/types.rbs
@@ -49,6 +49,7 @@ module Aws::Drs
attr_accessor force_uefi: bool
attr_accessor root_volume_name: ::String
attr_accessor volume_to_conversion_map: ::Hash[::String, ::Hash[::String, ::String]]
+ attr_accessor volume_to_product_codes: ::Hash[::String, ::Array[Types::ProductCode]]
attr_accessor volume_to_volume_size: ::Hash[::String, ::Integer]
SENSITIVE: []
end
@@ -137,6 +138,7 @@ module Aws::Drs
attr_accessor replicated_storage_bytes: ::Integer
attr_accessor rescanned_storage_bytes: ::Integer
attr_accessor total_storage_bytes: ::Integer
+ attr_accessor volume_status: ("REGULAR" | "CONTAINS_MARKETPLACE_PRODUCT_CODES" | "MISSING_VOLUME_ATTRIBUTES" | "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE")
SENSITIVE: []
end
@@ -653,6 +655,12 @@ module Aws::Drs
SENSITIVE: []
end
+ class ProductCode
+ attr_accessor product_code_id: ::String
+ attr_accessor product_code_mode: ("ENABLED" | "DISABLED")
+ SENSITIVE: []
+ end
+
class PutLaunchActionRequest
attr_accessor action_code: ::String
attr_accessor action_id: ::String
diff --git a/gems/aws-sdk-kafkaconnect/CHANGELOG.md b/gems/aws-sdk-kafkaconnect/CHANGELOG.md
index ee6fbb9288b..7de96079989 100644
--- a/gems/aws-sdk-kafkaconnect/CHANGELOG.md
+++ b/gems/aws-sdk-kafkaconnect/CHANGELOG.md
@@ -1,6 +1,11 @@
Unreleased Changes
------------------
+1.20.0 (2024-02-26)
+------------------
+
+* Feature - Adds support for tagging, with new TagResource, UntagResource and ListTagsForResource APIs to manage tags and updates to existing APIs to allow tag on create. This release also adds support for the new DeleteWorkerConfiguration API.
+
1.19.0 (2024-01-26)
------------------
diff --git a/gems/aws-sdk-kafkaconnect/VERSION b/gems/aws-sdk-kafkaconnect/VERSION
index 815d5ca06d5..39893559155 100644
--- a/gems/aws-sdk-kafkaconnect/VERSION
+++ b/gems/aws-sdk-kafkaconnect/VERSION
@@ -1 +1 @@
-1.19.0
+1.20.0
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect.rb
index 1131edd3abd..f27328953d3 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect.rb
@@ -52,6 +52,6 @@
# @!group service
module Aws::KafkaConnect
- GEM_VERSION = '1.19.0'
+ GEM_VERSION = '1.20.0'
end
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client.rb
index 36ad8c9f4cf..1af5f2f1186 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client.rb
@@ -421,7 +421,13 @@ def initialize(*args)
# Details about log delivery.
#
# @option params [required, Array] :plugins
- # 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.
#
# @option params [required, String] :service_execution_role_arn
# The Amazon Resource Name (ARN) of the IAM role used by the connector
@@ -430,6 +436,9 @@ def initialize(*args)
# connector that has Amazon S3 as a destination must have permissions
# that allow it to write to the S3 destination bucket.
#
+ # @option params [Hash] :tags
+ # The tags you want to attach to the connector.
+ #
# @option params [Types::WorkerConfiguration] :worker_configuration
# Specifies which worker configuration to use with the connector.
#
@@ -506,6 +515,9 @@ def initialize(*args)
# },
# ],
# service_execution_role_arn: "__string", # required
+ # tags: {
+ # "TagKey" => "TagValue",
+ # },
# worker_configuration: {
# revision: 1, # required
# worker_configuration_arn: "__string", # required
@@ -541,6 +553,9 @@ def create_connector(params = {}, options = {})
# @option params [required, String] :name
# The name of the custom plugin.
#
+ # @option params [Hash] :tags
+ # The tags you want to attach to the custom plugin.
+ #
# @return [Types::CreateCustomPluginResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::CreateCustomPluginResponse#custom_plugin_arn #custom_plugin_arn} => String
@@ -561,6 +576,9 @@ def create_connector(params = {}, options = {})
# },
# },
# name: "__stringMin1Max128", # required
+ # tags: {
+ # "TagKey" => "TagValue",
+ # },
# })
#
# @example Response structure
@@ -590,12 +608,16 @@ def create_custom_plugin(params = {}, options = {})
# @option params [required, String] :properties_file_content
# Base64 encoded contents of connect-distributed.properties file.
#
+ # @option params [Hash] :tags
+ # The tags you want to attach to the worker configuration.
+ #
# @return [Types::CreateWorkerConfigurationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::CreateWorkerConfigurationResponse#creation_time #creation_time} => Time
# * {Types::CreateWorkerConfigurationResponse#latest_revision #latest_revision} => Types::WorkerConfigurationRevisionSummary
# * {Types::CreateWorkerConfigurationResponse#name #name} => String
# * {Types::CreateWorkerConfigurationResponse#worker_configuration_arn #worker_configuration_arn} => String
+ # * {Types::CreateWorkerConfigurationResponse#worker_configuration_state #worker_configuration_state} => String
#
# @example Request syntax with placeholder values
#
@@ -603,6 +625,9 @@ def create_custom_plugin(params = {}, options = {})
# description: "__stringMax1024",
# name: "__stringMin1Max128", # required
# properties_file_content: "__sensitiveString", # required
+ # tags: {
+ # "TagKey" => "TagValue",
+ # },
# })
#
# @example Response structure
@@ -613,6 +638,7 @@ def create_custom_plugin(params = {}, options = {})
# resp.latest_revision.revision #=> Integer
# resp.name #=> String
# resp.worker_configuration_arn #=> String
+ # resp.worker_configuration_state #=> String, one of "ACTIVE", "DELETING"
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateWorkerConfiguration AWS API Documentation
#
@@ -689,6 +715,37 @@ def delete_custom_plugin(params = {}, options = {})
req.send_request(options)
end
+ # Deletes the specified worker configuration.
+ #
+ # @option params [required, String] :worker_configuration_arn
+ # The Amazon Resource Name (ARN) of the worker configuration that you
+ # want to delete.
+ #
+ # @return [Types::DeleteWorkerConfigurationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::DeleteWorkerConfigurationResponse#worker_configuration_arn #worker_configuration_arn} => String
+ # * {Types::DeleteWorkerConfigurationResponse#worker_configuration_state #worker_configuration_state} => String
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.delete_worker_configuration({
+ # worker_configuration_arn: "__string", # required
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.worker_configuration_arn #=> String
+ # resp.worker_configuration_state #=> String, one of "ACTIVE", "DELETING"
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration AWS API Documentation
+ #
+ # @overload delete_worker_configuration(params = {})
+ # @param [Hash] params ({})
+ def delete_worker_configuration(params = {}, options = {})
+ req = build_request(:delete_worker_configuration, params)
+ req.send_request(options)
+ end
+
# Returns summary information about the connector.
#
# @option params [required, String] :connector_arn
@@ -833,6 +890,7 @@ def describe_custom_plugin(params = {}, options = {})
# * {Types::DescribeWorkerConfigurationResponse#latest_revision #latest_revision} => Types::WorkerConfigurationRevisionDescription
# * {Types::DescribeWorkerConfigurationResponse#name #name} => String
# * {Types::DescribeWorkerConfigurationResponse#worker_configuration_arn #worker_configuration_arn} => String
+ # * {Types::DescribeWorkerConfigurationResponse#worker_configuration_state #worker_configuration_state} => String
#
# @example Request syntax with placeholder values
#
@@ -850,6 +908,7 @@ def describe_custom_plugin(params = {}, options = {})
# resp.latest_revision.revision #=> Integer
# resp.name #=> String
# resp.worker_configuration_arn #=> String
+ # resp.worker_configuration_state #=> String, one of "ACTIVE", "DELETING"
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeWorkerConfiguration AWS API Documentation
#
@@ -946,6 +1005,9 @@ def list_connectors(params = {}, options = {})
# @option params [Integer] :max_results
# The maximum number of custom plugins to list in one response.
#
+ # @option params [String] :name_prefix
+ # Lists custom plugin names that start with the specified text string.
+ #
# @option params [String] :next_token
# If the response of a ListCustomPlugins operation is truncated, it will
# include a NextToken. Send this NextToken in a subsequent request to
@@ -962,6 +1024,7 @@ def list_connectors(params = {}, options = {})
#
# resp = client.list_custom_plugins({
# max_results: 1,
+ # name_prefix: "__string",
# next_token: "__string",
# })
#
@@ -993,12 +1056,46 @@ def list_custom_plugins(params = {}, options = {})
req.send_request(options)
end
+ # Lists all the tags attached to the specified resource.
+ #
+ # @option params [required, String] :resource_arn
+ # The Amazon Resource Name (ARN) of the resource for which you want to
+ # list all attached tags.
+ #
+ # @return [Types::ListTagsForResourceResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::ListTagsForResourceResponse#tags #tags} => Hash<String,String>
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.list_tags_for_resource({
+ # resource_arn: "__string", # required
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.tags #=> Hash
+ # resp.tags["TagKey"] #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource AWS API Documentation
+ #
+ # @overload list_tags_for_resource(params = {})
+ # @param [Hash] params ({})
+ def list_tags_for_resource(params = {}, options = {})
+ req = build_request(:list_tags_for_resource, params)
+ req.send_request(options)
+ end
+
# Returns a list of all of the worker configurations in this account and
# Region.
#
# @option params [Integer] :max_results
# The maximum number of worker configurations to list in one response.
#
+ # @option params [String] :name_prefix
+ # Lists worker configuration names that start with the specified text
+ # string.
+ #
# @option params [String] :next_token
# If the response of a ListWorkerConfigurations operation is truncated,
# it will include a NextToken. Send this NextToken in a subsequent
@@ -1016,6 +1113,7 @@ def list_custom_plugins(params = {}, options = {})
#
# resp = client.list_worker_configurations({
# max_results: 1,
+ # name_prefix: "__string",
# next_token: "__string",
# })
#
@@ -1030,6 +1128,7 @@ def list_custom_plugins(params = {}, options = {})
# resp.worker_configurations[0].latest_revision.revision #=> Integer
# resp.worker_configurations[0].name #=> String
# resp.worker_configurations[0].worker_configuration_arn #=> String
+ # resp.worker_configurations[0].worker_configuration_state #=> String, one of "ACTIVE", "DELETING"
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListWorkerConfigurations AWS API Documentation
#
@@ -1040,6 +1139,62 @@ def list_worker_configurations(params = {}, options = {})
req.send_request(options)
end
+ # Attaches tags to the specified resource.
+ #
+ # @option params [required, String] :resource_arn
+ # The Amazon Resource Name (ARN) of the resource to which you want to
+ # attach tags.
+ #
+ # @option params [required, Hash] :tags
+ # The tags that you want to attach to the resource.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.tag_resource({
+ # resource_arn: "__string", # required
+ # tags: { # required
+ # "TagKey" => "TagValue",
+ # },
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource AWS API Documentation
+ #
+ # @overload tag_resource(params = {})
+ # @param [Hash] params ({})
+ def tag_resource(params = {}, options = {})
+ req = build_request(:tag_resource, params)
+ req.send_request(options)
+ end
+
+ # Removes tags from the specified resource.
+ #
+ # @option params [required, String] :resource_arn
+ # The Amazon Resource Name (ARN) of the resource from which you want to
+ # remove tags.
+ #
+ # @option params [required, Array] :tag_keys
+ # The keys of the tags that you want to remove from the resource.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.untag_resource({
+ # resource_arn: "__string", # required
+ # tag_keys: ["TagKey"], # required
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource AWS API Documentation
+ #
+ # @overload untag_resource(params = {})
+ # @param [Hash] params ({})
+ def untag_resource(params = {}, options = {})
+ req = build_request(:untag_resource, params)
+ req.send_request(options)
+ end
+
# Updates the specified connector.
#
# @option params [required, Types::CapacityUpdate] :capacity
@@ -1108,7 +1263,7 @@ def build_request(operation_name, params = {})
params: params,
config: config)
context[:gem_name] = 'aws-sdk-kafkaconnect'
- context[:gem_version] = '1.19.0'
+ context[:gem_version] = '1.20.0'
Seahorse::Client::Request.new(handlers, context)
end
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client_api.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client_api.rb
index 4d40ea63f0e..52dbd28a880 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client_api.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/client_api.rb
@@ -46,6 +46,8 @@ module ClientApi
DeleteConnectorResponse = Shapes::StructureShape.new(name: 'DeleteConnectorResponse')
DeleteCustomPluginRequest = Shapes::StructureShape.new(name: 'DeleteCustomPluginRequest')
DeleteCustomPluginResponse = Shapes::StructureShape.new(name: 'DeleteCustomPluginResponse')
+ DeleteWorkerConfigurationRequest = Shapes::StructureShape.new(name: 'DeleteWorkerConfigurationRequest')
+ DeleteWorkerConfigurationResponse = Shapes::StructureShape.new(name: 'DeleteWorkerConfigurationResponse')
DescribeConnectorRequest = Shapes::StructureShape.new(name: 'DescribeConnectorRequest')
DescribeConnectorResponse = Shapes::StructureShape.new(name: 'DescribeConnectorResponse')
DescribeCustomPluginRequest = Shapes::StructureShape.new(name: 'DescribeCustomPluginRequest')
@@ -68,6 +70,8 @@ module ClientApi
ListConnectorsResponse = Shapes::StructureShape.new(name: 'ListConnectorsResponse')
ListCustomPluginsRequest = Shapes::StructureShape.new(name: 'ListCustomPluginsRequest')
ListCustomPluginsResponse = Shapes::StructureShape.new(name: 'ListCustomPluginsResponse')
+ ListTagsForResourceRequest = Shapes::StructureShape.new(name: 'ListTagsForResourceRequest')
+ ListTagsForResourceResponse = Shapes::StructureShape.new(name: 'ListTagsForResourceResponse')
ListWorkerConfigurationsRequest = Shapes::StructureShape.new(name: 'ListWorkerConfigurationsRequest')
ListWorkerConfigurationsResponse = Shapes::StructureShape.new(name: 'ListWorkerConfigurationsResponse')
LogDelivery = Shapes::StructureShape.new(name: 'LogDelivery')
@@ -91,8 +95,16 @@ module ClientApi
ScaleOutPolicyUpdate = Shapes::StructureShape.new(name: 'ScaleOutPolicyUpdate')
ServiceUnavailableException = Shapes::StructureShape.new(name: 'ServiceUnavailableException')
StateDescription = Shapes::StructureShape.new(name: 'StateDescription')
+ TagKey = Shapes::StringShape.new(name: 'TagKey')
+ TagKeyList = Shapes::ListShape.new(name: 'TagKeyList')
+ TagResourceRequest = Shapes::StructureShape.new(name: 'TagResourceRequest')
+ TagResourceResponse = Shapes::StructureShape.new(name: 'TagResourceResponse')
+ TagValue = Shapes::StringShape.new(name: 'TagValue')
+ Tags = Shapes::MapShape.new(name: 'Tags')
TooManyRequestsException = Shapes::StructureShape.new(name: 'TooManyRequestsException')
UnauthorizedException = Shapes::StructureShape.new(name: 'UnauthorizedException')
+ UntagResourceRequest = Shapes::StructureShape.new(name: 'UntagResourceRequest')
+ UntagResourceResponse = Shapes::StructureShape.new(name: 'UntagResourceResponse')
UpdateConnectorRequest = Shapes::StructureShape.new(name: 'UpdateConnectorRequest')
UpdateConnectorResponse = Shapes::StructureShape.new(name: 'UpdateConnectorResponse')
Vpc = Shapes::StructureShape.new(name: 'Vpc')
@@ -101,6 +113,7 @@ module ClientApi
WorkerConfigurationDescription = Shapes::StructureShape.new(name: 'WorkerConfigurationDescription')
WorkerConfigurationRevisionDescription = Shapes::StructureShape.new(name: 'WorkerConfigurationRevisionDescription')
WorkerConfigurationRevisionSummary = Shapes::StructureShape.new(name: 'WorkerConfigurationRevisionSummary')
+ WorkerConfigurationState = Shapes::StringShape.new(name: 'WorkerConfigurationState')
WorkerConfigurationSummary = Shapes::StructureShape.new(name: 'WorkerConfigurationSummary')
WorkerLogDelivery = Shapes::StructureShape.new(name: 'WorkerLogDelivery')
WorkerLogDeliveryDescription = Shapes::StructureShape.new(name: 'WorkerLogDeliveryDescription')
@@ -207,6 +220,7 @@ module ClientApi
CreateConnectorRequest.add_member(:log_delivery, Shapes::ShapeRef.new(shape: LogDelivery, location_name: "logDelivery"))
CreateConnectorRequest.add_member(:plugins, Shapes::ShapeRef.new(shape: __listOfPlugin, required: true, location_name: "plugins"))
CreateConnectorRequest.add_member(:service_execution_role_arn, Shapes::ShapeRef.new(shape: __string, required: true, location_name: "serviceExecutionRoleArn"))
+ CreateConnectorRequest.add_member(:tags, Shapes::ShapeRef.new(shape: Tags, location_name: "tags"))
CreateConnectorRequest.add_member(:worker_configuration, Shapes::ShapeRef.new(shape: WorkerConfiguration, location_name: "workerConfiguration"))
CreateConnectorRequest.struct_class = Types::CreateConnectorRequest
@@ -219,6 +233,7 @@ module ClientApi
CreateCustomPluginRequest.add_member(:description, Shapes::ShapeRef.new(shape: __stringMax1024, location_name: "description"))
CreateCustomPluginRequest.add_member(:location, Shapes::ShapeRef.new(shape: CustomPluginLocation, required: true, location_name: "location"))
CreateCustomPluginRequest.add_member(:name, Shapes::ShapeRef.new(shape: __stringMin1Max128, required: true, location_name: "name"))
+ CreateCustomPluginRequest.add_member(:tags, Shapes::ShapeRef.new(shape: Tags, location_name: "tags"))
CreateCustomPluginRequest.struct_class = Types::CreateCustomPluginRequest
CreateCustomPluginResponse.add_member(:custom_plugin_arn, Shapes::ShapeRef.new(shape: __string, location_name: "customPluginArn"))
@@ -230,12 +245,14 @@ module ClientApi
CreateWorkerConfigurationRequest.add_member(:description, Shapes::ShapeRef.new(shape: __stringMax1024, location_name: "description"))
CreateWorkerConfigurationRequest.add_member(:name, Shapes::ShapeRef.new(shape: __stringMin1Max128, required: true, location_name: "name"))
CreateWorkerConfigurationRequest.add_member(:properties_file_content, Shapes::ShapeRef.new(shape: __sensitiveString, required: true, location_name: "propertiesFileContent"))
+ CreateWorkerConfigurationRequest.add_member(:tags, Shapes::ShapeRef.new(shape: Tags, location_name: "tags"))
CreateWorkerConfigurationRequest.struct_class = Types::CreateWorkerConfigurationRequest
CreateWorkerConfigurationResponse.add_member(:creation_time, Shapes::ShapeRef.new(shape: __timestampIso8601, location_name: "creationTime"))
CreateWorkerConfigurationResponse.add_member(:latest_revision, Shapes::ShapeRef.new(shape: WorkerConfigurationRevisionSummary, location_name: "latestRevision"))
CreateWorkerConfigurationResponse.add_member(:name, Shapes::ShapeRef.new(shape: __string, location_name: "name"))
CreateWorkerConfigurationResponse.add_member(:worker_configuration_arn, Shapes::ShapeRef.new(shape: __string, location_name: "workerConfigurationArn"))
+ CreateWorkerConfigurationResponse.add_member(:worker_configuration_state, Shapes::ShapeRef.new(shape: WorkerConfigurationState, location_name: "workerConfigurationState"))
CreateWorkerConfigurationResponse.struct_class = Types::CreateWorkerConfigurationResponse
CustomPlugin.add_member(:custom_plugin_arn, Shapes::ShapeRef.new(shape: __string, required: true, location_name: "customPluginArn"))
@@ -287,6 +304,13 @@ module ClientApi
DeleteCustomPluginResponse.add_member(:custom_plugin_state, Shapes::ShapeRef.new(shape: CustomPluginState, location_name: "customPluginState"))
DeleteCustomPluginResponse.struct_class = Types::DeleteCustomPluginResponse
+ DeleteWorkerConfigurationRequest.add_member(:worker_configuration_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "workerConfigurationArn"))
+ DeleteWorkerConfigurationRequest.struct_class = Types::DeleteWorkerConfigurationRequest
+
+ DeleteWorkerConfigurationResponse.add_member(:worker_configuration_arn, Shapes::ShapeRef.new(shape: __string, location_name: "workerConfigurationArn"))
+ DeleteWorkerConfigurationResponse.add_member(:worker_configuration_state, Shapes::ShapeRef.new(shape: WorkerConfigurationState, location_name: "workerConfigurationState"))
+ DeleteWorkerConfigurationResponse.struct_class = Types::DeleteWorkerConfigurationResponse
+
DescribeConnectorRequest.add_member(:connector_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "connectorArn"))
DescribeConnectorRequest.struct_class = Types::DescribeConnectorRequest
@@ -329,6 +353,7 @@ module ClientApi
DescribeWorkerConfigurationResponse.add_member(:latest_revision, Shapes::ShapeRef.new(shape: WorkerConfigurationRevisionDescription, location_name: "latestRevision"))
DescribeWorkerConfigurationResponse.add_member(:name, Shapes::ShapeRef.new(shape: __string, location_name: "name"))
DescribeWorkerConfigurationResponse.add_member(:worker_configuration_arn, Shapes::ShapeRef.new(shape: __string, location_name: "workerConfigurationArn"))
+ DescribeWorkerConfigurationResponse.add_member(:worker_configuration_state, Shapes::ShapeRef.new(shape: WorkerConfigurationState, location_name: "workerConfigurationState"))
DescribeWorkerConfigurationResponse.struct_class = Types::DescribeWorkerConfigurationResponse
FirehoseLogDelivery.add_member(:delivery_stream, Shapes::ShapeRef.new(shape: __string, location_name: "deliveryStream"))
@@ -373,6 +398,7 @@ module ClientApi
ListConnectorsResponse.struct_class = Types::ListConnectorsResponse
ListCustomPluginsRequest.add_member(:max_results, Shapes::ShapeRef.new(shape: MaxResults, location: "querystring", location_name: "maxResults"))
+ ListCustomPluginsRequest.add_member(:name_prefix, Shapes::ShapeRef.new(shape: __string, location: "querystring", location_name: "namePrefix"))
ListCustomPluginsRequest.add_member(:next_token, Shapes::ShapeRef.new(shape: __string, location: "querystring", location_name: "nextToken"))
ListCustomPluginsRequest.struct_class = Types::ListCustomPluginsRequest
@@ -380,7 +406,14 @@ module ClientApi
ListCustomPluginsResponse.add_member(:next_token, Shapes::ShapeRef.new(shape: __string, location_name: "nextToken"))
ListCustomPluginsResponse.struct_class = Types::ListCustomPluginsResponse
+ ListTagsForResourceRequest.add_member(:resource_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "resourceArn"))
+ ListTagsForResourceRequest.struct_class = Types::ListTagsForResourceRequest
+
+ ListTagsForResourceResponse.add_member(:tags, Shapes::ShapeRef.new(shape: Tags, location_name: "tags"))
+ ListTagsForResourceResponse.struct_class = Types::ListTagsForResourceResponse
+
ListWorkerConfigurationsRequest.add_member(:max_results, Shapes::ShapeRef.new(shape: MaxResults, location: "querystring", location_name: "maxResults"))
+ ListWorkerConfigurationsRequest.add_member(:name_prefix, Shapes::ShapeRef.new(shape: __string, location: "querystring", location_name: "namePrefix"))
ListWorkerConfigurationsRequest.add_member(:next_token, Shapes::ShapeRef.new(shape: __string, location: "querystring", location_name: "nextToken"))
ListWorkerConfigurationsRequest.struct_class = Types::ListWorkerConfigurationsRequest
@@ -460,12 +493,29 @@ module ClientApi
StateDescription.add_member(:message, Shapes::ShapeRef.new(shape: __string, location_name: "message"))
StateDescription.struct_class = Types::StateDescription
+ TagKeyList.member = Shapes::ShapeRef.new(shape: TagKey)
+
+ TagResourceRequest.add_member(:resource_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "resourceArn"))
+ TagResourceRequest.add_member(:tags, Shapes::ShapeRef.new(shape: Tags, required: true, location_name: "tags"))
+ TagResourceRequest.struct_class = Types::TagResourceRequest
+
+ TagResourceResponse.struct_class = Types::TagResourceResponse
+
+ Tags.key = Shapes::ShapeRef.new(shape: TagKey)
+ Tags.value = Shapes::ShapeRef.new(shape: TagValue)
+
TooManyRequestsException.add_member(:message, Shapes::ShapeRef.new(shape: __string, location_name: "message"))
TooManyRequestsException.struct_class = Types::TooManyRequestsException
UnauthorizedException.add_member(:message, Shapes::ShapeRef.new(shape: __string, location_name: "message"))
UnauthorizedException.struct_class = Types::UnauthorizedException
+ UntagResourceRequest.add_member(:resource_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "resourceArn"))
+ UntagResourceRequest.add_member(:tag_keys, Shapes::ShapeRef.new(shape: TagKeyList, required: true, location: "querystring", location_name: "tagKeys"))
+ UntagResourceRequest.struct_class = Types::UntagResourceRequest
+
+ UntagResourceResponse.struct_class = Types::UntagResourceResponse
+
UpdateConnectorRequest.add_member(:capacity, Shapes::ShapeRef.new(shape: CapacityUpdate, required: true, location_name: "capacity"))
UpdateConnectorRequest.add_member(:connector_arn, Shapes::ShapeRef.new(shape: __string, required: true, location: "uri", location_name: "connectorArn"))
UpdateConnectorRequest.add_member(:current_version, Shapes::ShapeRef.new(shape: __string, required: true, location: "querystring", location_name: "currentVersion"))
@@ -507,6 +557,7 @@ module ClientApi
WorkerConfigurationSummary.add_member(:latest_revision, Shapes::ShapeRef.new(shape: WorkerConfigurationRevisionSummary, location_name: "latestRevision"))
WorkerConfigurationSummary.add_member(:name, Shapes::ShapeRef.new(shape: __string, location_name: "name"))
WorkerConfigurationSummary.add_member(:worker_configuration_arn, Shapes::ShapeRef.new(shape: __string, location_name: "workerConfigurationArn"))
+ WorkerConfigurationSummary.add_member(:worker_configuration_state, Shapes::ShapeRef.new(shape: WorkerConfigurationState, location_name: "workerConfigurationState"))
WorkerConfigurationSummary.struct_class = Types::WorkerConfigurationSummary
WorkerLogDelivery.add_member(:cloud_watch_logs, Shapes::ShapeRef.new(shape: CloudWatchLogsLogDelivery, location_name: "cloudWatchLogs"))
@@ -631,6 +682,21 @@ module ClientApi
o.errors << Shapes::ShapeRef.new(shape: InternalServerErrorException)
end)
+ api.add_operation(:delete_worker_configuration, Seahorse::Model::Operation.new.tap do |o|
+ o.name = "DeleteWorkerConfiguration"
+ o.http_method = "DELETE"
+ o.http_request_uri = "/v1/worker-configurations/{workerConfigurationArn}"
+ o.input = Shapes::ShapeRef.new(shape: DeleteWorkerConfigurationRequest)
+ o.output = Shapes::ShapeRef.new(shape: DeleteWorkerConfigurationResponse)
+ o.errors << Shapes::ShapeRef.new(shape: NotFoundException)
+ o.errors << Shapes::ShapeRef.new(shape: BadRequestException)
+ o.errors << Shapes::ShapeRef.new(shape: ForbiddenException)
+ o.errors << Shapes::ShapeRef.new(shape: ServiceUnavailableException)
+ o.errors << Shapes::ShapeRef.new(shape: TooManyRequestsException)
+ o.errors << Shapes::ShapeRef.new(shape: UnauthorizedException)
+ o.errors << Shapes::ShapeRef.new(shape: InternalServerErrorException)
+ end)
+
api.add_operation(:describe_connector, Seahorse::Model::Operation.new.tap do |o|
o.name = "DescribeConnector"
o.http_method = "GET"
@@ -718,6 +784,21 @@ module ClientApi
)
end)
+ api.add_operation(:list_tags_for_resource, Seahorse::Model::Operation.new.tap do |o|
+ o.name = "ListTagsForResource"
+ o.http_method = "GET"
+ o.http_request_uri = "/v1/tags/{resourceArn}"
+ o.input = Shapes::ShapeRef.new(shape: ListTagsForResourceRequest)
+ o.output = Shapes::ShapeRef.new(shape: ListTagsForResourceResponse)
+ o.errors << Shapes::ShapeRef.new(shape: NotFoundException)
+ o.errors << Shapes::ShapeRef.new(shape: BadRequestException)
+ o.errors << Shapes::ShapeRef.new(shape: ForbiddenException)
+ o.errors << Shapes::ShapeRef.new(shape: ServiceUnavailableException)
+ o.errors << Shapes::ShapeRef.new(shape: TooManyRequestsException)
+ o.errors << Shapes::ShapeRef.new(shape: UnauthorizedException)
+ o.errors << Shapes::ShapeRef.new(shape: InternalServerErrorException)
+ end)
+
api.add_operation(:list_worker_configurations, Seahorse::Model::Operation.new.tap do |o|
o.name = "ListWorkerConfigurations"
o.http_method = "GET"
@@ -739,6 +820,37 @@ module ClientApi
)
end)
+ api.add_operation(:tag_resource, Seahorse::Model::Operation.new.tap do |o|
+ o.name = "TagResource"
+ o.http_method = "POST"
+ o.http_request_uri = "/v1/tags/{resourceArn}"
+ o.input = Shapes::ShapeRef.new(shape: TagResourceRequest)
+ o.output = Shapes::ShapeRef.new(shape: TagResourceResponse)
+ o.errors << Shapes::ShapeRef.new(shape: NotFoundException)
+ o.errors << Shapes::ShapeRef.new(shape: ConflictException)
+ o.errors << Shapes::ShapeRef.new(shape: BadRequestException)
+ o.errors << Shapes::ShapeRef.new(shape: ForbiddenException)
+ o.errors << Shapes::ShapeRef.new(shape: ServiceUnavailableException)
+ o.errors << Shapes::ShapeRef.new(shape: TooManyRequestsException)
+ o.errors << Shapes::ShapeRef.new(shape: UnauthorizedException)
+ o.errors << Shapes::ShapeRef.new(shape: InternalServerErrorException)
+ end)
+
+ api.add_operation(:untag_resource, Seahorse::Model::Operation.new.tap do |o|
+ o.name = "UntagResource"
+ o.http_method = "DELETE"
+ o.http_request_uri = "/v1/tags/{resourceArn}"
+ o.input = Shapes::ShapeRef.new(shape: UntagResourceRequest)
+ o.output = Shapes::ShapeRef.new(shape: UntagResourceResponse)
+ o.errors << Shapes::ShapeRef.new(shape: NotFoundException)
+ o.errors << Shapes::ShapeRef.new(shape: BadRequestException)
+ o.errors << Shapes::ShapeRef.new(shape: ForbiddenException)
+ o.errors << Shapes::ShapeRef.new(shape: ServiceUnavailableException)
+ o.errors << Shapes::ShapeRef.new(shape: TooManyRequestsException)
+ o.errors << Shapes::ShapeRef.new(shape: UnauthorizedException)
+ o.errors << Shapes::ShapeRef.new(shape: InternalServerErrorException)
+ end)
+
api.add_operation(:update_connector, Seahorse::Model::Operation.new.tap do |o|
o.name = "UpdateConnector"
o.http_method = "PUT"
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoint_provider.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoint_provider.rb
index 9a60bc1ee6b..9e977eabf5f 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoint_provider.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoint_provider.rb
@@ -32,7 +32,7 @@ def resolve_endpoint(parameters)
raise ArgumentError, "FIPS and DualStack are enabled, but this partition does not support one or both"
end
if Aws::Endpoints::Matchers.boolean_equals?(use_fips, true)
- if Aws::Endpoints::Matchers.boolean_equals?(true, Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"))
+ if Aws::Endpoints::Matchers.boolean_equals?(Aws::Endpoints::Matchers.attr(partition_result, "supportsFIPS"), true)
return Aws::Endpoints::Endpoint.new(url: "https://kafkaconnect-fips.#{region}.#{partition_result['dnsSuffix']}", headers: {}, properties: {})
end
raise ArgumentError, "FIPS is enabled but this partition does not support FIPS"
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoints.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoints.rb
index 21d9a3eb514..379755092ed 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoints.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/endpoints.rb
@@ -82,6 +82,20 @@ def self.build(context)
end
end
+ class DeleteWorkerConfiguration
+ def self.build(context)
+ unless context.config.regional_endpoint
+ endpoint = context.config.endpoint.to_s
+ end
+ Aws::KafkaConnect::EndpointParameters.new(
+ region: context.config.region,
+ use_dual_stack: context.config.use_dualstack_endpoint,
+ use_fips: context.config.use_fips_endpoint,
+ endpoint: endpoint,
+ )
+ end
+ end
+
class DescribeConnector
def self.build(context)
unless context.config.regional_endpoint
@@ -152,6 +166,20 @@ def self.build(context)
end
end
+ class ListTagsForResource
+ def self.build(context)
+ unless context.config.regional_endpoint
+ endpoint = context.config.endpoint.to_s
+ end
+ Aws::KafkaConnect::EndpointParameters.new(
+ region: context.config.region,
+ use_dual_stack: context.config.use_dualstack_endpoint,
+ use_fips: context.config.use_fips_endpoint,
+ endpoint: endpoint,
+ )
+ end
+ end
+
class ListWorkerConfigurations
def self.build(context)
unless context.config.regional_endpoint
@@ -166,6 +194,34 @@ def self.build(context)
end
end
+ class TagResource
+ def self.build(context)
+ unless context.config.regional_endpoint
+ endpoint = context.config.endpoint.to_s
+ end
+ Aws::KafkaConnect::EndpointParameters.new(
+ region: context.config.region,
+ use_dual_stack: context.config.use_dualstack_endpoint,
+ use_fips: context.config.use_fips_endpoint,
+ endpoint: endpoint,
+ )
+ end
+ end
+
+ class UntagResource
+ def self.build(context)
+ unless context.config.regional_endpoint
+ endpoint = context.config.endpoint.to_s
+ end
+ Aws::KafkaConnect::EndpointParameters.new(
+ region: context.config.region,
+ use_dual_stack: context.config.use_dualstack_endpoint,
+ use_fips: context.config.use_fips_endpoint,
+ endpoint: endpoint,
+ )
+ end
+ end
+
class UpdateConnector
def self.build(context)
unless context.config.regional_endpoint
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/plugins/endpoints.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/plugins/endpoints.rb
index 0f2e7c303b9..210e6d1dafd 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/plugins/endpoints.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/plugins/endpoints.rb
@@ -68,6 +68,8 @@ def parameters_for_operation(context)
Aws::KafkaConnect::Endpoints::DeleteConnector.build(context)
when :delete_custom_plugin
Aws::KafkaConnect::Endpoints::DeleteCustomPlugin.build(context)
+ when :delete_worker_configuration
+ Aws::KafkaConnect::Endpoints::DeleteWorkerConfiguration.build(context)
when :describe_connector
Aws::KafkaConnect::Endpoints::DescribeConnector.build(context)
when :describe_custom_plugin
@@ -78,8 +80,14 @@ def parameters_for_operation(context)
Aws::KafkaConnect::Endpoints::ListConnectors.build(context)
when :list_custom_plugins
Aws::KafkaConnect::Endpoints::ListCustomPlugins.build(context)
+ when :list_tags_for_resource
+ Aws::KafkaConnect::Endpoints::ListTagsForResource.build(context)
when :list_worker_configurations
Aws::KafkaConnect::Endpoints::ListWorkerConfigurations.build(context)
+ when :tag_resource
+ Aws::KafkaConnect::Endpoints::TagResource.build(context)
+ when :untag_resource
+ Aws::KafkaConnect::Endpoints::UntagResource.build(context)
when :update_connector
Aws::KafkaConnect::Endpoints::UpdateConnector.build(context)
end
diff --git a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/types.rb b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/types.rb
index 885b3b3a014..ead2b79b46c 100644
--- a/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/types.rb
+++ b/gems/aws-sdk-kafkaconnect/lib/aws-sdk-kafkaconnect/types.rb
@@ -415,7 +415,13 @@ class ConnectorSummary < Struct.new(
# @return [Types::LogDelivery]
#
# @!attribute [rw] plugins
- # 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.
# @return [Array]
#
# @!attribute [rw] service_execution_role_arn
@@ -426,6 +432,10 @@ class ConnectorSummary < Struct.new(
# that allow it to write to the S3 destination bucket.
# @return [String]
#
+ # @!attribute [rw] tags
+ # The tags you want to attach to the connector.
+ # @return [Hash]
+ #
# @!attribute [rw] worker_configuration
# Specifies which worker configuration to use with the connector.
# @return [Types::WorkerConfiguration]
@@ -444,6 +454,7 @@ class CreateConnectorRequest < Struct.new(
:log_delivery,
:plugins,
:service_execution_role_arn,
+ :tags,
:worker_configuration)
SENSITIVE = [:connector_configuration]
include Aws::Structure
@@ -488,13 +499,18 @@ class CreateConnectorResponse < Struct.new(
# The name of the custom plugin.
# @return [String]
#
+ # @!attribute [rw] tags
+ # The tags you want to attach to the custom plugin.
+ # @return [Hash]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateCustomPluginRequest AWS API Documentation
#
class CreateCustomPluginRequest < Struct.new(
:content_type,
:description,
:location,
- :name)
+ :name,
+ :tags)
SENSITIVE = []
include Aws::Structure
end
@@ -539,12 +555,17 @@ class CreateCustomPluginResponse < Struct.new(
# Base64 encoded contents of connect-distributed.properties file.
# @return [String]
#
+ # @!attribute [rw] tags
+ # The tags you want to attach to the worker configuration.
+ # @return [Hash]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateWorkerConfigurationRequest AWS API Documentation
#
class CreateWorkerConfigurationRequest < Struct.new(
:description,
:name,
- :properties_file_content)
+ :properties_file_content,
+ :tags)
SENSITIVE = [:properties_file_content]
include Aws::Structure
end
@@ -566,19 +587,24 @@ class CreateWorkerConfigurationRequest < Struct.new(
# configuration.
# @return [String]
#
+ # @!attribute [rw] worker_configuration_state
+ # The state of the worker configuration.
+ # @return [String]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateWorkerConfigurationResponse AWS API Documentation
#
class CreateWorkerConfigurationResponse < Struct.new(
:creation_time,
:latest_revision,
:name,
- :worker_configuration_arn)
+ :worker_configuration_arn,
+ :worker_configuration_state)
SENSITIVE = []
include Aws::Structure
end
- # A plugin is an AWS resource that contains the code that defines a
- # connector's logic.
+ # A plugin is an Amazon Web Services resource that contains the code
+ # that defines a connector's logic.
#
# @!attribute [rw] custom_plugin_arn
# The Amazon Resource Name (ARN) of the custom plugin.
@@ -812,6 +838,37 @@ class DeleteCustomPluginResponse < Struct.new(
include Aws::Structure
end
+ # @!attribute [rw] worker_configuration_arn
+ # The Amazon Resource Name (ARN) of the worker configuration that you
+ # want to delete.
+ # @return [String]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfigurationRequest AWS API Documentation
+ #
+ class DeleteWorkerConfigurationRequest < Struct.new(
+ :worker_configuration_arn)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
+ # @!attribute [rw] worker_configuration_arn
+ # The Amazon Resource Name (ARN) of the worker configuration that you
+ # requested to delete.
+ # @return [String]
+ #
+ # @!attribute [rw] worker_configuration_state
+ # The state of the worker configuration.
+ # @return [String]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfigurationResponse AWS API Documentation
+ #
+ class DeleteWorkerConfigurationResponse < Struct.new(
+ :worker_configuration_arn,
+ :worker_configuration_state)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
# @!attribute [rw] connector_arn
# The Amazon Resource Name (ARN) of the connector that you want to
# describe.
@@ -1012,6 +1069,10 @@ class DescribeWorkerConfigurationRequest < Struct.new(
# The Amazon Resource Name (ARN) of the custom configuration.
# @return [String]
#
+ # @!attribute [rw] worker_configuration_state
+ # The state of the worker configuration.
+ # @return [String]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeWorkerConfigurationResponse AWS API Documentation
#
class DescribeWorkerConfigurationResponse < Struct.new(
@@ -1019,7 +1080,8 @@ class DescribeWorkerConfigurationResponse < Struct.new(
:description,
:latest_revision,
:name,
- :worker_configuration_arn)
+ :worker_configuration_arn,
+ :worker_configuration_state)
SENSITIVE = []
include Aws::Structure
end
@@ -1235,6 +1297,10 @@ class ListConnectorsResponse < Struct.new(
# The maximum number of custom plugins to list in one response.
# @return [Integer]
#
+ # @!attribute [rw] name_prefix
+ # Lists custom plugin names that start with the specified text string.
+ # @return [String]
+ #
# @!attribute [rw] next_token
# If the response of a ListCustomPlugins operation is truncated, it
# will include a NextToken. Send this NextToken in a subsequent
@@ -1246,6 +1312,7 @@ class ListConnectorsResponse < Struct.new(
#
class ListCustomPluginsRequest < Struct.new(
:max_results,
+ :name_prefix,
:next_token)
SENSITIVE = []
include Aws::Structure
@@ -1271,10 +1338,41 @@ class ListCustomPluginsResponse < Struct.new(
include Aws::Structure
end
+ # @!attribute [rw] resource_arn
+ # The Amazon Resource Name (ARN) of the resource for which you want to
+ # list all attached tags.
+ # @return [String]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResourceRequest AWS API Documentation
+ #
+ class ListTagsForResourceRequest < Struct.new(
+ :resource_arn)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
+ # @!attribute [rw] tags
+ # Lists the tags attached to the specified resource in the
+ # corresponding request.
+ # @return [Hash]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResourceResponse AWS API Documentation
+ #
+ class ListTagsForResourceResponse < Struct.new(
+ :tags)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
# @!attribute [rw] max_results
# The maximum number of worker configurations to list in one response.
# @return [Integer]
#
+ # @!attribute [rw] name_prefix
+ # Lists worker configuration names that start with the specified text
+ # string.
+ # @return [String]
+ #
# @!attribute [rw] next_token
# If the response of a ListWorkerConfigurations operation is
# truncated, it will include a NextToken. Send this NextToken in a
@@ -1286,6 +1384,7 @@ class ListCustomPluginsResponse < Struct.new(
#
class ListWorkerConfigurationsRequest < Struct.new(
:max_results,
+ :name_prefix,
:next_token)
SENSITIVE = []
include Aws::Structure
@@ -1355,8 +1454,8 @@ class NotFoundException < Struct.new(
include Aws::Structure
end
- # 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.
#
# @!attribute [rw] custom_plugin
# Details about a custom plugin.
@@ -1665,6 +1764,28 @@ class StateDescription < Struct.new(
include Aws::Structure
end
+ # @!attribute [rw] resource_arn
+ # The Amazon Resource Name (ARN) of the resource to which you want to
+ # attach tags.
+ # @return [String]
+ #
+ # @!attribute [rw] tags
+ # The tags that you want to attach to the resource.
+ # @return [Hash]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResourceRequest AWS API Documentation
+ #
+ class TagResourceRequest < Struct.new(
+ :resource_arn,
+ :tags)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResourceResponse AWS API Documentation
+ #
+ class TagResourceResponse < Aws::EmptyStructure; end
+
# HTTP Status Code 429: Limit exceeded. Resource limit reached.
#
# @!attribute [rw] message
@@ -1692,6 +1813,28 @@ class UnauthorizedException < Struct.new(
include Aws::Structure
end
+ # @!attribute [rw] resource_arn
+ # The Amazon Resource Name (ARN) of the resource from which you want
+ # to remove tags.
+ # @return [String]
+ #
+ # @!attribute [rw] tag_keys
+ # The keys of the tags that you want to remove from the resource.
+ # @return [Array]
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResourceRequest AWS API Documentation
+ #
+ class UntagResourceRequest < Struct.new(
+ :resource_arn,
+ :tag_keys)
+ SENSITIVE = []
+ include Aws::Structure
+ end
+
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResourceResponse AWS API Documentation
+ #
+ class UntagResourceResponse < Aws::EmptyStructure; end
+
# @!attribute [rw] capacity
# The target capacity.
# @return [Types::CapacityUpdate]
@@ -1884,6 +2027,10 @@ class WorkerConfigurationRevisionSummary < Struct.new(
# The Amazon Resource Name (ARN) of the worker configuration.
# @return [String]
#
+ # @!attribute [rw] worker_configuration_state
+ # The state of the worker configuration.
+ # @return [String]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/WorkerConfigurationSummary AWS API Documentation
#
class WorkerConfigurationSummary < Struct.new(
@@ -1891,7 +2038,8 @@ class WorkerConfigurationSummary < Struct.new(
:description,
:latest_revision,
:name,
- :worker_configuration_arn)
+ :worker_configuration_arn,
+ :worker_configuration_state)
SENSITIVE = []
include Aws::Structure
end
diff --git a/gems/aws-sdk-kafkaconnect/sig/client.rbs b/gems/aws-sdk-kafkaconnect/sig/client.rbs
index d03468a15c7..6a065572842 100644
--- a/gems/aws-sdk-kafkaconnect/sig/client.rbs
+++ b/gems/aws-sdk-kafkaconnect/sig/client.rbs
@@ -142,6 +142,7 @@ module Aws
},
],
service_execution_role_arn: ::String,
+ ?tags: Hash[::String, ::String],
?worker_configuration: {
revision: ::Integer,
worker_configuration_arn: ::String
@@ -167,7 +168,8 @@ module Aws
object_version: ::String?
}
},
- name: ::String
+ name: ::String,
+ ?tags: Hash[::String, ::String]
) -> _CreateCustomPluginResponseSuccess
| (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _CreateCustomPluginResponseSuccess
@@ -177,12 +179,14 @@ module Aws
def latest_revision: () -> Types::WorkerConfigurationRevisionSummary
def name: () -> ::String
def worker_configuration_arn: () -> ::String
+ def worker_configuration_state: () -> ("ACTIVE" | "DELETING")
end
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#create_worker_configuration-instance_method
def create_worker_configuration: (
?description: ::String,
name: ::String,
- properties_file_content: ::String
+ properties_file_content: ::String,
+ ?tags: Hash[::String, ::String]
) -> _CreateWorkerConfigurationResponseSuccess
| (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _CreateWorkerConfigurationResponseSuccess
@@ -209,6 +213,17 @@ module Aws
) -> _DeleteCustomPluginResponseSuccess
| (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _DeleteCustomPluginResponseSuccess
+ interface _DeleteWorkerConfigurationResponseSuccess
+ include ::Seahorse::Client::_ResponseSuccess[Types::DeleteWorkerConfigurationResponse]
+ def worker_configuration_arn: () -> ::String
+ def worker_configuration_state: () -> ("ACTIVE" | "DELETING")
+ end
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#delete_worker_configuration-instance_method
+ def delete_worker_configuration: (
+ worker_configuration_arn: ::String
+ ) -> _DeleteWorkerConfigurationResponseSuccess
+ | (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _DeleteWorkerConfigurationResponseSuccess
+
interface _DescribeConnectorResponseSuccess
include ::Seahorse::Client::_ResponseSuccess[Types::DescribeConnectorResponse]
def capacity: () -> Types::CapacityDescription
@@ -258,6 +273,7 @@ module Aws
def latest_revision: () -> Types::WorkerConfigurationRevisionDescription
def name: () -> ::String
def worker_configuration_arn: () -> ::String
+ def worker_configuration_state: () -> ("ACTIVE" | "DELETING")
end
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#describe_worker_configuration-instance_method
def describe_worker_configuration: (
@@ -286,10 +302,21 @@ module Aws
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#list_custom_plugins-instance_method
def list_custom_plugins: (
?max_results: ::Integer,
+ ?name_prefix: ::String,
?next_token: ::String
) -> _ListCustomPluginsResponseSuccess
| (?Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _ListCustomPluginsResponseSuccess
+ interface _ListTagsForResourceResponseSuccess
+ include ::Seahorse::Client::_ResponseSuccess[Types::ListTagsForResourceResponse]
+ def tags: () -> ::Hash[::String, ::String]
+ end
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#list_tags_for_resource-instance_method
+ def list_tags_for_resource: (
+ resource_arn: ::String
+ ) -> _ListTagsForResourceResponseSuccess
+ | (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _ListTagsForResourceResponseSuccess
+
interface _ListWorkerConfigurationsResponseSuccess
include ::Seahorse::Client::_ResponseSuccess[Types::ListWorkerConfigurationsResponse]
def next_token: () -> ::String
@@ -298,10 +325,31 @@ module Aws
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#list_worker_configurations-instance_method
def list_worker_configurations: (
?max_results: ::Integer,
+ ?name_prefix: ::String,
?next_token: ::String
) -> _ListWorkerConfigurationsResponseSuccess
| (?Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _ListWorkerConfigurationsResponseSuccess
+ interface _TagResourceResponseSuccess
+ include ::Seahorse::Client::_ResponseSuccess[Types::TagResourceResponse]
+ end
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#tag_resource-instance_method
+ def tag_resource: (
+ resource_arn: ::String,
+ tags: Hash[::String, ::String]
+ ) -> _TagResourceResponseSuccess
+ | (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _TagResourceResponseSuccess
+
+ interface _UntagResourceResponseSuccess
+ include ::Seahorse::Client::_ResponseSuccess[Types::UntagResourceResponse]
+ end
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/KafkaConnect/Client.html#untag_resource-instance_method
+ def untag_resource: (
+ resource_arn: ::String,
+ tag_keys: Array[::String]
+ ) -> _UntagResourceResponseSuccess
+ | (Hash[Symbol, untyped] params, ?Hash[Symbol, untyped] options) -> _UntagResourceResponseSuccess
+
interface _UpdateConnectorResponseSuccess
include ::Seahorse::Client::_ResponseSuccess[Types::UpdateConnectorResponse]
def connector_arn: () -> ::String
diff --git a/gems/aws-sdk-kafkaconnect/sig/types.rbs b/gems/aws-sdk-kafkaconnect/sig/types.rbs
index 23a6b114a7b..c69b1b9df17 100644
--- a/gems/aws-sdk-kafkaconnect/sig/types.rbs
+++ b/gems/aws-sdk-kafkaconnect/sig/types.rbs
@@ -118,6 +118,7 @@ module Aws::KafkaConnect
attr_accessor log_delivery: Types::LogDelivery
attr_accessor plugins: ::Array[Types::Plugin]
attr_accessor service_execution_role_arn: ::String
+ attr_accessor tags: ::Hash[::String, ::String]
attr_accessor worker_configuration: Types::WorkerConfiguration
SENSITIVE: [:connector_configuration]
end
@@ -134,6 +135,7 @@ module Aws::KafkaConnect
attr_accessor description: ::String
attr_accessor location: Types::CustomPluginLocation
attr_accessor name: ::String
+ attr_accessor tags: ::Hash[::String, ::String]
SENSITIVE: []
end
@@ -149,6 +151,7 @@ module Aws::KafkaConnect
attr_accessor description: ::String
attr_accessor name: ::String
attr_accessor properties_file_content: ::String
+ attr_accessor tags: ::Hash[::String, ::String]
SENSITIVE: [:properties_file_content]
end
@@ -157,6 +160,7 @@ module Aws::KafkaConnect
attr_accessor latest_revision: Types::WorkerConfigurationRevisionSummary
attr_accessor name: ::String
attr_accessor worker_configuration_arn: ::String
+ attr_accessor worker_configuration_state: ("ACTIVE" | "DELETING")
SENSITIVE: []
end
@@ -231,6 +235,17 @@ module Aws::KafkaConnect
SENSITIVE: []
end
+ class DeleteWorkerConfigurationRequest
+ attr_accessor worker_configuration_arn: ::String
+ SENSITIVE: []
+ end
+
+ class DeleteWorkerConfigurationResponse
+ attr_accessor worker_configuration_arn: ::String
+ attr_accessor worker_configuration_state: ("ACTIVE" | "DELETING")
+ SENSITIVE: []
+ end
+
class DescribeConnectorRequest
attr_accessor connector_arn: ::String
SENSITIVE: []
@@ -284,6 +299,7 @@ module Aws::KafkaConnect
attr_accessor latest_revision: Types::WorkerConfigurationRevisionDescription
attr_accessor name: ::String
attr_accessor worker_configuration_arn: ::String
+ attr_accessor worker_configuration_state: ("ACTIVE" | "DELETING")
SENSITIVE: []
end
@@ -354,6 +370,7 @@ module Aws::KafkaConnect
class ListCustomPluginsRequest
attr_accessor max_results: ::Integer
+ attr_accessor name_prefix: ::String
attr_accessor next_token: ::String
SENSITIVE: []
end
@@ -364,8 +381,19 @@ module Aws::KafkaConnect
SENSITIVE: []
end
+ class ListTagsForResourceRequest
+ attr_accessor resource_arn: ::String
+ SENSITIVE: []
+ end
+
+ class ListTagsForResourceResponse
+ attr_accessor tags: ::Hash[::String, ::String]
+ SENSITIVE: []
+ end
+
class ListWorkerConfigurationsRequest
attr_accessor max_results: ::Integer
+ attr_accessor name_prefix: ::String
attr_accessor next_token: ::String
SENSITIVE: []
end
@@ -488,6 +516,15 @@ module Aws::KafkaConnect
SENSITIVE: []
end
+ class TagResourceRequest
+ attr_accessor resource_arn: ::String
+ attr_accessor tags: ::Hash[::String, ::String]
+ SENSITIVE: []
+ end
+
+ class TagResourceResponse < Aws::EmptyStructure
+ end
+
class TooManyRequestsException
attr_accessor message: ::String
SENSITIVE: []
@@ -498,6 +535,15 @@ module Aws::KafkaConnect
SENSITIVE: []
end
+ class UntagResourceRequest
+ attr_accessor resource_arn: ::String
+ attr_accessor tag_keys: ::Array[::String]
+ SENSITIVE: []
+ end
+
+ class UntagResourceResponse < Aws::EmptyStructure
+ end
+
class UpdateConnectorRequest
attr_accessor capacity: Types::CapacityUpdate
attr_accessor connector_arn: ::String
@@ -556,6 +602,7 @@ module Aws::KafkaConnect
attr_accessor latest_revision: Types::WorkerConfigurationRevisionSummary
attr_accessor name: ::String
attr_accessor worker_configuration_arn: ::String
+ attr_accessor worker_configuration_state: ("ACTIVE" | "DELETING")
SENSITIVE: []
end
diff --git a/gems/aws-sdk-rds/CHANGELOG.md b/gems/aws-sdk-rds/CHANGELOG.md
index 4cc47d52933..96d72494a9a 100644
--- a/gems/aws-sdk-rds/CHANGELOG.md
+++ b/gems/aws-sdk-rds/CHANGELOG.md
@@ -1,6 +1,11 @@
Unreleased Changes
------------------
+1.219.0 (2024-02-26)
+------------------
+
+* Feature - This release adds support for gp3 data volumes for Multi-AZ DB Clusters.
+
1.218.0 (2024-02-23)
------------------
diff --git a/gems/aws-sdk-rds/VERSION b/gems/aws-sdk-rds/VERSION
index aaf66f15301..ba5ffb38ed4 100644
--- a/gems/aws-sdk-rds/VERSION
+++ b/gems/aws-sdk-rds/VERSION
@@ -1 +1 @@
-1.218.0
+1.219.0
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds.rb
index 16c22f23b28..dc6e6cc99c7 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds.rb
@@ -78,6 +78,6 @@
# @!group service
module Aws::RDS
- GEM_VERSION = '1.218.0'
+ GEM_VERSION = '1.219.0'
end
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/client.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/client.rb
index 32d36758724..36dfaabe62d 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/client.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/client.rb
@@ -1417,6 +1417,7 @@ def copy_db_cluster_parameter_group(params = {}, options = {})
# resp.db_cluster_snapshot.db_system_id #=> String
# resp.db_cluster_snapshot.storage_type #=> String
# resp.db_cluster_snapshot.db_cluster_resource_id #=> String
+ # resp.db_cluster_snapshot.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/CopyDBClusterSnapshot AWS API Documentation
#
@@ -3664,6 +3665,7 @@ def create_custom_db_engine_version(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/CreateDBCluster AWS API Documentation
#
@@ -4090,6 +4092,7 @@ def create_db_cluster_parameter_group(params = {}, options = {})
# resp.db_cluster_snapshot.db_system_id #=> String
# resp.db_cluster_snapshot.storage_type #=> String
# resp.db_cluster_snapshot.db_cluster_resource_id #=> String
+ # resp.db_cluster_snapshot.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/CreateDBClusterSnapshot AWS API Documentation
#
@@ -8805,6 +8808,7 @@ def delete_custom_db_engine_version(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DeleteDBCluster AWS API Documentation
#
@@ -8861,6 +8865,7 @@ def delete_db_cluster(params = {}, options = {})
# resp.db_cluster_automated_backup.storage_type #=> String
# resp.db_cluster_automated_backup.iops #=> Integer
# resp.db_cluster_automated_backup.aws_backup_recovery_point_arn #=> String
+ # resp.db_cluster_automated_backup.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DeleteDBClusterAutomatedBackup AWS API Documentation
#
@@ -9106,6 +9111,7 @@ def delete_db_cluster_parameter_group(params = {}, options = {})
# resp.db_cluster_snapshot.db_system_id #=> String
# resp.db_cluster_snapshot.storage_type #=> String
# resp.db_cluster_snapshot.db_cluster_resource_id #=> String
+ # resp.db_cluster_snapshot.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DeleteDBClusterSnapshot AWS API Documentation
#
@@ -10972,6 +10978,7 @@ def describe_certificates(params = {}, options = {})
# resp.db_cluster_automated_backups[0].storage_type #=> String
# resp.db_cluster_automated_backups[0].iops #=> Integer
# resp.db_cluster_automated_backups[0].aws_backup_recovery_point_arn #=> String
+ # resp.db_cluster_automated_backups[0].storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DescribeDBClusterAutomatedBackups AWS API Documentation
#
@@ -11876,6 +11883,7 @@ def describe_db_cluster_snapshot_attributes(params = {}, options = {})
# resp.db_cluster_snapshots[0].db_system_id #=> String
# resp.db_cluster_snapshots[0].storage_type #=> String
# resp.db_cluster_snapshots[0].db_cluster_resource_id #=> String
+ # resp.db_cluster_snapshots[0].storage_throughput #=> Integer
#
#
# The following waiters are defined for this operation (see {Client#wait_until} for detailed usage):
@@ -12220,6 +12228,7 @@ def describe_db_cluster_snapshots(params = {}, options = {})
# resp.db_clusters[0].aws_backup_recovery_point_arn #=> String
# resp.db_clusters[0].limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_clusters[0].limitless_database.min_required_acu #=> Float
+ # resp.db_clusters[0].storage_throughput #=> Integer
#
#
# The following waiters are defined for this operation (see {Client#wait_until} for detailed usage):
@@ -17488,6 +17497,7 @@ def enable_http_endpoint(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/FailoverDBCluster AWS API Documentation
#
@@ -19140,6 +19150,7 @@ def modify_custom_db_engine_version(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/ModifyDBCluster AWS API Documentation
#
@@ -22705,6 +22716,7 @@ def promote_read_replica(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/PromoteReadReplicaDBCluster AWS API Documentation
#
@@ -22995,6 +23007,7 @@ def purchase_reserved_db_instances_offering(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/RebootDBCluster AWS API Documentation
#
@@ -24518,6 +24531,7 @@ def reset_db_parameter_group(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/RestoreDBClusterFromS3 AWS API Documentation
#
@@ -25232,6 +25246,7 @@ def restore_db_cluster_from_s3(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/RestoreDBClusterFromSnapshot AWS API Documentation
#
@@ -25921,6 +25936,7 @@ def restore_db_cluster_from_snapshot(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/RestoreDBClusterToPointInTime AWS API Documentation
#
@@ -26420,8 +26436,7 @@ def restore_db_cluster_to_point_in_time(params = {}, options = {})
# This setting doesn't apply to RDS Custom or Amazon Aurora.
#
# @option params [String] :db_cluster_snapshot_identifier
- # 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][1] in the *Amazon RDS User Guide*.
@@ -26441,9 +26456,6 @@ def restore_db_cluster_to_point_in_time(params = {}, options = {})
#
# * 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.
- #
#
#
# [1]: https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html
@@ -28731,6 +28743,7 @@ def start_activity_stream(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/StartDBCluster AWS API Documentation
#
@@ -29567,6 +29580,7 @@ def stop_activity_stream(params = {}, options = {})
# resp.db_cluster.aws_backup_recovery_point_arn #=> String
# resp.db_cluster.limitless_database.status #=> String, one of "active", "not-in-use", "enabled", "disabled", "enabling", "disabling", "modifying-max-capacity", "error"
# resp.db_cluster.limitless_database.min_required_acu #=> Float
+ # resp.db_cluster.storage_throughput #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/StopDBCluster AWS API Documentation
#
@@ -30414,7 +30428,7 @@ def build_request(operation_name, params = {})
params: params,
config: config)
context[:gem_name] = 'aws-sdk-rds'
- context[:gem_version] = '1.218.0'
+ context[:gem_version] = '1.219.0'
Seahorse::Client::Request.new(handlers, context)
end
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/client_api.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/client_api.rb
index 759f2b34067..c8135d4e7d5 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/client_api.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/client_api.rb
@@ -1422,6 +1422,7 @@ module ClientApi
DBCluster.add_member(:local_write_forwarding_status, Shapes::ShapeRef.new(shape: LocalWriteForwardingStatus, location_name: "LocalWriteForwardingStatus"))
DBCluster.add_member(:aws_backup_recovery_point_arn, Shapes::ShapeRef.new(shape: String, location_name: "AwsBackupRecoveryPointArn"))
DBCluster.add_member(:limitless_database, Shapes::ShapeRef.new(shape: LimitlessDatabase, location_name: "LimitlessDatabase"))
+ DBCluster.add_member(:storage_throughput, Shapes::ShapeRef.new(shape: IntegerOptional, location_name: "StorageThroughput"))
DBCluster.struct_class = Types::DBCluster
DBClusterAlreadyExistsFault.struct_class = Types::DBClusterAlreadyExistsFault
@@ -1450,6 +1451,7 @@ module ClientApi
DBClusterAutomatedBackup.add_member(:storage_type, Shapes::ShapeRef.new(shape: String, location_name: "StorageType"))
DBClusterAutomatedBackup.add_member(:iops, Shapes::ShapeRef.new(shape: IntegerOptional, location_name: "Iops"))
DBClusterAutomatedBackup.add_member(:aws_backup_recovery_point_arn, Shapes::ShapeRef.new(shape: String, location_name: "AwsBackupRecoveryPointArn"))
+ DBClusterAutomatedBackup.add_member(:storage_throughput, Shapes::ShapeRef.new(shape: IntegerOptional, location_name: "StorageThroughput"))
DBClusterAutomatedBackup.struct_class = Types::DBClusterAutomatedBackup
DBClusterAutomatedBackupList.member = Shapes::ShapeRef.new(shape: DBClusterAutomatedBackup, location_name: "DBClusterAutomatedBackup")
@@ -1592,6 +1594,7 @@ module ClientApi
DBClusterSnapshot.add_member(:db_system_id, Shapes::ShapeRef.new(shape: String, location_name: "DBSystemId"))
DBClusterSnapshot.add_member(:storage_type, Shapes::ShapeRef.new(shape: String, location_name: "StorageType"))
DBClusterSnapshot.add_member(:db_cluster_resource_id, Shapes::ShapeRef.new(shape: String, location_name: "DbClusterResourceId"))
+ DBClusterSnapshot.add_member(:storage_throughput, Shapes::ShapeRef.new(shape: IntegerOptional, location_name: "StorageThroughput"))
DBClusterSnapshot.struct_class = Types::DBClusterSnapshot
DBClusterSnapshotAlreadyExistsFault.struct_class = Types::DBClusterSnapshotAlreadyExistsFault
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster.rb
index b046799bf63..212f8a0a8b6 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster.rb
@@ -686,6 +686,16 @@ def limitless_database
data[:limitless_database]
end
+ # 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.
+ # @return [Integer]
+ def storage_throughput
+ data[:storage_throughput]
+ end
+
# @!endgroup
# @return [Client]
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster_snapshot.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster_snapshot.rb
index 0d3c4c0eaaa..64cc41fd6b7 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster_snapshot.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_cluster_snapshot.rb
@@ -209,6 +209,16 @@ def db_cluster_resource_id
data[:db_cluster_resource_id]
end
+ # 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.
+ # @return [Integer]
+ def storage_throughput
+ data[:storage_throughput]
+ end
+
# @!endgroup
# @return [Client]
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_snapshot.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_snapshot.rb
index ba5871e2962..b63825a0da7 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/db_snapshot.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/db_snapshot.rb
@@ -1119,8 +1119,7 @@ def delete(options = {})
#
# This setting doesn't apply to RDS Custom or Amazon Aurora.
# @option options [String] :db_cluster_snapshot_identifier
- # 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][1] in the *Amazon RDS User Guide*.
@@ -1140,9 +1139,6 @@ def delete(options = {})
#
# * 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.
- #
#
#
# [1]: https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html
diff --git a/gems/aws-sdk-rds/lib/aws-sdk-rds/types.rb b/gems/aws-sdk-rds/lib/aws-sdk-rds/types.rb
index 2ca1ef28765..de25615dc46 100644
--- a/gems/aws-sdk-rds/lib/aws-sdk-rds/types.rb
+++ b/gems/aws-sdk-rds/lib/aws-sdk-rds/types.rb
@@ -6869,6 +6869,14 @@ class CustomDBEngineVersionQuotaExceededFault < Aws::EmptyStructure; end
# The details for Aurora Limitless Database.
# @return [Types::LimitlessDatabase]
#
+ # @!attribute [rw] storage_throughput
+ # 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.
+ # @return [Integer]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DBCluster AWS API Documentation
#
class DBCluster < Struct.new(
@@ -6948,7 +6956,8 @@ class DBCluster < Struct.new(
:io_optimized_next_allowed_modification_time,
:local_write_forwarding_status,
:aws_backup_recovery_point_arn,
- :limitless_database)
+ :limitless_database,
+ :storage_throughput)
SENSITIVE = []
include Aws::Structure
end
@@ -7089,6 +7098,14 @@ class DBClusterAlreadyExistsFault < Aws::EmptyStructure; end
# Services Backup.
# @return [String]
#
+ # @!attribute [rw] storage_throughput
+ # 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.
+ # @return [Integer]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DBClusterAutomatedBackup AWS API Documentation
#
class DBClusterAutomatedBackup < Struct.new(
@@ -7115,7 +7132,8 @@ class DBClusterAutomatedBackup < Struct.new(
:kms_key_id,
:storage_type,
:iops,
- :aws_backup_recovery_point_arn)
+ :aws_backup_recovery_point_arn,
+ :storage_throughput)
SENSITIVE = []
include Aws::Structure
end
@@ -7786,6 +7804,14 @@ class DBClusterRoleQuotaExceededFault < Aws::EmptyStructure; end
# created from.
# @return [String]
#
+ # @!attribute [rw] storage_throughput
+ # 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.
+ # @return [Integer]
+ #
# @see http://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/DBClusterSnapshot AWS API Documentation
#
class DBClusterSnapshot < Struct.new(
@@ -7813,7 +7839,8 @@ class DBClusterSnapshot < Struct.new(
:tag_list,
:db_system_id,
:storage_type,
- :db_cluster_resource_id)
+ :db_cluster_resource_id,
+ :storage_throughput)
SENSITIVE = []
include Aws::Structure
end
@@ -23872,8 +23899,7 @@ class RestoreDBClusterToPointInTimeResult < Struct.new(
# @return [Integer]
#
# @!attribute [rw] db_cluster_snapshot_identifier
- # 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][1] in the *Amazon RDS User Guide*.
@@ -23893,9 +23919,6 @@ class RestoreDBClusterToPointInTimeResult < Struct.new(
#
# * 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.
- #
#
#
# [1]: https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html
diff --git a/gems/aws-sdk-rds/sig/db_cluster.rbs b/gems/aws-sdk-rds/sig/db_cluster.rbs
index 071d28bd9e1..aed423d82c2 100644
--- a/gems/aws-sdk-rds/sig/db_cluster.rbs
+++ b/gems/aws-sdk-rds/sig/db_cluster.rbs
@@ -246,6 +246,9 @@ module Aws
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBCluster.html#limitless_database-instance_method
def limitless_database: () -> Types::LimitlessDatabase
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBCluster.html#storage_throughput-instance_method
+ def storage_throughput: () -> ::Integer
+
def client: () -> Client
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBCluster.html#load-instance_method
diff --git a/gems/aws-sdk-rds/sig/db_cluster_snapshot.rbs b/gems/aws-sdk-rds/sig/db_cluster_snapshot.rbs
index 7923fdbb177..3b413e99b62 100644
--- a/gems/aws-sdk-rds/sig/db_cluster_snapshot.rbs
+++ b/gems/aws-sdk-rds/sig/db_cluster_snapshot.rbs
@@ -91,6 +91,9 @@ module Aws
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBClusterSnapshot.html#db_cluster_resource_id-instance_method
def db_cluster_resource_id: () -> ::String
+ # https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBClusterSnapshot.html#storage_throughput-instance_method
+ def storage_throughput: () -> ::Integer
+
def client: () -> Client
# https://docs.aws.amazon.com/sdk-for-ruby/v3/api/Aws/RDS/DBClusterSnapshot.html#load-instance_method
diff --git a/gems/aws-sdk-rds/sig/types.rbs b/gems/aws-sdk-rds/sig/types.rbs
index 0339c7decb0..37b7d0cf6ed 100644
--- a/gems/aws-sdk-rds/sig/types.rbs
+++ b/gems/aws-sdk-rds/sig/types.rbs
@@ -811,6 +811,7 @@ module Aws::RDS
attr_accessor local_write_forwarding_status: ("enabled" | "disabled" | "enabling" | "disabling" | "requested")
attr_accessor aws_backup_recovery_point_arn: ::String
attr_accessor limitless_database: Types::LimitlessDatabase
+ attr_accessor storage_throughput: ::Integer
SENSITIVE: []
end
@@ -842,6 +843,7 @@ module Aws::RDS
attr_accessor storage_type: ::String
attr_accessor iops: ::Integer
attr_accessor aws_backup_recovery_point_arn: ::String
+ attr_accessor storage_throughput: ::Integer
SENSITIVE: []
end
@@ -1010,6 +1012,7 @@ module Aws::RDS
attr_accessor db_system_id: ::String
attr_accessor storage_type: ::String
attr_accessor db_cluster_resource_id: ::String
+ attr_accessor storage_throughput: ::Integer
SENSITIVE: []
end