From 9cf7ffb8ebab8a9db01b92668cee43c6b961a077 Mon Sep 17 00:00:00 2001 From: AWS SDK For Ruby Date: Mon, 26 Feb 2024 19:17:09 +0000 Subject: [PATCH] Updated API models and rebuilt service gems. --- apis/apigateway/2015-07-09/docs-2.json | 6 +- .../2015-07-09/endpoint-rule-set-1.json | 40 ++-- apis/drs/2020-02-26/api-2.json | 42 +++- apis/drs/2020-02-26/docs-2.json | 37 +++ apis/kafkaconnect/2021-09-14/api-2.json | 215 +++++++++++++++++- apis/kafkaconnect/2021-09-14/docs-2.json | 97 +++++++- .../2021-09-14/endpoint-rule-set-1.json | 40 ++-- apis/rds/2014-10-31/api-2.json | 9 +- apis/rds/2014-10-31/docs-2.json | 5 +- gems/aws-sdk-apigateway/CHANGELOG.md | 5 + gems/aws-sdk-apigateway/VERSION | 2 +- .../lib/aws-sdk-apigateway.rb | 2 +- .../lib/aws-sdk-apigateway/client.rb | 7 +- .../aws-sdk-apigateway/endpoint_provider.rb | 2 +- .../lib/aws-sdk-apigateway/types.rb | 7 +- gems/aws-sdk-drs/CHANGELOG.md | 5 + gems/aws-sdk-drs/VERSION | 2 +- gems/aws-sdk-drs/lib/aws-sdk-drs.rb | 2 +- gems/aws-sdk-drs/lib/aws-sdk-drs/client.rb | 12 +- .../aws-sdk-drs/lib/aws-sdk-drs/client_api.rb | 17 ++ gems/aws-sdk-drs/lib/aws-sdk-drs/types.rb | 32 ++- gems/aws-sdk-drs/sig/types.rbs | 8 + gems/aws-sdk-kafkaconnect/CHANGELOG.md | 5 + gems/aws-sdk-kafkaconnect/VERSION | 2 +- .../lib/aws-sdk-kafkaconnect.rb | 2 +- .../lib/aws-sdk-kafkaconnect/client.rb | 159 ++++++++++++- .../lib/aws-sdk-kafkaconnect/client_api.rb | 112 +++++++++ .../aws-sdk-kafkaconnect/endpoint_provider.rb | 2 +- .../lib/aws-sdk-kafkaconnect/endpoints.rb | 56 +++++ .../aws-sdk-kafkaconnect/plugins/endpoints.rb | 8 + .../lib/aws-sdk-kafkaconnect/types.rb | 168 +++++++++++++- gems/aws-sdk-kafkaconnect/sig/client.rbs | 52 ++++- gems/aws-sdk-kafkaconnect/sig/types.rbs | 47 ++++ gems/aws-sdk-rds/CHANGELOG.md | 5 + gems/aws-sdk-rds/VERSION | 2 +- gems/aws-sdk-rds/lib/aws-sdk-rds.rb | 2 +- gems/aws-sdk-rds/lib/aws-sdk-rds/client.rb | 26 ++- .../aws-sdk-rds/lib/aws-sdk-rds/client_api.rb | 3 + .../aws-sdk-rds/lib/aws-sdk-rds/db_cluster.rb | 10 + .../lib/aws-sdk-rds/db_cluster_snapshot.rb | 10 + .../lib/aws-sdk-rds/db_snapshot.rb | 6 +- gems/aws-sdk-rds/lib/aws-sdk-rds/types.rb | 39 +++- gems/aws-sdk-rds/sig/db_cluster.rbs | 3 + gems/aws-sdk-rds/sig/db_cluster_snapshot.rbs | 3 + gems/aws-sdk-rds/sig/types.rbs | 3 + 45 files changed, 1212 insertions(+), 107 deletions(-) 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:

Default: 7 days

", + "DBCluster$StorageThroughput": "

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

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

", "DBClusterAutomatedBackup$BackupRetentionPeriod": "

The retention period for the automated backups.

", "DBClusterAutomatedBackup$Iops": "

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

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

", + "DBClusterAutomatedBackup$StorageThroughput": "

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

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

", "DBClusterCapacityInfo$PendingCapacity": "

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

", "DBClusterCapacityInfo$CurrentCapacity": "

The current capacity of the DB cluster.

", "DBClusterCapacityInfo$SecondsBeforeTimeout": "

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

", "DBClusterMember$PromotionTier": "

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

", + "DBClusterSnapshot$StorageThroughput": "

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

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

", "DBInstance$Iops": "

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

", "DBInstance$MonitoringInterval": "

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

", "DBInstance$PromotionTier": "

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

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

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

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

This setting is required for RDS Custom.

", "RestoreDBInstanceFromDBSnapshotMessage$BackupTarget": "

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

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

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

", "RestoreDBInstanceFromDBSnapshotMessage$NetworkType": "

The network type of the DB instance.

Valid Values:

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

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

", - "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "

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

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

Constraints:

", + "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "

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

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

Constraints:

", "RestoreDBInstanceFromS3Message$DBName": "

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

", "RestoreDBInstanceFromS3Message$DBInstanceIdentifier": "

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

Constraints:

Example: mydbinstance

", "RestoreDBInstanceFromS3Message$DBInstanceClass": "

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

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

", diff --git a/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