Provides a list of individual assessments that you can specify for a new premigration assessment run, given one or more parameters.
If you specify an existing migration task, this operation provides the default individual assessments you can specify for that task. Otherwise, the specified parameters model elements of a possible migration task on which to base a premigration assessment run.
To use these migration task modeling parameters, you must specify an existing replication instance, a source database engine, a target database engine, and a migration type. This combination of parameters potentially limits the default individual assessments available for an assessment run created for a corresponding migration task.
If you specify no parameters, this operation provides a list of all possible individual assessments that you can specify for an assessment run. If you specify any one of the task modeling parameters, you must specify all of them or the operation cannot provide a list of individual assessments. The only parameter that you can specify alone is for an existing migration task. The specified task definition then determines the default list of individual assessments that you can specify in an assessment run for the task.
", "DescribeCertificates": "Provides a description of the certificate.
", "DescribeConnections": "Describes the status of the connections that have been made between the replication instance and an endpoint. Connections are created when you test an endpoint.
", + "DescribeEndpointSettings": "Returns information about the possible endpoint settings available when you create an endpoint for a specific database engine.
", "DescribeEndpointTypes": "Returns information about the type of endpoints available.
", "DescribeEndpoints": "Returns information about the endpoints for your account in the current region.
", "DescribeEventCategories": "Lists categories for all event source types, or, if specified, for a specified source type. You can see a list of the event categories and source types in Working with Events and Notifications in the AWS Database Migration Service User Guide.
", @@ -140,6 +141,7 @@ "CreateReplicationInstanceMessage$PubliclyAccessible": " Specifies the accessibility options for the replication instance. A value of true represents an instance with a public IP address. A value of false represents an instance with a private IP address. The default value is true.
An option to set to avoid returning information about settings. Use this to reduce overhead when setting information is too large. To use this option, choose true; otherwise, choose false (the default).
Specifies the document ID. Use this setting when NestingLevel is set to \"none\".
Default value is \"false\".
A value that marks this endpoint setting as sensitive.
", "IBMDb2Settings$SetDataCaptureChanges": "Enables ongoing replication (CDC) as a BOOLEAN value. The default is true.
", "KafkaSettings$IncludeTransactionDetails": "Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for transaction_id, previous transaction_id, and transaction_record_id (the record offset within a transaction). The default is false.
Shows the partition value within the Kafka message output, unless the partition type is schema-table-type. The default is false.
Includes any data definition language (DDL) operations that change the table in the control data, such as rename-table, drop-table, add-column, drop-column, and rename-column. The default is false.
Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. The default is false.
Include NULL and empty columns for records migrated to the endpoint. The default is false.
Cleans and recreates table metadata information on the replication instance when a mismatch occurs. An example is a situation where running an alter DDL statement on a table might result in different information about the table cached in the replication instance.
", "MicrosoftSQLServerSettings$ReadBackupOnly": "When this attribute is set to Y, AWS DMS only reads changes from transaction log backups and doesn't read from the active transaction log file during ongoing replication. Setting this parameter to Y enables you to control active transaction log file growth during full load and ongoing replication tasks. However, it can add some source latency to ongoing replication.
Use this to attribute to transfer data for full-load operations using BCP. When the target table contains an identity column that does not exist in the source table, you must disable the use BCP for loading table option.
", + "MicrosoftSQLServerSettings$UseThirdPartyBackupDevice": "When this attribute is set to Y, DMS processes third-party transaction log backups if they are created in native format.
A Boolean value; set to true to activate the subscription.
", "ModifyReplicationInstanceMessage$MultiAZ": " Specifies whether the replication instance is a Multi-AZ deployment. You can't set the AvailabilityZone parameter if the Multi-AZ parameter is set to true.
A value that indicates that minor version upgrades are applied automatically to the replication instance during the maintenance window. Changing this parameter doesn't result in an outage, except in the case described following. The change is asynchronously applied as soon as possible.
An outage does result if these factors apply:
This parameter is set to true during the maintenance window.
A newer minor version is available.
AWS DMS has enabled automatic patching for the given engine version.
Adjusts the behavior of DMS when migrating from an SQL Server source database that is hosted as part of an Always On availability group cluster. If you need DMS to poll all the nodes in the Always On cluster for transaction backups, set this attribute to false.
If you want AWS Identity and Access Management (IAM) authorization enabled for this endpoint, set this parameter to true. Then attach the appropriate IAM policy document to your service role specified by ServiceAccessRoleArn. The default is false.
Set this attribute to set up table-level supplemental logging for the Oracle database. This attribute enables PRIMARY KEY supplemental logging on all tables selected for a migration task.
If you use this option, you still need to enable database-level supplemental logging.
", "OracleSettings$AllowSelectNestedTables": "Set this attribute to true to enable replication of Oracle tables containing columns that are nested tables or defined types.
Endpoint description.
" } }, + "EndpointSetting": { + "base": "Endpoint settings.
", + "refs": { + "EndpointSettingsList$member": null + } + }, + "EndpointSettingEnumValues": { + "base": null, + "refs": { + "EndpointSetting$EnumValues": "Enumerated values to use for this endpoint.
" + } + }, + "EndpointSettingTypeValue": { + "base": null, + "refs": { + "EndpointSetting$Type": "The type of endpoint. Valid values are source and target.
Descriptions of the endpoint settings available for your source or target database engine.
" + } + }, "Event": { "base": "Describes an identifiable significant activity that affects a replication instance or task. This object can provide the message, the available event categories, the date and source of the event, and the AWS DMS resource type.
", "refs": { @@ -852,6 +891,7 @@ "DescribeApplicableIndividualAssessmentsMessage$MaxRecords": "Maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
Default: 10
", "DescribeConnectionsMessage$MaxRecords": " The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
Default: 100
Constraints: Minimum 20, maximum 100.
", + "DescribeEndpointSettingsMessage$MaxRecords": "The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
Default: 100
Constraints: Minimum 20, maximum 100.
", "DescribeEndpointsMessage$MaxRecords": " The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
Default: 100
Constraints: Minimum 20, maximum 100.
", "DescribeEventSubscriptionsMessage$MaxRecords": " The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved.
Default: 100
Constraints: Minimum 20, maximum 100.
", @@ -873,6 +913,8 @@ "ElasticsearchSettings$FullLoadErrorPercentage": "The maximum percentage of records that can fail to be written before a full load operation stops.
To avoid early failure, this counter is only effective after 1000 records are transferred. Elasticsearch also has the concept of error monitoring during the last 10 minutes of an Observation Window. If transfer of all records fail in the last 10 minutes, the full load operation stops.
", "ElasticsearchSettings$ErrorRetryDuration": "The maximum number of seconds for which DMS retries failed API requests to the Elasticsearch cluster.
", "Endpoint$Port": "The port value used to access the endpoint.
", + "EndpointSetting$IntValueMin": "The minimum value of an endpoint setting that is of type int.
The maximum value of an endpoint setting that is of type int.
Endpoint TCP port.
", "IBMDb2Settings$MaxKBytesPerRead": "Maximum number of bytes per read, as a NUMBER value. The default is 64 KB.
", "KafkaSettings$MessageMaxBytes": "The maximum size in bytes for records created on the endpoint The default is 1,000,000.
", @@ -961,6 +1003,12 @@ "refs": { } }, + "KafkaSecurityProtocol": { + "base": null, + "refs": { + "KafkaSettings$SecurityProtocol": "Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include ssl-encryption, ssl-authentication, and sasl-ssl. sasl-ssl requires SaslUsername and SaslPassword.
Provides information that describes an Apache Kafka endpoint. This information includes the output format of records applied to the endpoint and details of transaction and control table data information.
", "refs": { @@ -1471,6 +1519,9 @@ "CreateEndpointMessage$Password": "The password to be used to log in to the endpoint database.
", "DocDbSettings$Password": "The password for the user account you use to access the DocumentDB source endpoint.
", "IBMDb2Settings$Password": "Endpoint connection password.
", + "ImportCertificateMessage$CertificatePem": "The contents of a .pem file, which contains an X.509 certificate.
The password for the client private key used to securely connect to a Kafka target endpoint.
", + "KafkaSettings$SaslPassword": "The secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
", "MicrosoftSQLServerSettings$Password": "Endpoint connection password.
", "ModifyEndpointMessage$Password": "The password to be used to login to the endpoint database.
", "MongoDbSettings$Password": "The password for the user account you use to access the MongoDB source endpoint.
", @@ -1625,6 +1676,9 @@ "DescribeCertificatesResponse$Marker": "The pagination token.
", "DescribeConnectionsMessage$Marker": " An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
The databse engine used for your source or target endpoint.
", + "DescribeEndpointSettingsMessage$Marker": "An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords.
The Amazon Resource Name (ARN) used by the service access IAM role.
", "Endpoint$ExternalTableDefinition": "The external table definition.
", "Endpoint$ExternalId": "Value returned by a call to CreateEndpoint that can be used for cross-account validation. Use it on a subsequent call to CreateEndpoint to create the endpoint with a cross-account.
", + "EndpointSetting$Name": "The name that you want to give the endpoint settings.
", + "EndpointSetting$Units": "The unit of measure for this endpoint setting.
", + "EndpointSetting$Applicability": "The relevance or validity of an endpoint setting for an engine name and its endpoint type.
", + "EndpointSettingEnumValues$member": null, "Event$SourceIdentifier": "The identifier of an event source.
", "Event$Message": "The event message.
", "EventCategoriesList$member": null, @@ -1712,11 +1770,14 @@ "IBMDb2Settings$SecretsManagerAccessRoleArn": "The full Amazon Resource Name (ARN) of the IAM role that specifies AWS DMS as the trusted entity and grants the required permissions to access the value in SecretsManagerSecret. SecretsManagerSecret has the value of the AWS Secrets Manager secret that allows access to the Db2 LUW endpoint.
You can specify one of two sets of values for these permissions. You can specify the values for this setting and SecretsManagerSecretId. Or you can specify clear-text values for UserName, Password, ServerName, and Port. You can't specify both. For more information on creating this SecretsManagerSecret and the SecretsManagerAccessRoleArn and SecretsManagerSecretId required to access it, see Using secrets to access AWS Database Migration Service resources in the AWS Database Migration Service User Guide.
The full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the Db2 LUW endpoint connection details.
A customer-assigned name for the certificate. Identifiers must begin with a letter and must contain only ASCII letters, digits, and hyphens. They can't end with a hyphen or contain two consecutive hyphens.
", - "ImportCertificateMessage$CertificatePem": "The contents of a .pem file, which contains an X.509 certificate.
The broker location and port of the Kafka broker that hosts your Kafka instance. Specify the broker in the form broker-hostname-or-ip:port . For example, \"ec2-12-345-678-901.compute-1.amazonaws.com:2345\".
A comma-separated list of one or more broker locations in your Kafka cluster that host your Kafka instance. Specify each broker location in the form broker-hostname-or-ip:port . For example, \"ec2-12-345-678-901.compute-1.amazonaws.com:2345\". For more information and examples of specifying a list of broker locations, see Using Apache Kafka as a target for AWS Database Migration Service in the AWS Data Migration Service User Guide.
The topic to which you migrate the data. If you don't specify a topic, AWS DMS specifies \"kafka-default-topic\" as the migration topic.
The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.
", + "KafkaSettings$SslClientKeyArn": "The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.
", + "KafkaSettings$SslCaCertificateArn": "The Amazon Resource Name (ARN) for the private Certification Authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
", + "KafkaSettings$SaslUsername": "The secure username you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
", "KeyList$member": null, "KinesisSettings$StreamArn": "The Amazon Resource Name (ARN) for the Amazon Kinesis Data Streams endpoint.
", "KinesisSettings$ServiceAccessRoleArn": "The Amazon Resource Name (ARN) for the AWS Identity and Access Management (IAM) role that AWS DMS uses to write to the Kinesis data stream.
", @@ -1749,7 +1810,7 @@ "ModifyReplicationSubnetGroupMessage$ReplicationSubnetGroupDescription": "A description for the replication instance subnet group.
", "ModifyReplicationTaskMessage$ReplicationTaskArn": "The Amazon Resource Name (ARN) of the replication task.
", "ModifyReplicationTaskMessage$ReplicationTaskIdentifier": "The replication task identifier.
Constraints:
Must contain 1-255 alphanumeric characters or hyphens.
First character must be a letter.
Cannot end with a hyphen or contain two consecutive hyphens.
When using the AWS CLI or boto3, provide the path of the JSON file that contains the table mappings. Precede the path with file://. When working with the DMS API, provide the JSON as the parameter value, for example: --table-mappings file://mappingfile.json
When using the AWS CLI or boto3, provide the path of the JSON file that contains the table mappings. Precede the path with file://. For example, --table-mappings file://mappingfile.json. When working with the DMS API, provide the JSON as the parameter value.
JSON file that contains settings for the task, such as task metadata settings.
", "ModifyReplicationTaskMessage$CdcStartPosition": "Indicates when you want a change data capture (CDC) operation to start. Use either CdcStartPosition or CdcStartTime to specify when you want a CDC operation to start. Specifying both values results in an error.
The value can be in date, checkpoint, or LSN/SCN format.
Date Example: --cdc-start-position “2018-03-08T12:12:12”
Checkpoint Example: --cdc-start-position \"checkpoint:V1#27#mysql-bin-changelog.157832:1975:-1:2002:677883278264080:mysql-bin-changelog.157832:1876#0#0#*#0#93\"
LSN Example: --cdc-start-position “mysql-bin-changelog.000024:373”
When you use this task setting with a source PostgreSQL database, a logical replication slot should already be created and associated with the source endpoint. You can verify this by setting the slotName extra connection attribute to the name of this logical replication slot. For more information, see Extra Connection Attributes When Using PostgreSQL as a Source for AWS DMS.
Indicates when you want a change data capture (CDC) operation to stop. The value can be either server time or commit time.
Server time example: --cdc-stop-position “server_time:2018-02-09T12:12:12”
Commit time example: --cdc-stop-position “commit_time: 2018-02-09T12:12:12 “
", @@ -1782,6 +1843,7 @@ "OracleSettings$DatabaseName": "Database name for the endpoint.
", "OracleSettings$SecurityDbEncryptionName": "For an Oracle source endpoint, the name of a key used for the transparent data encryption (TDE) of the columns and tablespaces in an Oracle source database that is encrypted using TDE. The key value is the value of the SecurityDbEncryption setting. For more information on setting the key name value of SecurityDbEncryptionName, see the information and example for setting the securityDbEncryptionName extra connection attribute in Supported encryption methods for using Oracle as a source for AWS DMS in the AWS Database Migration Service User Guide.
Fully qualified domain name of the endpoint.
", + "OracleSettings$SpatialDataOptionToGeoJsonFunctionName": "Use this attribute to convert SDO_GEOMETRY to GEOJSON format. By default, DMS calls the SDO2GEOJSON custom function if present and accessible. Or you can create your own custom function that mimics the operation of SDOGEOJSON and set SpatialDataOptionToGeoJsonFunctionName to call it instead.
Endpoint connection user name.
", "OracleSettings$SecretsManagerAccessRoleArn": "The full Amazon Resource Name (ARN) of the IAM role that specifies AWS DMS as the trusted entity and grants the required permissions to access the value in SecretsManagerSecret. SecretsManagerSecret has the value of the AWS Secrets Manager secret that allows access to the Oracle endpoint.
You can specify one of two sets of values for these permissions. You can specify the values for this setting and SecretsManagerSecretId. Or you can specify clear-text values for UserName, Password, ServerName, and Port. You can't specify both. For more information on creating this SecretsManagerSecret and the SecretsManagerAccessRoleArn and SecretsManagerSecretId required to access it, see Using secrets to access AWS Database Migration Service resources in the AWS Database Migration Service User Guide.
The full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the Oracle endpoint connection details.
Name of this individual assessment.
", "ReplicationTaskIndividualAssessment$Status": "Individual assessment status.
This status can have one of the following values:
\"cancelled\"
\"error\"
\"failed\"
\"passed\"
\"pending\"
\"running\"
The Amazon Resource Name (ARN) of the DMS resource that the pending maintenance action applies to. For information about creating an ARN, see Constructing an Amazon Resource Name (ARN) for AWS DMS in the DMS documentation.
", - "S3Settings$ServiceAccessRoleArn": "The Amazon Resource Name (ARN) used by the service access IAM role. It is a required parameter that enables DMS to write and read objects from an 3S bucket.
", + "S3Settings$ServiceAccessRoleArn": "The Amazon Resource Name (ARN) used by the service access IAM role. It is a required parameter that enables DMS to write and read objects from an S3 bucket.
", "S3Settings$ExternalTableDefinition": "Specifies how tables are defined in the S3 source files only.
", "S3Settings$CsvRowDelimiter": " The delimiter used to separate rows in the .csv file for both source and target. The default is a carriage return (\\n).
The delimiter used to separate columns in the .csv file for both source and target. The default is a comma.
", diff --git a/models/apis/dms/2016-01-01/paginators-1.json b/models/apis/dms/2016-01-01/paginators-1.json index 1cd57271f0..148e66ecf6 100644 --- a/models/apis/dms/2016-01-01/paginators-1.json +++ b/models/apis/dms/2016-01-01/paginators-1.json @@ -15,6 +15,11 @@ "output_token": "Marker", "limit_key": "MaxRecords" }, + "DescribeEndpointSettings": { + "input_token": "Marker", + "output_token": "Marker", + "limit_key": "MaxRecords" + }, "DescribeEndpointTypes": { "input_token": "Marker", "output_token": "Marker", diff --git a/models/apis/dms/2016-01-01/waiters-2.json b/models/apis/dms/2016-01-01/waiters-2.json index ebfc736ecf..73fba51002 100644 --- a/models/apis/dms/2016-01-01/waiters-2.json +++ b/models/apis/dms/2016-01-01/waiters-2.json @@ -191,12 +191,6 @@ "matcher":"pathAny", "state":"failure" }, - { - "argument":"ReplicationTasks[].Status", - "expected":"running", - "matcher":"pathAny", - "state":"failure" - }, { "argument":"ReplicationTasks[].Status", "expected":"failed", diff --git a/models/apis/sts/2011-06-15/api-2.json b/models/apis/sts/2011-06-15/api-2.json index e6aa451763..3a0ad9395c 100644 --- a/models/apis/sts/2011-06-15/api-2.json +++ b/models/apis/sts/2011-06-15/api-2.json @@ -487,7 +487,7 @@ }, "clientTokenType":{ "type":"string", - "max":2048, + "max":20000, "min":4 }, "dateType":{"type":"timestamp"}, diff --git a/models/endpoints/endpoints.json b/models/endpoints/endpoints.json index ebeb7028ce..2d9edc98cf 100644 --- a/models/endpoints/endpoints.json +++ b/models/endpoints/endpoints.json @@ -1245,6 +1245,7 @@ "ap-east-1" : { }, "ap-northeast-1" : { }, "ap-northeast-2" : { }, + "ap-northeast-3" : { }, "ap-south-1" : { }, "ap-southeast-1" : { }, "ap-southeast-2" : { }, @@ -3063,6 +3064,8 @@ }, "gamelift" : { "endpoints" : { + "af-south-1" : { }, + "ap-east-1" : { }, "ap-northeast-1" : { }, "ap-northeast-2" : { }, "ap-south-1" : { }, @@ -3070,8 +3073,12 @@ "ap-southeast-2" : { }, "ca-central-1" : { }, "eu-central-1" : { }, + "eu-north-1" : { }, + "eu-south-1" : { }, "eu-west-1" : { }, "eu-west-2" : { }, + "eu-west-3" : { }, + "me-south-1" : { }, "sa-east-1" : { }, "us-east-1" : { }, "us-east-2" : { }, @@ -9788,6 +9795,11 @@ "us-iso-east-1" : { } } }, + "firehose" : { + "endpoints" : { + "us-iso-east-1" : { } + } + }, "glacier" : { "endpoints" : { "us-iso-east-1" : { diff --git a/service/databasemigrationservice/api.go b/service/databasemigrationservice/api.go index 05acec2e43..0d44c0be1f 100644 --- a/service/databasemigrationservice/api.go +++ b/service/databasemigrationservice/api.go @@ -2004,6 +2004,139 @@ func (c *DatabaseMigrationService) DescribeConnectionsPagesWithContext(ctx aws.C return p.Err() } +const opDescribeEndpointSettings = "DescribeEndpointSettings" + +// DescribeEndpointSettingsRequest generates a "aws/request.Request" representing the +// client's request for the DescribeEndpointSettings operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See DescribeEndpointSettings for more information on using the DescribeEndpointSettings +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the DescribeEndpointSettingsRequest method. +// req, resp := client.DescribeEndpointSettingsRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEndpointSettings +func (c *DatabaseMigrationService) DescribeEndpointSettingsRequest(input *DescribeEndpointSettingsInput) (req *request.Request, output *DescribeEndpointSettingsOutput) { + op := &request.Operation{ + Name: opDescribeEndpointSettings, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"Marker"}, + OutputTokens: []string{"Marker"}, + LimitToken: "MaxRecords", + TruncationToken: "", + }, + } + + if input == nil { + input = &DescribeEndpointSettingsInput{} + } + + output = &DescribeEndpointSettingsOutput{} + req = c.newRequest(op, input, output) + return +} + +// DescribeEndpointSettings API operation for AWS Database Migration Service. +// +// Returns information about the possible endpoint settings available when you +// create an endpoint for a specific database engine. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Database Migration Service's +// API operation DescribeEndpointSettings for usage and error information. +// See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEndpointSettings +func (c *DatabaseMigrationService) DescribeEndpointSettings(input *DescribeEndpointSettingsInput) (*DescribeEndpointSettingsOutput, error) { + req, out := c.DescribeEndpointSettingsRequest(input) + return out, req.Send() +} + +// DescribeEndpointSettingsWithContext is the same as DescribeEndpointSettings with the addition of +// the ability to pass a context and additional request options. +// +// See DescribeEndpointSettings for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *DatabaseMigrationService) DescribeEndpointSettingsWithContext(ctx aws.Context, input *DescribeEndpointSettingsInput, opts ...request.Option) (*DescribeEndpointSettingsOutput, error) { + req, out := c.DescribeEndpointSettingsRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + +// DescribeEndpointSettingsPages iterates over the pages of a DescribeEndpointSettings operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See DescribeEndpointSettings method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a DescribeEndpointSettings operation. +// pageNum := 0 +// err := client.DescribeEndpointSettingsPages(params, +// func(page *databasemigrationservice.DescribeEndpointSettingsOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *DatabaseMigrationService) DescribeEndpointSettingsPages(input *DescribeEndpointSettingsInput, fn func(*DescribeEndpointSettingsOutput, bool) bool) error { + return c.DescribeEndpointSettingsPagesWithContext(aws.BackgroundContext(), input, fn) +} + +// DescribeEndpointSettingsPagesWithContext same as DescribeEndpointSettingsPages except +// it takes a Context and allows setting request options on the pages. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *DatabaseMigrationService) DescribeEndpointSettingsPagesWithContext(ctx aws.Context, input *DescribeEndpointSettingsInput, fn func(*DescribeEndpointSettingsOutput, bool) bool, opts ...request.Option) error { + p := request.Pagination{ + NewRequest: func() (*request.Request, error) { + var inCpy *DescribeEndpointSettingsInput + if input != nil { + tmp := *input + inCpy = &tmp + } + req, _ := c.DescribeEndpointSettingsRequest(inCpy) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return req, nil + }, + } + + for p.Next() { + if !fn(p.Page().(*DescribeEndpointSettingsOutput), !p.HasNextPage()) { + break + } + } + + return p.Err() +} + const opDescribeEndpointTypes = "DescribeEndpointTypes" // DescribeEndpointTypesRequest generates a "aws/request.Request" representing the @@ -4970,6 +5103,9 @@ func (c *DatabaseMigrationService) MoveReplicationTaskRequest(input *MoveReplica // * ResourceNotFoundFault // The resource could not be found. // +// * KMSKeyNotAccessibleFault +// AWS DMS cannot access the AWS KMS key. +// // See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/MoveReplicationTask func (c *DatabaseMigrationService) MoveReplicationTask(input *MoveReplicationTaskInput) (*MoveReplicationTaskOutput, error) { req, out := c.MoveReplicationTaskRequest(input) @@ -5782,6 +5918,10 @@ func (c *DatabaseMigrationService) TestConnectionRequest(input *TestConnectionIn // * ResourceQuotaExceededFault // The quota for this resource quota has been exceeded. // +// * AccessDeniedFault +// AWS DMS was denied access to the endpoint. Check that the role is correctly +// configured. +// // See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/TestConnection func (c *DatabaseMigrationService) TestConnection(input *TestConnectionInput) (*TestConnectionOutput, error) { req, out := c.TestConnectionRequest(input) @@ -8427,6 +8567,101 @@ func (s *DescribeConnectionsOutput) SetMarker(v string) *DescribeConnectionsOutp return s } +type DescribeEndpointSettingsInput struct { + _ struct{} `type:"structure"` + + // The databse engine used for your source or target endpoint. + // + // EngineName is a required field + EngineName *string `type:"string" required:"true"` + + // An optional pagination token provided by a previous request. If this parameter + // is specified, the response includes only records beyond the marker, up to + // the value specified by MaxRecords. + Marker *string `type:"string"` + + // The maximum number of records to include in the response. If more records + // exist than the specified MaxRecords value, a pagination token called a marker + // is included in the response so that the remaining results can be retrieved. + MaxRecords *int64 `type:"integer"` +} + +// String returns the string representation +func (s DescribeEndpointSettingsInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeEndpointSettingsInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DescribeEndpointSettingsInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DescribeEndpointSettingsInput"} + if s.EngineName == nil { + invalidParams.Add(request.NewErrParamRequired("EngineName")) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetEngineName sets the EngineName field's value. +func (s *DescribeEndpointSettingsInput) SetEngineName(v string) *DescribeEndpointSettingsInput { + s.EngineName = &v + return s +} + +// SetMarker sets the Marker field's value. +func (s *DescribeEndpointSettingsInput) SetMarker(v string) *DescribeEndpointSettingsInput { + s.Marker = &v + return s +} + +// SetMaxRecords sets the MaxRecords field's value. +func (s *DescribeEndpointSettingsInput) SetMaxRecords(v int64) *DescribeEndpointSettingsInput { + s.MaxRecords = &v + return s +} + +type DescribeEndpointSettingsOutput struct { + _ struct{} `type:"structure"` + + // Descriptions of the endpoint settings available for your source or target + // database engine. + EndpointSettings []*EndpointSetting `type:"list"` + + // An optional pagination token provided by a previous request. If this parameter + // is specified, the response includes only records beyond the marker, up to + // the value specified by MaxRecords. + Marker *string `type:"string"` +} + +// String returns the string representation +func (s DescribeEndpointSettingsOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeEndpointSettingsOutput) GoString() string { + return s.String() +} + +// SetEndpointSettings sets the EndpointSettings field's value. +func (s *DescribeEndpointSettingsOutput) SetEndpointSettings(v []*EndpointSetting) *DescribeEndpointSettingsOutput { + s.EndpointSettings = v + return s +} + +// SetMarker sets the Marker field's value. +func (s *DescribeEndpointSettingsOutput) SetMarker(v string) *DescribeEndpointSettingsOutput { + s.Marker = &v + return s +} + type DescribeEndpointTypesInput struct { _ struct{} `type:"structure"` @@ -10855,6 +11090,94 @@ func (s *Endpoint) SetUsername(v string) *Endpoint { return s } +// Endpoint settings. +type EndpointSetting struct { + _ struct{} `type:"structure"` + + // The relevance or validity of an endpoint setting for an engine name and its + // endpoint type. + Applicability *string `type:"string"` + + // Enumerated values to use for this endpoint. + EnumValues []*string `type:"list"` + + // The maximum value of an endpoint setting that is of type int. + IntValueMax *int64 `type:"integer"` + + // The minimum value of an endpoint setting that is of type int. + IntValueMin *int64 `type:"integer"` + + // The name that you want to give the endpoint settings. + Name *string `type:"string"` + + // A value that marks this endpoint setting as sensitive. + Sensitive *bool `type:"boolean"` + + // The type of endpoint. Valid values are source and target. + Type *string `type:"string" enum:"EndpointSettingTypeValue"` + + // The unit of measure for this endpoint setting. + Units *string `type:"string"` +} + +// String returns the string representation +func (s EndpointSetting) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s EndpointSetting) GoString() string { + return s.String() +} + +// SetApplicability sets the Applicability field's value. +func (s *EndpointSetting) SetApplicability(v string) *EndpointSetting { + s.Applicability = &v + return s +} + +// SetEnumValues sets the EnumValues field's value. +func (s *EndpointSetting) SetEnumValues(v []*string) *EndpointSetting { + s.EnumValues = v + return s +} + +// SetIntValueMax sets the IntValueMax field's value. +func (s *EndpointSetting) SetIntValueMax(v int64) *EndpointSetting { + s.IntValueMax = &v + return s +} + +// SetIntValueMin sets the IntValueMin field's value. +func (s *EndpointSetting) SetIntValueMin(v int64) *EndpointSetting { + s.IntValueMin = &v + return s +} + +// SetName sets the Name field's value. +func (s *EndpointSetting) SetName(v string) *EndpointSetting { + s.Name = &v + return s +} + +// SetSensitive sets the Sensitive field's value. +func (s *EndpointSetting) SetSensitive(v bool) *EndpointSetting { + s.Sensitive = &v + return s +} + +// SetType sets the Type field's value. +func (s *EndpointSetting) SetType(v string) *EndpointSetting { + s.Type = &v + return s +} + +// SetUnits sets the Units field's value. +func (s *EndpointSetting) SetUnits(v string) *EndpointSetting { + s.Units = &v + return s +} + // Describes an identifiable significant activity that affects a replication // instance or task. This object can provide the message, the available event // categories, the date and source of the event, and the AWS DMS resource type. @@ -11254,7 +11577,7 @@ type ImportCertificateInput struct { CertificateIdentifier *string `type:"string" required:"true"` // The contents of a .pem file, which contains an X.509 certificate. - CertificatePem *string `type:"string"` + CertificatePem *string `type:"string" sensitive:"true"` // The location of an imported Oracle Wallet certificate for use with SSL. // @@ -11960,9 +12283,12 @@ func (s *KMSThrottlingFault) RequestID() string { type KafkaSettings struct { _ struct{} `type:"structure"` - // The broker location and port of the Kafka broker that hosts your Kafka instance. - // Specify the broker in the form broker-hostname-or-ip:port . For example, - // "ec2-12-345-678-901.compute-1.amazonaws.com:2345". + // A comma-separated list of one or more broker locations in your Kafka cluster + // that host your Kafka instance. Specify each broker location in the form broker-hostname-or-ip:port + // . For example, "ec2-12-345-678-901.compute-1.amazonaws.com:2345". For more + // information and examples of specifying a list of broker locations, see Using + // Apache Kafka as a target for AWS Database Migration Service (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafka.html) + // in the AWS Data Migration Service User Guide. Broker *string `type:"string"` // Shows detailed control information for table definition, column definition, @@ -12005,6 +12331,37 @@ type KafkaSettings struct { // throttling. The default is false. PartitionIncludeSchemaTable *bool `type:"boolean"` + // The secure password you created when you first set up your MSK cluster to + // validate a client identity and make an encrypted connection between server + // and client using SASL-SSL authentication. + SaslPassword *string `type:"string" sensitive:"true"` + + // The secure username you created when you first set up your MSK cluster to + // validate a client identity and make an encrypted connection between server + // and client using SASL-SSL authentication. + SaslUsername *string `type:"string"` + + // Set secure connection to a Kafka target endpoint using Transport Layer Security + // (TLS). Options include ssl-encryption, ssl-authentication, and sasl-ssl. + // sasl-ssl requires SaslUsername and SaslPassword. + SecurityProtocol *string `type:"string" enum:"KafkaSecurityProtocol"` + + // The Amazon Resource Name (ARN) for the private Certification Authority (CA) + // cert that AWS DMS uses to securely connect to your Kafka target endpoint. + SslCaCertificateArn *string `type:"string"` + + // The Amazon Resource Name (ARN) of the client certificate used to securely + // connect to a Kafka target endpoint. + SslClientCertificateArn *string `type:"string"` + + // The Amazon Resource Name (ARN) for the client private key used to securely + // connect to a Kafka target endpoint. + SslClientKeyArn *string `type:"string"` + + // The password for the client private key used to securely connect to a Kafka + // target endpoint. + SslClientKeyPassword *string `type:"string" sensitive:"true"` + // The topic to which you migrate the data. If you don't specify a topic, AWS // DMS specifies "kafka-default-topic" as the migration topic. Topic *string `type:"string"` @@ -12074,6 +12431,48 @@ func (s *KafkaSettings) SetPartitionIncludeSchemaTable(v bool) *KafkaSettings { return s } +// SetSaslPassword sets the SaslPassword field's value. +func (s *KafkaSettings) SetSaslPassword(v string) *KafkaSettings { + s.SaslPassword = &v + return s +} + +// SetSaslUsername sets the SaslUsername field's value. +func (s *KafkaSettings) SetSaslUsername(v string) *KafkaSettings { + s.SaslUsername = &v + return s +} + +// SetSecurityProtocol sets the SecurityProtocol field's value. +func (s *KafkaSettings) SetSecurityProtocol(v string) *KafkaSettings { + s.SecurityProtocol = &v + return s +} + +// SetSslCaCertificateArn sets the SslCaCertificateArn field's value. +func (s *KafkaSettings) SetSslCaCertificateArn(v string) *KafkaSettings { + s.SslCaCertificateArn = &v + return s +} + +// SetSslClientCertificateArn sets the SslClientCertificateArn field's value. +func (s *KafkaSettings) SetSslClientCertificateArn(v string) *KafkaSettings { + s.SslClientCertificateArn = &v + return s +} + +// SetSslClientKeyArn sets the SslClientKeyArn field's value. +func (s *KafkaSettings) SetSslClientKeyArn(v string) *KafkaSettings { + s.SslClientKeyArn = &v + return s +} + +// SetSslClientKeyPassword sets the SslClientKeyPassword field's value. +func (s *KafkaSettings) SetSslClientKeyPassword(v string) *KafkaSettings { + s.SslClientKeyPassword = &v + return s +} + // SetTopic sets the Topic field's value. func (s *KafkaSettings) SetTopic(v string) *KafkaSettings { s.Topic = &v @@ -12277,6 +12676,12 @@ type MicrosoftSQLServerSettings struct { // Endpoint TCP port. Port *int64 `type:"integer"` + // Cleans and recreates table metadata information on the replication instance + // when a mismatch occurs. An example is a situation where running an alter + // DDL statement on a table might result in different information about the + // table cached in the replication instance. + QuerySingleAlwaysOnNode *bool `type:"boolean"` + // When this attribute is set to Y, AWS DMS only reads changes from transaction // log backups and doesn't read from the active transaction log file during // ongoing replication. Setting this parameter to Y enables you to control active @@ -12329,6 +12734,10 @@ type MicrosoftSQLServerSettings struct { // the source table, you must disable the use BCP for loading table option. UseBcpFullLoad *bool `type:"boolean"` + // When this attribute is set to Y, DMS processes third-party transaction log + // backups if they are created in native format. + UseThirdPartyBackupDevice *bool `type:"boolean"` + // Endpoint connection user name. Username *string `type:"string"` } @@ -12373,6 +12782,12 @@ func (s *MicrosoftSQLServerSettings) SetPort(v int64) *MicrosoftSQLServerSetting return s } +// SetQuerySingleAlwaysOnNode sets the QuerySingleAlwaysOnNode field's value. +func (s *MicrosoftSQLServerSettings) SetQuerySingleAlwaysOnNode(v bool) *MicrosoftSQLServerSettings { + s.QuerySingleAlwaysOnNode = &v + return s +} + // SetReadBackupOnly sets the ReadBackupOnly field's value. func (s *MicrosoftSQLServerSettings) SetReadBackupOnly(v bool) *MicrosoftSQLServerSettings { s.ReadBackupOnly = &v @@ -12409,6 +12824,12 @@ func (s *MicrosoftSQLServerSettings) SetUseBcpFullLoad(v bool) *MicrosoftSQLServ return s } +// SetUseThirdPartyBackupDevice sets the UseThirdPartyBackupDevice field's value. +func (s *MicrosoftSQLServerSettings) SetUseThirdPartyBackupDevice(v bool) *MicrosoftSQLServerSettings { + s.UseThirdPartyBackupDevice = &v + return s +} + // SetUsername sets the Username field's value. func (s *MicrosoftSQLServerSettings) SetUsername(v string) *MicrosoftSQLServerSettings { s.Username = &v @@ -13273,9 +13694,9 @@ type ModifyReplicationTaskInput struct { ReplicationTaskSettings *string `type:"string"` // When using the AWS CLI or boto3, provide the path of the JSON file that contains - // the table mappings. Precede the path with file://. When working with the - // DMS API, provide the JSON as the parameter value, for example: --table-mappings - // file://mappingfile.json + // the table mappings. Precede the path with file://. For example, --table-mappings + // file://mappingfile.json. When working with the DMS API, provide the JSON + // as the parameter value. TableMappings *string `type:"string"` // Supplemental information that the task requires to migrate the data for certain @@ -13645,6 +14066,12 @@ type MySQLSettings struct { // or fails. AfterConnectScript *string `type:"string"` + // Adjusts the behavior of DMS when migrating from an SQL Server source database + // that is hosted as part of an Always On availability group cluster. If you + // need DMS to poll all the nodes in the Always On cluster for transaction backups, + // set this attribute to false. + CleanSourceMetadataOnMismatch *bool `type:"boolean"` + // Database name for the endpoint. DatabaseName *string `type:"string"` @@ -13733,6 +14160,12 @@ func (s *MySQLSettings) SetAfterConnectScript(v string) *MySQLSettings { return s } +// SetCleanSourceMetadataOnMismatch sets the CleanSourceMetadataOnMismatch field's value. +func (s *MySQLSettings) SetCleanSourceMetadataOnMismatch(v bool) *MySQLSettings { + s.CleanSourceMetadataOnMismatch = &v + return s +} + // SetDatabaseName sets the DatabaseName field's value. func (s *MySQLSettings) SetDatabaseName(v string) *MySQLSettings { s.DatabaseName = &v @@ -14121,6 +14554,12 @@ type OracleSettings struct { // Fully qualified domain name of the endpoint. ServerName *string `type:"string"` + // Use this attribute to convert SDO_GEOMETRY to GEOJSON format. By default, + // DMS calls the SDO2GEOJSON custom function if present and accessible. Or you + // can create your own custom function that mimics the operation of SDOGEOJSON + // and set SpatialDataOptionToGeoJsonFunctionName to call it instead. + SpatialDataOptionToGeoJsonFunctionName *string `type:"string"` + // Set this attribute to true in order to use the Binary Reader to capture change // data for an Amazon RDS for Oracle as the source. This tells the DMS instance // to use any specified prefix replacement to access all online redo logs. @@ -14332,6 +14771,12 @@ func (s *OracleSettings) SetServerName(v string) *OracleSettings { return s } +// SetSpatialDataOptionToGeoJsonFunctionName sets the SpatialDataOptionToGeoJsonFunctionName field's value. +func (s *OracleSettings) SetSpatialDataOptionToGeoJsonFunctionName(v string) *OracleSettings { + s.SpatialDataOptionToGeoJsonFunctionName = &v + return s +} + // SetUseAlternateFolderForOnline sets the UseAlternateFolderForOnline field's value. func (s *OracleSettings) SetUseAlternateFolderForOnline(v bool) *OracleSettings { s.UseAlternateFolderForOnline = &v @@ -17338,7 +17783,7 @@ type S3Settings struct { ServerSideEncryptionKmsKeyId *string `type:"string"` // The Amazon Resource Name (ARN) used by the service access IAM role. It is - // a required parameter that enables DMS to write and read objects from an 3S + // a required parameter that enables DMS to write and read objects from an S3 // bucket. ServiceAccessRoleArn *string `type:"string"` @@ -19103,6 +19548,54 @@ func EncryptionModeValue_Values() []string { } } +const ( + // EndpointSettingTypeValueString is a EndpointSettingTypeValue enum value + EndpointSettingTypeValueString = "string" + + // EndpointSettingTypeValueBoolean is a EndpointSettingTypeValue enum value + EndpointSettingTypeValueBoolean = "boolean" + + // EndpointSettingTypeValueInteger is a EndpointSettingTypeValue enum value + EndpointSettingTypeValueInteger = "integer" + + // EndpointSettingTypeValueEnum is a EndpointSettingTypeValue enum value + EndpointSettingTypeValueEnum = "enum" +) + +// EndpointSettingTypeValue_Values returns all elements of the EndpointSettingTypeValue enum +func EndpointSettingTypeValue_Values() []string { + return []string{ + EndpointSettingTypeValueString, + EndpointSettingTypeValueBoolean, + EndpointSettingTypeValueInteger, + EndpointSettingTypeValueEnum, + } +} + +const ( + // KafkaSecurityProtocolPlaintext is a KafkaSecurityProtocol enum value + KafkaSecurityProtocolPlaintext = "plaintext" + + // KafkaSecurityProtocolSslAuthentication is a KafkaSecurityProtocol enum value + KafkaSecurityProtocolSslAuthentication = "ssl-authentication" + + // KafkaSecurityProtocolSslEncryption is a KafkaSecurityProtocol enum value + KafkaSecurityProtocolSslEncryption = "ssl-encryption" + + // KafkaSecurityProtocolSaslSsl is a KafkaSecurityProtocol enum value + KafkaSecurityProtocolSaslSsl = "sasl-ssl" +) + +// KafkaSecurityProtocol_Values returns all elements of the KafkaSecurityProtocol enum +func KafkaSecurityProtocol_Values() []string { + return []string{ + KafkaSecurityProtocolPlaintext, + KafkaSecurityProtocolSslAuthentication, + KafkaSecurityProtocolSslEncryption, + KafkaSecurityProtocolSaslSsl, + } +} + const ( // MessageFormatValueJson is a MessageFormatValue enum value MessageFormatValueJson = "json" diff --git a/service/databasemigrationservice/databasemigrationserviceiface/interface.go b/service/databasemigrationservice/databasemigrationserviceiface/interface.go index 27103cb6b2..ec1b0de8a3 100644 --- a/service/databasemigrationservice/databasemigrationserviceiface/interface.go +++ b/service/databasemigrationservice/databasemigrationserviceiface/interface.go @@ -149,6 +149,13 @@ type DatabaseMigrationServiceAPI interface { DescribeConnectionsPages(*databasemigrationservice.DescribeConnectionsInput, func(*databasemigrationservice.DescribeConnectionsOutput, bool) bool) error DescribeConnectionsPagesWithContext(aws.Context, *databasemigrationservice.DescribeConnectionsInput, func(*databasemigrationservice.DescribeConnectionsOutput, bool) bool, ...request.Option) error + DescribeEndpointSettings(*databasemigrationservice.DescribeEndpointSettingsInput) (*databasemigrationservice.DescribeEndpointSettingsOutput, error) + DescribeEndpointSettingsWithContext(aws.Context, *databasemigrationservice.DescribeEndpointSettingsInput, ...request.Option) (*databasemigrationservice.DescribeEndpointSettingsOutput, error) + DescribeEndpointSettingsRequest(*databasemigrationservice.DescribeEndpointSettingsInput) (*request.Request, *databasemigrationservice.DescribeEndpointSettingsOutput) + + DescribeEndpointSettingsPages(*databasemigrationservice.DescribeEndpointSettingsInput, func(*databasemigrationservice.DescribeEndpointSettingsOutput, bool) bool) error + DescribeEndpointSettingsPagesWithContext(aws.Context, *databasemigrationservice.DescribeEndpointSettingsInput, func(*databasemigrationservice.DescribeEndpointSettingsOutput, bool) bool, ...request.Option) error + DescribeEndpointTypes(*databasemigrationservice.DescribeEndpointTypesInput) (*databasemigrationservice.DescribeEndpointTypesOutput, error) DescribeEndpointTypesWithContext(aws.Context, *databasemigrationservice.DescribeEndpointTypesInput, ...request.Option) (*databasemigrationservice.DescribeEndpointTypesOutput, error) DescribeEndpointTypesRequest(*databasemigrationservice.DescribeEndpointTypesInput) (*request.Request, *databasemigrationservice.DescribeEndpointTypesOutput) diff --git a/service/databasemigrationservice/examples_test.go b/service/databasemigrationservice/examples_test.go index 6202e9a45f..27de2fdc50 100644 --- a/service/databasemigrationservice/examples_test.go +++ b/service/databasemigrationservice/examples_test.go @@ -1262,6 +1262,8 @@ func ExampleDatabaseMigrationService_TestConnection_shared00() { fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) + case databasemigrationservice.ErrCodeAccessDeniedFault: + fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } diff --git a/service/databasemigrationservice/waiters.go b/service/databasemigrationservice/waiters.go index d034d3f654..27a56246f1 100644 --- a/service/databasemigrationservice/waiters.go +++ b/service/databasemigrationservice/waiters.go @@ -467,11 +467,6 @@ func (c *DatabaseMigrationService) WaitUntilReplicationTaskStoppedWithContext(ct Matcher: request.PathAnyWaiterMatch, Argument: "ReplicationTasks[].Status", Expected: "starting", }, - { - State: request.FailureWaiterState, - Matcher: request.PathAnyWaiterMatch, Argument: "ReplicationTasks[].Status", - Expected: "running", - }, { State: request.FailureWaiterState, Matcher: request.PathAnyWaiterMatch, Argument: "ReplicationTasks[].Status",