AWS SDK for Go (PILOT)
API Reference

PREVIEW DOCUMENTATION - This is a preview of a new format for the AWS SDK for Go API Reference documentation. For the current AWS SDK for Go API Reference, see https://docs.aws.amazon.com/sdk-for-go/api/.

We welcome your feedback on this new version of the documentation. Send your comments to aws-sdkdocs-feedback@amazon.com.

DatabaseMigrationService

import "github.com/aws/aws-sdk-go/service/databasemigrationservice"

type DatabaseMigrationService struct { *client.Client }

DatabaseMigrationService provides the API operation methods for making requests to AWS Database Migration Service. See this package's package overview docs for details on the service.

DatabaseMigrationService methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

Client

Type: *client.Client

Method

AddTagsToResource

func (c *DatabaseMigrationService) AddTagsToResource(input *AddTagsToResourceInput) (*AddTagsToResourceOutput, error)

AddTagsToResource API operation for AWS Database Migration Service.

Adds metadata tags to an AWS DMS resource, including replication instance, endpoint, security group, and migration task. These tags can also be used with cost allocation reporting to track cost associated with DMS resources, or used in a Condition statement in an IAM policy for DMS.

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 AddTagsToResource for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/AddTagsToResource

Example

DatabaseMigrationService AddTagsToResource shared00

Add tags to resource

Adds metadata tags to an AWS DMS resource, including replication instance, endpoint, security group, and migration task. These tags can also be used with cost allocation reporting to track cost associated with AWS DMS resources, or used in a Condition statement in an IAM policy for AWS DMS.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.AddTagsToResourceInput{ ResourceArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:ASXWXJZLNWNT5HTWCGV2BUJQ7E"), Tags: []*databasemigrationservice.Tag{ { Key: aws.String("Acount"), Value: aws.String("1633456"), }, }, } result, err := svc.AddTagsToResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

AddTagsToResourceRequest

func (c *DatabaseMigrationService) AddTagsToResourceRequest(input *AddTagsToResourceInput) (req *request.Request, output *AddTagsToResourceOutput)

AddTagsToResourceRequest generates a "aws/request.Request" representing the client's request for the AddTagsToResource 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 AddTagsToResource for more information on using the AddTagsToResource 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 AddTagsToResourceRequest method. req, resp := client.AddTagsToResourceRequest(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/AddTagsToResource

AddTagsToResourceWithContext

func (c *DatabaseMigrationService) AddTagsToResourceWithContext(ctx aws.Context, input *AddTagsToResourceInput, opts ...request.Option) (*AddTagsToResourceOutput, error)

AddTagsToResourceWithContext is the same as AddTagsToResource with the addition of the ability to pass a context and additional request options.

See AddTagsToResource 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.

See Also

For more information about using this API, see AWS API Documentation.

CreateEndpoint

func (c *DatabaseMigrationService) CreateEndpoint(input *CreateEndpointInput) (*CreateEndpointOutput, error)

CreateEndpoint API operation for AWS Database Migration Service.

Creates an endpoint using the provided settings.

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 CreateEndpoint for usage and error information.

Returned Error Codes:

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/CreateEndpoint

Example

DatabaseMigrationService CreateEndpoint shared00

Create endpoint

Creates an endpoint using the provided settings.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.CreateEndpointInput{ CertificateArn: aws.String(""), DatabaseName: aws.String("testdb"), EndpointIdentifier: aws.String("test-endpoint-1"), EndpointType: aws.String("source"), EngineName: aws.String("mysql"), ExtraConnectionAttributes: aws.String(""), KmsKeyId: aws.String("arn:aws:kms:us-east-1:123456789012:key/4c1731d6-5435-ed4d-be13-d53411a7cfbd"), Password: aws.String("pasword"), Port: aws.Int64(3306), ServerName: aws.String("mydb.cx1llnox7iyx.us-west-2.rds.amazonaws.com"), SslMode: aws.String("require"), Tags: []*databasemigrationservice.Tag{ { Key: aws.String("Acount"), Value: aws.String("143327655"), }, }, Username: aws.String("username"), } result, err := svc.CreateEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

CreateEndpointRequest

func (c *DatabaseMigrationService) CreateEndpointRequest(input *CreateEndpointInput) (req *request.Request, output *CreateEndpointOutput)

CreateEndpointRequest generates a "aws/request.Request" representing the client's request for the CreateEndpoint 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 CreateEndpoint for more information on using the CreateEndpoint 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 CreateEndpointRequest method. req, resp := client.CreateEndpointRequest(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/CreateEndpoint

CreateEndpointWithContext

func (c *DatabaseMigrationService) CreateEndpointWithContext(ctx aws.Context, input *CreateEndpointInput, opts ...request.Option) (*CreateEndpointOutput, error)

CreateEndpointWithContext is the same as CreateEndpoint with the addition of the ability to pass a context and additional request options.

See CreateEndpoint 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.

See Also

For more information about using this API, see AWS API Documentation.

CreateEventSubscription

func (c *DatabaseMigrationService) CreateEventSubscription(input *CreateEventSubscriptionInput) (*CreateEventSubscriptionOutput, error)

CreateEventSubscription API operation for AWS Database Migration Service.

Creates an AWS DMS event notification subscription.

You can specify the type of source (SourceType) you want to be notified of, provide a list of AWS DMS source IDs (SourceIds) that triggers the events, and provide a list of event categories (EventCategories) for events you want to be notified of. If you specify both the SourceType and SourceIds, such as SourceType = replication-instance and SourceIdentifier = my-replinstance, you will be notified of all the replication instance events for the specified source. If you specify a SourceType but don't specify a SourceIdentifier, you receive notice of the events for that source type for all your AWS DMS sources. If you don't specify either SourceType nor SourceIdentifier, you will be notified of events generated from all AWS DMS sources belonging to your customer account.

For more information about AWS DMS events, see Working with Events and Notifications (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the AWS Database Migration Service User Guide.

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 CreateEventSubscription for usage and error information.

Returned Error Codes:

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeSNSInvalidTopicFault "SNSInvalidTopicFault" The SNS topic is invalid.

  • ErrCodeSNSNoAuthorizationFault "SNSNoAuthorizationFault" You are not authorized for the SNS subscription.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/CreateEventSubscription

CreateEventSubscriptionRequest

func (c *DatabaseMigrationService) CreateEventSubscriptionRequest(input *CreateEventSubscriptionInput) (req *request.Request, output *CreateEventSubscriptionOutput)

CreateEventSubscriptionRequest generates a "aws/request.Request" representing the client's request for the CreateEventSubscription 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 CreateEventSubscription for more information on using the CreateEventSubscription 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 CreateEventSubscriptionRequest method. req, resp := client.CreateEventSubscriptionRequest(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/CreateEventSubscription

CreateEventSubscriptionWithContext

func (c *DatabaseMigrationService) CreateEventSubscriptionWithContext(ctx aws.Context, input *CreateEventSubscriptionInput, opts ...request.Option) (*CreateEventSubscriptionOutput, error)

CreateEventSubscriptionWithContext is the same as CreateEventSubscription with the addition of the ability to pass a context and additional request options.

See CreateEventSubscription 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.

See Also

For more information about using this API, see AWS API Documentation.

CreateReplicationInstance

func (c *DatabaseMigrationService) CreateReplicationInstance(input *CreateReplicationInstanceInput) (*CreateReplicationInstanceOutput, error)

CreateReplicationInstance API operation for AWS Database Migration Service.

Creates the replication instance using the specified parameters.

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 CreateReplicationInstance for usage and error information.

Returned Error Codes:

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeInsufficientResourceCapacityFault "InsufficientResourceCapacityFault" There are not enough resources allocated to the database migration.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeStorageQuotaExceededFault "StorageQuotaExceededFault" The storage quota has been exceeded.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs "ReplicationSubnetGroupDoesNotCoverEnoughAZs" The replication subnet group does not cover enough Availability Zones (AZs). Edit the replication subnet group and add more AZs.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeInvalidSubnet "InvalidSubnet" The subnet provided is invalid.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/CreateReplicationInstance

Example

DatabaseMigrationService CreateReplicationInstance shared00

Create replication instance

Creates the replication instance using the specified parameters.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.CreateReplicationInstanceInput{ AllocatedStorage: aws.Int64(123), AutoMinorVersionUpgrade: aws.Bool(true), AvailabilityZone: aws.String(""), EngineVersion: aws.String(""), KmsKeyId: aws.String(""), MultiAZ: aws.Bool(true), PreferredMaintenanceWindow: aws.String(""), PubliclyAccessible: aws.Bool(true), ReplicationInstanceClass: aws.String(""), ReplicationInstanceIdentifier: aws.String(""), ReplicationSubnetGroupIdentifier: aws.String(""), Tags: []*databasemigrationservice.Tag{ { Key: aws.String("string"), Value: aws.String("string"), }, }, } result, err := svc.CreateReplicationInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeInsufficientResourceCapacityFault: fmt.Println(databasemigrationservice.ErrCodeInsufficientResourceCapacityFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeStorageQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeStorageQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidSubnet: fmt.Println(databasemigrationservice.ErrCodeInvalidSubnet, aerr.Error()) case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

CreateReplicationInstanceRequest

func (c *DatabaseMigrationService) CreateReplicationInstanceRequest(input *CreateReplicationInstanceInput) (req *request.Request, output *CreateReplicationInstanceOutput)

CreateReplicationInstanceRequest generates a "aws/request.Request" representing the client's request for the CreateReplicationInstance 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 CreateReplicationInstance for more information on using the CreateReplicationInstance 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 CreateReplicationInstanceRequest method. req, resp := client.CreateReplicationInstanceRequest(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/CreateReplicationInstance

CreateReplicationInstanceWithContext

func (c *DatabaseMigrationService) CreateReplicationInstanceWithContext(ctx aws.Context, input *CreateReplicationInstanceInput, opts ...request.Option) (*CreateReplicationInstanceOutput, error)

CreateReplicationInstanceWithContext is the same as CreateReplicationInstance with the addition of the ability to pass a context and additional request options.

See CreateReplicationInstance 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.

See Also

For more information about using this API, see AWS API Documentation.

CreateReplicationSubnetGroup

func (c *DatabaseMigrationService) CreateReplicationSubnetGroup(input *CreateReplicationSubnetGroupInput) (*CreateReplicationSubnetGroupOutput, error)

CreateReplicationSubnetGroup API operation for AWS Database Migration Service.

Creates a replication subnet group given a list of the subnet IDs in a VPC.

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 CreateReplicationSubnetGroup for usage and error information.

Returned Error Codes:

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs "ReplicationSubnetGroupDoesNotCoverEnoughAZs" The replication subnet group does not cover enough Availability Zones (AZs). Edit the replication subnet group and add more AZs.

  • ErrCodeInvalidSubnet "InvalidSubnet" The subnet provided is invalid.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/CreateReplicationSubnetGroup

Example

DatabaseMigrationService CreateReplicationSubnetGroup shared00

Create replication subnet group

Creates a replication subnet group given a list of the subnet IDs in a VPC.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.CreateReplicationSubnetGroupInput{ ReplicationSubnetGroupDescription: aws.String("US West subnet group"), ReplicationSubnetGroupIdentifier: aws.String("us-west-2ab-vpc-215ds366"), SubnetIds: []*string{ aws.String("subnet-e145356n"), aws.String("subnet-58f79200"), }, Tags: []*databasemigrationservice.Tag{ { Key: aws.String("Acount"), Value: aws.String("145235"), }, }, } result, err := svc.CreateReplicationSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case databasemigrationservice.ErrCodeInvalidSubnet: fmt.Println(databasemigrationservice.ErrCodeInvalidSubnet, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

CreateReplicationSubnetGroupRequest

func (c *DatabaseMigrationService) CreateReplicationSubnetGroupRequest(input *CreateReplicationSubnetGroupInput) (req *request.Request, output *CreateReplicationSubnetGroupOutput)

CreateReplicationSubnetGroupRequest generates a "aws/request.Request" representing the client's request for the CreateReplicationSubnetGroup 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 CreateReplicationSubnetGroup for more information on using the CreateReplicationSubnetGroup 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 CreateReplicationSubnetGroupRequest method. req, resp := client.CreateReplicationSubnetGroupRequest(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/CreateReplicationSubnetGroup

CreateReplicationSubnetGroupWithContext

func (c *DatabaseMigrationService) CreateReplicationSubnetGroupWithContext(ctx aws.Context, input *CreateReplicationSubnetGroupInput, opts ...request.Option) (*CreateReplicationSubnetGroupOutput, error)

CreateReplicationSubnetGroupWithContext is the same as CreateReplicationSubnetGroup with the addition of the ability to pass a context and additional request options.

See CreateReplicationSubnetGroup 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.

See Also

For more information about using this API, see AWS API Documentation.

CreateReplicationTask

func (c *DatabaseMigrationService) CreateReplicationTask(input *CreateReplicationTaskInput) (*CreateReplicationTaskOutput, error)

CreateReplicationTask API operation for AWS Database Migration Service.

Creates a replication task using the specified parameters.

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 CreateReplicationTask for usage and error information.

Returned Error Codes:

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/CreateReplicationTask

Example

DatabaseMigrationService CreateReplicationTask shared00

Create replication task

Creates a replication task using the specified parameters.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.CreateReplicationTaskInput{ CdcStartTime: parseTime("2006-01-02T15:04:05Z", "2016-12-14T18:25:43Z"), MigrationType: aws.String("full-load"), ReplicationInstanceArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), ReplicationTaskIdentifier: aws.String("task1"), ReplicationTaskSettings: aws.String(""), SourceEndpointArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:ZW5UAN6P4E77EC7YWHK4RZZ3BE"), TableMappings: aws.String("file://mappingfile.json"), Tags: []*databasemigrationservice.Tag{ { Key: aws.String("Acount"), Value: aws.String("24352226"), }, }, TargetEndpointArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:ASXWXJZLNWNT5HTWCGV2BUJQ7E"), } result, err := svc.CreateReplicationTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

CreateReplicationTaskRequest

func (c *DatabaseMigrationService) CreateReplicationTaskRequest(input *CreateReplicationTaskInput) (req *request.Request, output *CreateReplicationTaskOutput)

CreateReplicationTaskRequest generates a "aws/request.Request" representing the client's request for the CreateReplicationTask 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 CreateReplicationTask for more information on using the CreateReplicationTask 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 CreateReplicationTaskRequest method. req, resp := client.CreateReplicationTaskRequest(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/CreateReplicationTask

CreateReplicationTaskWithContext

func (c *DatabaseMigrationService) CreateReplicationTaskWithContext(ctx aws.Context, input *CreateReplicationTaskInput, opts ...request.Option) (*CreateReplicationTaskOutput, error)

CreateReplicationTaskWithContext is the same as CreateReplicationTask with the addition of the ability to pass a context and additional request options.

See CreateReplicationTask 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteCertificate

func (c *DatabaseMigrationService) DeleteCertificate(input *DeleteCertificateInput) (*DeleteCertificateOutput, error)

DeleteCertificate API operation for AWS Database Migration Service.

Deletes the specified certificate.

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 DeleteCertificate for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteCertificate

Example

DatabaseMigrationService DeleteCertificate shared00

Delete Certificate

Deletes the specified certificate.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DeleteCertificateInput{ CertificateArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUSM457DE6XFJCJQ"), } result, err := svc.DeleteCertificate(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DeleteCertificateRequest

func (c *DatabaseMigrationService) DeleteCertificateRequest(input *DeleteCertificateInput) (req *request.Request, output *DeleteCertificateOutput)

DeleteCertificateRequest generates a "aws/request.Request" representing the client's request for the DeleteCertificate 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 DeleteCertificate for more information on using the DeleteCertificate 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 DeleteCertificateRequest method. req, resp := client.DeleteCertificateRequest(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/DeleteCertificate

DeleteCertificateWithContext

func (c *DatabaseMigrationService) DeleteCertificateWithContext(ctx aws.Context, input *DeleteCertificateInput, opts ...request.Option) (*DeleteCertificateOutput, error)

DeleteCertificateWithContext is the same as DeleteCertificate with the addition of the ability to pass a context and additional request options.

See DeleteCertificate 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteEndpoint

func (c *DatabaseMigrationService) DeleteEndpoint(input *DeleteEndpointInput) (*DeleteEndpointOutput, error)

DeleteEndpoint API operation for AWS Database Migration Service.

Deletes the specified endpoint.

All tasks associated with the endpoint must be deleted before you can delete the endpoint.

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 DeleteEndpoint for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteEndpoint

Example

DatabaseMigrationService DeleteEndpoint shared00

Delete Endpoint

Deletes the specified endpoint. All tasks associated with the endpoint must be deleted before you can delete the endpoint.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DeleteEndpointInput{ EndpointArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:RAAR3R22XSH46S3PWLC3NJAWKM"), } result, err := svc.DeleteEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DeleteEndpointRequest

func (c *DatabaseMigrationService) DeleteEndpointRequest(input *DeleteEndpointInput) (req *request.Request, output *DeleteEndpointOutput)

DeleteEndpointRequest generates a "aws/request.Request" representing the client's request for the DeleteEndpoint 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 DeleteEndpoint for more information on using the DeleteEndpoint 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 DeleteEndpointRequest method. req, resp := client.DeleteEndpointRequest(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/DeleteEndpoint

DeleteEndpointWithContext

func (c *DatabaseMigrationService) DeleteEndpointWithContext(ctx aws.Context, input *DeleteEndpointInput, opts ...request.Option) (*DeleteEndpointOutput, error)

DeleteEndpointWithContext is the same as DeleteEndpoint with the addition of the ability to pass a context and additional request options.

See DeleteEndpoint 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteEventSubscription

func (c *DatabaseMigrationService) DeleteEventSubscription(input *DeleteEventSubscriptionInput) (*DeleteEventSubscriptionOutput, error)

DeleteEventSubscription API operation for AWS Database Migration Service.

Deletes an AWS DMS event subscription.

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 DeleteEventSubscription for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteEventSubscription

DeleteEventSubscriptionRequest

func (c *DatabaseMigrationService) DeleteEventSubscriptionRequest(input *DeleteEventSubscriptionInput) (req *request.Request, output *DeleteEventSubscriptionOutput)

DeleteEventSubscriptionRequest generates a "aws/request.Request" representing the client's request for the DeleteEventSubscription 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 DeleteEventSubscription for more information on using the DeleteEventSubscription 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 DeleteEventSubscriptionRequest method. req, resp := client.DeleteEventSubscriptionRequest(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/DeleteEventSubscription

DeleteEventSubscriptionWithContext

func (c *DatabaseMigrationService) DeleteEventSubscriptionWithContext(ctx aws.Context, input *DeleteEventSubscriptionInput, opts ...request.Option) (*DeleteEventSubscriptionOutput, error)

DeleteEventSubscriptionWithContext is the same as DeleteEventSubscription with the addition of the ability to pass a context and additional request options.

See DeleteEventSubscription 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteReplicationInstance

func (c *DatabaseMigrationService) DeleteReplicationInstance(input *DeleteReplicationInstanceInput) (*DeleteReplicationInstanceOutput, error)

DeleteReplicationInstance API operation for AWS Database Migration Service.

Deletes the specified replication instance.

You must delete any migration tasks that are associated with the replication instance before you can delete it.

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 DeleteReplicationInstance for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteReplicationInstance

Example

DatabaseMigrationService DeleteReplicationInstance shared00

Delete Replication Instance

Deletes the specified replication instance. You must delete any migration tasks that are associated with the replication instance before you can delete it.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DeleteReplicationInstanceInput{ ReplicationInstanceArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), } result, err := svc.DeleteReplicationInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DeleteReplicationInstanceRequest

func (c *DatabaseMigrationService) DeleteReplicationInstanceRequest(input *DeleteReplicationInstanceInput) (req *request.Request, output *DeleteReplicationInstanceOutput)

DeleteReplicationInstanceRequest generates a "aws/request.Request" representing the client's request for the DeleteReplicationInstance 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 DeleteReplicationInstance for more information on using the DeleteReplicationInstance 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 DeleteReplicationInstanceRequest method. req, resp := client.DeleteReplicationInstanceRequest(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/DeleteReplicationInstance

DeleteReplicationInstanceWithContext

func (c *DatabaseMigrationService) DeleteReplicationInstanceWithContext(ctx aws.Context, input *DeleteReplicationInstanceInput, opts ...request.Option) (*DeleteReplicationInstanceOutput, error)

DeleteReplicationInstanceWithContext is the same as DeleteReplicationInstance with the addition of the ability to pass a context and additional request options.

See DeleteReplicationInstance 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteReplicationSubnetGroup

func (c *DatabaseMigrationService) DeleteReplicationSubnetGroup(input *DeleteReplicationSubnetGroupInput) (*DeleteReplicationSubnetGroupOutput, error)

DeleteReplicationSubnetGroup API operation for AWS Database Migration Service.

Deletes a subnet group.

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 DeleteReplicationSubnetGroup for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteReplicationSubnetGroup

Example

DatabaseMigrationService DeleteReplicationSubnetGroup shared00

Delete Replication Subnet Group

Deletes a replication subnet group.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DeleteReplicationSubnetGroupInput{ ReplicationSubnetGroupIdentifier: aws.String("us-west-2ab-vpc-215ds366"), } result, err := svc.DeleteReplicationSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DeleteReplicationSubnetGroupRequest

func (c *DatabaseMigrationService) DeleteReplicationSubnetGroupRequest(input *DeleteReplicationSubnetGroupInput) (req *request.Request, output *DeleteReplicationSubnetGroupOutput)

DeleteReplicationSubnetGroupRequest generates a "aws/request.Request" representing the client's request for the DeleteReplicationSubnetGroup 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 DeleteReplicationSubnetGroup for more information on using the DeleteReplicationSubnetGroup 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 DeleteReplicationSubnetGroupRequest method. req, resp := client.DeleteReplicationSubnetGroupRequest(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/DeleteReplicationSubnetGroup

DeleteReplicationSubnetGroupWithContext

func (c *DatabaseMigrationService) DeleteReplicationSubnetGroupWithContext(ctx aws.Context, input *DeleteReplicationSubnetGroupInput, opts ...request.Option) (*DeleteReplicationSubnetGroupOutput, error)

DeleteReplicationSubnetGroupWithContext is the same as DeleteReplicationSubnetGroup with the addition of the ability to pass a context and additional request options.

See DeleteReplicationSubnetGroup 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.

See Also

For more information about using this API, see AWS API Documentation.

DeleteReplicationTask

func (c *DatabaseMigrationService) DeleteReplicationTask(input *DeleteReplicationTaskInput) (*DeleteReplicationTaskOutput, error)

DeleteReplicationTask API operation for AWS Database Migration Service.

Deletes the specified replication task.

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 DeleteReplicationTask for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DeleteReplicationTask

Example

DatabaseMigrationService DeleteReplicationTask shared00

Delete Replication Task

Deletes the specified replication task.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DeleteReplicationTaskInput{ ReplicationTaskArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), } result, err := svc.DeleteReplicationTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DeleteReplicationTaskRequest

func (c *DatabaseMigrationService) DeleteReplicationTaskRequest(input *DeleteReplicationTaskInput) (req *request.Request, output *DeleteReplicationTaskOutput)

DeleteReplicationTaskRequest generates a "aws/request.Request" representing the client's request for the DeleteReplicationTask 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 DeleteReplicationTask for more information on using the DeleteReplicationTask 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 DeleteReplicationTaskRequest method. req, resp := client.DeleteReplicationTaskRequest(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/DeleteReplicationTask

DeleteReplicationTaskWithContext

func (c *DatabaseMigrationService) DeleteReplicationTaskWithContext(ctx aws.Context, input *DeleteReplicationTaskInput, opts ...request.Option) (*DeleteReplicationTaskOutput, error)

DeleteReplicationTaskWithContext is the same as DeleteReplicationTask with the addition of the ability to pass a context and additional request options.

See DeleteReplicationTask 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeAccountAttributes

func (c *DatabaseMigrationService) DescribeAccountAttributes(input *DescribeAccountAttributesInput) (*DescribeAccountAttributesOutput, error)

DescribeAccountAttributes API operation for AWS Database Migration Service.

Lists all of the AWS DMS attributes for a customer account. The attributes include AWS DMS quotas for the account, such as the number of replication instances allowed. The description for a quota includes the quota name, current usage toward that quota, and the quota's maximum value.

This command does not take any parameters.

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 DescribeAccountAttributes for usage and error information. See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeAccountAttributes

Example

DatabaseMigrationService DescribeAccountAttributes shared00

Describe acount attributes

Lists all of the AWS DMS attributes for a customer account. The attributes include AWS DMS quotas for the account, such as the number of replication instances allowed. The description for a quota includes the quota name, current usage toward that quota, and the quota's maximum value. This operation does not take any parameters.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeAccountAttributesInput{} result, err := svc.DescribeAccountAttributes(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeAccountAttributesRequest

func (c *DatabaseMigrationService) DescribeAccountAttributesRequest(input *DescribeAccountAttributesInput) (req *request.Request, output *DescribeAccountAttributesOutput)

DescribeAccountAttributesRequest generates a "aws/request.Request" representing the client's request for the DescribeAccountAttributes 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 DescribeAccountAttributes for more information on using the DescribeAccountAttributes 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 DescribeAccountAttributesRequest method. req, resp := client.DescribeAccountAttributesRequest(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/DescribeAccountAttributes

DescribeAccountAttributesWithContext

func (c *DatabaseMigrationService) DescribeAccountAttributesWithContext(ctx aws.Context, input *DescribeAccountAttributesInput, opts ...request.Option) (*DescribeAccountAttributesOutput, error)

DescribeAccountAttributesWithContext is the same as DescribeAccountAttributes with the addition of the ability to pass a context and additional request options.

See DescribeAccountAttributes 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeCertificates

func (c *DatabaseMigrationService) DescribeCertificates(input *DescribeCertificatesInput) (*DescribeCertificatesOutput, error)

DescribeCertificates API operation for AWS Database Migration Service.

Provides a description of the certificate.

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 DescribeCertificates for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeCertificates

Example

DatabaseMigrationService DescribeCertificates shared00

Describe certificates

Provides a description of the certificate.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeCertificatesInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeCertificates(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeCertificatesPages

func (c *DatabaseMigrationService) DescribeCertificatesPages(input *DescribeCertificatesInput, fn func(*DescribeCertificatesOutput, bool) bool) error

DescribeCertificatesPages iterates over the pages of a DescribeCertificates operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeCertificates 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 DescribeCertificates operation. pageNum := 0 err := client.DescribeCertificatesPages(params, func(page *DescribeCertificatesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeCertificatesPagesWithContext

func (c *DatabaseMigrationService) DescribeCertificatesPagesWithContext(ctx aws.Context, input *DescribeCertificatesInput, fn func(*DescribeCertificatesOutput, bool) bool, opts ...request.Option) error

DescribeCertificatesPagesWithContext same as DescribeCertificatesPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeCertificatesRequest

func (c *DatabaseMigrationService) DescribeCertificatesRequest(input *DescribeCertificatesInput) (req *request.Request, output *DescribeCertificatesOutput)

DescribeCertificatesRequest generates a "aws/request.Request" representing the client's request for the DescribeCertificates 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 DescribeCertificates for more information on using the DescribeCertificates 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 DescribeCertificatesRequest method. req, resp := client.DescribeCertificatesRequest(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/DescribeCertificates

DescribeCertificatesWithContext

func (c *DatabaseMigrationService) DescribeCertificatesWithContext(ctx aws.Context, input *DescribeCertificatesInput, opts ...request.Option) (*DescribeCertificatesOutput, error)

DescribeCertificatesWithContext is the same as DescribeCertificates with the addition of the ability to pass a context and additional request options.

See DescribeCertificates 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeConnections

func (c *DatabaseMigrationService) DescribeConnections(input *DescribeConnectionsInput) (*DescribeConnectionsOutput, error)

DescribeConnections API operation for AWS Database Migration Service.

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.

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 DescribeConnections for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeConnections

Example

DatabaseMigrationService DescribeConnections shared00

Describe connections

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.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeConnectionsInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeConnections(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeConnectionsPages

func (c *DatabaseMigrationService) DescribeConnectionsPages(input *DescribeConnectionsInput, fn func(*DescribeConnectionsOutput, bool) bool) error

DescribeConnectionsPages iterates over the pages of a DescribeConnections operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeConnections 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 DescribeConnections operation. pageNum := 0 err := client.DescribeConnectionsPages(params, func(page *DescribeConnectionsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeConnectionsPagesWithContext

func (c *DatabaseMigrationService) DescribeConnectionsPagesWithContext(ctx aws.Context, input *DescribeConnectionsInput, fn func(*DescribeConnectionsOutput, bool) bool, opts ...request.Option) error

DescribeConnectionsPagesWithContext same as DescribeConnectionsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeConnectionsRequest

func (c *DatabaseMigrationService) DescribeConnectionsRequest(input *DescribeConnectionsInput) (req *request.Request, output *DescribeConnectionsOutput)

DescribeConnectionsRequest generates a "aws/request.Request" representing the client's request for the DescribeConnections 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 DescribeConnections for more information on using the DescribeConnections 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 DescribeConnectionsRequest method. req, resp := client.DescribeConnectionsRequest(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/DescribeConnections

DescribeConnectionsWithContext

func (c *DatabaseMigrationService) DescribeConnectionsWithContext(ctx aws.Context, input *DescribeConnectionsInput, opts ...request.Option) (*DescribeConnectionsOutput, error)

DescribeConnectionsWithContext is the same as DescribeConnections with the addition of the ability to pass a context and additional request options.

See DescribeConnections 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpointTypes

func (c *DatabaseMigrationService) DescribeEndpointTypes(input *DescribeEndpointTypesInput) (*DescribeEndpointTypesOutput, error)

DescribeEndpointTypes API operation for AWS Database Migration Service.

Returns information about the type of endpoints available.

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 DescribeEndpointTypes for usage and error information. See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEndpointTypes

Example

DatabaseMigrationService DescribeEndpointTypes shared00

Describe endpoint types

Returns information about the type of endpoints available.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeEndpointTypesInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeEndpointTypes(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeEndpointTypesPages

func (c *DatabaseMigrationService) DescribeEndpointTypesPages(input *DescribeEndpointTypesInput, fn func(*DescribeEndpointTypesOutput, bool) bool) error

DescribeEndpointTypesPages iterates over the pages of a DescribeEndpointTypes operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeEndpointTypes 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 DescribeEndpointTypes operation. pageNum := 0 err := client.DescribeEndpointTypesPages(params, func(page *DescribeEndpointTypesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpointTypesPagesWithContext

func (c *DatabaseMigrationService) DescribeEndpointTypesPagesWithContext(ctx aws.Context, input *DescribeEndpointTypesInput, fn func(*DescribeEndpointTypesOutput, bool) bool, opts ...request.Option) error

DescribeEndpointTypesPagesWithContext same as DescribeEndpointTypesPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpointTypesRequest

func (c *DatabaseMigrationService) DescribeEndpointTypesRequest(input *DescribeEndpointTypesInput) (req *request.Request, output *DescribeEndpointTypesOutput)

DescribeEndpointTypesRequest generates a "aws/request.Request" representing the client's request for the DescribeEndpointTypes 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 DescribeEndpointTypes for more information on using the DescribeEndpointTypes 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 DescribeEndpointTypesRequest method. req, resp := client.DescribeEndpointTypesRequest(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/DescribeEndpointTypes

DescribeEndpointTypesWithContext

func (c *DatabaseMigrationService) DescribeEndpointTypesWithContext(ctx aws.Context, input *DescribeEndpointTypesInput, opts ...request.Option) (*DescribeEndpointTypesOutput, error)

DescribeEndpointTypesWithContext is the same as DescribeEndpointTypes with the addition of the ability to pass a context and additional request options.

See DescribeEndpointTypes 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpoints

func (c *DatabaseMigrationService) DescribeEndpoints(input *DescribeEndpointsInput) (*DescribeEndpointsOutput, error)

DescribeEndpoints API operation for AWS Database Migration Service.

Returns information about the endpoints for your account in the current region.

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 DescribeEndpoints for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEndpoints

Example

DatabaseMigrationService DescribeEndpoints shared00

Describe endpoints

Returns information about the endpoints for your account in the current region.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeEndpointsInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeEndpoints(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeEndpointsPages

func (c *DatabaseMigrationService) DescribeEndpointsPages(input *DescribeEndpointsInput, fn func(*DescribeEndpointsOutput, bool) bool) error

DescribeEndpointsPages iterates over the pages of a DescribeEndpoints operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeEndpoints 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 DescribeEndpoints operation. pageNum := 0 err := client.DescribeEndpointsPages(params, func(page *DescribeEndpointsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpointsPagesWithContext

func (c *DatabaseMigrationService) DescribeEndpointsPagesWithContext(ctx aws.Context, input *DescribeEndpointsInput, fn func(*DescribeEndpointsOutput, bool) bool, opts ...request.Option) error

DescribeEndpointsPagesWithContext same as DescribeEndpointsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEndpointsRequest

func (c *DatabaseMigrationService) DescribeEndpointsRequest(input *DescribeEndpointsInput) (req *request.Request, output *DescribeEndpointsOutput)

DescribeEndpointsRequest generates a "aws/request.Request" representing the client's request for the DescribeEndpoints 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 DescribeEndpoints for more information on using the DescribeEndpoints 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 DescribeEndpointsRequest method. req, resp := client.DescribeEndpointsRequest(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/DescribeEndpoints

DescribeEndpointsWithContext

func (c *DatabaseMigrationService) DescribeEndpointsWithContext(ctx aws.Context, input *DescribeEndpointsInput, opts ...request.Option) (*DescribeEndpointsOutput, error)

DescribeEndpointsWithContext is the same as DescribeEndpoints with the addition of the ability to pass a context and additional request options.

See DescribeEndpoints 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventCategories

func (c *DatabaseMigrationService) DescribeEventCategories(input *DescribeEventCategoriesInput) (*DescribeEventCategoriesOutput, error)

DescribeEventCategories API operation for AWS Database Migration Service.

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 (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the AWS Database Migration Service User Guide.

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 DescribeEventCategories for usage and error information. See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEventCategories

DescribeEventCategoriesRequest

func (c *DatabaseMigrationService) DescribeEventCategoriesRequest(input *DescribeEventCategoriesInput) (req *request.Request, output *DescribeEventCategoriesOutput)

DescribeEventCategoriesRequest generates a "aws/request.Request" representing the client's request for the DescribeEventCategories 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 DescribeEventCategories for more information on using the DescribeEventCategories 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 DescribeEventCategoriesRequest method. req, resp := client.DescribeEventCategoriesRequest(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/DescribeEventCategories

DescribeEventCategoriesWithContext

func (c *DatabaseMigrationService) DescribeEventCategoriesWithContext(ctx aws.Context, input *DescribeEventCategoriesInput, opts ...request.Option) (*DescribeEventCategoriesOutput, error)

DescribeEventCategoriesWithContext is the same as DescribeEventCategories with the addition of the ability to pass a context and additional request options.

See DescribeEventCategories 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventSubscriptions

func (c *DatabaseMigrationService) DescribeEventSubscriptions(input *DescribeEventSubscriptionsInput) (*DescribeEventSubscriptionsOutput, error)

DescribeEventSubscriptions API operation for AWS Database Migration Service.

Lists all the event subscriptions for a customer account. The description of a subscription includes SubscriptionName, SNSTopicARN, CustomerID, SourceType, SourceID, CreationTime, and Status.

If you specify SubscriptionName, this action lists the description for that subscription.

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 DescribeEventSubscriptions for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEventSubscriptions

DescribeEventSubscriptionsPages

func (c *DatabaseMigrationService) DescribeEventSubscriptionsPages(input *DescribeEventSubscriptionsInput, fn func(*DescribeEventSubscriptionsOutput, bool) bool) error

DescribeEventSubscriptionsPages iterates over the pages of a DescribeEventSubscriptions operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeEventSubscriptions 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 DescribeEventSubscriptions operation. pageNum := 0 err := client.DescribeEventSubscriptionsPages(params, func(page *DescribeEventSubscriptionsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventSubscriptionsPagesWithContext

func (c *DatabaseMigrationService) DescribeEventSubscriptionsPagesWithContext(ctx aws.Context, input *DescribeEventSubscriptionsInput, fn func(*DescribeEventSubscriptionsOutput, bool) bool, opts ...request.Option) error

DescribeEventSubscriptionsPagesWithContext same as DescribeEventSubscriptionsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventSubscriptionsRequest

func (c *DatabaseMigrationService) DescribeEventSubscriptionsRequest(input *DescribeEventSubscriptionsInput) (req *request.Request, output *DescribeEventSubscriptionsOutput)

DescribeEventSubscriptionsRequest generates a "aws/request.Request" representing the client's request for the DescribeEventSubscriptions 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 DescribeEventSubscriptions for more information on using the DescribeEventSubscriptions 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 DescribeEventSubscriptionsRequest method. req, resp := client.DescribeEventSubscriptionsRequest(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/DescribeEventSubscriptions

DescribeEventSubscriptionsWithContext

func (c *DatabaseMigrationService) DescribeEventSubscriptionsWithContext(ctx aws.Context, input *DescribeEventSubscriptionsInput, opts ...request.Option) (*DescribeEventSubscriptionsOutput, error)

DescribeEventSubscriptionsWithContext is the same as DescribeEventSubscriptions with the addition of the ability to pass a context and additional request options.

See DescribeEventSubscriptions 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEvents

func (c *DatabaseMigrationService) DescribeEvents(input *DescribeEventsInput) (*DescribeEventsOutput, error)

DescribeEvents API operation for AWS Database Migration Service.

Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the AWS Database Migration User Guide.

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 DescribeEvents for usage and error information. See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeEvents

DescribeEventsPages

func (c *DatabaseMigrationService) DescribeEventsPages(input *DescribeEventsInput, fn func(*DescribeEventsOutput, bool) bool) error

DescribeEventsPages iterates over the pages of a DescribeEvents operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeEvents 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 DescribeEvents operation. pageNum := 0 err := client.DescribeEventsPages(params, func(page *DescribeEventsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventsPagesWithContext

func (c *DatabaseMigrationService) DescribeEventsPagesWithContext(ctx aws.Context, input *DescribeEventsInput, fn func(*DescribeEventsOutput, bool) bool, opts ...request.Option) error

DescribeEventsPagesWithContext same as DescribeEventsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeEventsRequest

func (c *DatabaseMigrationService) DescribeEventsRequest(input *DescribeEventsInput) (req *request.Request, output *DescribeEventsOutput)

DescribeEventsRequest generates a "aws/request.Request" representing the client's request for the DescribeEvents 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 DescribeEvents for more information on using the DescribeEvents 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 DescribeEventsRequest method. req, resp := client.DescribeEventsRequest(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/DescribeEvents

DescribeEventsWithContext

func (c *DatabaseMigrationService) DescribeEventsWithContext(ctx aws.Context, input *DescribeEventsInput, opts ...request.Option) (*DescribeEventsOutput, error)

DescribeEventsWithContext is the same as DescribeEvents with the addition of the ability to pass a context and additional request options.

See DescribeEvents 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeOrderableReplicationInstances

func (c *DatabaseMigrationService) DescribeOrderableReplicationInstances(input *DescribeOrderableReplicationInstancesInput) (*DescribeOrderableReplicationInstancesOutput, error)

DescribeOrderableReplicationInstances API operation for AWS Database Migration Service.

Returns information about the replication instance types that can be created in the specified region.

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 DescribeOrderableReplicationInstances for usage and error information. See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeOrderableReplicationInstances

Example

DatabaseMigrationService DescribeOrderableReplicationInstances shared00

Describe orderable replication instances

Returns information about the replication instance types that can be created in the specified region.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeOrderableReplicationInstancesInput{ Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeOrderableReplicationInstances(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeOrderableReplicationInstancesPages

func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesPages(input *DescribeOrderableReplicationInstancesInput, fn func(*DescribeOrderableReplicationInstancesOutput, bool) bool) error

DescribeOrderableReplicationInstancesPages iterates over the pages of a DescribeOrderableReplicationInstances operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeOrderableReplicationInstances 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 DescribeOrderableReplicationInstances operation. pageNum := 0 err := client.DescribeOrderableReplicationInstancesPages(params, func(page *DescribeOrderableReplicationInstancesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeOrderableReplicationInstancesPagesWithContext

func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesPagesWithContext(ctx aws.Context, input *DescribeOrderableReplicationInstancesInput, fn func(*DescribeOrderableReplicationInstancesOutput, bool) bool, opts ...request.Option) error

DescribeOrderableReplicationInstancesPagesWithContext same as DescribeOrderableReplicationInstancesPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeOrderableReplicationInstancesRequest

func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesRequest(input *DescribeOrderableReplicationInstancesInput) (req *request.Request, output *DescribeOrderableReplicationInstancesOutput)

DescribeOrderableReplicationInstancesRequest generates a "aws/request.Request" representing the client's request for the DescribeOrderableReplicationInstances 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 DescribeOrderableReplicationInstances for more information on using the DescribeOrderableReplicationInstances 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 DescribeOrderableReplicationInstancesRequest method. req, resp := client.DescribeOrderableReplicationInstancesRequest(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/DescribeOrderableReplicationInstances

DescribeOrderableReplicationInstancesWithContext

func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesWithContext(ctx aws.Context, input *DescribeOrderableReplicationInstancesInput, opts ...request.Option) (*DescribeOrderableReplicationInstancesOutput, error)

DescribeOrderableReplicationInstancesWithContext is the same as DescribeOrderableReplicationInstances with the addition of the ability to pass a context and additional request options.

See DescribeOrderableReplicationInstances 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeRefreshSchemasStatus

func (c *DatabaseMigrationService) DescribeRefreshSchemasStatus(input *DescribeRefreshSchemasStatusInput) (*DescribeRefreshSchemasStatusOutput, error)

DescribeRefreshSchemasStatus API operation for AWS Database Migration Service.

Returns the status of the RefreshSchemas operation.

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 DescribeRefreshSchemasStatus for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeRefreshSchemasStatus

Example

DatabaseMigrationService DescribeRefreshSchemasStatus shared00

Describe refresh schema status

Returns the status of the refresh-schemas operation.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeRefreshSchemasStatusInput{ EndpointArn: aws.String(""), } result, err := svc.DescribeRefreshSchemasStatus(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeRefreshSchemasStatusRequest

func (c *DatabaseMigrationService) DescribeRefreshSchemasStatusRequest(input *DescribeRefreshSchemasStatusInput) (req *request.Request, output *DescribeRefreshSchemasStatusOutput)

DescribeRefreshSchemasStatusRequest generates a "aws/request.Request" representing the client's request for the DescribeRefreshSchemasStatus 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 DescribeRefreshSchemasStatus for more information on using the DescribeRefreshSchemasStatus 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 DescribeRefreshSchemasStatusRequest method. req, resp := client.DescribeRefreshSchemasStatusRequest(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/DescribeRefreshSchemasStatus

DescribeRefreshSchemasStatusWithContext

func (c *DatabaseMigrationService) DescribeRefreshSchemasStatusWithContext(ctx aws.Context, input *DescribeRefreshSchemasStatusInput, opts ...request.Option) (*DescribeRefreshSchemasStatusOutput, error)

DescribeRefreshSchemasStatusWithContext is the same as DescribeRefreshSchemasStatus with the addition of the ability to pass a context and additional request options.

See DescribeRefreshSchemasStatus 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstanceTaskLogs

func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogs(input *DescribeReplicationInstanceTaskLogsInput) (*DescribeReplicationInstanceTaskLogsOutput, error)

DescribeReplicationInstanceTaskLogs API operation for AWS Database Migration Service.

Returns information about the task logs for the specified task.

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 DescribeReplicationInstanceTaskLogs for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeReplicationInstanceTaskLogs

DescribeReplicationInstanceTaskLogsPages

func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogsPages(input *DescribeReplicationInstanceTaskLogsInput, fn func(*DescribeReplicationInstanceTaskLogsOutput, bool) bool) error

DescribeReplicationInstanceTaskLogsPages iterates over the pages of a DescribeReplicationInstanceTaskLogs operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeReplicationInstanceTaskLogs 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 DescribeReplicationInstanceTaskLogs operation. pageNum := 0 err := client.DescribeReplicationInstanceTaskLogsPages(params, func(page *DescribeReplicationInstanceTaskLogsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstanceTaskLogsPagesWithContext

func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogsPagesWithContext(ctx aws.Context, input *DescribeReplicationInstanceTaskLogsInput, fn func(*DescribeReplicationInstanceTaskLogsOutput, bool) bool, opts ...request.Option) error

DescribeReplicationInstanceTaskLogsPagesWithContext same as DescribeReplicationInstanceTaskLogsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstanceTaskLogsRequest

func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogsRequest(input *DescribeReplicationInstanceTaskLogsInput) (req *request.Request, output *DescribeReplicationInstanceTaskLogsOutput)

DescribeReplicationInstanceTaskLogsRequest generates a "aws/request.Request" representing the client's request for the DescribeReplicationInstanceTaskLogs 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 DescribeReplicationInstanceTaskLogs for more information on using the DescribeReplicationInstanceTaskLogs 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 DescribeReplicationInstanceTaskLogsRequest method. req, resp := client.DescribeReplicationInstanceTaskLogsRequest(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/DescribeReplicationInstanceTaskLogs

DescribeReplicationInstanceTaskLogsWithContext

func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogsWithContext(ctx aws.Context, input *DescribeReplicationInstanceTaskLogsInput, opts ...request.Option) (*DescribeReplicationInstanceTaskLogsOutput, error)

DescribeReplicationInstanceTaskLogsWithContext is the same as DescribeReplicationInstanceTaskLogs with the addition of the ability to pass a context and additional request options.

See DescribeReplicationInstanceTaskLogs 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstances

func (c *DatabaseMigrationService) DescribeReplicationInstances(input *DescribeReplicationInstancesInput) (*DescribeReplicationInstancesOutput, error)

DescribeReplicationInstances API operation for AWS Database Migration Service.

Returns information about replication instances for your account in the current region.

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 DescribeReplicationInstances for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeReplicationInstances

Example

DatabaseMigrationService DescribeReplicationInstances shared00

Describe replication instances

Returns the status of the refresh-schemas operation.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeReplicationInstancesInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeReplicationInstances(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeReplicationInstancesPages

func (c *DatabaseMigrationService) DescribeReplicationInstancesPages(input *DescribeReplicationInstancesInput, fn func(*DescribeReplicationInstancesOutput, bool) bool) error

DescribeReplicationInstancesPages iterates over the pages of a DescribeReplicationInstances operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeReplicationInstances 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 DescribeReplicationInstances operation. pageNum := 0 err := client.DescribeReplicationInstancesPages(params, func(page *DescribeReplicationInstancesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstancesPagesWithContext

func (c *DatabaseMigrationService) DescribeReplicationInstancesPagesWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, fn func(*DescribeReplicationInstancesOutput, bool) bool, opts ...request.Option) error

DescribeReplicationInstancesPagesWithContext same as DescribeReplicationInstancesPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationInstancesRequest

func (c *DatabaseMigrationService) DescribeReplicationInstancesRequest(input *DescribeReplicationInstancesInput) (req *request.Request, output *DescribeReplicationInstancesOutput)

DescribeReplicationInstancesRequest generates a "aws/request.Request" representing the client's request for the DescribeReplicationInstances 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 DescribeReplicationInstances for more information on using the DescribeReplicationInstances 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 DescribeReplicationInstancesRequest method. req, resp := client.DescribeReplicationInstancesRequest(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/DescribeReplicationInstances

DescribeReplicationInstancesWithContext

func (c *DatabaseMigrationService) DescribeReplicationInstancesWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, opts ...request.Option) (*DescribeReplicationInstancesOutput, error)

DescribeReplicationInstancesWithContext is the same as DescribeReplicationInstances with the addition of the ability to pass a context and additional request options.

See DescribeReplicationInstances 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationSubnetGroups

func (c *DatabaseMigrationService) DescribeReplicationSubnetGroups(input *DescribeReplicationSubnetGroupsInput) (*DescribeReplicationSubnetGroupsOutput, error)

DescribeReplicationSubnetGroups API operation for AWS Database Migration Service.

Returns information about the replication subnet groups.

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 DescribeReplicationSubnetGroups for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeReplicationSubnetGroups

Example

DatabaseMigrationService DescribeReplicationSubnetGroups shared00

Describe replication subnet groups

Returns information about the replication subnet groups.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeReplicationSubnetGroupsInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeReplicationSubnetGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeReplicationSubnetGroupsPages

func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsPages(input *DescribeReplicationSubnetGroupsInput, fn func(*DescribeReplicationSubnetGroupsOutput, bool) bool) error

DescribeReplicationSubnetGroupsPages iterates over the pages of a DescribeReplicationSubnetGroups operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeReplicationSubnetGroups 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 DescribeReplicationSubnetGroups operation. pageNum := 0 err := client.DescribeReplicationSubnetGroupsPages(params, func(page *DescribeReplicationSubnetGroupsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationSubnetGroupsPagesWithContext

func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsPagesWithContext(ctx aws.Context, input *DescribeReplicationSubnetGroupsInput, fn func(*DescribeReplicationSubnetGroupsOutput, bool) bool, opts ...request.Option) error

DescribeReplicationSubnetGroupsPagesWithContext same as DescribeReplicationSubnetGroupsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationSubnetGroupsRequest

func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsRequest(input *DescribeReplicationSubnetGroupsInput) (req *request.Request, output *DescribeReplicationSubnetGroupsOutput)

DescribeReplicationSubnetGroupsRequest generates a "aws/request.Request" representing the client's request for the DescribeReplicationSubnetGroups 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 DescribeReplicationSubnetGroups for more information on using the DescribeReplicationSubnetGroups 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 DescribeReplicationSubnetGroupsRequest method. req, resp := client.DescribeReplicationSubnetGroupsRequest(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/DescribeReplicationSubnetGroups

DescribeReplicationSubnetGroupsWithContext

func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsWithContext(ctx aws.Context, input *DescribeReplicationSubnetGroupsInput, opts ...request.Option) (*DescribeReplicationSubnetGroupsOutput, error)

DescribeReplicationSubnetGroupsWithContext is the same as DescribeReplicationSubnetGroups with the addition of the ability to pass a context and additional request options.

See DescribeReplicationSubnetGroups 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTaskAssessmentResults

func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResults(input *DescribeReplicationTaskAssessmentResultsInput) (*DescribeReplicationTaskAssessmentResultsOutput, error)

DescribeReplicationTaskAssessmentResults API operation for AWS Database Migration Service.

Returns the task assessment results from Amazon S3. This action always returns the latest results.

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 DescribeReplicationTaskAssessmentResults for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeReplicationTaskAssessmentResults

DescribeReplicationTaskAssessmentResultsPages

func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsPages(input *DescribeReplicationTaskAssessmentResultsInput, fn func(*DescribeReplicationTaskAssessmentResultsOutput, bool) bool) error

DescribeReplicationTaskAssessmentResultsPages iterates over the pages of a DescribeReplicationTaskAssessmentResults operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeReplicationTaskAssessmentResults 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 DescribeReplicationTaskAssessmentResults operation. pageNum := 0 err := client.DescribeReplicationTaskAssessmentResultsPages(params, func(page *DescribeReplicationTaskAssessmentResultsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTaskAssessmentResultsPagesWithContext

func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsPagesWithContext(ctx aws.Context, input *DescribeReplicationTaskAssessmentResultsInput, fn func(*DescribeReplicationTaskAssessmentResultsOutput, bool) bool, opts ...request.Option) error

DescribeReplicationTaskAssessmentResultsPagesWithContext same as DescribeReplicationTaskAssessmentResultsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTaskAssessmentResultsRequest

func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsRequest(input *DescribeReplicationTaskAssessmentResultsInput) (req *request.Request, output *DescribeReplicationTaskAssessmentResultsOutput)

DescribeReplicationTaskAssessmentResultsRequest generates a "aws/request.Request" representing the client's request for the DescribeReplicationTaskAssessmentResults 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 DescribeReplicationTaskAssessmentResults for more information on using the DescribeReplicationTaskAssessmentResults 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 DescribeReplicationTaskAssessmentResultsRequest method. req, resp := client.DescribeReplicationTaskAssessmentResultsRequest(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/DescribeReplicationTaskAssessmentResults

DescribeReplicationTaskAssessmentResultsWithContext

func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsWithContext(ctx aws.Context, input *DescribeReplicationTaskAssessmentResultsInput, opts ...request.Option) (*DescribeReplicationTaskAssessmentResultsOutput, error)

DescribeReplicationTaskAssessmentResultsWithContext is the same as DescribeReplicationTaskAssessmentResults with the addition of the ability to pass a context and additional request options.

See DescribeReplicationTaskAssessmentResults 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTasks

func (c *DatabaseMigrationService) DescribeReplicationTasks(input *DescribeReplicationTasksInput) (*DescribeReplicationTasksOutput, error)

DescribeReplicationTasks API operation for AWS Database Migration Service.

Returns information about replication tasks for your account in the current region.

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 DescribeReplicationTasks for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeReplicationTasks

Example

DatabaseMigrationService DescribeReplicationTasks shared00

Describe replication tasks

Returns information about replication tasks for your account in the current region.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeReplicationTasksInput{ Filters: []*databasemigrationservice.Filter{ { Name: aws.String("string"), Values: []*string{ aws.String("string"), aws.String("string"), }, }, }, Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeReplicationTasks(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeReplicationTasksPages

func (c *DatabaseMigrationService) DescribeReplicationTasksPages(input *DescribeReplicationTasksInput, fn func(*DescribeReplicationTasksOutput, bool) bool) error

DescribeReplicationTasksPages iterates over the pages of a DescribeReplicationTasks operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeReplicationTasks 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 DescribeReplicationTasks operation. pageNum := 0 err := client.DescribeReplicationTasksPages(params, func(page *DescribeReplicationTasksOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTasksPagesWithContext

func (c *DatabaseMigrationService) DescribeReplicationTasksPagesWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, fn func(*DescribeReplicationTasksOutput, bool) bool, opts ...request.Option) error

DescribeReplicationTasksPagesWithContext same as DescribeReplicationTasksPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeReplicationTasksRequest

func (c *DatabaseMigrationService) DescribeReplicationTasksRequest(input *DescribeReplicationTasksInput) (req *request.Request, output *DescribeReplicationTasksOutput)

DescribeReplicationTasksRequest generates a "aws/request.Request" representing the client's request for the DescribeReplicationTasks 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 DescribeReplicationTasks for more information on using the DescribeReplicationTasks 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 DescribeReplicationTasksRequest method. req, resp := client.DescribeReplicationTasksRequest(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/DescribeReplicationTasks

DescribeReplicationTasksWithContext

func (c *DatabaseMigrationService) DescribeReplicationTasksWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, opts ...request.Option) (*DescribeReplicationTasksOutput, error)

DescribeReplicationTasksWithContext is the same as DescribeReplicationTasks with the addition of the ability to pass a context and additional request options.

See DescribeReplicationTasks 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeSchemas

func (c *DatabaseMigrationService) DescribeSchemas(input *DescribeSchemasInput) (*DescribeSchemasOutput, error)

DescribeSchemas API operation for AWS Database Migration Service.

Returns information about the schema for the specified endpoint.

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 DescribeSchemas for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeSchemas

Example

DatabaseMigrationService DescribeSchemas shared00

Describe schemas

Returns information about the schema for the specified endpoint.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeSchemasInput{ EndpointArn: aws.String(""), Marker: aws.String(""), MaxRecords: aws.Int64(123), } result, err := svc.DescribeSchemas(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeSchemasPages

func (c *DatabaseMigrationService) DescribeSchemasPages(input *DescribeSchemasInput, fn func(*DescribeSchemasOutput, bool) bool) error

DescribeSchemasPages iterates over the pages of a DescribeSchemas operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeSchemas 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 DescribeSchemas operation. pageNum := 0 err := client.DescribeSchemasPages(params, func(page *DescribeSchemasOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeSchemasPagesWithContext

func (c *DatabaseMigrationService) DescribeSchemasPagesWithContext(ctx aws.Context, input *DescribeSchemasInput, fn func(*DescribeSchemasOutput, bool) bool, opts ...request.Option) error

DescribeSchemasPagesWithContext same as DescribeSchemasPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeSchemasRequest

func (c *DatabaseMigrationService) DescribeSchemasRequest(input *DescribeSchemasInput) (req *request.Request, output *DescribeSchemasOutput)

DescribeSchemasRequest generates a "aws/request.Request" representing the client's request for the DescribeSchemas 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 DescribeSchemas for more information on using the DescribeSchemas 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 DescribeSchemasRequest method. req, resp := client.DescribeSchemasRequest(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/DescribeSchemas

DescribeSchemasWithContext

func (c *DatabaseMigrationService) DescribeSchemasWithContext(ctx aws.Context, input *DescribeSchemasInput, opts ...request.Option) (*DescribeSchemasOutput, error)

DescribeSchemasWithContext is the same as DescribeSchemas with the addition of the ability to pass a context and additional request options.

See DescribeSchemas 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeTableStatistics

func (c *DatabaseMigrationService) DescribeTableStatistics(input *DescribeTableStatisticsInput) (*DescribeTableStatisticsOutput, error)

DescribeTableStatistics API operation for AWS Database Migration Service.

Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.

Note that the "last updated" column the DMS console only indicates the time that AWS DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.

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 DescribeTableStatistics for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/DescribeTableStatistics

Example

DatabaseMigrationService DescribeTableStatistics shared00

Describe table statistics

Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.DescribeTableStatisticsInput{ Marker: aws.String(""), MaxRecords: aws.Int64(123), ReplicationTaskArn: aws.String(""), } result, err := svc.DescribeTableStatistics(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

DescribeTableStatisticsPages

func (c *DatabaseMigrationService) DescribeTableStatisticsPages(input *DescribeTableStatisticsInput, fn func(*DescribeTableStatisticsOutput, bool) bool) error

DescribeTableStatisticsPages iterates over the pages of a DescribeTableStatistics operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeTableStatistics 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 DescribeTableStatistics operation. pageNum := 0 err := client.DescribeTableStatisticsPages(params, func(page *DescribeTableStatisticsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })

See Also

For more information about using this API, see AWS API Documentation.

DescribeTableStatisticsPagesWithContext

func (c *DatabaseMigrationService) DescribeTableStatisticsPagesWithContext(ctx aws.Context, input *DescribeTableStatisticsInput, fn func(*DescribeTableStatisticsOutput, bool) bool, opts ...request.Option) error

DescribeTableStatisticsPagesWithContext same as DescribeTableStatisticsPages 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.

See Also

For more information about using this API, see AWS API Documentation.

DescribeTableStatisticsRequest

func (c *DatabaseMigrationService) DescribeTableStatisticsRequest(input *DescribeTableStatisticsInput) (req *request.Request, output *DescribeTableStatisticsOutput)

DescribeTableStatisticsRequest generates a "aws/request.Request" representing the client's request for the DescribeTableStatistics 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 DescribeTableStatistics for more information on using the DescribeTableStatistics 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 DescribeTableStatisticsRequest method. req, resp := client.DescribeTableStatisticsRequest(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/DescribeTableStatistics

DescribeTableStatisticsWithContext

func (c *DatabaseMigrationService) DescribeTableStatisticsWithContext(ctx aws.Context, input *DescribeTableStatisticsInput, opts ...request.Option) (*DescribeTableStatisticsOutput, error)

DescribeTableStatisticsWithContext is the same as DescribeTableStatistics with the addition of the ability to pass a context and additional request options.

See DescribeTableStatistics 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.

See Also

For more information about using this API, see AWS API Documentation.

ImportCertificate

func (c *DatabaseMigrationService) ImportCertificate(input *ImportCertificateInput) (*ImportCertificateOutput, error)

ImportCertificate API operation for AWS Database Migration Service.

Uploads the specified certificate.

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 ImportCertificate for usage and error information.

Returned Error Codes:

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeInvalidCertificateFault "InvalidCertificateFault" The certificate was not valid.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ImportCertificate

Example

DatabaseMigrationService ImportCertificate shared00

Import certificate

Uploads the specified certificate.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.ImportCertificateInput{ CertificateIdentifier: aws.String(""), CertificatePem: aws.String(""), } result, err := svc.ImportCertificate(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidCertificateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidCertificateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

ImportCertificateRequest

func (c *DatabaseMigrationService) ImportCertificateRequest(input *ImportCertificateInput) (req *request.Request, output *ImportCertificateOutput)

ImportCertificateRequest generates a "aws/request.Request" representing the client's request for the ImportCertificate 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 ImportCertificate for more information on using the ImportCertificate 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 ImportCertificateRequest method. req, resp := client.ImportCertificateRequest(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/ImportCertificate

ImportCertificateWithContext

func (c *DatabaseMigrationService) ImportCertificateWithContext(ctx aws.Context, input *ImportCertificateInput, opts ...request.Option) (*ImportCertificateOutput, error)

ImportCertificateWithContext is the same as ImportCertificate with the addition of the ability to pass a context and additional request options.

See ImportCertificate 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.

See Also

For more information about using this API, see AWS API Documentation.

ListTagsForResource

func (c *DatabaseMigrationService) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for AWS Database Migration Service.

Lists all tags for an AWS DMS resource.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for AWS Database Migration Service's API operation ListTagsForResource for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ListTagsForResource

Example

DatabaseMigrationService ListTagsForResource shared00

List tags for resource

Lists all tags for an AWS DMS resource.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.ListTagsForResourceInput{ ResourceArn: aws.String(""), } result, err := svc.ListTagsForResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

ListTagsForResourceRequest

func (c *DatabaseMigrationService) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListTagsForResourceRequest method. req, resp := client.ListTagsForResourceRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ListTagsForResource

ListTagsForResourceWithContext

func (c *DatabaseMigrationService) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

See Also

For more information about using this API, see AWS API Documentation.

ModifyEndpoint

func (c *DatabaseMigrationService) ModifyEndpoint(input *ModifyEndpointInput) (*ModifyEndpointOutput, error)

ModifyEndpoint API operation for AWS Database Migration Service.

Modifies the specified endpoint.

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 ModifyEndpoint for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ModifyEndpoint

Example

DatabaseMigrationService ModifyEndpoint shared00

Modify endpoint

Modifies the specified endpoint.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.ModifyEndpointInput{ CertificateArn: aws.String(""), DatabaseName: aws.String(""), EndpointArn: aws.String(""), EndpointIdentifier: aws.String(""), EndpointType: aws.String("source"), EngineName: aws.String(""), ExtraConnectionAttributes: aws.String(""), Password: aws.String(""), Port: aws.Int64(123), ServerName: aws.String(""), SslMode: aws.String("require"), Username: aws.String(""), } result, err := svc.ModifyEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

ModifyEndpointRequest

func (c *DatabaseMigrationService) ModifyEndpointRequest(input *ModifyEndpointInput) (req *request.Request, output *ModifyEndpointOutput)

ModifyEndpointRequest generates a "aws/request.Request" representing the client's request for the ModifyEndpoint 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 ModifyEndpoint for more information on using the ModifyEndpoint 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 ModifyEndpointRequest method. req, resp := client.ModifyEndpointRequest(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/ModifyEndpoint

ModifyEndpointWithContext

func (c *DatabaseMigrationService) ModifyEndpointWithContext(ctx aws.Context, input *ModifyEndpointInput, opts ...request.Option) (*ModifyEndpointOutput, error)

ModifyEndpointWithContext is the same as ModifyEndpoint with the addition of the ability to pass a context and additional request options.

See ModifyEndpoint 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.

See Also

For more information about using this API, see AWS API Documentation.

ModifyEventSubscription

func (c *DatabaseMigrationService) ModifyEventSubscription(input *ModifyEventSubscriptionInput) (*ModifyEventSubscriptionOutput, error)

ModifyEventSubscription API operation for AWS Database Migration Service.

Modifies an existing AWS DMS event notification subscription.

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 ModifyEventSubscription for usage and error information.

Returned Error Codes:

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeSNSInvalidTopicFault "SNSInvalidTopicFault" The SNS topic is invalid.

  • ErrCodeSNSNoAuthorizationFault "SNSNoAuthorizationFault" You are not authorized for the SNS subscription.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ModifyEventSubscription

ModifyEventSubscriptionRequest

func (c *DatabaseMigrationService) ModifyEventSubscriptionRequest(input *ModifyEventSubscriptionInput) (req *request.Request, output *ModifyEventSubscriptionOutput)

ModifyEventSubscriptionRequest generates a "aws/request.Request" representing the client's request for the ModifyEventSubscription 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 ModifyEventSubscription for more information on using the ModifyEventSubscription 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 ModifyEventSubscriptionRequest method. req, resp := client.ModifyEventSubscriptionRequest(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/ModifyEventSubscription

ModifyEventSubscriptionWithContext

func (c *DatabaseMigrationService) ModifyEventSubscriptionWithContext(ctx aws.Context, input *ModifyEventSubscriptionInput, opts ...request.Option) (*ModifyEventSubscriptionOutput, error)

ModifyEventSubscriptionWithContext is the same as ModifyEventSubscription with the addition of the ability to pass a context and additional request options.

See ModifyEventSubscription 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.

See Also

For more information about using this API, see AWS API Documentation.

ModifyReplicationInstance

func (c *DatabaseMigrationService) ModifyReplicationInstance(input *ModifyReplicationInstanceInput) (*ModifyReplicationInstanceOutput, error)

ModifyReplicationInstance API operation for AWS Database Migration Service.

Modifies the replication instance to apply new settings. You can change one or more parameters by specifying these parameters and the new values in the request.

Some settings are applied during the maintenance window.

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 ModifyReplicationInstance for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInsufficientResourceCapacityFault "InsufficientResourceCapacityFault" There are not enough resources allocated to the database migration.

  • ErrCodeStorageQuotaExceededFault "StorageQuotaExceededFault" The storage quota has been exceeded.

  • ErrCodeUpgradeDependencyFailureFault "UpgradeDependencyFailureFault" An upgrade dependency is preventing the database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ModifyReplicationInstance

Example

DatabaseMigrationService ModifyReplicationInstance shared00

Modify replication instance

Modifies the replication instance to apply new settings. You can change one or more parameters by specifying these parameters and the new values in the request. Some settings are applied during the maintenance window.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.ModifyReplicationInstanceInput{ AllocatedStorage: aws.Int64(123), AllowMajorVersionUpgrade: aws.Bool(true), ApplyImmediately: aws.Bool(true), AutoMinorVersionUpgrade: aws.Bool(true), EngineVersion: aws.String("1.5.0"), MultiAZ: aws.Bool(true), PreferredMaintenanceWindow: aws.String("sun:06:00-sun:14:00"), ReplicationInstanceArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), ReplicationInstanceClass: aws.String("dms.t2.micro"), ReplicationInstanceIdentifier: aws.String("test-rep-1"), } result, err := svc.ModifyReplicationInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceAlreadyExistsFault: fmt.Println(databasemigrationservice.ErrCodeResourceAlreadyExistsFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInsufficientResourceCapacityFault: fmt.Println(databasemigrationservice.ErrCodeInsufficientResourceCapacityFault, aerr.Error()) case databasemigrationservice.ErrCodeStorageQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeStorageQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeUpgradeDependencyFailureFault: fmt.Println(databasemigrationservice.ErrCodeUpgradeDependencyFailureFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

ModifyReplicationInstanceRequest

func (c *DatabaseMigrationService) ModifyReplicationInstanceRequest(input *ModifyReplicationInstanceInput) (req *request.Request, output *ModifyReplicationInstanceOutput)

ModifyReplicationInstanceRequest generates a "aws/request.Request" representing the client's request for the ModifyReplicationInstance 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 ModifyReplicationInstance for more information on using the ModifyReplicationInstance 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 ModifyReplicationInstanceRequest method. req, resp := client.ModifyReplicationInstanceRequest(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/ModifyReplicationInstance

ModifyReplicationInstanceWithContext

func (c *DatabaseMigrationService) ModifyReplicationInstanceWithContext(ctx aws.Context, input *ModifyReplicationInstanceInput, opts ...request.Option) (*ModifyReplicationInstanceOutput, error)

ModifyReplicationInstanceWithContext is the same as ModifyReplicationInstance with the addition of the ability to pass a context and additional request options.

See ModifyReplicationInstance 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.

See Also

For more information about using this API, see AWS API Documentation.

ModifyReplicationSubnetGroup

func (c *DatabaseMigrationService) ModifyReplicationSubnetGroup(input *ModifyReplicationSubnetGroupInput) (*ModifyReplicationSubnetGroupOutput, error)

ModifyReplicationSubnetGroup API operation for AWS Database Migration Service.

Modifies the settings for the specified replication subnet group.

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 ModifyReplicationSubnetGroup for usage and error information.

Returned Error Codes:

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

  • ErrCodeSubnetAlreadyInUse "SubnetAlreadyInUse" The specified subnet is already in use.

  • ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs "ReplicationSubnetGroupDoesNotCoverEnoughAZs" The replication subnet group does not cover enough Availability Zones (AZs). Edit the replication subnet group and add more AZs.

  • ErrCodeInvalidSubnet "InvalidSubnet" The subnet provided is invalid.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ModifyReplicationSubnetGroup

Example

DatabaseMigrationService ModifyReplicationSubnetGroup shared00

Modify replication subnet group

Modifies the settings for the specified replication subnet group.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.ModifyReplicationSubnetGroupInput{ ReplicationSubnetGroupDescription: aws.String(""), ReplicationSubnetGroupIdentifier: aws.String(""), } result, err := svc.ModifyReplicationSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) case databasemigrationservice.ErrCodeSubnetAlreadyInUse: fmt.Println(databasemigrationservice.ErrCodeSubnetAlreadyInUse, aerr.Error()) case databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(databasemigrationservice.ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case databasemigrationservice.ErrCodeInvalidSubnet: fmt.Println(databasemigrationservice.ErrCodeInvalidSubnet, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

ModifyReplicationSubnetGroupRequest

func (c *DatabaseMigrationService) ModifyReplicationSubnetGroupRequest(input *ModifyReplicationSubnetGroupInput) (req *request.Request, output *ModifyReplicationSubnetGroupOutput)

ModifyReplicationSubnetGroupRequest generates a "aws/request.Request" representing the client's request for the ModifyReplicationSubnetGroup 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 ModifyReplicationSubnetGroup for more information on using the ModifyReplicationSubnetGroup 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 ModifyReplicationSubnetGroupRequest method. req, resp := client.ModifyReplicationSubnetGroupRequest(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/ModifyReplicationSubnetGroup

ModifyReplicationSubnetGroupWithContext

func (c *DatabaseMigrationService) ModifyReplicationSubnetGroupWithContext(ctx aws.Context, input *ModifyReplicationSubnetGroupInput, opts ...request.Option) (*ModifyReplicationSubnetGroupOutput, error)

ModifyReplicationSubnetGroupWithContext is the same as ModifyReplicationSubnetGroup with the addition of the ability to pass a context and additional request options.

See ModifyReplicationSubnetGroup 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.

See Also

For more information about using this API, see AWS API Documentation.

ModifyReplicationTask

func (c *DatabaseMigrationService) ModifyReplicationTask(input *ModifyReplicationTaskInput) (*ModifyReplicationTaskOutput, error)

ModifyReplicationTask API operation for AWS Database Migration Service.

Modifies the specified replication task.

You can't modify the task endpoints. The task must be stopped before you can modify it.

For more information about AWS DMS tasks, see Working with Migration Tasks (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.html) in the AWS Database Migration Service User Guide.

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 ModifyReplicationTask for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeResourceAlreadyExistsFault "ResourceAlreadyExistsFault" The resource you are attempting to create already exists.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ModifyReplicationTask

ModifyReplicationTaskRequest

func (c *DatabaseMigrationService) ModifyReplicationTaskRequest(input *ModifyReplicationTaskInput) (req *request.Request, output *ModifyReplicationTaskOutput)

ModifyReplicationTaskRequest generates a "aws/request.Request" representing the client's request for the ModifyReplicationTask 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 ModifyReplicationTask for more information on using the ModifyReplicationTask 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 ModifyReplicationTaskRequest method. req, resp := client.ModifyReplicationTaskRequest(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/ModifyReplicationTask

ModifyReplicationTaskWithContext

func (c *DatabaseMigrationService) ModifyReplicationTaskWithContext(ctx aws.Context, input *ModifyReplicationTaskInput, opts ...request.Option) (*ModifyReplicationTaskOutput, error)

ModifyReplicationTaskWithContext is the same as ModifyReplicationTask with the addition of the ability to pass a context and additional request options.

See ModifyReplicationTask 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.

See Also

For more information about using this API, see AWS API Documentation.

RebootReplicationInstance

func (c *DatabaseMigrationService) RebootReplicationInstance(input *RebootReplicationInstanceInput) (*RebootReplicationInstanceOutput, error)

RebootReplicationInstance API operation for AWS Database Migration Service.

Reboots a replication instance. Rebooting results in a momentary outage, until the replication instance becomes available again.

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 RebootReplicationInstance for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/RebootReplicationInstance

RebootReplicationInstanceRequest

func (c *DatabaseMigrationService) RebootReplicationInstanceRequest(input *RebootReplicationInstanceInput) (req *request.Request, output *RebootReplicationInstanceOutput)

RebootReplicationInstanceRequest generates a "aws/request.Request" representing the client's request for the RebootReplicationInstance 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 RebootReplicationInstance for more information on using the RebootReplicationInstance 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 RebootReplicationInstanceRequest method. req, resp := client.RebootReplicationInstanceRequest(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/RebootReplicationInstance

RebootReplicationInstanceWithContext

func (c *DatabaseMigrationService) RebootReplicationInstanceWithContext(ctx aws.Context, input *RebootReplicationInstanceInput, opts ...request.Option) (*RebootReplicationInstanceOutput, error)

RebootReplicationInstanceWithContext is the same as RebootReplicationInstance with the addition of the ability to pass a context and additional request options.

See RebootReplicationInstance 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.

See Also

For more information about using this API, see AWS API Documentation.

RefreshSchemas

func (c *DatabaseMigrationService) RefreshSchemas(input *RefreshSchemasInput) (*RefreshSchemasOutput, error)

RefreshSchemas API operation for AWS Database Migration Service.

Populates the schema for the specified endpoint. This is an asynchronous operation and can take several minutes. You can check the status of this operation by calling the DescribeRefreshSchemasStatus operation.

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 RefreshSchemas for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/RefreshSchemas

Example

DatabaseMigrationService RefreshSchemas shared00

Refresh schema

Populates the schema for the specified endpoint. This is an asynchronous operation and can take several minutes. You can check the status of this operation by calling the describe-refresh-schemas-status operation.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.RefreshSchemasInput{ EndpointArn: aws.String(""), ReplicationInstanceArn: aws.String(""), } result, err := svc.RefreshSchemas(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

RefreshSchemasRequest

func (c *DatabaseMigrationService) RefreshSchemasRequest(input *RefreshSchemasInput) (req *request.Request, output *RefreshSchemasOutput)

RefreshSchemasRequest generates a "aws/request.Request" representing the client's request for the RefreshSchemas 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 RefreshSchemas for more information on using the RefreshSchemas 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 RefreshSchemasRequest method. req, resp := client.RefreshSchemasRequest(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/RefreshSchemas

RefreshSchemasWithContext

func (c *DatabaseMigrationService) RefreshSchemasWithContext(ctx aws.Context, input *RefreshSchemasInput, opts ...request.Option) (*RefreshSchemasOutput, error)

RefreshSchemasWithContext is the same as RefreshSchemas with the addition of the ability to pass a context and additional request options.

See RefreshSchemas 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.

See Also

For more information about using this API, see AWS API Documentation.

ReloadTables

func (c *DatabaseMigrationService) ReloadTables(input *ReloadTablesInput) (*ReloadTablesOutput, error)

ReloadTables API operation for AWS Database Migration Service.

Reloads the target database table with the source data.

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 ReloadTables for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/ReloadTables

ReloadTablesRequest

func (c *DatabaseMigrationService) ReloadTablesRequest(input *ReloadTablesInput) (req *request.Request, output *ReloadTablesOutput)

ReloadTablesRequest generates a "aws/request.Request" representing the client's request for the ReloadTables 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 ReloadTables for more information on using the ReloadTables 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 ReloadTablesRequest method. req, resp := client.ReloadTablesRequest(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/ReloadTables

ReloadTablesWithContext

func (c *DatabaseMigrationService) ReloadTablesWithContext(ctx aws.Context, input *ReloadTablesInput, opts ...request.Option) (*ReloadTablesOutput, error)

ReloadTablesWithContext is the same as ReloadTables with the addition of the ability to pass a context and additional request options.

See ReloadTables 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.

See Also

For more information about using this API, see AWS API Documentation.

RemoveTagsFromResource

func (c *DatabaseMigrationService) RemoveTagsFromResource(input *RemoveTagsFromResourceInput) (*RemoveTagsFromResourceOutput, error)

RemoveTagsFromResource API operation for AWS Database Migration Service.

Removes metadata tags from a DMS resource.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for AWS Database Migration Service's API operation RemoveTagsFromResource for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/RemoveTagsFromResource

Example

DatabaseMigrationService RemoveTagsFromResource shared00

Remove tags from resource

Removes metadata tags from an AWS DMS resource.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.RemoveTagsFromResourceInput{ ResourceArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:ASXWXJZLNWNT5HTWCGV2BUJQ7E"), } result, err := svc.RemoveTagsFromResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

RemoveTagsFromResourceRequest

func (c *DatabaseMigrationService) RemoveTagsFromResourceRequest(input *RemoveTagsFromResourceInput) (req *request.Request, output *RemoveTagsFromResourceOutput)

RemoveTagsFromResourceRequest generates a "aws/request.Request" representing the client's request for the RemoveTagsFromResource 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 RemoveTagsFromResource for more information on using the RemoveTagsFromResource 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 RemoveTagsFromResourceRequest method. req, resp := client.RemoveTagsFromResourceRequest(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/RemoveTagsFromResource

RemoveTagsFromResourceWithContext

func (c *DatabaseMigrationService) RemoveTagsFromResourceWithContext(ctx aws.Context, input *RemoveTagsFromResourceInput, opts ...request.Option) (*RemoveTagsFromResourceOutput, error)

RemoveTagsFromResourceWithContext is the same as RemoveTagsFromResource with the addition of the ability to pass a context and additional request options.

See RemoveTagsFromResource 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.

See Also

For more information about using this API, see AWS API Documentation.

StartReplicationTask

func (c *DatabaseMigrationService) StartReplicationTask(input *StartReplicationTaskInput) (*StartReplicationTaskOutput, error)

StartReplicationTask API operation for AWS Database Migration Service.

Starts the replication task.

For more information about AWS DMS tasks, see Working with Migration Tasks (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.html) in the AWS Database Migration Service User Guide.

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 StartReplicationTask for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeAccessDeniedFault "AccessDeniedFault" AWS DMS was denied access to the endpoint.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/StartReplicationTask

Example

DatabaseMigrationService StartReplicationTask shared00

Start replication task

Starts the replication task.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.StartReplicationTaskInput{ CdcStartTime: parseTime("2006-01-02T15:04:05Z", "2016-12-14T13:33:20Z"), ReplicationTaskArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), StartReplicationTaskType: aws.String("start-replication"), } result, err := svc.StartReplicationTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeAccessDeniedFault: fmt.Println(databasemigrationservice.ErrCodeAccessDeniedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

StartReplicationTaskAssessment

func (c *DatabaseMigrationService) StartReplicationTaskAssessment(input *StartReplicationTaskAssessmentInput) (*StartReplicationTaskAssessmentOutput, error)

StartReplicationTaskAssessment API operation for AWS Database Migration Service.

Starts the replication task assessment for unsupported data types in the source database.

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 StartReplicationTaskAssessment for usage and error information.

Returned Error Codes:

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/StartReplicationTaskAssessment

StartReplicationTaskAssessmentRequest

func (c *DatabaseMigrationService) StartReplicationTaskAssessmentRequest(input *StartReplicationTaskAssessmentInput) (req *request.Request, output *StartReplicationTaskAssessmentOutput)

StartReplicationTaskAssessmentRequest generates a "aws/request.Request" representing the client's request for the StartReplicationTaskAssessment 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 StartReplicationTaskAssessment for more information on using the StartReplicationTaskAssessment 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 StartReplicationTaskAssessmentRequest method. req, resp := client.StartReplicationTaskAssessmentRequest(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/StartReplicationTaskAssessment

StartReplicationTaskAssessmentWithContext

func (c *DatabaseMigrationService) StartReplicationTaskAssessmentWithContext(ctx aws.Context, input *StartReplicationTaskAssessmentInput, opts ...request.Option) (*StartReplicationTaskAssessmentOutput, error)

StartReplicationTaskAssessmentWithContext is the same as StartReplicationTaskAssessment with the addition of the ability to pass a context and additional request options.

See StartReplicationTaskAssessment 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.

See Also

For more information about using this API, see AWS API Documentation.

StartReplicationTaskRequest

func (c *DatabaseMigrationService) StartReplicationTaskRequest(input *StartReplicationTaskInput) (req *request.Request, output *StartReplicationTaskOutput)

StartReplicationTaskRequest generates a "aws/request.Request" representing the client's request for the StartReplicationTask 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 StartReplicationTask for more information on using the StartReplicationTask 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 StartReplicationTaskRequest method. req, resp := client.StartReplicationTaskRequest(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/StartReplicationTask

StartReplicationTaskWithContext

func (c *DatabaseMigrationService) StartReplicationTaskWithContext(ctx aws.Context, input *StartReplicationTaskInput, opts ...request.Option) (*StartReplicationTaskOutput, error)

StartReplicationTaskWithContext is the same as StartReplicationTask with the addition of the ability to pass a context and additional request options.

See StartReplicationTask 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.

See Also

For more information about using this API, see AWS API Documentation.

StopReplicationTask

func (c *DatabaseMigrationService) StopReplicationTask(input *StopReplicationTaskInput) (*StopReplicationTaskOutput, error)

StopReplicationTask API operation for AWS Database Migration Service.

Stops the replication task.

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 StopReplicationTask for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/StopReplicationTask

Example

DatabaseMigrationService StopReplicationTask shared00

Stop replication task

Stops the replication task.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.StopReplicationTaskInput{ ReplicationTaskArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:ASXWXJZLNWNT5HTWCGV2BUJQ7E"), } result, err := svc.StopReplicationTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

StopReplicationTaskRequest

func (c *DatabaseMigrationService) StopReplicationTaskRequest(input *StopReplicationTaskInput) (req *request.Request, output *StopReplicationTaskOutput)

StopReplicationTaskRequest generates a "aws/request.Request" representing the client's request for the StopReplicationTask 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 StopReplicationTask for more information on using the StopReplicationTask 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 StopReplicationTaskRequest method. req, resp := client.StopReplicationTaskRequest(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/StopReplicationTask

StopReplicationTaskWithContext

func (c *DatabaseMigrationService) StopReplicationTaskWithContext(ctx aws.Context, input *StopReplicationTaskInput, opts ...request.Option) (*StopReplicationTaskOutput, error)

StopReplicationTaskWithContext is the same as StopReplicationTask with the addition of the ability to pass a context and additional request options.

See StopReplicationTask 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.

See Also

For more information about using this API, see AWS API Documentation.

TestConnection

func (c *DatabaseMigrationService) TestConnection(input *TestConnectionInput) (*TestConnectionOutput, error)

TestConnection API operation for AWS Database Migration Service.

Tests the connection between the replication instance and the endpoint.

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 TestConnection for usage and error information.

Returned Error Codes:

  • ErrCodeResourceNotFoundFault "ResourceNotFoundFault" The resource could not be found.

  • ErrCodeInvalidResourceStateFault "InvalidResourceStateFault" The resource is in a state that prevents it from being used for database migration.

  • ErrCodeKMSKeyNotAccessibleFault "KMSKeyNotAccessibleFault" AWS DMS cannot access the KMS key.

  • ErrCodeResourceQuotaExceededFault "ResourceQuotaExceededFault" The quota for this resource quota has been exceeded.

See also, https://docs.aws.amazon.com/goto/WebAPI/dms-2016-01-01/TestConnection

Example

DatabaseMigrationService TestConnection shared00

Test conection

Tests the connection between the replication instance and the endpoint.

{ svc := databasemigrationservice.New(session.New()) input := &databasemigrationservice.TestConnectionInput{ EndpointArn: aws.String("arn:aws:dms:us-east-1:123456789012:endpoint:RAAR3R22XSH46S3PWLC3NJAWKM"), ReplicationInstanceArn: aws.String("arn:aws:dms:us-east-1:123456789012:rep:6UTDJGBOUS3VI3SUWA66XFJCJQ"), } result, err := svc.TestConnection(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case databasemigrationservice.ErrCodeResourceNotFoundFault: fmt.Println(databasemigrationservice.ErrCodeResourceNotFoundFault, aerr.Error()) case databasemigrationservice.ErrCodeInvalidResourceStateFault: fmt.Println(databasemigrationservice.ErrCodeInvalidResourceStateFault, aerr.Error()) case databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(databasemigrationservice.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case databasemigrationservice.ErrCodeResourceQuotaExceededFault: fmt.Println(databasemigrationservice.ErrCodeResourceQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { fmt.Println(err.Error()) } return } fmt.Println(result) }

TestConnectionRequest

func (c *DatabaseMigrationService) TestConnectionRequest(input *TestConnectionInput) (req *request.Request, output *TestConnectionOutput)

TestConnectionRequest generates a "aws/request.Request" representing the client's request for the TestConnection 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 TestConnection for more information on using the TestConnection 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 TestConnectionRequest method. req, resp := client.TestConnectionRequest(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/TestConnection

TestConnectionWithContext

func (c *DatabaseMigrationService) TestConnectionWithContext(ctx aws.Context, input *TestConnectionInput, opts ...request.Option) (*TestConnectionOutput, error)

TestConnectionWithContext is the same as TestConnection with the addition of the ability to pass a context and additional request options.

See TestConnection 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.

See Also

For more information about using this API, see AWS API Documentation.

WaitUntilEndpointDeleted

func (c *DatabaseMigrationService) WaitUntilEndpointDeleted(input *DescribeEndpointsInput) error

WaitUntilEndpointDeleted uses the AWS Database Migration Service API operation DescribeEndpoints to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilEndpointDeletedWithContext

func (c *DatabaseMigrationService) WaitUntilEndpointDeletedWithContext(ctx aws.Context, input *DescribeEndpointsInput, opts ...request.WaiterOption) error

WaitUntilEndpointDeletedWithContext is an extended version of WaitUntilEndpointDeleted. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationInstanceAvailable

func (c *DatabaseMigrationService) WaitUntilReplicationInstanceAvailable(input *DescribeReplicationInstancesInput) error

WaitUntilReplicationInstanceAvailable uses the AWS Database Migration Service API operation DescribeReplicationInstances to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationInstanceAvailableWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationInstanceAvailableWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, opts ...request.WaiterOption) error

WaitUntilReplicationInstanceAvailableWithContext is an extended version of WaitUntilReplicationInstanceAvailable. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationInstanceDeleted

func (c *DatabaseMigrationService) WaitUntilReplicationInstanceDeleted(input *DescribeReplicationInstancesInput) error

WaitUntilReplicationInstanceDeleted uses the AWS Database Migration Service API operation DescribeReplicationInstances to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationInstanceDeletedWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationInstanceDeletedWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, opts ...request.WaiterOption) error

WaitUntilReplicationInstanceDeletedWithContext is an extended version of WaitUntilReplicationInstanceDeleted. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationTaskDeleted

func (c *DatabaseMigrationService) WaitUntilReplicationTaskDeleted(input *DescribeReplicationTasksInput) error

WaitUntilReplicationTaskDeleted uses the AWS Database Migration Service API operation DescribeReplicationTasks to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationTaskDeletedWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationTaskDeletedWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, opts ...request.WaiterOption) error

WaitUntilReplicationTaskDeletedWithContext is an extended version of WaitUntilReplicationTaskDeleted. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationTaskReady

func (c *DatabaseMigrationService) WaitUntilReplicationTaskReady(input *DescribeReplicationTasksInput) error

WaitUntilReplicationTaskReady uses the AWS Database Migration Service API operation DescribeReplicationTasks to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationTaskReadyWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationTaskReadyWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, opts ...request.WaiterOption) error

WaitUntilReplicationTaskReadyWithContext is an extended version of WaitUntilReplicationTaskReady. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationTaskRunning

func (c *DatabaseMigrationService) WaitUntilReplicationTaskRunning(input *DescribeReplicationTasksInput) error

WaitUntilReplicationTaskRunning uses the AWS Database Migration Service API operation DescribeReplicationTasks to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationTaskRunningWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationTaskRunningWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, opts ...request.WaiterOption) error

WaitUntilReplicationTaskRunningWithContext is an extended version of WaitUntilReplicationTaskRunning. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilReplicationTaskStopped

func (c *DatabaseMigrationService) WaitUntilReplicationTaskStopped(input *DescribeReplicationTasksInput) error

WaitUntilReplicationTaskStopped uses the AWS Database Migration Service API operation DescribeReplicationTasks to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilReplicationTaskStoppedWithContext

func (c *DatabaseMigrationService) WaitUntilReplicationTaskStoppedWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, opts ...request.WaiterOption) error

WaitUntilReplicationTaskStoppedWithContext is an extended version of WaitUntilReplicationTaskStopped. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

WaitUntilTestConnectionSucceeds

func (c *DatabaseMigrationService) WaitUntilTestConnectionSucceeds(input *DescribeConnectionsInput) error

WaitUntilTestConnectionSucceeds uses the AWS Database Migration Service API operation DescribeConnections to wait for a condition to be met before returning. If the condition is not met within the max attempt window, an error will be returned.

WaitUntilTestConnectionSucceedsWithContext

func (c *DatabaseMigrationService) WaitUntilTestConnectionSucceedsWithContext(ctx aws.Context, input *DescribeConnectionsInput, opts ...request.WaiterOption) error

WaitUntilTestConnectionSucceedsWithContext is an extended version of WaitUntilTestConnectionSucceeds. With the support for passing in a context and options to configure the Waiter and the underlying request options.

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.

On this page: