Documentation
¶
Overview ¶
Package databasemigrationservice provides the API client, operations, and parameter types for AWS Database Migration Service.
Database Migration Service Database Migration Service (DMS) can migrate your data to and from the most widely used commercial and open-source databases such as Oracle, PostgreSQL, Microsoft SQL Server, Amazon Redshift, MariaDB, Amazon Aurora, MySQL, and SAP Adaptive Server Enterprise (ASE). The service supports homogeneous migrations such as Oracle to Oracle, as well as heterogeneous migrations between different database platforms, such as Oracle to MySQL or SQL Server to PostgreSQL. For more information about DMS, see What Is Database Migration Service? (https://docs.aws.amazon.com/dms/latest/userguide/Welcome.html) in the Database Migration Service User Guide.
Index ¶
- Constants
- func NewDefaultEndpointResolver() *internalendpoints.Resolver
- func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)
- func WithEndpointResolver(v EndpointResolver) func(*Options)
- type AddTagsToResourceInput
- type AddTagsToResourceOutput
- type ApplyPendingMaintenanceActionInput
- type ApplyPendingMaintenanceActionOutput
- type CancelReplicationTaskAssessmentRunInput
- type CancelReplicationTaskAssessmentRunOutput
- type Client
- func (c *Client) AddTagsToResource(ctx context.Context, params *AddTagsToResourceInput, optFns ...func(*Options)) (*AddTagsToResourceOutput, error)
- func (c *Client) ApplyPendingMaintenanceAction(ctx context.Context, params *ApplyPendingMaintenanceActionInput, ...) (*ApplyPendingMaintenanceActionOutput, error)
- func (c *Client) CancelReplicationTaskAssessmentRun(ctx context.Context, params *CancelReplicationTaskAssessmentRunInput, ...) (*CancelReplicationTaskAssessmentRunOutput, error)
- func (c *Client) CreateEndpoint(ctx context.Context, params *CreateEndpointInput, optFns ...func(*Options)) (*CreateEndpointOutput, error)
- func (c *Client) CreateEventSubscription(ctx context.Context, params *CreateEventSubscriptionInput, ...) (*CreateEventSubscriptionOutput, error)
- func (c *Client) CreateFleetAdvisorCollector(ctx context.Context, params *CreateFleetAdvisorCollectorInput, ...) (*CreateFleetAdvisorCollectorOutput, error)
- func (c *Client) CreateReplicationInstance(ctx context.Context, params *CreateReplicationInstanceInput, ...) (*CreateReplicationInstanceOutput, error)
- func (c *Client) CreateReplicationSubnetGroup(ctx context.Context, params *CreateReplicationSubnetGroupInput, ...) (*CreateReplicationSubnetGroupOutput, error)
- func (c *Client) CreateReplicationTask(ctx context.Context, params *CreateReplicationTaskInput, ...) (*CreateReplicationTaskOutput, error)
- func (c *Client) DeleteCertificate(ctx context.Context, params *DeleteCertificateInput, optFns ...func(*Options)) (*DeleteCertificateOutput, error)
- func (c *Client) DeleteConnection(ctx context.Context, params *DeleteConnectionInput, optFns ...func(*Options)) (*DeleteConnectionOutput, error)
- func (c *Client) DeleteEndpoint(ctx context.Context, params *DeleteEndpointInput, optFns ...func(*Options)) (*DeleteEndpointOutput, error)
- func (c *Client) DeleteEventSubscription(ctx context.Context, params *DeleteEventSubscriptionInput, ...) (*DeleteEventSubscriptionOutput, error)
- func (c *Client) DeleteFleetAdvisorCollector(ctx context.Context, params *DeleteFleetAdvisorCollectorInput, ...) (*DeleteFleetAdvisorCollectorOutput, error)
- func (c *Client) DeleteFleetAdvisorDatabases(ctx context.Context, params *DeleteFleetAdvisorDatabasesInput, ...) (*DeleteFleetAdvisorDatabasesOutput, error)
- func (c *Client) DeleteReplicationInstance(ctx context.Context, params *DeleteReplicationInstanceInput, ...) (*DeleteReplicationInstanceOutput, error)
- func (c *Client) DeleteReplicationSubnetGroup(ctx context.Context, params *DeleteReplicationSubnetGroupInput, ...) (*DeleteReplicationSubnetGroupOutput, error)
- func (c *Client) DeleteReplicationTask(ctx context.Context, params *DeleteReplicationTaskInput, ...) (*DeleteReplicationTaskOutput, error)
- func (c *Client) DeleteReplicationTaskAssessmentRun(ctx context.Context, params *DeleteReplicationTaskAssessmentRunInput, ...) (*DeleteReplicationTaskAssessmentRunOutput, error)
- func (c *Client) DescribeAccountAttributes(ctx context.Context, params *DescribeAccountAttributesInput, ...) (*DescribeAccountAttributesOutput, error)
- func (c *Client) DescribeApplicableIndividualAssessments(ctx context.Context, params *DescribeApplicableIndividualAssessmentsInput, ...) (*DescribeApplicableIndividualAssessmentsOutput, error)
- func (c *Client) DescribeCertificates(ctx context.Context, params *DescribeCertificatesInput, ...) (*DescribeCertificatesOutput, error)
- func (c *Client) DescribeConnections(ctx context.Context, params *DescribeConnectionsInput, ...) (*DescribeConnectionsOutput, error)
- func (c *Client) DescribeEndpointSettings(ctx context.Context, params *DescribeEndpointSettingsInput, ...) (*DescribeEndpointSettingsOutput, error)
- func (c *Client) DescribeEndpointTypes(ctx context.Context, params *DescribeEndpointTypesInput, ...) (*DescribeEndpointTypesOutput, error)
- func (c *Client) DescribeEndpoints(ctx context.Context, params *DescribeEndpointsInput, optFns ...func(*Options)) (*DescribeEndpointsOutput, error)
- func (c *Client) DescribeEventCategories(ctx context.Context, params *DescribeEventCategoriesInput, ...) (*DescribeEventCategoriesOutput, error)
- func (c *Client) DescribeEventSubscriptions(ctx context.Context, params *DescribeEventSubscriptionsInput, ...) (*DescribeEventSubscriptionsOutput, error)
- func (c *Client) DescribeEvents(ctx context.Context, params *DescribeEventsInput, optFns ...func(*Options)) (*DescribeEventsOutput, error)
- func (c *Client) DescribeFleetAdvisorCollectors(ctx context.Context, params *DescribeFleetAdvisorCollectorsInput, ...) (*DescribeFleetAdvisorCollectorsOutput, error)
- func (c *Client) DescribeFleetAdvisorDatabases(ctx context.Context, params *DescribeFleetAdvisorDatabasesInput, ...) (*DescribeFleetAdvisorDatabasesOutput, error)
- func (c *Client) DescribeFleetAdvisorLsaAnalysis(ctx context.Context, params *DescribeFleetAdvisorLsaAnalysisInput, ...) (*DescribeFleetAdvisorLsaAnalysisOutput, error)
- func (c *Client) DescribeFleetAdvisorSchemaObjectSummary(ctx context.Context, params *DescribeFleetAdvisorSchemaObjectSummaryInput, ...) (*DescribeFleetAdvisorSchemaObjectSummaryOutput, error)
- func (c *Client) DescribeFleetAdvisorSchemas(ctx context.Context, params *DescribeFleetAdvisorSchemasInput, ...) (*DescribeFleetAdvisorSchemasOutput, error)
- func (c *Client) DescribeOrderableReplicationInstances(ctx context.Context, params *DescribeOrderableReplicationInstancesInput, ...) (*DescribeOrderableReplicationInstancesOutput, error)
- func (c *Client) DescribePendingMaintenanceActions(ctx context.Context, params *DescribePendingMaintenanceActionsInput, ...) (*DescribePendingMaintenanceActionsOutput, error)
- func (c *Client) DescribeRefreshSchemasStatus(ctx context.Context, params *DescribeRefreshSchemasStatusInput, ...) (*DescribeRefreshSchemasStatusOutput, error)
- func (c *Client) DescribeReplicationInstanceTaskLogs(ctx context.Context, params *DescribeReplicationInstanceTaskLogsInput, ...) (*DescribeReplicationInstanceTaskLogsOutput, error)
- func (c *Client) DescribeReplicationInstances(ctx context.Context, params *DescribeReplicationInstancesInput, ...) (*DescribeReplicationInstancesOutput, error)
- func (c *Client) DescribeReplicationSubnetGroups(ctx context.Context, params *DescribeReplicationSubnetGroupsInput, ...) (*DescribeReplicationSubnetGroupsOutput, error)
- func (c *Client) DescribeReplicationTaskAssessmentResults(ctx context.Context, params *DescribeReplicationTaskAssessmentResultsInput, ...) (*DescribeReplicationTaskAssessmentResultsOutput, error)
- func (c *Client) DescribeReplicationTaskAssessmentRuns(ctx context.Context, params *DescribeReplicationTaskAssessmentRunsInput, ...) (*DescribeReplicationTaskAssessmentRunsOutput, error)
- func (c *Client) DescribeReplicationTaskIndividualAssessments(ctx context.Context, params *DescribeReplicationTaskIndividualAssessmentsInput, ...) (*DescribeReplicationTaskIndividualAssessmentsOutput, error)
- func (c *Client) DescribeReplicationTasks(ctx context.Context, params *DescribeReplicationTasksInput, ...) (*DescribeReplicationTasksOutput, error)
- func (c *Client) DescribeSchemas(ctx context.Context, params *DescribeSchemasInput, optFns ...func(*Options)) (*DescribeSchemasOutput, error)
- func (c *Client) DescribeTableStatistics(ctx context.Context, params *DescribeTableStatisticsInput, ...) (*DescribeTableStatisticsOutput, error)
- func (c *Client) ImportCertificate(ctx context.Context, params *ImportCertificateInput, optFns ...func(*Options)) (*ImportCertificateOutput, error)
- func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, ...) (*ListTagsForResourceOutput, error)
- func (c *Client) ModifyEndpoint(ctx context.Context, params *ModifyEndpointInput, optFns ...func(*Options)) (*ModifyEndpointOutput, error)
- func (c *Client) ModifyEventSubscription(ctx context.Context, params *ModifyEventSubscriptionInput, ...) (*ModifyEventSubscriptionOutput, error)
- func (c *Client) ModifyReplicationInstance(ctx context.Context, params *ModifyReplicationInstanceInput, ...) (*ModifyReplicationInstanceOutput, error)
- func (c *Client) ModifyReplicationSubnetGroup(ctx context.Context, params *ModifyReplicationSubnetGroupInput, ...) (*ModifyReplicationSubnetGroupOutput, error)
- func (c *Client) ModifyReplicationTask(ctx context.Context, params *ModifyReplicationTaskInput, ...) (*ModifyReplicationTaskOutput, error)
- func (c *Client) MoveReplicationTask(ctx context.Context, params *MoveReplicationTaskInput, ...) (*MoveReplicationTaskOutput, error)
- func (c *Client) RebootReplicationInstance(ctx context.Context, params *RebootReplicationInstanceInput, ...) (*RebootReplicationInstanceOutput, error)
- func (c *Client) RefreshSchemas(ctx context.Context, params *RefreshSchemasInput, optFns ...func(*Options)) (*RefreshSchemasOutput, error)
- func (c *Client) ReloadTables(ctx context.Context, params *ReloadTablesInput, optFns ...func(*Options)) (*ReloadTablesOutput, error)
- func (c *Client) RemoveTagsFromResource(ctx context.Context, params *RemoveTagsFromResourceInput, ...) (*RemoveTagsFromResourceOutput, error)
- func (c *Client) RunFleetAdvisorLsaAnalysis(ctx context.Context, params *RunFleetAdvisorLsaAnalysisInput, ...) (*RunFleetAdvisorLsaAnalysisOutput, error)
- func (c *Client) StartReplicationTask(ctx context.Context, params *StartReplicationTaskInput, ...) (*StartReplicationTaskOutput, error)
- func (c *Client) StartReplicationTaskAssessment(ctx context.Context, params *StartReplicationTaskAssessmentInput, ...) (*StartReplicationTaskAssessmentOutput, error)
- func (c *Client) StartReplicationTaskAssessmentRun(ctx context.Context, params *StartReplicationTaskAssessmentRunInput, ...) (*StartReplicationTaskAssessmentRunOutput, error)
- func (c *Client) StopReplicationTask(ctx context.Context, params *StopReplicationTaskInput, ...) (*StopReplicationTaskOutput, error)
- func (c *Client) TestConnection(ctx context.Context, params *TestConnectionInput, optFns ...func(*Options)) (*TestConnectionOutput, error)
- func (c *Client) UpdateSubscriptionsToEventBridge(ctx context.Context, params *UpdateSubscriptionsToEventBridgeInput, ...) (*UpdateSubscriptionsToEventBridgeOutput, error)
- type CreateEndpointInput
- type CreateEndpointOutput
- type CreateEventSubscriptionInput
- type CreateEventSubscriptionOutput
- type CreateFleetAdvisorCollectorInput
- type CreateFleetAdvisorCollectorOutput
- type CreateReplicationInstanceInput
- type CreateReplicationInstanceOutput
- type CreateReplicationSubnetGroupInput
- type CreateReplicationSubnetGroupOutput
- type CreateReplicationTaskInput
- type CreateReplicationTaskOutput
- type DeleteCertificateInput
- type DeleteCertificateOutput
- type DeleteConnectionInput
- type DeleteConnectionOutput
- type DeleteEndpointInput
- type DeleteEndpointOutput
- type DeleteEventSubscriptionInput
- type DeleteEventSubscriptionOutput
- type DeleteFleetAdvisorCollectorInput
- type DeleteFleetAdvisorCollectorOutput
- type DeleteFleetAdvisorDatabasesInput
- type DeleteFleetAdvisorDatabasesOutput
- type DeleteReplicationInstanceInput
- type DeleteReplicationInstanceOutput
- type DeleteReplicationSubnetGroupInput
- type DeleteReplicationSubnetGroupOutput
- type DeleteReplicationTaskAssessmentRunInput
- type DeleteReplicationTaskAssessmentRunOutput
- type DeleteReplicationTaskInput
- type DeleteReplicationTaskOutput
- type DescribeAccountAttributesInput
- type DescribeAccountAttributesOutput
- type DescribeApplicableIndividualAssessmentsAPIClient
- type DescribeApplicableIndividualAssessmentsInput
- type DescribeApplicableIndividualAssessmentsOutput
- type DescribeApplicableIndividualAssessmentsPaginator
- type DescribeApplicableIndividualAssessmentsPaginatorOptions
- type DescribeCertificatesAPIClient
- type DescribeCertificatesInput
- type DescribeCertificatesOutput
- type DescribeCertificatesPaginator
- type DescribeCertificatesPaginatorOptions
- type DescribeConnectionsAPIClient
- type DescribeConnectionsInput
- type DescribeConnectionsOutput
- type DescribeConnectionsPaginator
- type DescribeConnectionsPaginatorOptions
- type DescribeEndpointSettingsAPIClient
- type DescribeEndpointSettingsInput
- type DescribeEndpointSettingsOutput
- type DescribeEndpointSettingsPaginator
- type DescribeEndpointSettingsPaginatorOptions
- type DescribeEndpointTypesAPIClient
- type DescribeEndpointTypesInput
- type DescribeEndpointTypesOutput
- type DescribeEndpointTypesPaginator
- type DescribeEndpointTypesPaginatorOptions
- type DescribeEndpointsAPIClient
- type DescribeEndpointsInput
- type DescribeEndpointsOutput
- type DescribeEndpointsPaginator
- type DescribeEndpointsPaginatorOptions
- type DescribeEventCategoriesInput
- type DescribeEventCategoriesOutput
- type DescribeEventSubscriptionsAPIClient
- type DescribeEventSubscriptionsInput
- type DescribeEventSubscriptionsOutput
- type DescribeEventSubscriptionsPaginator
- type DescribeEventSubscriptionsPaginatorOptions
- type DescribeEventsAPIClient
- type DescribeEventsInput
- type DescribeEventsOutput
- type DescribeEventsPaginator
- type DescribeEventsPaginatorOptions
- type DescribeFleetAdvisorCollectorsAPIClient
- type DescribeFleetAdvisorCollectorsInput
- type DescribeFleetAdvisorCollectorsOutput
- type DescribeFleetAdvisorCollectorsPaginator
- type DescribeFleetAdvisorCollectorsPaginatorOptions
- type DescribeFleetAdvisorDatabasesAPIClient
- type DescribeFleetAdvisorDatabasesInput
- type DescribeFleetAdvisorDatabasesOutput
- type DescribeFleetAdvisorDatabasesPaginator
- type DescribeFleetAdvisorDatabasesPaginatorOptions
- type DescribeFleetAdvisorLsaAnalysisAPIClient
- type DescribeFleetAdvisorLsaAnalysisInput
- type DescribeFleetAdvisorLsaAnalysisOutput
- type DescribeFleetAdvisorLsaAnalysisPaginator
- type DescribeFleetAdvisorLsaAnalysisPaginatorOptions
- type DescribeFleetAdvisorSchemaObjectSummaryAPIClient
- type DescribeFleetAdvisorSchemaObjectSummaryInput
- type DescribeFleetAdvisorSchemaObjectSummaryOutput
- type DescribeFleetAdvisorSchemaObjectSummaryPaginator
- type DescribeFleetAdvisorSchemaObjectSummaryPaginatorOptions
- type DescribeFleetAdvisorSchemasAPIClient
- type DescribeFleetAdvisorSchemasInput
- type DescribeFleetAdvisorSchemasOutput
- type DescribeFleetAdvisorSchemasPaginator
- type DescribeFleetAdvisorSchemasPaginatorOptions
- type DescribeOrderableReplicationInstancesAPIClient
- type DescribeOrderableReplicationInstancesInput
- type DescribeOrderableReplicationInstancesOutput
- type DescribeOrderableReplicationInstancesPaginator
- type DescribeOrderableReplicationInstancesPaginatorOptions
- type DescribePendingMaintenanceActionsAPIClient
- type DescribePendingMaintenanceActionsInput
- type DescribePendingMaintenanceActionsOutput
- type DescribePendingMaintenanceActionsPaginator
- type DescribePendingMaintenanceActionsPaginatorOptions
- type DescribeRefreshSchemasStatusInput
- type DescribeRefreshSchemasStatusOutput
- type DescribeReplicationInstanceTaskLogsAPIClient
- type DescribeReplicationInstanceTaskLogsInput
- type DescribeReplicationInstanceTaskLogsOutput
- type DescribeReplicationInstanceTaskLogsPaginator
- type DescribeReplicationInstanceTaskLogsPaginatorOptions
- type DescribeReplicationInstancesAPIClient
- type DescribeReplicationInstancesInput
- type DescribeReplicationInstancesOutput
- type DescribeReplicationInstancesPaginator
- type DescribeReplicationInstancesPaginatorOptions
- type DescribeReplicationSubnetGroupsAPIClient
- type DescribeReplicationSubnetGroupsInput
- type DescribeReplicationSubnetGroupsOutput
- type DescribeReplicationSubnetGroupsPaginator
- type DescribeReplicationSubnetGroupsPaginatorOptions
- type DescribeReplicationTaskAssessmentResultsAPIClient
- type DescribeReplicationTaskAssessmentResultsInput
- type DescribeReplicationTaskAssessmentResultsOutput
- type DescribeReplicationTaskAssessmentResultsPaginator
- type DescribeReplicationTaskAssessmentResultsPaginatorOptions
- type DescribeReplicationTaskAssessmentRunsAPIClient
- type DescribeReplicationTaskAssessmentRunsInput
- type DescribeReplicationTaskAssessmentRunsOutput
- type DescribeReplicationTaskAssessmentRunsPaginator
- type DescribeReplicationTaskAssessmentRunsPaginatorOptions
- type DescribeReplicationTaskIndividualAssessmentsAPIClient
- type DescribeReplicationTaskIndividualAssessmentsInput
- type DescribeReplicationTaskIndividualAssessmentsOutput
- type DescribeReplicationTaskIndividualAssessmentsPaginator
- type DescribeReplicationTaskIndividualAssessmentsPaginatorOptions
- type DescribeReplicationTasksAPIClient
- type DescribeReplicationTasksInput
- type DescribeReplicationTasksOutput
- type DescribeReplicationTasksPaginator
- type DescribeReplicationTasksPaginatorOptions
- type DescribeSchemasAPIClient
- type DescribeSchemasInput
- type DescribeSchemasOutput
- type DescribeSchemasPaginator
- type DescribeSchemasPaginatorOptions
- type DescribeTableStatisticsAPIClient
- type DescribeTableStatisticsInput
- type DescribeTableStatisticsOutput
- type DescribeTableStatisticsPaginator
- type DescribeTableStatisticsPaginatorOptions
- type EndpointDeletedWaiter
- type EndpointDeletedWaiterOptions
- type EndpointResolver
- type EndpointResolverFunc
- type EndpointResolverOptions
- type HTTPClient
- type HTTPSignerV4
- type ImportCertificateInput
- type ImportCertificateOutput
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type ModifyEndpointInput
- type ModifyEndpointOutput
- type ModifyEventSubscriptionInput
- type ModifyEventSubscriptionOutput
- type ModifyReplicationInstanceInput
- type ModifyReplicationInstanceOutput
- type ModifyReplicationSubnetGroupInput
- type ModifyReplicationSubnetGroupOutput
- type ModifyReplicationTaskInput
- type ModifyReplicationTaskOutput
- type MoveReplicationTaskInput
- type MoveReplicationTaskOutput
- type Options
- type RebootReplicationInstanceInput
- type RebootReplicationInstanceOutput
- type RefreshSchemasInput
- type RefreshSchemasOutput
- type ReloadTablesInput
- type ReloadTablesOutput
- type RemoveTagsFromResourceInput
- type RemoveTagsFromResourceOutput
- type ReplicationInstanceAvailableWaiter
- type ReplicationInstanceAvailableWaiterOptions
- type ReplicationInstanceDeletedWaiter
- type ReplicationInstanceDeletedWaiterOptions
- type ReplicationTaskDeletedWaiter
- type ReplicationTaskDeletedWaiterOptions
- type ReplicationTaskReadyWaiter
- type ReplicationTaskReadyWaiterOptions
- type ReplicationTaskRunningWaiter
- type ReplicationTaskRunningWaiterOptions
- type ReplicationTaskStoppedWaiter
- type ReplicationTaskStoppedWaiterOptions
- type ResolveEndpoint
- type RunFleetAdvisorLsaAnalysisInput
- type RunFleetAdvisorLsaAnalysisOutput
- type StartReplicationTaskAssessmentInput
- type StartReplicationTaskAssessmentOutput
- type StartReplicationTaskAssessmentRunInput
- type StartReplicationTaskAssessmentRunOutput
- type StartReplicationTaskInput
- type StartReplicationTaskOutput
- type StopReplicationTaskInput
- type StopReplicationTaskOutput
- type TestConnectionInput
- type TestConnectionOutput
- type TestConnectionSucceedsWaiter
- type TestConnectionSucceedsWaiterOptions
- type UpdateSubscriptionsToEventBridgeInput
- type UpdateSubscriptionsToEventBridgeOutput
Constants ¶
const ServiceAPIVersion = "2016-01-01"
const ServiceID = "Database Migration Service"
Variables ¶
This section is empty.
Functions ¶
func NewDefaultEndpointResolver ¶
func NewDefaultEndpointResolver() *internalendpoints.Resolver
NewDefaultEndpointResolver constructs a new service endpoint resolver
func WithAPIOptions ¶ added in v1.0.0
func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)
WithAPIOptions returns a functional option for setting the Client's APIOptions option.
func WithEndpointResolver ¶
func WithEndpointResolver(v EndpointResolver) func(*Options)
WithEndpointResolver returns a functional option for setting the Client's EndpointResolver option.
Types ¶
type AddTagsToResourceInput ¶
type AddTagsToResourceInput struct { // Identifies the DMS resource to which tags should be added. The value for this // parameter is an Amazon Resource Name (ARN). For DMS, you can tag a replication // instance, an endpoint, or a replication task. // // This member is required. ResourceArn *string // One or more tags to be assigned to the resource. // // This member is required. Tags []types.Tag // contains filtered or unexported fields }
Associates a set of tags with an DMS resource.
type AddTagsToResourceOutput ¶
type AddTagsToResourceOutput struct { // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ApplyPendingMaintenanceActionInput ¶
type ApplyPendingMaintenanceActionInput struct { // The pending maintenance action to apply to this resource. Valid values: // os-upgrade, system-update, db-upgrade // // This member is required. ApplyAction *string // A value that specifies the type of opt-in request, or undoes an opt-in request. // You can't undo an opt-in request of type immediate. Valid values: // // * immediate - // Apply the maintenance action immediately. // // * next-maintenance - Apply the // maintenance action during the next maintenance window for the resource. // // * // undo-opt-in - Cancel any existing next-maintenance opt-in requests. // // This member is required. OptInType *string // The Amazon Resource Name (ARN) of the DMS resource that the pending maintenance // action applies to. // // This member is required. ReplicationInstanceArn *string // contains filtered or unexported fields }
type ApplyPendingMaintenanceActionOutput ¶
type ApplyPendingMaintenanceActionOutput struct { // The DMS resource that the pending maintenance action will be applied to. ResourcePendingMaintenanceActions *types.ResourcePendingMaintenanceActions // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CancelReplicationTaskAssessmentRunInput ¶
type CancelReplicationTaskAssessmentRunInput struct { // Amazon Resource Name (ARN) of the premigration assessment run to be canceled. // // This member is required. ReplicationTaskAssessmentRunArn *string // contains filtered or unexported fields }
type CancelReplicationTaskAssessmentRunOutput ¶
type CancelReplicationTaskAssessmentRunOutput struct { // The ReplicationTaskAssessmentRun object for the canceled assessment run. ReplicationTaskAssessmentRun *types.ReplicationTaskAssessmentRun // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client provides the API client to make operations call for AWS Database Migration Service.
func New ¶
New returns an initialized Client based on the functional options. Provide additional functional options to further configure the behavior of the client, such as changing the client's endpoint or adding custom middleware behavior.
func NewFromConfig ¶
NewFromConfig returns a new client from the provided config.
func (*Client) AddTagsToResource ¶
func (c *Client) AddTagsToResource(ctx context.Context, params *AddTagsToResourceInput, optFns ...func(*Options)) (*AddTagsToResourceOutput, error)
Adds metadata tags to an 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. For more information, see Tag (https://docs.aws.amazon.com/dms/latest/APIReference/API_Tag.html) data type description.
func (*Client) ApplyPendingMaintenanceAction ¶
func (c *Client) ApplyPendingMaintenanceAction(ctx context.Context, params *ApplyPendingMaintenanceActionInput, optFns ...func(*Options)) (*ApplyPendingMaintenanceActionOutput, error)
Applies a pending maintenance action to a resource (for example, to a replication instance).
func (*Client) CancelReplicationTaskAssessmentRun ¶
func (c *Client) CancelReplicationTaskAssessmentRun(ctx context.Context, params *CancelReplicationTaskAssessmentRunInput, optFns ...func(*Options)) (*CancelReplicationTaskAssessmentRunOutput, error)
Cancels a single premigration assessment run. This operation prevents any individual assessments from running if they haven't started running. It also attempts to cancel any individual assessments that are currently running.
func (*Client) CreateEndpoint ¶
func (c *Client) CreateEndpoint(ctx context.Context, params *CreateEndpointInput, optFns ...func(*Options)) (*CreateEndpointOutput, error)
Creates an endpoint using the provided settings. For a MySQL source or target endpoint, don't explicitly specify the database using the DatabaseName request parameter on the CreateEndpoint API call. Specifying DatabaseName when you create a MySQL endpoint replicates all the task tables to this single database. For MySQL endpoints, you specify the database only when you specify the schema in the table-mapping rules of the DMS task.
func (*Client) CreateEventSubscription ¶
func (c *Client) CreateEventSubscription(ctx context.Context, params *CreateEventSubscriptionInput, optFns ...func(*Options)) (*CreateEventSubscriptionOutput, error)
Creates an DMS event notification subscription. You can specify the type of source (SourceType) you want to be notified of, provide a list of 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 DMS sources. If you don't specify either SourceType nor SourceIdentifier, you will be notified of events generated from all DMS sources belonging to your customer account. For more information about DMS events, see Working with Events and Notifications (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the Database Migration Service User Guide.
func (*Client) CreateFleetAdvisorCollector ¶ added in v1.19.0
func (c *Client) CreateFleetAdvisorCollector(ctx context.Context, params *CreateFleetAdvisorCollectorInput, optFns ...func(*Options)) (*CreateFleetAdvisorCollectorOutput, error)
Creates a Fleet Advisor collector using the specified parameters.
func (*Client) CreateReplicationInstance ¶
func (c *Client) CreateReplicationInstance(ctx context.Context, params *CreateReplicationInstanceInput, optFns ...func(*Options)) (*CreateReplicationInstanceOutput, error)
Creates the replication instance using the specified parameters. DMS requires that your account have certain roles with appropriate permissions before you can create a replication instance. For information on the required roles, see Creating the IAM Roles to Use With the CLI and DMS API (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Security.html#CHAP_Security.APIRole). For information on the required permissions, see IAM Permissions Needed to Use DMS (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Security.html#CHAP_Security.IAMPermissions).
func (*Client) CreateReplicationSubnetGroup ¶
func (c *Client) CreateReplicationSubnetGroup(ctx context.Context, params *CreateReplicationSubnetGroupInput, optFns ...func(*Options)) (*CreateReplicationSubnetGroupOutput, error)
Creates a replication subnet group given a list of the subnet IDs in a VPC. The VPC needs to have at least one subnet in at least two availability zones in the Amazon Web Services Region, otherwise the service will throw a ReplicationSubnetGroupDoesNotCoverEnoughAZs exception.
func (*Client) CreateReplicationTask ¶
func (c *Client) CreateReplicationTask(ctx context.Context, params *CreateReplicationTaskInput, optFns ...func(*Options)) (*CreateReplicationTaskOutput, error)
Creates a replication task using the specified parameters.
func (*Client) DeleteCertificate ¶
func (c *Client) DeleteCertificate(ctx context.Context, params *DeleteCertificateInput, optFns ...func(*Options)) (*DeleteCertificateOutput, error)
Deletes the specified certificate.
func (*Client) DeleteConnection ¶
func (c *Client) DeleteConnection(ctx context.Context, params *DeleteConnectionInput, optFns ...func(*Options)) (*DeleteConnectionOutput, error)
Deletes the connection between a replication instance and an endpoint.
func (*Client) DeleteEndpoint ¶
func (c *Client) DeleteEndpoint(ctx context.Context, params *DeleteEndpointInput, optFns ...func(*Options)) (*DeleteEndpointOutput, error)
Deletes the specified endpoint. All tasks associated with the endpoint must be deleted before you can delete the endpoint.
func (*Client) DeleteEventSubscription ¶
func (c *Client) DeleteEventSubscription(ctx context.Context, params *DeleteEventSubscriptionInput, optFns ...func(*Options)) (*DeleteEventSubscriptionOutput, error)
Deletes an DMS event subscription.
func (*Client) DeleteFleetAdvisorCollector ¶ added in v1.19.0
func (c *Client) DeleteFleetAdvisorCollector(ctx context.Context, params *DeleteFleetAdvisorCollectorInput, optFns ...func(*Options)) (*DeleteFleetAdvisorCollectorOutput, error)
Deletes the specified Fleet Advisor collector.
func (*Client) DeleteFleetAdvisorDatabases ¶ added in v1.19.0
func (c *Client) DeleteFleetAdvisorDatabases(ctx context.Context, params *DeleteFleetAdvisorDatabasesInput, optFns ...func(*Options)) (*DeleteFleetAdvisorDatabasesOutput, error)
Deletes the specified Fleet Advisor collector databases.
func (*Client) DeleteReplicationInstance ¶
func (c *Client) DeleteReplicationInstance(ctx context.Context, params *DeleteReplicationInstanceInput, optFns ...func(*Options)) (*DeleteReplicationInstanceOutput, error)
Deletes the specified replication instance. You must delete any migration tasks that are associated with the replication instance before you can delete it.
func (*Client) DeleteReplicationSubnetGroup ¶
func (c *Client) DeleteReplicationSubnetGroup(ctx context.Context, params *DeleteReplicationSubnetGroupInput, optFns ...func(*Options)) (*DeleteReplicationSubnetGroupOutput, error)
Deletes a subnet group.
func (*Client) DeleteReplicationTask ¶
func (c *Client) DeleteReplicationTask(ctx context.Context, params *DeleteReplicationTaskInput, optFns ...func(*Options)) (*DeleteReplicationTaskOutput, error)
Deletes the specified replication task.
func (*Client) DeleteReplicationTaskAssessmentRun ¶
func (c *Client) DeleteReplicationTaskAssessmentRun(ctx context.Context, params *DeleteReplicationTaskAssessmentRunInput, optFns ...func(*Options)) (*DeleteReplicationTaskAssessmentRunOutput, error)
Deletes the record of a single premigration assessment run. This operation removes all metadata that DMS maintains about this assessment run. However, the operation leaves untouched all information about this assessment run that is stored in your Amazon S3 bucket.
func (*Client) DescribeAccountAttributes ¶
func (c *Client) DescribeAccountAttributes(ctx context.Context, params *DescribeAccountAttributesInput, optFns ...func(*Options)) (*DescribeAccountAttributesOutput, error)
Lists all of the DMS attributes for a customer account. These attributes include DMS quotas for the account and a unique account identifier in a particular DMS region. DMS quotas include a list of resource quotas supported by the account, such as the number of replication instances allowed. The description for each resource quota, includes the quota name, current usage toward that quota, and the quota's maximum value. DMS uses the unique account identifier to name each artifact used by DMS in the given region. This command does not take any parameters.
func (*Client) DescribeApplicableIndividualAssessments ¶
func (c *Client) DescribeApplicableIndividualAssessments(ctx context.Context, params *DescribeApplicableIndividualAssessmentsInput, optFns ...func(*Options)) (*DescribeApplicableIndividualAssessmentsOutput, error)
Provides a list of individual assessments that you can specify for a new premigration assessment run, given one or more parameters. If you specify an existing migration task, this operation provides the default individual assessments you can specify for that task. Otherwise, the specified parameters model elements of a possible migration task on which to base a premigration assessment run. To use these migration task modeling parameters, you must specify an existing replication instance, a source database engine, a target database engine, and a migration type. This combination of parameters potentially limits the default individual assessments available for an assessment run created for a corresponding migration task. If you specify no parameters, this operation provides a list of all possible individual assessments that you can specify for an assessment run. If you specify any one of the task modeling parameters, you must specify all of them or the operation cannot provide a list of individual assessments. The only parameter that you can specify alone is for an existing migration task. The specified task definition then determines the default list of individual assessments that you can specify in an assessment run for the task.
func (*Client) DescribeCertificates ¶
func (c *Client) DescribeCertificates(ctx context.Context, params *DescribeCertificatesInput, optFns ...func(*Options)) (*DescribeCertificatesOutput, error)
Provides a description of the certificate.
func (*Client) DescribeConnections ¶
func (c *Client) DescribeConnections(ctx context.Context, params *DescribeConnectionsInput, optFns ...func(*Options)) (*DescribeConnectionsOutput, error)
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.
func (*Client) DescribeEndpointSettings ¶ added in v1.3.0
func (c *Client) DescribeEndpointSettings(ctx context.Context, params *DescribeEndpointSettingsInput, optFns ...func(*Options)) (*DescribeEndpointSettingsOutput, error)
Returns information about the possible endpoint settings available when you create an endpoint for a specific database engine.
func (*Client) DescribeEndpointTypes ¶
func (c *Client) DescribeEndpointTypes(ctx context.Context, params *DescribeEndpointTypesInput, optFns ...func(*Options)) (*DescribeEndpointTypesOutput, error)
Returns information about the type of endpoints available.
func (*Client) DescribeEndpoints ¶
func (c *Client) DescribeEndpoints(ctx context.Context, params *DescribeEndpointsInput, optFns ...func(*Options)) (*DescribeEndpointsOutput, error)
Returns information about the endpoints for your account in the current region.
func (*Client) DescribeEventCategories ¶
func (c *Client) DescribeEventCategories(ctx context.Context, params *DescribeEventCategoriesInput, optFns ...func(*Options)) (*DescribeEventCategoriesOutput, error)
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 Database Migration Service User Guide.
func (*Client) DescribeEventSubscriptions ¶
func (c *Client) DescribeEventSubscriptions(ctx context.Context, params *DescribeEventSubscriptionsInput, optFns ...func(*Options)) (*DescribeEventSubscriptionsOutput, error)
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.
func (*Client) DescribeEvents ¶
func (c *Client) DescribeEvents(ctx context.Context, params *DescribeEventsInput, optFns ...func(*Options)) (*DescribeEventsOutput, error)
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on DMS events, see Working with Events and Notifications (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the Database Migration Service User Guide.
func (*Client) DescribeFleetAdvisorCollectors ¶ added in v1.19.0
func (c *Client) DescribeFleetAdvisorCollectors(ctx context.Context, params *DescribeFleetAdvisorCollectorsInput, optFns ...func(*Options)) (*DescribeFleetAdvisorCollectorsOutput, error)
Returns a list of the Fleet Advisor collectors in your account.
func (*Client) DescribeFleetAdvisorDatabases ¶ added in v1.19.0
func (c *Client) DescribeFleetAdvisorDatabases(ctx context.Context, params *DescribeFleetAdvisorDatabasesInput, optFns ...func(*Options)) (*DescribeFleetAdvisorDatabasesOutput, error)
Returns a list of Fleet Advisor databases in your account.
func (*Client) DescribeFleetAdvisorLsaAnalysis ¶ added in v1.19.0
func (c *Client) DescribeFleetAdvisorLsaAnalysis(ctx context.Context, params *DescribeFleetAdvisorLsaAnalysisInput, optFns ...func(*Options)) (*DescribeFleetAdvisorLsaAnalysisOutput, error)
Provides descriptions of large-scale assessment (LSA) analyses produced by your Fleet Advisor collectors.
func (*Client) DescribeFleetAdvisorSchemaObjectSummary ¶ added in v1.19.0
func (c *Client) DescribeFleetAdvisorSchemaObjectSummary(ctx context.Context, params *DescribeFleetAdvisorSchemaObjectSummaryInput, optFns ...func(*Options)) (*DescribeFleetAdvisorSchemaObjectSummaryOutput, error)
Provides descriptions of the schemas discovered by your Fleet Advisor collectors.
func (*Client) DescribeFleetAdvisorSchemas ¶ added in v1.19.0
func (c *Client) DescribeFleetAdvisorSchemas(ctx context.Context, params *DescribeFleetAdvisorSchemasInput, optFns ...func(*Options)) (*DescribeFleetAdvisorSchemasOutput, error)
Returns a list of schemas detected by Fleet Advisor Collectors in your account.
func (*Client) DescribeOrderableReplicationInstances ¶
func (c *Client) DescribeOrderableReplicationInstances(ctx context.Context, params *DescribeOrderableReplicationInstancesInput, optFns ...func(*Options)) (*DescribeOrderableReplicationInstancesOutput, error)
Returns information about the replication instance types that can be created in the specified region.
func (*Client) DescribePendingMaintenanceActions ¶
func (c *Client) DescribePendingMaintenanceActions(ctx context.Context, params *DescribePendingMaintenanceActionsInput, optFns ...func(*Options)) (*DescribePendingMaintenanceActionsOutput, error)
For internal use only
func (*Client) DescribeRefreshSchemasStatus ¶
func (c *Client) DescribeRefreshSchemasStatus(ctx context.Context, params *DescribeRefreshSchemasStatusInput, optFns ...func(*Options)) (*DescribeRefreshSchemasStatusOutput, error)
Returns the status of the RefreshSchemas operation.
func (*Client) DescribeReplicationInstanceTaskLogs ¶
func (c *Client) DescribeReplicationInstanceTaskLogs(ctx context.Context, params *DescribeReplicationInstanceTaskLogsInput, optFns ...func(*Options)) (*DescribeReplicationInstanceTaskLogsOutput, error)
Returns information about the task logs for the specified task.
func (*Client) DescribeReplicationInstances ¶
func (c *Client) DescribeReplicationInstances(ctx context.Context, params *DescribeReplicationInstancesInput, optFns ...func(*Options)) (*DescribeReplicationInstancesOutput, error)
Returns information about replication instances for your account in the current region.
func (*Client) DescribeReplicationSubnetGroups ¶
func (c *Client) DescribeReplicationSubnetGroups(ctx context.Context, params *DescribeReplicationSubnetGroupsInput, optFns ...func(*Options)) (*DescribeReplicationSubnetGroupsOutput, error)
Returns information about the replication subnet groups.
func (*Client) DescribeReplicationTaskAssessmentResults ¶
func (c *Client) DescribeReplicationTaskAssessmentResults(ctx context.Context, params *DescribeReplicationTaskAssessmentResultsInput, optFns ...func(*Options)) (*DescribeReplicationTaskAssessmentResultsOutput, error)
Returns the task assessment results from the Amazon S3 bucket that DMS creates in your Amazon Web Services account. This action always returns the latest results. For more information about DMS task assessments, see Creating a task assessment report (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.AssessmentReport.html) in the Database Migration Service User Guide.
func (*Client) DescribeReplicationTaskAssessmentRuns ¶
func (c *Client) DescribeReplicationTaskAssessmentRuns(ctx context.Context, params *DescribeReplicationTaskAssessmentRunsInput, optFns ...func(*Options)) (*DescribeReplicationTaskAssessmentRunsOutput, error)
Returns a paginated list of premigration assessment runs based on filter settings. These filter settings can specify a combination of premigration assessment runs, migration tasks, replication instances, and assessment run status values. This operation doesn't return information about individual assessments. For this information, see the DescribeReplicationTaskIndividualAssessments operation.
func (*Client) DescribeReplicationTaskIndividualAssessments ¶
func (c *Client) DescribeReplicationTaskIndividualAssessments(ctx context.Context, params *DescribeReplicationTaskIndividualAssessmentsInput, optFns ...func(*Options)) (*DescribeReplicationTaskIndividualAssessmentsOutput, error)
Returns a paginated list of individual assessments based on filter settings. These filter settings can specify a combination of premigration assessment runs, migration tasks, and assessment status values.
func (*Client) DescribeReplicationTasks ¶
func (c *Client) DescribeReplicationTasks(ctx context.Context, params *DescribeReplicationTasksInput, optFns ...func(*Options)) (*DescribeReplicationTasksOutput, error)
Returns information about replication tasks for your account in the current region.
func (*Client) DescribeSchemas ¶
func (c *Client) DescribeSchemas(ctx context.Context, params *DescribeSchemasInput, optFns ...func(*Options)) (*DescribeSchemasOutput, error)
Returns information about the schema for the specified endpoint.
func (*Client) DescribeTableStatistics ¶
func (c *Client) DescribeTableStatistics(ctx context.Context, params *DescribeTableStatisticsInput, optFns ...func(*Options)) (*DescribeTableStatisticsOutput, error)
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 DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.
func (*Client) ImportCertificate ¶
func (c *Client) ImportCertificate(ctx context.Context, params *ImportCertificateInput, optFns ...func(*Options)) (*ImportCertificateOutput, error)
Uploads the specified certificate.
func (*Client) ListTagsForResource ¶
func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, optFns ...func(*Options)) (*ListTagsForResourceOutput, error)
Lists all metadata tags attached to an DMS resource, including replication instance, endpoint, security group, and migration task. For more information, see Tag (https://docs.aws.amazon.com/dms/latest/APIReference/API_Tag.html) data type description.
func (*Client) ModifyEndpoint ¶
func (c *Client) ModifyEndpoint(ctx context.Context, params *ModifyEndpointInput, optFns ...func(*Options)) (*ModifyEndpointOutput, error)
Modifies the specified endpoint. For a MySQL source or target endpoint, don't explicitly specify the database using the DatabaseName request parameter on the ModifyEndpoint API call. Specifying DatabaseName when you modify a MySQL endpoint replicates all the task tables to this single database. For MySQL endpoints, you specify the database only when you specify the schema in the table-mapping rules of the DMS task.
func (*Client) ModifyEventSubscription ¶
func (c *Client) ModifyEventSubscription(ctx context.Context, params *ModifyEventSubscriptionInput, optFns ...func(*Options)) (*ModifyEventSubscriptionOutput, error)
Modifies an existing DMS event notification subscription.
func (*Client) ModifyReplicationInstance ¶
func (c *Client) ModifyReplicationInstance(ctx context.Context, params *ModifyReplicationInstanceInput, optFns ...func(*Options)) (*ModifyReplicationInstanceOutput, error)
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.
func (*Client) ModifyReplicationSubnetGroup ¶
func (c *Client) ModifyReplicationSubnetGroup(ctx context.Context, params *ModifyReplicationSubnetGroupInput, optFns ...func(*Options)) (*ModifyReplicationSubnetGroupOutput, error)
Modifies the settings for the specified replication subnet group.
func (*Client) ModifyReplicationTask ¶
func (c *Client) ModifyReplicationTask(ctx context.Context, params *ModifyReplicationTaskInput, optFns ...func(*Options)) (*ModifyReplicationTaskOutput, error)
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 DMS tasks, see Working with Migration Tasks (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.html) in the Database Migration Service User Guide.
func (*Client) MoveReplicationTask ¶ added in v0.30.0
func (c *Client) MoveReplicationTask(ctx context.Context, params *MoveReplicationTaskInput, optFns ...func(*Options)) (*MoveReplicationTaskOutput, error)
Moves a replication task from its current replication instance to a different target replication instance using the specified parameters. The target replication instance must be created with the same or later DMS version as the current replication instance.
func (*Client) RebootReplicationInstance ¶
func (c *Client) RebootReplicationInstance(ctx context.Context, params *RebootReplicationInstanceInput, optFns ...func(*Options)) (*RebootReplicationInstanceOutput, error)
Reboots a replication instance. Rebooting results in a momentary outage, until the replication instance becomes available again.
func (*Client) RefreshSchemas ¶
func (c *Client) RefreshSchemas(ctx context.Context, params *RefreshSchemasInput, optFns ...func(*Options)) (*RefreshSchemasOutput, error)
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.
func (*Client) ReloadTables ¶
func (c *Client) ReloadTables(ctx context.Context, params *ReloadTablesInput, optFns ...func(*Options)) (*ReloadTablesOutput, error)
Reloads the target database table with the source data. You can only use this operation with a task in the RUNNING state, otherwise the service will throw an InvalidResourceStateFault exception.
func (*Client) RemoveTagsFromResource ¶
func (c *Client) RemoveTagsFromResource(ctx context.Context, params *RemoveTagsFromResourceInput, optFns ...func(*Options)) (*RemoveTagsFromResourceOutput, error)
Removes metadata tags from an DMS resource, including replication instance, endpoint, security group, and migration task. For more information, see Tag (https://docs.aws.amazon.com/dms/latest/APIReference/API_Tag.html) data type description.
func (*Client) RunFleetAdvisorLsaAnalysis ¶ added in v1.19.0
func (c *Client) RunFleetAdvisorLsaAnalysis(ctx context.Context, params *RunFleetAdvisorLsaAnalysisInput, optFns ...func(*Options)) (*RunFleetAdvisorLsaAnalysisOutput, error)
Runs large-scale assessment (LSA) analysis on every Fleet Advisor collector in your account.
func (*Client) StartReplicationTask ¶
func (c *Client) StartReplicationTask(ctx context.Context, params *StartReplicationTaskInput, optFns ...func(*Options)) (*StartReplicationTaskOutput, error)
Starts the replication task. For more information about DMS tasks, see Working with Migration Tasks (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.html) in the Database Migration Service User Guide.
func (*Client) StartReplicationTaskAssessment ¶
func (c *Client) StartReplicationTaskAssessment(ctx context.Context, params *StartReplicationTaskAssessmentInput, optFns ...func(*Options)) (*StartReplicationTaskAssessmentOutput, error)
Starts the replication task assessment for unsupported data types in the source database. You can only use this operation for a task if the following conditions are true:
* The task must be in the stopped state.
* The task must have successful connections to the source and target.
If either of these conditions are not met, an InvalidResourceStateFault error will result. For information about DMS task assessments, see Creating a task assessment report (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.AssessmentReport.html) in the Database Migration Service User Guide.
func (*Client) StartReplicationTaskAssessmentRun ¶
func (c *Client) StartReplicationTaskAssessmentRun(ctx context.Context, params *StartReplicationTaskAssessmentRunInput, optFns ...func(*Options)) (*StartReplicationTaskAssessmentRunOutput, error)
Starts a new premigration assessment run for one or more individual assessments of a migration task. The assessments that you can specify depend on the source and target database engine and the migration type defined for the given task. To run this operation, your migration task must already be created. After you run this operation, you can review the status of each individual assessment. You can also run the migration task manually after the assessment run and its individual assessments complete.
func (*Client) StopReplicationTask ¶
func (c *Client) StopReplicationTask(ctx context.Context, params *StopReplicationTaskInput, optFns ...func(*Options)) (*StopReplicationTaskOutput, error)
Stops the replication task.
func (*Client) TestConnection ¶
func (c *Client) TestConnection(ctx context.Context, params *TestConnectionInput, optFns ...func(*Options)) (*TestConnectionOutput, error)
Tests the connection between the replication instance and the endpoint.
func (*Client) UpdateSubscriptionsToEventBridge ¶ added in v1.21.0
func (c *Client) UpdateSubscriptionsToEventBridge(ctx context.Context, params *UpdateSubscriptionsToEventBridgeInput, optFns ...func(*Options)) (*UpdateSubscriptionsToEventBridgeOutput, error)
Migrates 10 active and enabled Amazon SNS subscriptions at a time and converts them to corresponding Amazon EventBridge rules. By default, this operation migrates subscriptions only when all your replication instance versions are 3.4.6 or higher. If any replication instances are from versions earlier than 3.4.6, the operation raises an error and tells you to upgrade these instances to version 3.4.6 or higher. To enable migration regardless of version, set the Force option to true. However, if you don't upgrade instances earlier than version 3.4.6, some types of events might not be available when you use Amazon EventBridge. To call this operation, make sure that you have certain permissions added to your user account. For more information, see Migrating event subscriptions to Amazon EventBridge (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html#CHAP_Events-migrate-to-eventbridge) in the Amazon Web Services Database Migration Service User Guide.
type CreateEndpointInput ¶
type CreateEndpointInput struct { // The database endpoint identifier. Identifiers must begin with a letter and must // contain only ASCII letters, digits, and hyphens. They can't end with a hyphen, // or contain two consecutive hyphens. // // This member is required. EndpointIdentifier *string // The type of endpoint. Valid values are source and target. // // This member is required. EndpointType types.ReplicationEndpointTypeValue // The type of engine for the endpoint. Valid values, depending on the EndpointType // value, include "mysql", "oracle", "postgres", "mariadb", "aurora", // "aurora-postgresql", "opensearch", "redshift", "s3", "db2", "db2-zos", // "azuredb", "sybase", "dynamodb", "mongodb", "kinesis", "kafka", "elasticsearch", // "docdb", "sqlserver", "neptune", and "babelfish". // // This member is required. EngineName *string // The Amazon Resource Name (ARN) for the certificate. CertificateArn *string // The name of the endpoint database. For a MySQL source or target endpoint, do not // specify DatabaseName. To migrate to a specific database, use this setting and // targetDbType. DatabaseName *string // The settings in JSON format for the DMS transfer type of source endpoint. // Possible settings include the following: // // * ServiceAccessRoleArn - The Amazon // Resource Name (ARN) used by the service access IAM role. The role must allow the // iam:PassRole action. // // * BucketName - The name of the S3 bucket to // use. // // Shorthand syntax for these settings is as follows: // ServiceAccessRoleArn=string,BucketName=string JSON syntax for these settings is // as follows: { "ServiceAccessRoleArn": "string", "BucketName": "string", } DmsTransferSettings *types.DmsTransferSettings // Provides information that defines a DocumentDB endpoint. DocDbSettings *types.DocDbSettings // Settings in JSON format for the target Amazon DynamoDB endpoint. For information // about other available settings, see Using Object Mapping to Migrate Data to // DynamoDB // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.DynamoDB.html#CHAP_Target.DynamoDB.ObjectMapping) // in the Database Migration Service User Guide. DynamoDbSettings *types.DynamoDbSettings // Settings in JSON format for the target OpenSearch endpoint. For more information // about the available settings, see Extra Connection Attributes When Using // OpenSearch as a Target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Elasticsearch.html#CHAP_Target.Elasticsearch.Configuration) // in the Database Migration Service User Guide. ElasticsearchSettings *types.ElasticsearchSettings // The external table definition. ExternalTableDefinition *string // Additional attributes associated with the connection. Each attribute is // specified as a name-value pair associated by an equal sign (=). Multiple // attributes are separated by a semicolon (;) with no additional white space. For // information on the attributes available for connecting your source or target // endpoint, see Working with DMS Endpoints // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Endpoints.html) in the // Database Migration Service User Guide. ExtraConnectionAttributes *string // Settings in JSON format for the source GCP MySQL endpoint. GcpMySQLSettings *types.GcpMySQLSettings // Settings in JSON format for the source IBM Db2 LUW endpoint. For information // about other available settings, see Extra connection attributes when using Db2 // LUW as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.DB2.html#CHAP_Source.DB2.ConnectionAttrib) // in the Database Migration Service User Guide. IBMDb2Settings *types.IBMDb2Settings // Settings in JSON format for the target Apache Kafka endpoint. For more // information about the available settings, see Using object mapping to migrate // data to a Kafka topic // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafka.html#CHAP_Target.Kafka.ObjectMapping) // in the Database Migration Service User Guide. KafkaSettings *types.KafkaSettings // Settings in JSON format for the target endpoint for Amazon Kinesis Data Streams. // For more information about the available settings, see Using object mapping to // migrate data to a Kinesis data stream // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kinesis.html#CHAP_Target.Kinesis.ObjectMapping) // in the Database Migration Service User Guide. KinesisSettings *types.KinesisSettings // An KMS key identifier that is used to encrypt the connection parameters for the // endpoint. If you don't specify a value for the KmsKeyId parameter, then DMS uses // your default encryption key. KMS creates the default encryption key for your // Amazon Web Services account. Your Amazon Web Services account has a different // default encryption key for each Amazon Web Services Region. KmsKeyId *string // Settings in JSON format for the source and target Microsoft SQL Server endpoint. // For information about other available settings, see Extra connection attributes // when using SQL Server as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.SQLServer.html#CHAP_Source.SQLServer.ConnectionAttrib) // and Extra connection attributes when using SQL Server as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.SQLServer.html#CHAP_Target.SQLServer.ConnectionAttrib) // in the Database Migration Service User Guide. MicrosoftSQLServerSettings *types.MicrosoftSQLServerSettings // Settings in JSON format for the source MongoDB endpoint. For more information // about the available settings, see Endpoint configuration settings when using // MongoDB as a source for Database Migration Service // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.MongoDB.html#CHAP_Source.MongoDB.Configuration) // in the Database Migration Service User Guide. MongoDbSettings *types.MongoDbSettings // Settings in JSON format for the source and target MySQL endpoint. For // information about other available settings, see Extra connection attributes when // using MySQL as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.MySQL.html#CHAP_Source.MySQL.ConnectionAttrib) // and Extra connection attributes when using a MySQL-compatible database as a // target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.MySQL.html#CHAP_Target.MySQL.ConnectionAttrib) // in the Database Migration Service User Guide. MySQLSettings *types.MySQLSettings // Settings in JSON format for the target Amazon Neptune endpoint. For more // information about the available settings, see Specifying graph-mapping rules // using Gremlin and R2RML for Amazon Neptune as a target // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Neptune.html#CHAP_Target.Neptune.EndpointSettings) // in the Database Migration Service User Guide. NeptuneSettings *types.NeptuneSettings // Settings in JSON format for the source and target Oracle endpoint. For // information about other available settings, see Extra connection attributes when // using Oracle as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.Oracle.html#CHAP_Source.Oracle.ConnectionAttrib) // and Extra connection attributes when using Oracle as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Oracle.html#CHAP_Target.Oracle.ConnectionAttrib) // in the Database Migration Service User Guide. OracleSettings *types.OracleSettings // The password to be used to log in to the endpoint database. Password *string // The port used by the endpoint database. Port *int32 // Settings in JSON format for the source and target PostgreSQL endpoint. For // information about other available settings, see Extra connection attributes when // using PostgreSQL as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib) // and Extra connection attributes when using PostgreSQL as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.PostgreSQL.html#CHAP_Target.PostgreSQL.ConnectionAttrib) // in the Database Migration Service User Guide. PostgreSQLSettings *types.PostgreSQLSettings // Settings in JSON format for the target Redis endpoint. RedisSettings *types.RedisSettings // Provides information that defines an Amazon Redshift endpoint. RedshiftSettings *types.RedshiftSettings // A friendly name for the resource identifier at the end of the EndpointArn // response parameter that is returned in the created Endpoint object. The value // for this parameter can have up to 31 characters. It can contain only ASCII // letters, digits, and hyphen ('-'). Also, it can't end with a hyphen or contain // two consecutive hyphens, and can only begin with a letter, such as // Example-App-ARN1. For example, this value might result in the EndpointArn value // arn:aws:dms:eu-west-1:012345678901:rep:Example-App-ARN1. If you don't specify a // ResourceIdentifier value, DMS generates a default identifier value for the end // of EndpointArn. ResourceIdentifier *string // Settings in JSON format for the target Amazon S3 endpoint. For more information // about the available settings, see Extra Connection Attributes When Using Amazon // S3 as a Target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.S3.html#CHAP_Target.S3.Configuring) // in the Database Migration Service User Guide. S3Settings *types.S3Settings // The name of the server where the endpoint database resides. ServerName *string // The Amazon Resource Name (ARN) for the service access role that you want to use // to create the endpoint. The role must allow the iam:PassRole action. ServiceAccessRoleArn *string // The Secure Sockets Layer (SSL) mode to use for the SSL connection. The default // is none SslMode types.DmsSslModeValue // Settings in JSON format for the source and target SAP ASE endpoint. For // information about other available settings, see Extra connection attributes when // using SAP ASE as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.SAP.html#CHAP_Source.SAP.ConnectionAttrib) // and Extra connection attributes when using SAP ASE as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.SAP.html#CHAP_Target.SAP.ConnectionAttrib) // in the Database Migration Service User Guide. SybaseSettings *types.SybaseSettings // One or more tags to be assigned to the endpoint. Tags []types.Tag // The user name to be used to log in to the endpoint database. Username *string // contains filtered or unexported fields }
type CreateEndpointOutput ¶
type CreateEndpointOutput struct { // The endpoint that was created. Endpoint *types.Endpoint // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CreateEventSubscriptionInput ¶
type CreateEventSubscriptionInput struct { // The Amazon Resource Name (ARN) of the Amazon SNS topic created for event // notification. The ARN is created by Amazon SNS when you create a topic and // subscribe to it. // // This member is required. SnsTopicArn *string // The name of the DMS event notification subscription. This name must be less than // 255 characters. // // This member is required. SubscriptionName *string // A Boolean value; set to true to activate the subscription, or set to false to // create the subscription but not activate it. Enabled *bool // A list of event categories for a source type that you want to subscribe to. For // more information, see Working with Events and Notifications // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Events.html) in the // Database Migration Service User Guide. EventCategories []string // A list of identifiers for which DMS provides notification events. If you don't // specify a value, notifications are provided for all sources. If you specify // multiple values, they must be of the same type. For example, if you specify a // database instance ID, then all of the other values must be database instance // IDs. SourceIds []string // The type of DMS resource that generates the events. For example, if you want to // be notified of events generated by a replication instance, you set this // parameter to replication-instance. If this value isn't specified, all events are // returned. Valid values: replication-instance | replication-task SourceType *string // One or more tags to be assigned to the event subscription. Tags []types.Tag // contains filtered or unexported fields }
type CreateEventSubscriptionOutput ¶
type CreateEventSubscriptionOutput struct { // The event subscription that was created. EventSubscription *types.EventSubscription // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CreateFleetAdvisorCollectorInput ¶ added in v1.19.0
type CreateFleetAdvisorCollectorInput struct { // The name of your Fleet Advisor collector (for example, sample-collector). // // This member is required. CollectorName *string // The Amazon S3 bucket that the Fleet Advisor collector uses to store inventory // metadata. // // This member is required. S3BucketName *string // The IAM role that grants permissions to access the specified Amazon S3 bucket. // // This member is required. ServiceAccessRoleArn *string // A summary description of your Fleet Advisor collector. Description *string // contains filtered or unexported fields }
type CreateFleetAdvisorCollectorOutput ¶ added in v1.19.0
type CreateFleetAdvisorCollectorOutput struct { // The name of the new Fleet Advisor collector. CollectorName *string // The unique ID of the new Fleet Advisor collector, for example: // 22fda70c-40d5-4acf-b233-a495bd8eb7f5 CollectorReferencedId *string // A summary description of the Fleet Advisor collector. Description *string // The Amazon S3 bucket that the collector uses to store inventory metadata. S3BucketName *string // The IAM role that grants permissions to access the specified Amazon S3 bucket. ServiceAccessRoleArn *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CreateReplicationInstanceInput ¶
type CreateReplicationInstanceInput struct { // The compute and memory capacity of the replication instance as defined for the // specified replication instance class. For example to specify the instance class // dms.c4.large, set this parameter to "dms.c4.large". For more information on the // settings and capacities for the available replication instance classes, see // Selecting the right DMS replication instance for your migration // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.html#CHAP_ReplicationInstance.InDepth). // // This member is required. ReplicationInstanceClass *string // The replication instance identifier. This parameter is stored as a lowercase // string. Constraints: // // * Must contain 1-63 alphanumeric characters or hyphens. // // * // First character must be a letter. // // * Can't end with a hyphen or contain two // consecutive hyphens. // // Example: myrepinstance // // This member is required. ReplicationInstanceIdentifier *string // The amount of storage (in gigabytes) to be initially allocated for the // replication instance. AllocatedStorage *int32 // A value that indicates whether minor engine upgrades are applied automatically // to the replication instance during the maintenance window. This parameter // defaults to true. Default: true AutoMinorVersionUpgrade *bool // The Availability Zone where the replication instance will be created. The // default value is a random, system-chosen Availability Zone in the endpoint's // Amazon Web Services Region, for example: us-east-1d AvailabilityZone *string // A list of custom DNS name servers supported for the replication instance to // access your on-premise source or target database. This list overrides the // default name servers supported by the replication instance. You can specify a // comma-separated list of internet addresses for up to four on-premise DNS name // servers. For example: "1.1.1.1,2.2.2.2,3.3.3.3,4.4.4.4" DnsNameServers *string // The engine version number of the replication instance. If an engine version // number is not specified when a replication instance is created, the default is // the latest engine version available. EngineVersion *string // An KMS key identifier that is used to encrypt the data on the replication // instance. If you don't specify a value for the KmsKeyId parameter, then DMS uses // your default encryption key. KMS creates the default encryption key for your // Amazon Web Services account. Your Amazon Web Services account has a different // default encryption key for each Amazon Web Services Region. KmsKeyId *string // Specifies whether the replication instance is a Multi-AZ deployment. You can't // set the AvailabilityZone parameter if the Multi-AZ parameter is set to true. MultiAZ *bool // The type of IP address protocol used by a replication instance, such as IPv4 // only or Dual-stack that supports both IPv4 and IPv6 addressing. IPv6 only is not // yet supported. NetworkType *string // The weekly time range during which system maintenance can occur, in Universal // Coordinated Time (UTC). Format: ddd:hh24:mi-ddd:hh24:mi Default: A 30-minute // window selected at random from an 8-hour block of time per Amazon Web Services // Region, occurring on a random day of the week. Valid Days: Mon, Tue, Wed, Thu, // Fri, Sat, Sun Constraints: Minimum 30-minute window. PreferredMaintenanceWindow *string // Specifies the accessibility options for the replication instance. A value of // true represents an instance with a public IP address. A value of false // represents an instance with a private IP address. The default value is true. PubliclyAccessible *bool // A subnet group to associate with the replication instance. ReplicationSubnetGroupIdentifier *string // A friendly name for the resource identifier at the end of the EndpointArn // response parameter that is returned in the created Endpoint object. The value // for this parameter can have up to 31 characters. It can contain only ASCII // letters, digits, and hyphen ('-'). Also, it can't end with a hyphen or contain // two consecutive hyphens, and can only begin with a letter, such as // Example-App-ARN1. For example, this value might result in the EndpointArn value // arn:aws:dms:eu-west-1:012345678901:rep:Example-App-ARN1. If you don't specify a // ResourceIdentifier value, DMS generates a default identifier value for the end // of EndpointArn. ResourceIdentifier *string // One or more tags to be assigned to the replication instance. Tags []types.Tag // Specifies the VPC security group to be used with the replication instance. The // VPC security group must work with the VPC containing the replication instance. VpcSecurityGroupIds []string // contains filtered or unexported fields }
type CreateReplicationInstanceOutput ¶
type CreateReplicationInstanceOutput struct { // The replication instance that was created. ReplicationInstance *types.ReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CreateReplicationSubnetGroupInput ¶
type CreateReplicationSubnetGroupInput struct { // The description for the subnet group. // // This member is required. ReplicationSubnetGroupDescription *string // The name for the replication subnet group. This value is stored as a lowercase // string. Constraints: Must contain no more than 255 alphanumeric characters, // periods, spaces, underscores, or hyphens. Must not be "default". Example: // mySubnetgroup // // This member is required. ReplicationSubnetGroupIdentifier *string // One or more subnet IDs to be assigned to the subnet group. // // This member is required. SubnetIds []string // One or more tags to be assigned to the subnet group. Tags []types.Tag // contains filtered or unexported fields }
type CreateReplicationSubnetGroupOutput ¶
type CreateReplicationSubnetGroupOutput struct { // The replication subnet group that was created. ReplicationSubnetGroup *types.ReplicationSubnetGroup // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type CreateReplicationTaskInput ¶
type CreateReplicationTaskInput struct { // The migration type. Valid values: full-load | cdc | full-load-and-cdc // // This member is required. MigrationType types.MigrationTypeValue // The Amazon Resource Name (ARN) of a replication instance. // // This member is required. ReplicationInstanceArn *string // An identifier for the replication task. Constraints: // // * Must contain 1-255 // alphanumeric characters or hyphens. // // * First character must be a letter. // // * // Cannot end with a hyphen or contain two consecutive hyphens. // // This member is required. ReplicationTaskIdentifier *string // An Amazon Resource Name (ARN) that uniquely identifies the source endpoint. // // This member is required. SourceEndpointArn *string // The table mappings for the task, in JSON format. For more information, see Using // Table Mapping to Specify Task Settings // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TableMapping.html) // in the Database Migration Service User Guide. // // This member is required. TableMappings *string // An Amazon Resource Name (ARN) that uniquely identifies the target endpoint. // // This member is required. TargetEndpointArn *string // Indicates when you want a change data capture (CDC) operation to start. Use // either CdcStartPosition or CdcStartTime to specify when you want a CDC operation // to start. Specifying both values results in an error. The value can be in date, // checkpoint, or LSN/SCN format. Date Example: --cdc-start-position // “2018-03-08T12:12:12” Checkpoint Example: --cdc-start-position // "checkpoint:V1#27#mysql-bin-changelog.157832:1975:-1:2002:677883278264080:mysql-bin-changelog.157832:1876#0#0#*#0#93" // LSN Example: --cdc-start-position “mysql-bin-changelog.000024:373” When you use // this task setting with a source PostgreSQL database, a logical replication slot // should already be created and associated with the source endpoint. You can // verify this by setting the slotName extra connection attribute to the name of // this logical replication slot. For more information, see Extra Connection // Attributes When Using PostgreSQL as a Source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib). CdcStartPosition *string // Indicates the start time for a change data capture (CDC) operation. Use either // CdcStartTime or CdcStartPosition to specify when you want a CDC operation to // start. Specifying both values results in an error. Timestamp Example: // --cdc-start-time “2018-03-08T12:12:12” CdcStartTime *time.Time // Indicates when you want a change data capture (CDC) operation to stop. The value // can be either server time or commit time. Server time example: // --cdc-stop-position “server_time:2018-02-09T12:12:12” Commit time example: // --cdc-stop-position “commit_time: 2018-02-09T12:12:12 “ CdcStopPosition *string // Overall settings for the task, in JSON format. For more information, see // Specifying Task Settings for Database Migration Service Tasks // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TaskSettings.html) // in the Database Migration Service User Guide. ReplicationTaskSettings *string // A friendly name for the resource identifier at the end of the EndpointArn // response parameter that is returned in the created Endpoint object. The value // for this parameter can have up to 31 characters. It can contain only ASCII // letters, digits, and hyphen ('-'). Also, it can't end with a hyphen or contain // two consecutive hyphens, and can only begin with a letter, such as // Example-App-ARN1. For example, this value might result in the EndpointArn value // arn:aws:dms:eu-west-1:012345678901:rep:Example-App-ARN1. If you don't specify a // ResourceIdentifier value, DMS generates a default identifier value for the end // of EndpointArn. ResourceIdentifier *string // One or more tags to be assigned to the replication task. Tags []types.Tag // Supplemental information that the task requires to migrate the data for certain // source and target endpoints. For more information, see Specifying Supplemental // Data for Task Settings // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.TaskData.html) in // the Database Migration Service User Guide. TaskData *string // contains filtered or unexported fields }
type CreateReplicationTaskOutput ¶
type CreateReplicationTaskOutput struct { // The replication task that was created. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteCertificateInput ¶
type DeleteCertificateInput struct { // The Amazon Resource Name (ARN) of the certificate. // // This member is required. CertificateArn *string // contains filtered or unexported fields }
type DeleteCertificateOutput ¶
type DeleteCertificateOutput struct { // The Secure Sockets Layer (SSL) certificate. Certificate *types.Certificate // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteConnectionInput ¶
type DeleteConnectionInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // contains filtered or unexported fields }
type DeleteConnectionOutput ¶
type DeleteConnectionOutput struct { // The connection that is being deleted. Connection *types.Connection // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteEndpointInput ¶
type DeleteEndpointInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // contains filtered or unexported fields }
type DeleteEndpointOutput ¶
type DeleteEndpointOutput struct { // The endpoint that was deleted. Endpoint *types.Endpoint // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteEventSubscriptionInput ¶
type DeleteEventSubscriptionInput struct { // The name of the DMS event notification subscription to be deleted. // // This member is required. SubscriptionName *string // contains filtered or unexported fields }
type DeleteEventSubscriptionOutput ¶
type DeleteEventSubscriptionOutput struct { // The event subscription that was deleted. EventSubscription *types.EventSubscription // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteFleetAdvisorCollectorInput ¶ added in v1.19.0
type DeleteFleetAdvisorCollectorInput struct { // The reference ID of the Fleet Advisor collector to delete. // // This member is required. CollectorReferencedId *string // contains filtered or unexported fields }
type DeleteFleetAdvisorCollectorOutput ¶ added in v1.19.0
type DeleteFleetAdvisorCollectorOutput struct { // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteFleetAdvisorDatabasesInput ¶ added in v1.19.0
type DeleteFleetAdvisorDatabasesInput struct { // The IDs of the Fleet Advisor collector databases to delete. // // This member is required. DatabaseIds []string // contains filtered or unexported fields }
type DeleteFleetAdvisorDatabasesOutput ¶ added in v1.19.0
type DeleteFleetAdvisorDatabasesOutput struct { // The IDs of the databases that the operation deleted. DatabaseIds []string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteReplicationInstanceInput ¶
type DeleteReplicationInstanceInput struct { // The Amazon Resource Name (ARN) of the replication instance to be deleted. // // This member is required. ReplicationInstanceArn *string // contains filtered or unexported fields }
type DeleteReplicationInstanceOutput ¶
type DeleteReplicationInstanceOutput struct { // The replication instance that was deleted. ReplicationInstance *types.ReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteReplicationSubnetGroupInput ¶
type DeleteReplicationSubnetGroupInput struct { // The subnet group name of the replication instance. // // This member is required. ReplicationSubnetGroupIdentifier *string // contains filtered or unexported fields }
type DeleteReplicationSubnetGroupOutput ¶
type DeleteReplicationSubnetGroupOutput struct { // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteReplicationTaskAssessmentRunInput ¶
type DeleteReplicationTaskAssessmentRunInput struct { // Amazon Resource Name (ARN) of the premigration assessment run to be deleted. // // This member is required. ReplicationTaskAssessmentRunArn *string // contains filtered or unexported fields }
type DeleteReplicationTaskAssessmentRunOutput ¶
type DeleteReplicationTaskAssessmentRunOutput struct { // The ReplicationTaskAssessmentRun object for the deleted assessment run. ReplicationTaskAssessmentRun *types.ReplicationTaskAssessmentRun // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DeleteReplicationTaskInput ¶
type DeleteReplicationTaskInput struct { // The Amazon Resource Name (ARN) of the replication task to be deleted. // // This member is required. ReplicationTaskArn *string // contains filtered or unexported fields }
type DeleteReplicationTaskOutput ¶
type DeleteReplicationTaskOutput struct { // The deleted replication task. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeAccountAttributesInput ¶
type DescribeAccountAttributesInput struct {
// contains filtered or unexported fields
}
type DescribeAccountAttributesOutput ¶
type DescribeAccountAttributesOutput struct { // Account quota information. AccountQuotas []types.AccountQuota // A unique DMS identifier for an account in a particular Amazon Web Services // Region. The value of this identifier has the following format: c99999999999. DMS // uses this identifier to name artifacts. For example, DMS uses this identifier to // name the default Amazon S3 bucket for storing task assessment reports in a given // Amazon Web Services Region. The format of this S3 bucket name is the following: // dms-AccountNumber-UniqueAccountIdentifier. Here is an example name for this // default S3 bucket: dms-111122223333-c44445555666. DMS supports the // UniqueAccountIdentifier parameter in versions 3.1.4 and later. UniqueAccountIdentifier *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeApplicableIndividualAssessmentsAPIClient ¶ added in v0.30.0
type DescribeApplicableIndividualAssessmentsAPIClient interface {
DescribeApplicableIndividualAssessments(context.Context, *DescribeApplicableIndividualAssessmentsInput, ...func(*Options)) (*DescribeApplicableIndividualAssessmentsOutput, error)
}
DescribeApplicableIndividualAssessmentsAPIClient is a client that implements the DescribeApplicableIndividualAssessments operation.
type DescribeApplicableIndividualAssessmentsInput ¶
type DescribeApplicableIndividualAssessmentsInput struct { // Optional pagination token provided by a previous request. If this parameter is // specified, the response includes only records beyond the marker, up to the value // specified by MaxRecords. Marker *string // Maximum number of records to include in the response. If more records exist than // the specified MaxRecords value, a pagination token called a marker is included // in the response so that the remaining results can be retrieved. MaxRecords *int32 // Name of the migration type that each provided individual assessment must // support. MigrationType types.MigrationTypeValue // ARN of a replication instance on which you want to base the default list of // individual assessments. ReplicationInstanceArn *string // Amazon Resource Name (ARN) of a migration task on which you want to base the // default list of individual assessments. ReplicationTaskArn *string // Name of a database engine that the specified replication instance supports as a // source. SourceEngineName *string // Name of a database engine that the specified replication instance supports as a // target. TargetEngineName *string // contains filtered or unexported fields }
type DescribeApplicableIndividualAssessmentsOutput ¶
type DescribeApplicableIndividualAssessmentsOutput struct { // List of names for the individual assessments supported by the premigration // assessment run that you start based on the specified request parameters. For // more information on the available individual assessments, including // compatibility with different migration task configurations, see Working with // premigration assessment runs // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.AssessmentReport.html) // in the Database Migration Service User Guide. IndividualAssessmentNames []string // Pagination token returned for you to pass to a subsequent request. If you pass // this token as the Marker value in a subsequent request, the response includes // only records beyond the marker, up to the value specified in the request by // MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeApplicableIndividualAssessmentsPaginator ¶ added in v0.30.0
type DescribeApplicableIndividualAssessmentsPaginator struct {
// contains filtered or unexported fields
}
DescribeApplicableIndividualAssessmentsPaginator is a paginator for DescribeApplicableIndividualAssessments
func NewDescribeApplicableIndividualAssessmentsPaginator ¶ added in v0.30.0
func NewDescribeApplicableIndividualAssessmentsPaginator(client DescribeApplicableIndividualAssessmentsAPIClient, params *DescribeApplicableIndividualAssessmentsInput, optFns ...func(*DescribeApplicableIndividualAssessmentsPaginatorOptions)) *DescribeApplicableIndividualAssessmentsPaginator
NewDescribeApplicableIndividualAssessmentsPaginator returns a new DescribeApplicableIndividualAssessmentsPaginator
func (*DescribeApplicableIndividualAssessmentsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeApplicableIndividualAssessmentsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeApplicableIndividualAssessmentsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeApplicableIndividualAssessmentsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeApplicableIndividualAssessmentsOutput, error)
NextPage retrieves the next DescribeApplicableIndividualAssessments page.
type DescribeApplicableIndividualAssessmentsPaginatorOptions ¶ added in v0.30.0
type DescribeApplicableIndividualAssessmentsPaginatorOptions struct { // Maximum number of records to include in the response. If more records exist than // the specified MaxRecords value, a pagination token called a marker is included // in the response so that the remaining results can be retrieved. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeApplicableIndividualAssessmentsPaginatorOptions is the paginator options for DescribeApplicableIndividualAssessments
type DescribeCertificatesAPIClient ¶ added in v0.30.0
type DescribeCertificatesAPIClient interface {
DescribeCertificates(context.Context, *DescribeCertificatesInput, ...func(*Options)) (*DescribeCertificatesOutput, error)
}
DescribeCertificatesAPIClient is a client that implements the DescribeCertificates operation.
type DescribeCertificatesInput ¶
type DescribeCertificatesInput struct { // Filters applied to the certificates described in the form of key-value pairs. // Valid values are certificate-arn and certificate-id. Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 10 MaxRecords *int32 // contains filtered or unexported fields }
type DescribeCertificatesOutput ¶
type DescribeCertificatesOutput struct { // The Secure Sockets Layer (SSL) certificates associated with the replication // instance. Certificates []types.Certificate // The pagination token. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeCertificatesPaginator ¶ added in v0.30.0
type DescribeCertificatesPaginator struct {
// contains filtered or unexported fields
}
DescribeCertificatesPaginator is a paginator for DescribeCertificates
func NewDescribeCertificatesPaginator ¶ added in v0.30.0
func NewDescribeCertificatesPaginator(client DescribeCertificatesAPIClient, params *DescribeCertificatesInput, optFns ...func(*DescribeCertificatesPaginatorOptions)) *DescribeCertificatesPaginator
NewDescribeCertificatesPaginator returns a new DescribeCertificatesPaginator
func (*DescribeCertificatesPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeCertificatesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeCertificatesPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeCertificatesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeCertificatesOutput, error)
NextPage retrieves the next DescribeCertificates page.
type DescribeCertificatesPaginatorOptions ¶ added in v0.30.0
type DescribeCertificatesPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 10 Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeCertificatesPaginatorOptions is the paginator options for DescribeCertificates
type DescribeConnectionsAPIClient ¶ added in v0.30.0
type DescribeConnectionsAPIClient interface {
DescribeConnections(context.Context, *DescribeConnectionsInput, ...func(*Options)) (*DescribeConnectionsOutput, error)
}
DescribeConnectionsAPIClient is a client that implements the DescribeConnections operation.
type DescribeConnectionsInput ¶
type DescribeConnectionsInput struct { // The filters applied to the connection. Valid filter names: endpoint-arn | // replication-instance-arn Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeConnectionsOutput ¶
type DescribeConnectionsOutput struct { // A description of the connections. Connections []types.Connection // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeConnectionsPaginator ¶ added in v0.30.0
type DescribeConnectionsPaginator struct {
// contains filtered or unexported fields
}
DescribeConnectionsPaginator is a paginator for DescribeConnections
func NewDescribeConnectionsPaginator ¶ added in v0.30.0
func NewDescribeConnectionsPaginator(client DescribeConnectionsAPIClient, params *DescribeConnectionsInput, optFns ...func(*DescribeConnectionsPaginatorOptions)) *DescribeConnectionsPaginator
NewDescribeConnectionsPaginator returns a new DescribeConnectionsPaginator
func (*DescribeConnectionsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeConnectionsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeConnectionsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeConnectionsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeConnectionsOutput, error)
NextPage retrieves the next DescribeConnections page.
type DescribeConnectionsPaginatorOptions ¶ added in v0.30.0
type DescribeConnectionsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeConnectionsPaginatorOptions is the paginator options for DescribeConnections
type DescribeEndpointSettingsAPIClient ¶ added in v1.3.0
type DescribeEndpointSettingsAPIClient interface {
DescribeEndpointSettings(context.Context, *DescribeEndpointSettingsInput, ...func(*Options)) (*DescribeEndpointSettingsOutput, error)
}
DescribeEndpointSettingsAPIClient is a client that implements the DescribeEndpointSettings operation.
type DescribeEndpointSettingsInput ¶ added in v1.3.0
type DescribeEndpointSettingsInput struct { // The databse engine used for your source or target endpoint. // // This member is required. EngineName *string // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeEndpointSettingsOutput ¶ added in v1.3.0
type DescribeEndpointSettingsOutput struct { // Descriptions of the endpoint settings available for your source or target // database engine. EndpointSettings []types.EndpointSetting // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEndpointSettingsPaginator ¶ added in v1.3.0
type DescribeEndpointSettingsPaginator struct {
// contains filtered or unexported fields
}
DescribeEndpointSettingsPaginator is a paginator for DescribeEndpointSettings
func NewDescribeEndpointSettingsPaginator ¶ added in v1.3.0
func NewDescribeEndpointSettingsPaginator(client DescribeEndpointSettingsAPIClient, params *DescribeEndpointSettingsInput, optFns ...func(*DescribeEndpointSettingsPaginatorOptions)) *DescribeEndpointSettingsPaginator
NewDescribeEndpointSettingsPaginator returns a new DescribeEndpointSettingsPaginator
func (*DescribeEndpointSettingsPaginator) HasMorePages ¶ added in v1.3.0
func (p *DescribeEndpointSettingsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeEndpointSettingsPaginator) NextPage ¶ added in v1.3.0
func (p *DescribeEndpointSettingsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeEndpointSettingsOutput, error)
NextPage retrieves the next DescribeEndpointSettings page.
type DescribeEndpointSettingsPaginatorOptions ¶ added in v1.3.0
type DescribeEndpointSettingsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeEndpointSettingsPaginatorOptions is the paginator options for DescribeEndpointSettings
type DescribeEndpointTypesAPIClient ¶ added in v0.30.0
type DescribeEndpointTypesAPIClient interface {
DescribeEndpointTypes(context.Context, *DescribeEndpointTypesInput, ...func(*Options)) (*DescribeEndpointTypesOutput, error)
}
DescribeEndpointTypesAPIClient is a client that implements the DescribeEndpointTypes operation.
type DescribeEndpointTypesInput ¶
type DescribeEndpointTypesInput struct { // Filters applied to the endpoint types. Valid filter names: engine-name | // endpoint-type Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeEndpointTypesOutput ¶
type DescribeEndpointTypesOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The types of endpoints that are supported. SupportedEndpointTypes []types.SupportedEndpointType // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEndpointTypesPaginator ¶ added in v0.30.0
type DescribeEndpointTypesPaginator struct {
// contains filtered or unexported fields
}
DescribeEndpointTypesPaginator is a paginator for DescribeEndpointTypes
func NewDescribeEndpointTypesPaginator ¶ added in v0.30.0
func NewDescribeEndpointTypesPaginator(client DescribeEndpointTypesAPIClient, params *DescribeEndpointTypesInput, optFns ...func(*DescribeEndpointTypesPaginatorOptions)) *DescribeEndpointTypesPaginator
NewDescribeEndpointTypesPaginator returns a new DescribeEndpointTypesPaginator
func (*DescribeEndpointTypesPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeEndpointTypesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeEndpointTypesPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeEndpointTypesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeEndpointTypesOutput, error)
NextPage retrieves the next DescribeEndpointTypes page.
type DescribeEndpointTypesPaginatorOptions ¶ added in v0.30.0
type DescribeEndpointTypesPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeEndpointTypesPaginatorOptions is the paginator options for DescribeEndpointTypes
type DescribeEndpointsAPIClient ¶ added in v0.30.0
type DescribeEndpointsAPIClient interface {
DescribeEndpoints(context.Context, *DescribeEndpointsInput, ...func(*Options)) (*DescribeEndpointsOutput, error)
}
DescribeEndpointsAPIClient is a client that implements the DescribeEndpoints operation.
type DescribeEndpointsInput ¶
type DescribeEndpointsInput struct { // Filters applied to the endpoints. Valid filter names: endpoint-arn | // endpoint-type | endpoint-id | engine-name Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeEndpointsOutput ¶
type DescribeEndpointsOutput struct { // Endpoint description. Endpoints []types.Endpoint // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEndpointsPaginator ¶ added in v0.30.0
type DescribeEndpointsPaginator struct {
// contains filtered or unexported fields
}
DescribeEndpointsPaginator is a paginator for DescribeEndpoints
func NewDescribeEndpointsPaginator ¶ added in v0.30.0
func NewDescribeEndpointsPaginator(client DescribeEndpointsAPIClient, params *DescribeEndpointsInput, optFns ...func(*DescribeEndpointsPaginatorOptions)) *DescribeEndpointsPaginator
NewDescribeEndpointsPaginator returns a new DescribeEndpointsPaginator
func (*DescribeEndpointsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeEndpointsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeEndpointsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeEndpointsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeEndpointsOutput, error)
NextPage retrieves the next DescribeEndpoints page.
type DescribeEndpointsPaginatorOptions ¶ added in v0.30.0
type DescribeEndpointsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeEndpointsPaginatorOptions is the paginator options for DescribeEndpoints
type DescribeEventCategoriesOutput ¶
type DescribeEventCategoriesOutput struct { // A list of event categories. EventCategoryGroupList []types.EventCategoryGroup // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEventSubscriptionsAPIClient ¶ added in v0.30.0
type DescribeEventSubscriptionsAPIClient interface {
DescribeEventSubscriptions(context.Context, *DescribeEventSubscriptionsInput, ...func(*Options)) (*DescribeEventSubscriptionsOutput, error)
}
DescribeEventSubscriptionsAPIClient is a client that implements the DescribeEventSubscriptions operation.
type DescribeEventSubscriptionsInput ¶
type DescribeEventSubscriptionsInput struct { // Filters applied to event subscriptions. Valid filter names: // event-subscription-arn | event-subscription-id Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // The name of the DMS event subscription to be described. SubscriptionName *string // contains filtered or unexported fields }
type DescribeEventSubscriptionsOutput ¶
type DescribeEventSubscriptionsOutput struct { // A list of event subscriptions. EventSubscriptionsList []types.EventSubscription // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEventSubscriptionsPaginator ¶ added in v0.30.0
type DescribeEventSubscriptionsPaginator struct {
// contains filtered or unexported fields
}
DescribeEventSubscriptionsPaginator is a paginator for DescribeEventSubscriptions
func NewDescribeEventSubscriptionsPaginator ¶ added in v0.30.0
func NewDescribeEventSubscriptionsPaginator(client DescribeEventSubscriptionsAPIClient, params *DescribeEventSubscriptionsInput, optFns ...func(*DescribeEventSubscriptionsPaginatorOptions)) *DescribeEventSubscriptionsPaginator
NewDescribeEventSubscriptionsPaginator returns a new DescribeEventSubscriptionsPaginator
func (*DescribeEventSubscriptionsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeEventSubscriptionsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeEventSubscriptionsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeEventSubscriptionsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeEventSubscriptionsOutput, error)
NextPage retrieves the next DescribeEventSubscriptions page.
type DescribeEventSubscriptionsPaginatorOptions ¶ added in v0.30.0
type DescribeEventSubscriptionsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeEventSubscriptionsPaginatorOptions is the paginator options for DescribeEventSubscriptions
type DescribeEventsAPIClient ¶ added in v0.30.0
type DescribeEventsAPIClient interface {
DescribeEvents(context.Context, *DescribeEventsInput, ...func(*Options)) (*DescribeEventsOutput, error)
}
DescribeEventsAPIClient is a client that implements the DescribeEvents operation.
type DescribeEventsInput ¶
type DescribeEventsInput struct { // The duration of the events to be listed. Duration *int32 // The end time for the events to be listed. EndTime *time.Time // A list of event categories for the source type that you've chosen. EventCategories []string // Filters applied to events. The only valid filter is replication-instance-id. Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // The identifier of an event source. SourceIdentifier *string // The type of DMS resource that generates events. Valid values: // replication-instance | replication-task SourceType types.SourceType // The start time for the events to be listed. StartTime *time.Time // contains filtered or unexported fields }
type DescribeEventsOutput ¶
type DescribeEventsOutput struct { // The events described. Events []types.Event // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeEventsPaginator ¶ added in v0.30.0
type DescribeEventsPaginator struct {
// contains filtered or unexported fields
}
DescribeEventsPaginator is a paginator for DescribeEvents
func NewDescribeEventsPaginator ¶ added in v0.30.0
func NewDescribeEventsPaginator(client DescribeEventsAPIClient, params *DescribeEventsInput, optFns ...func(*DescribeEventsPaginatorOptions)) *DescribeEventsPaginator
NewDescribeEventsPaginator returns a new DescribeEventsPaginator
func (*DescribeEventsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeEventsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeEventsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeEventsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeEventsOutput, error)
NextPage retrieves the next DescribeEvents page.
type DescribeEventsPaginatorOptions ¶ added in v0.30.0
type DescribeEventsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeEventsPaginatorOptions is the paginator options for DescribeEvents
type DescribeFleetAdvisorCollectorsAPIClient ¶ added in v1.19.0
type DescribeFleetAdvisorCollectorsAPIClient interface {
DescribeFleetAdvisorCollectors(context.Context, *DescribeFleetAdvisorCollectorsInput, ...func(*Options)) (*DescribeFleetAdvisorCollectorsOutput, error)
}
DescribeFleetAdvisorCollectorsAPIClient is a client that implements the DescribeFleetAdvisorCollectors operation.
type DescribeFleetAdvisorCollectorsInput ¶ added in v1.19.0
type DescribeFleetAdvisorCollectorsInput struct { // If you specify any of the following filters, the output includes information for // only those collectors that meet the filter criteria: // // * collector-referenced-id // – The ID of the collector agent, for example // d4610ac5-e323-4ad9-bc50-eaf7249dfe9d. // // * collector-name – The name of the // collector agent. // // An example is: describe-fleet-advisor-collectors --filter // Name="collector-referenced-id",Values="d4610ac5-e323-4ad9-bc50-eaf7249dfe9d" Filters []types.Filter // Sets the maximum number of records returned in the response. MaxRecords *int32 // If NextToken is returned by a previous response, there are more results // available. The value of NextToken is a unique pagination token for each page. // Make the call again using the returned token to retrieve the next page. Keep all // other arguments unchanged. NextToken *string // contains filtered or unexported fields }
type DescribeFleetAdvisorCollectorsOutput ¶ added in v1.19.0
type DescribeFleetAdvisorCollectorsOutput struct { // Provides descriptions of the Fleet Advisor collectors, including the collectors' // name and ID, and the latest inventory data. Collectors []types.CollectorResponse // If NextToken is returned, there are more results available. The value of // NextToken is a unique pagination token for each page. Make the call again using // the returned token to retrieve the next page. Keep all other arguments // unchanged. NextToken *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeFleetAdvisorCollectorsPaginator ¶ added in v1.19.0
type DescribeFleetAdvisorCollectorsPaginator struct {
// contains filtered or unexported fields
}
DescribeFleetAdvisorCollectorsPaginator is a paginator for DescribeFleetAdvisorCollectors
func NewDescribeFleetAdvisorCollectorsPaginator ¶ added in v1.19.0
func NewDescribeFleetAdvisorCollectorsPaginator(client DescribeFleetAdvisorCollectorsAPIClient, params *DescribeFleetAdvisorCollectorsInput, optFns ...func(*DescribeFleetAdvisorCollectorsPaginatorOptions)) *DescribeFleetAdvisorCollectorsPaginator
NewDescribeFleetAdvisorCollectorsPaginator returns a new DescribeFleetAdvisorCollectorsPaginator
func (*DescribeFleetAdvisorCollectorsPaginator) HasMorePages ¶ added in v1.19.0
func (p *DescribeFleetAdvisorCollectorsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeFleetAdvisorCollectorsPaginator) NextPage ¶ added in v1.19.0
func (p *DescribeFleetAdvisorCollectorsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeFleetAdvisorCollectorsOutput, error)
NextPage retrieves the next DescribeFleetAdvisorCollectors page.
type DescribeFleetAdvisorCollectorsPaginatorOptions ¶ added in v1.19.0
type DescribeFleetAdvisorCollectorsPaginatorOptions struct { // Sets the maximum number of records returned in the response. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeFleetAdvisorCollectorsPaginatorOptions is the paginator options for DescribeFleetAdvisorCollectors
type DescribeFleetAdvisorDatabasesAPIClient ¶ added in v1.19.0
type DescribeFleetAdvisorDatabasesAPIClient interface {
DescribeFleetAdvisorDatabases(context.Context, *DescribeFleetAdvisorDatabasesInput, ...func(*Options)) (*DescribeFleetAdvisorDatabasesOutput, error)
}
DescribeFleetAdvisorDatabasesAPIClient is a client that implements the DescribeFleetAdvisorDatabases operation.
type DescribeFleetAdvisorDatabasesInput ¶ added in v1.19.0
type DescribeFleetAdvisorDatabasesInput struct { // If you specify any of the following filters, the output includes information for // only those databases that meet the filter criteria: // // * database-id – The ID of // the database. // // * database-name – The name of the database. // // * database-engine – // The name of the database engine. // // * server-ip-address – The IP address of the // database server. // // * database-ip-address – The IP address of the database. // // * // collector-name – The name of the associated Fleet Advisor collector. // // An example // is: describe-fleet-advisor-databases --filter Name="database-id",Values="45" Filters []types.Filter // Sets the maximum number of records returned in the response. MaxRecords *int32 // If NextToken is returned by a previous response, there are more results // available. The value of NextToken is a unique pagination token for each page. // Make the call again using the returned token to retrieve the next page. Keep all // other arguments unchanged. NextToken *string // contains filtered or unexported fields }
type DescribeFleetAdvisorDatabasesOutput ¶ added in v1.19.0
type DescribeFleetAdvisorDatabasesOutput struct { // Provides descriptions of the Fleet Advisor collector databases, including the // database's collector, ID, and name. Databases []types.DatabaseResponse // If NextToken is returned, there are more results available. The value of // NextToken is a unique pagination token for each page. Make the call again using // the returned token to retrieve the next page. Keep all other arguments // unchanged. NextToken *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeFleetAdvisorDatabasesPaginator ¶ added in v1.19.0
type DescribeFleetAdvisorDatabasesPaginator struct {
// contains filtered or unexported fields
}
DescribeFleetAdvisorDatabasesPaginator is a paginator for DescribeFleetAdvisorDatabases
func NewDescribeFleetAdvisorDatabasesPaginator ¶ added in v1.19.0
func NewDescribeFleetAdvisorDatabasesPaginator(client DescribeFleetAdvisorDatabasesAPIClient, params *DescribeFleetAdvisorDatabasesInput, optFns ...func(*DescribeFleetAdvisorDatabasesPaginatorOptions)) *DescribeFleetAdvisorDatabasesPaginator
NewDescribeFleetAdvisorDatabasesPaginator returns a new DescribeFleetAdvisorDatabasesPaginator
func (*DescribeFleetAdvisorDatabasesPaginator) HasMorePages ¶ added in v1.19.0
func (p *DescribeFleetAdvisorDatabasesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeFleetAdvisorDatabasesPaginator) NextPage ¶ added in v1.19.0
func (p *DescribeFleetAdvisorDatabasesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeFleetAdvisorDatabasesOutput, error)
NextPage retrieves the next DescribeFleetAdvisorDatabases page.
type DescribeFleetAdvisorDatabasesPaginatorOptions ¶ added in v1.19.0
type DescribeFleetAdvisorDatabasesPaginatorOptions struct { // Sets the maximum number of records returned in the response. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeFleetAdvisorDatabasesPaginatorOptions is the paginator options for DescribeFleetAdvisorDatabases
type DescribeFleetAdvisorLsaAnalysisAPIClient ¶ added in v1.19.0
type DescribeFleetAdvisorLsaAnalysisAPIClient interface {
DescribeFleetAdvisorLsaAnalysis(context.Context, *DescribeFleetAdvisorLsaAnalysisInput, ...func(*Options)) (*DescribeFleetAdvisorLsaAnalysisOutput, error)
}
DescribeFleetAdvisorLsaAnalysisAPIClient is a client that implements the DescribeFleetAdvisorLsaAnalysis operation.
type DescribeFleetAdvisorLsaAnalysisInput ¶ added in v1.19.0
type DescribeFleetAdvisorLsaAnalysisInput struct { // Sets the maximum number of records returned in the response. MaxRecords *int32 // If NextToken is returned by a previous response, there are more results // available. The value of NextToken is a unique pagination token for each page. // Make the call again using the returned token to retrieve the next page. Keep all // other arguments unchanged. NextToken *string // contains filtered or unexported fields }
type DescribeFleetAdvisorLsaAnalysisOutput ¶ added in v1.19.0
type DescribeFleetAdvisorLsaAnalysisOutput struct { // A list of FleetAdvisorLsaAnalysisResponse objects. Analysis []types.FleetAdvisorLsaAnalysisResponse // If NextToken is returned, there are more results available. The value of // NextToken is a unique pagination token for each page. Make the call again using // the returned token to retrieve the next page. Keep all other arguments // unchanged. NextToken *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeFleetAdvisorLsaAnalysisPaginator ¶ added in v1.19.0
type DescribeFleetAdvisorLsaAnalysisPaginator struct {
// contains filtered or unexported fields
}
DescribeFleetAdvisorLsaAnalysisPaginator is a paginator for DescribeFleetAdvisorLsaAnalysis
func NewDescribeFleetAdvisorLsaAnalysisPaginator ¶ added in v1.19.0
func NewDescribeFleetAdvisorLsaAnalysisPaginator(client DescribeFleetAdvisorLsaAnalysisAPIClient, params *DescribeFleetAdvisorLsaAnalysisInput, optFns ...func(*DescribeFleetAdvisorLsaAnalysisPaginatorOptions)) *DescribeFleetAdvisorLsaAnalysisPaginator
NewDescribeFleetAdvisorLsaAnalysisPaginator returns a new DescribeFleetAdvisorLsaAnalysisPaginator
func (*DescribeFleetAdvisorLsaAnalysisPaginator) HasMorePages ¶ added in v1.19.0
func (p *DescribeFleetAdvisorLsaAnalysisPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeFleetAdvisorLsaAnalysisPaginator) NextPage ¶ added in v1.19.0
func (p *DescribeFleetAdvisorLsaAnalysisPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeFleetAdvisorLsaAnalysisOutput, error)
NextPage retrieves the next DescribeFleetAdvisorLsaAnalysis page.
type DescribeFleetAdvisorLsaAnalysisPaginatorOptions ¶ added in v1.19.0
type DescribeFleetAdvisorLsaAnalysisPaginatorOptions struct { // Sets the maximum number of records returned in the response. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeFleetAdvisorLsaAnalysisPaginatorOptions is the paginator options for DescribeFleetAdvisorLsaAnalysis
type DescribeFleetAdvisorSchemaObjectSummaryAPIClient ¶ added in v1.19.0
type DescribeFleetAdvisorSchemaObjectSummaryAPIClient interface {
DescribeFleetAdvisorSchemaObjectSummary(context.Context, *DescribeFleetAdvisorSchemaObjectSummaryInput, ...func(*Options)) (*DescribeFleetAdvisorSchemaObjectSummaryOutput, error)
}
DescribeFleetAdvisorSchemaObjectSummaryAPIClient is a client that implements the DescribeFleetAdvisorSchemaObjectSummary operation.
type DescribeFleetAdvisorSchemaObjectSummaryInput ¶ added in v1.19.0
type DescribeFleetAdvisorSchemaObjectSummaryInput struct { // If you specify any of the following filters, the output includes information for // only those schema objects that meet the filter criteria: // // * schema-id – The ID // of the schema, for example d4610ac5-e323-4ad9-bc50-eaf7249dfe9d. // // Example: // describe-fleet-advisor-schema-object-summary --filter // Name="schema-id",Values="50" Filters []types.Filter // Sets the maximum number of records returned in the response. MaxRecords *int32 // If NextToken is returned by a previous response, there are more results // available. The value of NextToken is a unique pagination token for each page. // Make the call again using the returned token to retrieve the next page. Keep all // other arguments unchanged. NextToken *string // contains filtered or unexported fields }
type DescribeFleetAdvisorSchemaObjectSummaryOutput ¶ added in v1.19.0
type DescribeFleetAdvisorSchemaObjectSummaryOutput struct { // A collection of FleetAdvisorSchemaObjectResponse objects. FleetAdvisorSchemaObjects []types.FleetAdvisorSchemaObjectResponse // If NextToken is returned, there are more results available. The value of // NextToken is a unique pagination token for each page. Make the call again using // the returned token to retrieve the next page. Keep all other arguments // unchanged. NextToken *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeFleetAdvisorSchemaObjectSummaryPaginator ¶ added in v1.19.0
type DescribeFleetAdvisorSchemaObjectSummaryPaginator struct {
// contains filtered or unexported fields
}
DescribeFleetAdvisorSchemaObjectSummaryPaginator is a paginator for DescribeFleetAdvisorSchemaObjectSummary
func NewDescribeFleetAdvisorSchemaObjectSummaryPaginator ¶ added in v1.19.0
func NewDescribeFleetAdvisorSchemaObjectSummaryPaginator(client DescribeFleetAdvisorSchemaObjectSummaryAPIClient, params *DescribeFleetAdvisorSchemaObjectSummaryInput, optFns ...func(*DescribeFleetAdvisorSchemaObjectSummaryPaginatorOptions)) *DescribeFleetAdvisorSchemaObjectSummaryPaginator
NewDescribeFleetAdvisorSchemaObjectSummaryPaginator returns a new DescribeFleetAdvisorSchemaObjectSummaryPaginator
func (*DescribeFleetAdvisorSchemaObjectSummaryPaginator) HasMorePages ¶ added in v1.19.0
func (p *DescribeFleetAdvisorSchemaObjectSummaryPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeFleetAdvisorSchemaObjectSummaryPaginator) NextPage ¶ added in v1.19.0
func (p *DescribeFleetAdvisorSchemaObjectSummaryPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeFleetAdvisorSchemaObjectSummaryOutput, error)
NextPage retrieves the next DescribeFleetAdvisorSchemaObjectSummary page.
type DescribeFleetAdvisorSchemaObjectSummaryPaginatorOptions ¶ added in v1.19.0
type DescribeFleetAdvisorSchemaObjectSummaryPaginatorOptions struct { // Sets the maximum number of records returned in the response. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeFleetAdvisorSchemaObjectSummaryPaginatorOptions is the paginator options for DescribeFleetAdvisorSchemaObjectSummary
type DescribeFleetAdvisorSchemasAPIClient ¶ added in v1.19.0
type DescribeFleetAdvisorSchemasAPIClient interface {
DescribeFleetAdvisorSchemas(context.Context, *DescribeFleetAdvisorSchemasInput, ...func(*Options)) (*DescribeFleetAdvisorSchemasOutput, error)
}
DescribeFleetAdvisorSchemasAPIClient is a client that implements the DescribeFleetAdvisorSchemas operation.
type DescribeFleetAdvisorSchemasInput ¶ added in v1.19.0
type DescribeFleetAdvisorSchemasInput struct { // If you specify any of the following filters, the output includes information for // only those schemas that meet the filter criteria: // // * complexity – The schema's // complexity, for example Simple. // // * database-id – The ID of the schema's // database. // // * database-ip-address – The IP address of the schema's database. // // * // database-name – The name of the schema's database. // // * database-engine – The name // of the schema database's engine. // // * original-schema-name – The name of the // schema's database's main schema. // // * schema-id – The ID of the schema, for // example 15. // // * schema-name – The name of the schema. // // * server-ip-address – The // IP address of the schema database's server. // // An example is: // describe-fleet-advisor-schemas --filter Name="schema-id",Values="50" Filters []types.Filter // Sets the maximum number of records returned in the response. MaxRecords *int32 // If NextToken is returned by a previous response, there are more results // available. The value of NextToken is a unique pagination token for each page. // Make the call again using the returned token to retrieve the next page. Keep all // other arguments unchanged. NextToken *string // contains filtered or unexported fields }
type DescribeFleetAdvisorSchemasOutput ¶ added in v1.19.0
type DescribeFleetAdvisorSchemasOutput struct { // A collection of SchemaResponse objects. FleetAdvisorSchemas []types.SchemaResponse // If NextToken is returned, there are more results available. The value of // NextToken is a unique pagination token for each page. Make the call again using // the returned token to retrieve the next page. Keep all other arguments // unchanged. NextToken *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeFleetAdvisorSchemasPaginator ¶ added in v1.19.0
type DescribeFleetAdvisorSchemasPaginator struct {
// contains filtered or unexported fields
}
DescribeFleetAdvisorSchemasPaginator is a paginator for DescribeFleetAdvisorSchemas
func NewDescribeFleetAdvisorSchemasPaginator ¶ added in v1.19.0
func NewDescribeFleetAdvisorSchemasPaginator(client DescribeFleetAdvisorSchemasAPIClient, params *DescribeFleetAdvisorSchemasInput, optFns ...func(*DescribeFleetAdvisorSchemasPaginatorOptions)) *DescribeFleetAdvisorSchemasPaginator
NewDescribeFleetAdvisorSchemasPaginator returns a new DescribeFleetAdvisorSchemasPaginator
func (*DescribeFleetAdvisorSchemasPaginator) HasMorePages ¶ added in v1.19.0
func (p *DescribeFleetAdvisorSchemasPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeFleetAdvisorSchemasPaginator) NextPage ¶ added in v1.19.0
func (p *DescribeFleetAdvisorSchemasPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeFleetAdvisorSchemasOutput, error)
NextPage retrieves the next DescribeFleetAdvisorSchemas page.
type DescribeFleetAdvisorSchemasPaginatorOptions ¶ added in v1.19.0
type DescribeFleetAdvisorSchemasPaginatorOptions struct { // Sets the maximum number of records returned in the response. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeFleetAdvisorSchemasPaginatorOptions is the paginator options for DescribeFleetAdvisorSchemas
type DescribeOrderableReplicationInstancesAPIClient ¶ added in v0.30.0
type DescribeOrderableReplicationInstancesAPIClient interface {
DescribeOrderableReplicationInstances(context.Context, *DescribeOrderableReplicationInstancesInput, ...func(*Options)) (*DescribeOrderableReplicationInstancesOutput, error)
}
DescribeOrderableReplicationInstancesAPIClient is a client that implements the DescribeOrderableReplicationInstances operation.
type DescribeOrderableReplicationInstancesInput ¶
type DescribeOrderableReplicationInstancesInput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeOrderableReplicationInstancesOutput ¶
type DescribeOrderableReplicationInstancesOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The order-able replication instances available. OrderableReplicationInstances []types.OrderableReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeOrderableReplicationInstancesPaginator ¶ added in v0.30.0
type DescribeOrderableReplicationInstancesPaginator struct {
// contains filtered or unexported fields
}
DescribeOrderableReplicationInstancesPaginator is a paginator for DescribeOrderableReplicationInstances
func NewDescribeOrderableReplicationInstancesPaginator ¶ added in v0.30.0
func NewDescribeOrderableReplicationInstancesPaginator(client DescribeOrderableReplicationInstancesAPIClient, params *DescribeOrderableReplicationInstancesInput, optFns ...func(*DescribeOrderableReplicationInstancesPaginatorOptions)) *DescribeOrderableReplicationInstancesPaginator
NewDescribeOrderableReplicationInstancesPaginator returns a new DescribeOrderableReplicationInstancesPaginator
func (*DescribeOrderableReplicationInstancesPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeOrderableReplicationInstancesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeOrderableReplicationInstancesPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeOrderableReplicationInstancesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeOrderableReplicationInstancesOutput, error)
NextPage retrieves the next DescribeOrderableReplicationInstances page.
type DescribeOrderableReplicationInstancesPaginatorOptions ¶ added in v0.30.0
type DescribeOrderableReplicationInstancesPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeOrderableReplicationInstancesPaginatorOptions is the paginator options for DescribeOrderableReplicationInstances
type DescribePendingMaintenanceActionsAPIClient ¶ added in v0.30.0
type DescribePendingMaintenanceActionsAPIClient interface {
DescribePendingMaintenanceActions(context.Context, *DescribePendingMaintenanceActionsInput, ...func(*Options)) (*DescribePendingMaintenanceActionsOutput, error)
}
DescribePendingMaintenanceActionsAPIClient is a client that implements the DescribePendingMaintenanceActions operation.
type DescribePendingMaintenanceActionsInput ¶
type DescribePendingMaintenanceActionsInput struct { // Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // The Amazon Resource Name (ARN) of the replication instance. ReplicationInstanceArn *string // contains filtered or unexported fields }
type DescribePendingMaintenanceActionsOutput ¶
type DescribePendingMaintenanceActionsOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The pending maintenance action. PendingMaintenanceActions []types.ResourcePendingMaintenanceActions // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribePendingMaintenanceActionsPaginator ¶ added in v0.30.0
type DescribePendingMaintenanceActionsPaginator struct {
// contains filtered or unexported fields
}
DescribePendingMaintenanceActionsPaginator is a paginator for DescribePendingMaintenanceActions
func NewDescribePendingMaintenanceActionsPaginator ¶ added in v0.30.0
func NewDescribePendingMaintenanceActionsPaginator(client DescribePendingMaintenanceActionsAPIClient, params *DescribePendingMaintenanceActionsInput, optFns ...func(*DescribePendingMaintenanceActionsPaginatorOptions)) *DescribePendingMaintenanceActionsPaginator
NewDescribePendingMaintenanceActionsPaginator returns a new DescribePendingMaintenanceActionsPaginator
func (*DescribePendingMaintenanceActionsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribePendingMaintenanceActionsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribePendingMaintenanceActionsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribePendingMaintenanceActionsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribePendingMaintenanceActionsOutput, error)
NextPage retrieves the next DescribePendingMaintenanceActions page.
type DescribePendingMaintenanceActionsPaginatorOptions ¶ added in v0.30.0
type DescribePendingMaintenanceActionsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribePendingMaintenanceActionsPaginatorOptions is the paginator options for DescribePendingMaintenanceActions
type DescribeRefreshSchemasStatusInput ¶
type DescribeRefreshSchemasStatusInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // contains filtered or unexported fields }
type DescribeRefreshSchemasStatusOutput ¶
type DescribeRefreshSchemasStatusOutput struct { // The status of the schema. RefreshSchemasStatus *types.RefreshSchemasStatus // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationInstanceTaskLogsAPIClient ¶ added in v0.30.0
type DescribeReplicationInstanceTaskLogsAPIClient interface {
DescribeReplicationInstanceTaskLogs(context.Context, *DescribeReplicationInstanceTaskLogsInput, ...func(*Options)) (*DescribeReplicationInstanceTaskLogsOutput, error)
}
DescribeReplicationInstanceTaskLogsAPIClient is a client that implements the DescribeReplicationInstanceTaskLogs operation.
type DescribeReplicationInstanceTaskLogsInput ¶
type DescribeReplicationInstanceTaskLogsInput struct { // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeReplicationInstanceTaskLogsOutput ¶
type DescribeReplicationInstanceTaskLogsOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The Amazon Resource Name (ARN) of the replication instance. ReplicationInstanceArn *string // An array of replication task log metadata. Each member of the array contains the // replication task name, ARN, and task log size (in bytes). ReplicationInstanceTaskLogs []types.ReplicationInstanceTaskLog // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationInstanceTaskLogsPaginator ¶ added in v0.30.0
type DescribeReplicationInstanceTaskLogsPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationInstanceTaskLogsPaginator is a paginator for DescribeReplicationInstanceTaskLogs
func NewDescribeReplicationInstanceTaskLogsPaginator ¶ added in v0.30.0
func NewDescribeReplicationInstanceTaskLogsPaginator(client DescribeReplicationInstanceTaskLogsAPIClient, params *DescribeReplicationInstanceTaskLogsInput, optFns ...func(*DescribeReplicationInstanceTaskLogsPaginatorOptions)) *DescribeReplicationInstanceTaskLogsPaginator
NewDescribeReplicationInstanceTaskLogsPaginator returns a new DescribeReplicationInstanceTaskLogsPaginator
func (*DescribeReplicationInstanceTaskLogsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationInstanceTaskLogsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationInstanceTaskLogsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationInstanceTaskLogsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationInstanceTaskLogsOutput, error)
NextPage retrieves the next DescribeReplicationInstanceTaskLogs page.
type DescribeReplicationInstanceTaskLogsPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationInstanceTaskLogsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationInstanceTaskLogsPaginatorOptions is the paginator options for DescribeReplicationInstanceTaskLogs
type DescribeReplicationInstancesAPIClient ¶ added in v0.30.0
type DescribeReplicationInstancesAPIClient interface {
DescribeReplicationInstances(context.Context, *DescribeReplicationInstancesInput, ...func(*Options)) (*DescribeReplicationInstancesOutput, error)
}
DescribeReplicationInstancesAPIClient is a client that implements the DescribeReplicationInstances operation.
type DescribeReplicationInstancesInput ¶
type DescribeReplicationInstancesInput struct { // Filters applied to replication instances. Valid filter names: // replication-instance-arn | replication-instance-id | replication-instance-class // | engine-version Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeReplicationInstancesOutput ¶
type DescribeReplicationInstancesOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The replication instances described. ReplicationInstances []types.ReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationInstancesPaginator ¶ added in v0.30.0
type DescribeReplicationInstancesPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationInstancesPaginator is a paginator for DescribeReplicationInstances
func NewDescribeReplicationInstancesPaginator ¶ added in v0.30.0
func NewDescribeReplicationInstancesPaginator(client DescribeReplicationInstancesAPIClient, params *DescribeReplicationInstancesInput, optFns ...func(*DescribeReplicationInstancesPaginatorOptions)) *DescribeReplicationInstancesPaginator
NewDescribeReplicationInstancesPaginator returns a new DescribeReplicationInstancesPaginator
func (*DescribeReplicationInstancesPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationInstancesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationInstancesPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationInstancesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationInstancesOutput, error)
NextPage retrieves the next DescribeReplicationInstances page.
type DescribeReplicationInstancesPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationInstancesPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationInstancesPaginatorOptions is the paginator options for DescribeReplicationInstances
type DescribeReplicationSubnetGroupsAPIClient ¶ added in v0.30.0
type DescribeReplicationSubnetGroupsAPIClient interface {
DescribeReplicationSubnetGroups(context.Context, *DescribeReplicationSubnetGroupsInput, ...func(*Options)) (*DescribeReplicationSubnetGroupsOutput, error)
}
DescribeReplicationSubnetGroupsAPIClient is a client that implements the DescribeReplicationSubnetGroups operation.
type DescribeReplicationSubnetGroupsInput ¶
type DescribeReplicationSubnetGroupsInput struct { // Filters applied to replication subnet groups. Valid filter names: // replication-subnet-group-id Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeReplicationSubnetGroupsOutput ¶
type DescribeReplicationSubnetGroupsOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // A description of the replication subnet groups. ReplicationSubnetGroups []types.ReplicationSubnetGroup // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationSubnetGroupsPaginator ¶ added in v0.30.0
type DescribeReplicationSubnetGroupsPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationSubnetGroupsPaginator is a paginator for DescribeReplicationSubnetGroups
func NewDescribeReplicationSubnetGroupsPaginator ¶ added in v0.30.0
func NewDescribeReplicationSubnetGroupsPaginator(client DescribeReplicationSubnetGroupsAPIClient, params *DescribeReplicationSubnetGroupsInput, optFns ...func(*DescribeReplicationSubnetGroupsPaginatorOptions)) *DescribeReplicationSubnetGroupsPaginator
NewDescribeReplicationSubnetGroupsPaginator returns a new DescribeReplicationSubnetGroupsPaginator
func (*DescribeReplicationSubnetGroupsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationSubnetGroupsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationSubnetGroupsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationSubnetGroupsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationSubnetGroupsOutput, error)
NextPage retrieves the next DescribeReplicationSubnetGroups page.
type DescribeReplicationSubnetGroupsPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationSubnetGroupsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationSubnetGroupsPaginatorOptions is the paginator options for DescribeReplicationSubnetGroups
type DescribeReplicationTaskAssessmentResultsAPIClient ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentResultsAPIClient interface {
DescribeReplicationTaskAssessmentResults(context.Context, *DescribeReplicationTaskAssessmentResultsInput, ...func(*Options)) (*DescribeReplicationTaskAssessmentResultsOutput, error)
}
DescribeReplicationTaskAssessmentResultsAPIClient is a client that implements the DescribeReplicationTaskAssessmentResults operation.
type DescribeReplicationTaskAssessmentResultsInput ¶
type DescribeReplicationTaskAssessmentResultsInput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // The Amazon Resource Name (ARN) string that uniquely identifies the task. When // this input parameter is specified, the API returns only one result and ignore // the values of the MaxRecords and Marker parameters. ReplicationTaskArn *string // contains filtered or unexported fields }
type DescribeReplicationTaskAssessmentResultsOutput ¶
type DescribeReplicationTaskAssessmentResultsOutput struct { // - The Amazon S3 bucket where the task assessment report is located. BucketName *string // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The task assessment report. ReplicationTaskAssessmentResults []types.ReplicationTaskAssessmentResult // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationTaskAssessmentResultsPaginator ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentResultsPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationTaskAssessmentResultsPaginator is a paginator for DescribeReplicationTaskAssessmentResults
func NewDescribeReplicationTaskAssessmentResultsPaginator ¶ added in v0.30.0
func NewDescribeReplicationTaskAssessmentResultsPaginator(client DescribeReplicationTaskAssessmentResultsAPIClient, params *DescribeReplicationTaskAssessmentResultsInput, optFns ...func(*DescribeReplicationTaskAssessmentResultsPaginatorOptions)) *DescribeReplicationTaskAssessmentResultsPaginator
NewDescribeReplicationTaskAssessmentResultsPaginator returns a new DescribeReplicationTaskAssessmentResultsPaginator
func (*DescribeReplicationTaskAssessmentResultsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationTaskAssessmentResultsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationTaskAssessmentResultsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationTaskAssessmentResultsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationTaskAssessmentResultsOutput, error)
NextPage retrieves the next DescribeReplicationTaskAssessmentResults page.
type DescribeReplicationTaskAssessmentResultsPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentResultsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationTaskAssessmentResultsPaginatorOptions is the paginator options for DescribeReplicationTaskAssessmentResults
type DescribeReplicationTaskAssessmentRunsAPIClient ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentRunsAPIClient interface {
DescribeReplicationTaskAssessmentRuns(context.Context, *DescribeReplicationTaskAssessmentRunsInput, ...func(*Options)) (*DescribeReplicationTaskAssessmentRunsOutput, error)
}
DescribeReplicationTaskAssessmentRunsAPIClient is a client that implements the DescribeReplicationTaskAssessmentRuns operation.
type DescribeReplicationTaskAssessmentRunsInput ¶
type DescribeReplicationTaskAssessmentRunsInput struct { // Filters applied to the premigration assessment runs described in the form of // key-value pairs. Valid filter names: replication-task-assessment-run-arn, // replication-task-arn, replication-instance-arn, status Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeReplicationTaskAssessmentRunsOutput ¶
type DescribeReplicationTaskAssessmentRunsOutput struct { // A pagination token returned for you to pass to a subsequent request. If you pass // this token as the Marker value in a subsequent request, the response includes // only records beyond the marker, up to the value specified in the request by // MaxRecords. Marker *string // One or more premigration assessment runs as specified by Filters. ReplicationTaskAssessmentRuns []types.ReplicationTaskAssessmentRun // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationTaskAssessmentRunsPaginator ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentRunsPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationTaskAssessmentRunsPaginator is a paginator for DescribeReplicationTaskAssessmentRuns
func NewDescribeReplicationTaskAssessmentRunsPaginator ¶ added in v0.30.0
func NewDescribeReplicationTaskAssessmentRunsPaginator(client DescribeReplicationTaskAssessmentRunsAPIClient, params *DescribeReplicationTaskAssessmentRunsInput, optFns ...func(*DescribeReplicationTaskAssessmentRunsPaginatorOptions)) *DescribeReplicationTaskAssessmentRunsPaginator
NewDescribeReplicationTaskAssessmentRunsPaginator returns a new DescribeReplicationTaskAssessmentRunsPaginator
func (*DescribeReplicationTaskAssessmentRunsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationTaskAssessmentRunsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationTaskAssessmentRunsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationTaskAssessmentRunsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationTaskAssessmentRunsOutput, error)
NextPage retrieves the next DescribeReplicationTaskAssessmentRuns page.
type DescribeReplicationTaskAssessmentRunsPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationTaskAssessmentRunsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationTaskAssessmentRunsPaginatorOptions is the paginator options for DescribeReplicationTaskAssessmentRuns
type DescribeReplicationTaskIndividualAssessmentsAPIClient ¶ added in v0.30.0
type DescribeReplicationTaskIndividualAssessmentsAPIClient interface {
DescribeReplicationTaskIndividualAssessments(context.Context, *DescribeReplicationTaskIndividualAssessmentsInput, ...func(*Options)) (*DescribeReplicationTaskIndividualAssessmentsOutput, error)
}
DescribeReplicationTaskIndividualAssessmentsAPIClient is a client that implements the DescribeReplicationTaskIndividualAssessments operation.
type DescribeReplicationTaskIndividualAssessmentsInput ¶
type DescribeReplicationTaskIndividualAssessmentsInput struct { // Filters applied to the individual assessments described in the form of key-value // pairs. Valid filter names: replication-task-assessment-run-arn, // replication-task-arn, status Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeReplicationTaskIndividualAssessmentsOutput ¶
type DescribeReplicationTaskIndividualAssessmentsOutput struct { // A pagination token returned for you to pass to a subsequent request. If you pass // this token as the Marker value in a subsequent request, the response includes // only records beyond the marker, up to the value specified in the request by // MaxRecords. Marker *string // One or more individual assessments as specified by Filters. ReplicationTaskIndividualAssessments []types.ReplicationTaskIndividualAssessment // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationTaskIndividualAssessmentsPaginator ¶ added in v0.30.0
type DescribeReplicationTaskIndividualAssessmentsPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationTaskIndividualAssessmentsPaginator is a paginator for DescribeReplicationTaskIndividualAssessments
func NewDescribeReplicationTaskIndividualAssessmentsPaginator ¶ added in v0.30.0
func NewDescribeReplicationTaskIndividualAssessmentsPaginator(client DescribeReplicationTaskIndividualAssessmentsAPIClient, params *DescribeReplicationTaskIndividualAssessmentsInput, optFns ...func(*DescribeReplicationTaskIndividualAssessmentsPaginatorOptions)) *DescribeReplicationTaskIndividualAssessmentsPaginator
NewDescribeReplicationTaskIndividualAssessmentsPaginator returns a new DescribeReplicationTaskIndividualAssessmentsPaginator
func (*DescribeReplicationTaskIndividualAssessmentsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationTaskIndividualAssessmentsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationTaskIndividualAssessmentsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationTaskIndividualAssessmentsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationTaskIndividualAssessmentsOutput, error)
NextPage retrieves the next DescribeReplicationTaskIndividualAssessments page.
type DescribeReplicationTaskIndividualAssessmentsPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationTaskIndividualAssessmentsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationTaskIndividualAssessmentsPaginatorOptions is the paginator options for DescribeReplicationTaskIndividualAssessments
type DescribeReplicationTasksAPIClient ¶ added in v0.30.0
type DescribeReplicationTasksAPIClient interface {
DescribeReplicationTasks(context.Context, *DescribeReplicationTasksInput, ...func(*Options)) (*DescribeReplicationTasksOutput, error)
}
DescribeReplicationTasksAPIClient is a client that implements the DescribeReplicationTasks operation.
type DescribeReplicationTasksInput ¶
type DescribeReplicationTasksInput struct { // Filters applied to replication tasks. Valid filter names: replication-task-arn | // replication-task-id | migration-type | endpoint-arn | replication-instance-arn Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // An option to set to avoid returning information about settings. Use this to // reduce overhead when setting information is too large. To use this option, // choose true; otherwise, choose false (the default). WithoutSettings *bool // contains filtered or unexported fields }
type DescribeReplicationTasksOutput ¶
type DescribeReplicationTasksOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // A description of the replication tasks. ReplicationTasks []types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeReplicationTasksPaginator ¶ added in v0.30.0
type DescribeReplicationTasksPaginator struct {
// contains filtered or unexported fields
}
DescribeReplicationTasksPaginator is a paginator for DescribeReplicationTasks
func NewDescribeReplicationTasksPaginator ¶ added in v0.30.0
func NewDescribeReplicationTasksPaginator(client DescribeReplicationTasksAPIClient, params *DescribeReplicationTasksInput, optFns ...func(*DescribeReplicationTasksPaginatorOptions)) *DescribeReplicationTasksPaginator
NewDescribeReplicationTasksPaginator returns a new DescribeReplicationTasksPaginator
func (*DescribeReplicationTasksPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeReplicationTasksPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeReplicationTasksPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeReplicationTasksPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeReplicationTasksOutput, error)
NextPage retrieves the next DescribeReplicationTasks page.
type DescribeReplicationTasksPaginatorOptions ¶ added in v0.30.0
type DescribeReplicationTasksPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeReplicationTasksPaginatorOptions is the paginator options for DescribeReplicationTasks
type DescribeSchemasAPIClient ¶ added in v0.30.0
type DescribeSchemasAPIClient interface {
DescribeSchemas(context.Context, *DescribeSchemasInput, ...func(*Options)) (*DescribeSchemasOutput, error)
}
DescribeSchemasAPIClient is a client that implements the DescribeSchemas operation.
type DescribeSchemasInput ¶
type DescribeSchemasInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeSchemasOutput ¶
type DescribeSchemasOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The described schema. Schemas []string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeSchemasPaginator ¶ added in v0.30.0
type DescribeSchemasPaginator struct {
// contains filtered or unexported fields
}
DescribeSchemasPaginator is a paginator for DescribeSchemas
func NewDescribeSchemasPaginator ¶ added in v0.30.0
func NewDescribeSchemasPaginator(client DescribeSchemasAPIClient, params *DescribeSchemasInput, optFns ...func(*DescribeSchemasPaginatorOptions)) *DescribeSchemasPaginator
NewDescribeSchemasPaginator returns a new DescribeSchemasPaginator
func (*DescribeSchemasPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeSchemasPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeSchemasPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeSchemasPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeSchemasOutput, error)
NextPage retrieves the next DescribeSchemas page.
type DescribeSchemasPaginatorOptions ¶ added in v0.30.0
type DescribeSchemasPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 100. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeSchemasPaginatorOptions is the paginator options for DescribeSchemas
type DescribeTableStatisticsAPIClient ¶ added in v0.30.0
type DescribeTableStatisticsAPIClient interface {
DescribeTableStatistics(context.Context, *DescribeTableStatisticsInput, ...func(*Options)) (*DescribeTableStatisticsOutput, error)
}
DescribeTableStatisticsAPIClient is a client that implements the DescribeTableStatistics operation.
type DescribeTableStatisticsInput ¶
type DescribeTableStatisticsInput struct { // The Amazon Resource Name (ARN) of the replication task. // // This member is required. ReplicationTaskArn *string // Filters applied to table statistics. Valid filter names: schema-name | // table-name | table-state A combination of filters creates an AND condition where // each record matches all specified filters. Filters []types.Filter // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 500. MaxRecords *int32 // contains filtered or unexported fields }
type DescribeTableStatisticsOutput ¶
type DescribeTableStatisticsOutput struct { // An optional pagination token provided by a previous request. If this parameter // is specified, the response includes only records beyond the marker, up to the // value specified by MaxRecords. Marker *string // The Amazon Resource Name (ARN) of the replication task. ReplicationTaskArn *string // The table statistics. TableStatistics []types.TableStatistics // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type DescribeTableStatisticsPaginator ¶ added in v0.30.0
type DescribeTableStatisticsPaginator struct {
// contains filtered or unexported fields
}
DescribeTableStatisticsPaginator is a paginator for DescribeTableStatistics
func NewDescribeTableStatisticsPaginator ¶ added in v0.30.0
func NewDescribeTableStatisticsPaginator(client DescribeTableStatisticsAPIClient, params *DescribeTableStatisticsInput, optFns ...func(*DescribeTableStatisticsPaginatorOptions)) *DescribeTableStatisticsPaginator
NewDescribeTableStatisticsPaginator returns a new DescribeTableStatisticsPaginator
func (*DescribeTableStatisticsPaginator) HasMorePages ¶ added in v0.30.0
func (p *DescribeTableStatisticsPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*DescribeTableStatisticsPaginator) NextPage ¶ added in v0.30.0
func (p *DescribeTableStatisticsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*DescribeTableStatisticsOutput, error)
NextPage retrieves the next DescribeTableStatistics page.
type DescribeTableStatisticsPaginatorOptions ¶ added in v0.30.0
type DescribeTableStatisticsPaginatorOptions struct { // The maximum number of records to include in the response. If more records exist // than the specified MaxRecords value, a pagination token called a marker is // included in the response so that the remaining results can be retrieved. // Default: 100 Constraints: Minimum 20, maximum 500. Limit int32 // Set to true if pagination should stop if the service returns a pagination token // that matches the most recent token provided to the service. StopOnDuplicateToken bool }
DescribeTableStatisticsPaginatorOptions is the paginator options for DescribeTableStatistics
type EndpointDeletedWaiter ¶ added in v0.31.0
type EndpointDeletedWaiter struct {
// contains filtered or unexported fields
}
EndpointDeletedWaiter defines the waiters for EndpointDeleted
func NewEndpointDeletedWaiter ¶ added in v0.31.0
func NewEndpointDeletedWaiter(client DescribeEndpointsAPIClient, optFns ...func(*EndpointDeletedWaiterOptions)) *EndpointDeletedWaiter
NewEndpointDeletedWaiter constructs a EndpointDeletedWaiter.
func (*EndpointDeletedWaiter) Wait ¶ added in v0.31.0
func (w *EndpointDeletedWaiter) Wait(ctx context.Context, params *DescribeEndpointsInput, maxWaitDur time.Duration, optFns ...func(*EndpointDeletedWaiterOptions)) error
Wait calls the waiter function for EndpointDeleted waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*EndpointDeletedWaiter) WaitForOutput ¶ added in v1.11.0
func (w *EndpointDeletedWaiter) WaitForOutput(ctx context.Context, params *DescribeEndpointsInput, maxWaitDur time.Duration, optFns ...func(*EndpointDeletedWaiterOptions)) (*DescribeEndpointsOutput, error)
WaitForOutput calls the waiter function for EndpointDeleted waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type EndpointDeletedWaiterOptions ¶ added in v0.31.0
type EndpointDeletedWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // EndpointDeletedWaiter will use default minimum delay of 5 seconds. Note that // MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, EndpointDeletedWaiter will use default max delay of 120 seconds. Note // that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeEndpointsInput, *DescribeEndpointsOutput, error) (bool, error) }
EndpointDeletedWaiterOptions are waiter options for EndpointDeletedWaiter
type EndpointResolver ¶
type EndpointResolver interface {
ResolveEndpoint(region string, options EndpointResolverOptions) (aws.Endpoint, error)
}
EndpointResolver interface for resolving service endpoints.
func EndpointResolverFromURL ¶ added in v1.1.0
func EndpointResolverFromURL(url string, optFns ...func(*aws.Endpoint)) EndpointResolver
EndpointResolverFromURL returns an EndpointResolver configured using the provided endpoint url. By default, the resolved endpoint resolver uses the client region as signing region, and the endpoint source is set to EndpointSourceCustom.You can provide functional options to configure endpoint values for the resolved endpoint.
type EndpointResolverFunc ¶
type EndpointResolverFunc func(region string, options EndpointResolverOptions) (aws.Endpoint, error)
EndpointResolverFunc is a helper utility that wraps a function so it satisfies the EndpointResolver interface. This is useful when you want to add additional endpoint resolving logic, or stub out specific endpoints with custom values.
func (EndpointResolverFunc) ResolveEndpoint ¶
func (fn EndpointResolverFunc) ResolveEndpoint(region string, options EndpointResolverOptions) (endpoint aws.Endpoint, err error)
type EndpointResolverOptions ¶ added in v0.29.0
type EndpointResolverOptions = internalendpoints.Options
EndpointResolverOptions is the service endpoint resolver options
type HTTPSignerV4 ¶
type ImportCertificateInput ¶
type ImportCertificateInput struct { // A customer-assigned name for the certificate. Identifiers must begin with a // letter and must contain only ASCII letters, digits, and hyphens. They can't end // with a hyphen or contain two consecutive hyphens. // // This member is required. CertificateIdentifier *string // The contents of a .pem file, which contains an X.509 certificate. CertificatePem *string // The location of an imported Oracle Wallet certificate for use with SSL. Provide // the name of a .sso file using the fileb:// prefix. You can't provide the // certificate inline. Example: filebase64("${path.root}/rds-ca-2019-root.sso") CertificateWallet []byte // The tags associated with the certificate. Tags []types.Tag // contains filtered or unexported fields }
type ImportCertificateOutput ¶
type ImportCertificateOutput struct { // The certificate to be uploaded. Certificate *types.Certificate // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ListTagsForResourceInput ¶
type ListTagsForResourceInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the DMS resource // to list tags for. This returns a list of keys (names of tags) created for the // resource and their associated tag values. ResourceArn *string // List of ARNs that identify multiple DMS resources that you want to list tags // for. This returns a list of keys (tag names) and their associated tag values. It // also returns each tag's associated ResourceArn value, which is the ARN of the // resource for which each listed tag is created. ResourceArnList []string // contains filtered or unexported fields }
type ListTagsForResourceOutput ¶
type ListTagsForResourceOutput struct { // A list of tags for the resource. TagList []types.Tag // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ModifyEndpointInput ¶
type ModifyEndpointInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // The Amazon Resource Name (ARN) of the certificate used for SSL connection. CertificateArn *string // The name of the endpoint database. For a MySQL source or target endpoint, do not // specify DatabaseName. DatabaseName *string // The settings in JSON format for the DMS transfer type of source endpoint. // Attributes include the following: // // * serviceAccessRoleArn - The Amazon Resource // Name (ARN) used by the service access IAM role. The role must allow the // iam:PassRole action. // // * BucketName - The name of the S3 bucket to // use. // // Shorthand syntax for these settings is as follows: // ServiceAccessRoleArn=string ,BucketName=string JSON syntax for these settings is // as follows: { "ServiceAccessRoleArn": "string", "BucketName": "string"} DmsTransferSettings *types.DmsTransferSettings // Settings in JSON format for the source DocumentDB endpoint. For more information // about the available settings, see the configuration properties section in Using // DocumentDB as a Target for Database Migration Service // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.DocumentDB.html) // in the Database Migration Service User Guide. DocDbSettings *types.DocDbSettings // Settings in JSON format for the target Amazon DynamoDB endpoint. For information // about other available settings, see Using Object Mapping to Migrate Data to // DynamoDB // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.DynamoDB.html#CHAP_Target.DynamoDB.ObjectMapping) // in the Database Migration Service User Guide. DynamoDbSettings *types.DynamoDbSettings // Settings in JSON format for the target OpenSearch endpoint. For more information // about the available settings, see Extra Connection Attributes When Using // OpenSearch as a Target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Elasticsearch.html#CHAP_Target.Elasticsearch.Configuration) // in the Database Migration Service User Guide. ElasticsearchSettings *types.ElasticsearchSettings // The database endpoint identifier. Identifiers must begin with a letter and must // contain only ASCII letters, digits, and hyphens. They can't end with a hyphen or // contain two consecutive hyphens. EndpointIdentifier *string // The type of endpoint. Valid values are source and target. EndpointType types.ReplicationEndpointTypeValue // The database engine name. Valid values, depending on the EndpointType, include // "mysql", "oracle", "postgres", "mariadb", "aurora", "aurora-postgresql", // "redshift", "s3", "db2", "db2-zos", "azuredb", "sybase", "dynamodb", "mongodb", // "kinesis", "kafka", "elasticsearch", "documentdb", "sqlserver", "neptune", and // "babelfish". EngineName *string // If this attribute is Y, the current call to ModifyEndpoint replaces all existing // endpoint settings with the exact settings that you specify in this call. If this // attribute is N, the current call to ModifyEndpoint does two things: // // * It // replaces any endpoint settings that already exist with new values, for settings // with the same names. // // * It creates new endpoint settings that you specify in the // call, for settings with different names. // // For example, if you call // create-endpoint ... --endpoint-settings '{"a":1}' ..., the endpoint has the // following endpoint settings: '{"a":1}'. If you then call modify-endpoint ... // --endpoint-settings '{"b":2}' ... for the same endpoint, the endpoint has the // following settings: '{"a":1,"b":2}'. However, suppose that you follow this with // a call to modify-endpoint ... --endpoint-settings '{"b":2}' --exact-settings ... // for that same endpoint again. Then the endpoint has the following settings: // '{"b":2}'. All existing settings are replaced with the exact settings that you // specify. ExactSettings *bool // The external table definition. ExternalTableDefinition *string // Additional attributes associated with the connection. To reset this parameter, // pass the empty string ("") as an argument. ExtraConnectionAttributes *string // Settings in JSON format for the source GCP MySQL endpoint. GcpMySQLSettings *types.GcpMySQLSettings // Settings in JSON format for the source IBM Db2 LUW endpoint. For information // about other available settings, see Extra connection attributes when using Db2 // LUW as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.DB2.html#CHAP_Source.DB2.ConnectionAttrib) // in the Database Migration Service User Guide. IBMDb2Settings *types.IBMDb2Settings // Settings in JSON format for the target Apache Kafka endpoint. For more // information about the available settings, see Using object mapping to migrate // data to a Kafka topic // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafka.html#CHAP_Target.Kafka.ObjectMapping) // in the Database Migration Service User Guide. KafkaSettings *types.KafkaSettings // Settings in JSON format for the target endpoint for Amazon Kinesis Data Streams. // For more information about the available settings, see Using object mapping to // migrate data to a Kinesis data stream // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kinesis.html#CHAP_Target.Kinesis.ObjectMapping) // in the Database Migration Service User Guide. KinesisSettings *types.KinesisSettings // Settings in JSON format for the source and target Microsoft SQL Server endpoint. // For information about other available settings, see Extra connection attributes // when using SQL Server as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.SQLServer.html#CHAP_Source.SQLServer.ConnectionAttrib) // and Extra connection attributes when using SQL Server as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.SQLServer.html#CHAP_Target.SQLServer.ConnectionAttrib) // in the Database Migration Service User Guide. MicrosoftSQLServerSettings *types.MicrosoftSQLServerSettings // Settings in JSON format for the source MongoDB endpoint. For more information // about the available settings, see the configuration properties section in // Endpoint configuration settings when using MongoDB as a source for Database // Migration Service // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.MongoDB.html#CHAP_Source.MongoDB.Configuration) // in the Database Migration Service User Guide. MongoDbSettings *types.MongoDbSettings // Settings in JSON format for the source and target MySQL endpoint. For // information about other available settings, see Extra connection attributes when // using MySQL as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.MySQL.html#CHAP_Source.MySQL.ConnectionAttrib) // and Extra connection attributes when using a MySQL-compatible database as a // target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.MySQL.html#CHAP_Target.MySQL.ConnectionAttrib) // in the Database Migration Service User Guide. MySQLSettings *types.MySQLSettings // Settings in JSON format for the target Amazon Neptune endpoint. For more // information about the available settings, see Specifying graph-mapping rules // using Gremlin and R2RML for Amazon Neptune as a target // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Neptune.html#CHAP_Target.Neptune.EndpointSettings) // in the Database Migration Service User Guide. NeptuneSettings *types.NeptuneSettings // Settings in JSON format for the source and target Oracle endpoint. For // information about other available settings, see Extra connection attributes when // using Oracle as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.Oracle.html#CHAP_Source.Oracle.ConnectionAttrib) // and Extra connection attributes when using Oracle as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Oracle.html#CHAP_Target.Oracle.ConnectionAttrib) // in the Database Migration Service User Guide. OracleSettings *types.OracleSettings // The password to be used to login to the endpoint database. Password *string // The port used by the endpoint database. Port *int32 // Settings in JSON format for the source and target PostgreSQL endpoint. For // information about other available settings, see Extra connection attributes when // using PostgreSQL as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib) // and Extra connection attributes when using PostgreSQL as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.PostgreSQL.html#CHAP_Target.PostgreSQL.ConnectionAttrib) // in the Database Migration Service User Guide. PostgreSQLSettings *types.PostgreSQLSettings // Settings in JSON format for the Redis target endpoint. RedisSettings *types.RedisSettings // Provides information that defines an Amazon Redshift endpoint. RedshiftSettings *types.RedshiftSettings // Settings in JSON format for the target Amazon S3 endpoint. For more information // about the available settings, see Extra Connection Attributes When Using Amazon // S3 as a Target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.S3.html#CHAP_Target.S3.Configuring) // in the Database Migration Service User Guide. S3Settings *types.S3Settings // The name of the server where the endpoint database resides. ServerName *string // The Amazon Resource Name (ARN) for the IAM role you want to use to modify the // endpoint. The role must allow the iam:PassRole action. ServiceAccessRoleArn *string // The SSL mode used to connect to the endpoint. The default value is none. SslMode types.DmsSslModeValue // Settings in JSON format for the source and target SAP ASE endpoint. For // information about other available settings, see Extra connection attributes when // using SAP ASE as a source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.SAP.html#CHAP_Source.SAP.ConnectionAttrib) // and Extra connection attributes when using SAP ASE as a target for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.SAP.html#CHAP_Target.SAP.ConnectionAttrib) // in the Database Migration Service User Guide. SybaseSettings *types.SybaseSettings // The user name to be used to login to the endpoint database. Username *string // contains filtered or unexported fields }
type ModifyEndpointOutput ¶
type ModifyEndpointOutput struct { // The modified endpoint. Endpoint *types.Endpoint // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ModifyEventSubscriptionInput ¶
type ModifyEventSubscriptionInput struct { // The name of the DMS event notification subscription to be modified. // // This member is required. SubscriptionName *string // A Boolean value; set to true to activate the subscription. Enabled *bool // A list of event categories for a source type that you want to subscribe to. Use // the DescribeEventCategories action to see a list of event categories. EventCategories []string // The Amazon Resource Name (ARN) of the Amazon SNS topic created for event // notification. The ARN is created by Amazon SNS when you create a topic and // subscribe to it. SnsTopicArn *string // The type of DMS resource that generates the events you want to subscribe to. // Valid values: replication-instance | replication-task SourceType *string // contains filtered or unexported fields }
type ModifyEventSubscriptionOutput ¶
type ModifyEventSubscriptionOutput struct { // The modified event subscription. EventSubscription *types.EventSubscription // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ModifyReplicationInstanceInput ¶
type ModifyReplicationInstanceInput struct { // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // The amount of storage (in gigabytes) to be allocated for the replication // instance. AllocatedStorage *int32 // Indicates that major version upgrades are allowed. Changing this parameter does // not result in an outage, and the change is asynchronously applied as soon as // possible. This parameter must be set to true when specifying a value for the // EngineVersion parameter that is a different major version than the replication // instance's current version. AllowMajorVersionUpgrade bool // Indicates whether the changes should be applied immediately or during the next // maintenance window. ApplyImmediately bool // A value that indicates that minor version upgrades are applied automatically to // the replication instance during the maintenance window. Changing this parameter // doesn't result in an outage, except in the case described following. The change // is asynchronously applied as soon as possible. An outage does result if these // factors apply: // // * This parameter is set to true during the maintenance // window. // // * A newer minor version is available. // // * DMS has enabled automatic // patching for the given engine version. AutoMinorVersionUpgrade *bool // The engine version number of the replication instance. When modifying a major // engine version of an instance, also set AllowMajorVersionUpgrade to true. EngineVersion *string // Specifies whether the replication instance is a Multi-AZ deployment. You can't // set the AvailabilityZone parameter if the Multi-AZ parameter is set to true. MultiAZ *bool // The type of IP address protocol used by a replication instance, such as IPv4 // only or Dual-stack that supports both IPv4 and IPv6 addressing. IPv6 only is not // yet supported. NetworkType *string // The weekly time range (in UTC) during which system maintenance can occur, which // might result in an outage. Changing this parameter does not result in an outage, // except in the following situation, and the change is asynchronously applied as // soon as possible. If moving this window to the current time, there must be at // least 30 minutes between the current time and end of the window to ensure // pending changes are applied. Default: Uses existing setting Format: // ddd:hh24:mi-ddd:hh24:mi Valid Days: Mon | Tue | Wed | Thu | Fri | Sat | Sun // Constraints: Must be at least 30 minutes PreferredMaintenanceWindow *string // The compute and memory capacity of the replication instance as defined for the // specified replication instance class. For example to specify the instance class // dms.c4.large, set this parameter to "dms.c4.large". For more information on the // settings and capacities for the available replication instance classes, see // Selecting the right DMS replication instance for your migration // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.html#CHAP_ReplicationInstance.InDepth). ReplicationInstanceClass *string // The replication instance identifier. This parameter is stored as a lowercase // string. ReplicationInstanceIdentifier *string // Specifies the VPC security group to be used with the replication instance. The // VPC security group must work with the VPC containing the replication instance. VpcSecurityGroupIds []string // contains filtered or unexported fields }
type ModifyReplicationInstanceOutput ¶
type ModifyReplicationInstanceOutput struct { // The modified replication instance. ReplicationInstance *types.ReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ModifyReplicationSubnetGroupInput ¶
type ModifyReplicationSubnetGroupInput struct { // The name of the replication instance subnet group. // // This member is required. ReplicationSubnetGroupIdentifier *string // A list of subnet IDs. // // This member is required. SubnetIds []string // A description for the replication instance subnet group. ReplicationSubnetGroupDescription *string // contains filtered or unexported fields }
type ModifyReplicationSubnetGroupOutput ¶
type ModifyReplicationSubnetGroupOutput struct { // The modified replication subnet group. ReplicationSubnetGroup *types.ReplicationSubnetGroup // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ModifyReplicationTaskInput ¶
type ModifyReplicationTaskInput struct { // The Amazon Resource Name (ARN) of the replication task. // // This member is required. ReplicationTaskArn *string // Indicates when you want a change data capture (CDC) operation to start. Use // either CdcStartPosition or CdcStartTime to specify when you want a CDC operation // to start. Specifying both values results in an error. The value can be in date, // checkpoint, or LSN/SCN format. Date Example: --cdc-start-position // “2018-03-08T12:12:12” Checkpoint Example: --cdc-start-position // "checkpoint:V1#27#mysql-bin-changelog.157832:1975:-1:2002:677883278264080:mysql-bin-changelog.157832:1876#0#0#*#0#93" // LSN Example: --cdc-start-position “mysql-bin-changelog.000024:373” When you use // this task setting with a source PostgreSQL database, a logical replication slot // should already be created and associated with the source endpoint. You can // verify this by setting the slotName extra connection attribute to the name of // this logical replication slot. For more information, see Extra Connection // Attributes When Using PostgreSQL as a Source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib). CdcStartPosition *string // Indicates the start time for a change data capture (CDC) operation. Use either // CdcStartTime or CdcStartPosition to specify when you want a CDC operation to // start. Specifying both values results in an error. Timestamp Example: // --cdc-start-time “2018-03-08T12:12:12” CdcStartTime *time.Time // Indicates when you want a change data capture (CDC) operation to stop. The value // can be either server time or commit time. Server time example: // --cdc-stop-position “server_time:2018-02-09T12:12:12” Commit time example: // --cdc-stop-position “commit_time: 2018-02-09T12:12:12 “ CdcStopPosition *string // The migration type. Valid values: full-load | cdc | full-load-and-cdc MigrationType types.MigrationTypeValue // The replication task identifier. Constraints: // // * Must contain 1-255 alphanumeric // characters or hyphens. // // * First character must be a letter. // // * Cannot end with a // hyphen or contain two consecutive hyphens. ReplicationTaskIdentifier *string // JSON file that contains settings for the task, such as task metadata settings. ReplicationTaskSettings *string // When using the CLI or boto3, provide the path of the JSON file that contains the // table mappings. Precede the path with file://. For example, --table-mappings // file://mappingfile.json. When working with the DMS API, provide the JSON as the // parameter value. TableMappings *string // Supplemental information that the task requires to migrate the data for certain // source and target endpoints. For more information, see Specifying Supplemental // Data for Task Settings // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.TaskData.html) in // the Database Migration Service User Guide. TaskData *string // contains filtered or unexported fields }
type ModifyReplicationTaskOutput ¶
type ModifyReplicationTaskOutput struct { // The replication task that was modified. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type MoveReplicationTaskInput ¶ added in v0.30.0
type MoveReplicationTaskInput struct { // The Amazon Resource Name (ARN) of the task that you want to move. // // This member is required. ReplicationTaskArn *string // The ARN of the replication instance where you want to move the task to. // // This member is required. TargetReplicationInstanceArn *string // contains filtered or unexported fields }
type MoveReplicationTaskOutput ¶ added in v0.30.0
type MoveReplicationTaskOutput struct { // The replication task that was moved. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type Options ¶
type Options struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // Configures the events that will be sent to the configured logger. ClientLogMode aws.ClientLogMode // The credentials object to use when signing requests. Credentials aws.CredentialsProvider // The configuration DefaultsMode that the SDK should use when constructing the // clients initial default settings. DefaultsMode aws.DefaultsMode // The endpoint options to be used when attempting to resolve an endpoint. EndpointOptions EndpointResolverOptions // The service endpoint resolver. EndpointResolver EndpointResolver // Signature Version 4 (SigV4) Signer HTTPSignerV4 HTTPSignerV4 // The logger writer interface to write logging messages to. Logger logging.Logger // The region to send requests to. (Required) Region string // RetryMaxAttempts specifies the maximum number attempts an API client will call // an operation that fails with a retryable error. A value of 0 is ignored, and // will not be used to configure the API client created default retryer, or modify // per operation call's retry max attempts. When creating a new API Clients this // member will only be used if the Retryer Options member is nil. This value will // be ignored if Retryer is not nil. If specified in an operation call's functional // options with a value that is different than the constructed client's Options, // the Client's Retryer will be wrapped to use the operation's specific // RetryMaxAttempts value. RetryMaxAttempts int // RetryMode specifies the retry mode the API client will be created with, if // Retryer option is not also specified. When creating a new API Clients this // member will only be used if the Retryer Options member is nil. This value will // be ignored if Retryer is not nil. Currently does not support per operation call // overrides, may in the future. RetryMode aws.RetryMode // Retryer guides how HTTP requests should be retried in case of recoverable // failures. When nil the API client will use a default retryer. The kind of // default retry created by the API client can be changed with the RetryMode // option. Retryer aws.Retryer // The RuntimeEnvironment configuration, only populated if the DefaultsMode is set // to DefaultsModeAuto and is initialized using config.LoadDefaultConfig. You // should not populate this structure programmatically, or rely on the values here // within your applications. RuntimeEnvironment aws.RuntimeEnvironment // The HTTP client to invoke API calls with. Defaults to client's default HTTP // implementation if nil. HTTPClient HTTPClient // contains filtered or unexported fields }
type RebootReplicationInstanceInput ¶
type RebootReplicationInstanceInput struct { // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // If this parameter is true, the reboot is conducted through a Multi-AZ failover. // If the instance isn't configured for Multi-AZ, then you can't specify true. ( // --force-planned-failover and --force-failover can't both be set to true.) ForceFailover *bool // If this parameter is true, the reboot is conducted through a planned Multi-AZ // failover where resources are released and cleaned up prior to conducting the // failover. If the instance isn”t configured for Multi-AZ, then you can't specify // true. ( --force-planned-failover and --force-failover can't both be set to // true.) ForcePlannedFailover *bool // contains filtered or unexported fields }
type RebootReplicationInstanceOutput ¶
type RebootReplicationInstanceOutput struct { // The replication instance that is being rebooted. ReplicationInstance *types.ReplicationInstance // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type RefreshSchemasInput ¶
type RefreshSchemasInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // contains filtered or unexported fields }
type RefreshSchemasOutput ¶
type RefreshSchemasOutput struct { // The status of the refreshed schema. RefreshSchemasStatus *types.RefreshSchemasStatus // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ReloadTablesInput ¶
type ReloadTablesInput struct { // The Amazon Resource Name (ARN) of the replication task. // // This member is required. ReplicationTaskArn *string // The name and schema of the table to be reloaded. // // This member is required. TablesToReload []types.TableToReload // Options for reload. Specify data-reload to reload the data and re-validate it if // validation is enabled. Specify validate-only to re-validate the table. This // option applies only when validation is enabled for the task. Valid values: // data-reload, validate-only Default value is data-reload. ReloadOption types.ReloadOptionValue // contains filtered or unexported fields }
type ReloadTablesOutput ¶
type ReloadTablesOutput struct { // The Amazon Resource Name (ARN) of the replication task. ReplicationTaskArn *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type RemoveTagsFromResourceInput ¶
type RemoveTagsFromResourceInput struct { // An DMS resource from which you want to remove tag(s). The value for this // parameter is an Amazon Resource Name (ARN). // // This member is required. ResourceArn *string // The tag key (name) of the tag to be removed. // // This member is required. TagKeys []string // contains filtered or unexported fields }
Removes one or more tags from an DMS resource.
type RemoveTagsFromResourceOutput ¶
type RemoveTagsFromResourceOutput struct { // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type ReplicationInstanceAvailableWaiter ¶ added in v0.31.0
type ReplicationInstanceAvailableWaiter struct {
// contains filtered or unexported fields
}
ReplicationInstanceAvailableWaiter defines the waiters for ReplicationInstanceAvailable
func NewReplicationInstanceAvailableWaiter ¶ added in v0.31.0
func NewReplicationInstanceAvailableWaiter(client DescribeReplicationInstancesAPIClient, optFns ...func(*ReplicationInstanceAvailableWaiterOptions)) *ReplicationInstanceAvailableWaiter
NewReplicationInstanceAvailableWaiter constructs a ReplicationInstanceAvailableWaiter.
func (*ReplicationInstanceAvailableWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationInstanceAvailableWaiter) Wait(ctx context.Context, params *DescribeReplicationInstancesInput, maxWaitDur time.Duration, optFns ...func(*ReplicationInstanceAvailableWaiterOptions)) error
Wait calls the waiter function for ReplicationInstanceAvailable waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationInstanceAvailableWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationInstanceAvailableWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationInstancesInput, maxWaitDur time.Duration, optFns ...func(*ReplicationInstanceAvailableWaiterOptions)) (*DescribeReplicationInstancesOutput, error)
WaitForOutput calls the waiter function for ReplicationInstanceAvailable waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationInstanceAvailableWaiterOptions ¶ added in v0.31.0
type ReplicationInstanceAvailableWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationInstanceAvailableWaiter will use default minimum delay of 60 seconds. // Note that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationInstanceAvailableWaiter will use default max delay of 120 // seconds. Note that MaxDelay must resolve to value greater than or equal to the // MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationInstancesInput, *DescribeReplicationInstancesOutput, error) (bool, error) }
ReplicationInstanceAvailableWaiterOptions are waiter options for ReplicationInstanceAvailableWaiter
type ReplicationInstanceDeletedWaiter ¶ added in v0.31.0
type ReplicationInstanceDeletedWaiter struct {
// contains filtered or unexported fields
}
ReplicationInstanceDeletedWaiter defines the waiters for ReplicationInstanceDeleted
func NewReplicationInstanceDeletedWaiter ¶ added in v0.31.0
func NewReplicationInstanceDeletedWaiter(client DescribeReplicationInstancesAPIClient, optFns ...func(*ReplicationInstanceDeletedWaiterOptions)) *ReplicationInstanceDeletedWaiter
NewReplicationInstanceDeletedWaiter constructs a ReplicationInstanceDeletedWaiter.
func (*ReplicationInstanceDeletedWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationInstanceDeletedWaiter) Wait(ctx context.Context, params *DescribeReplicationInstancesInput, maxWaitDur time.Duration, optFns ...func(*ReplicationInstanceDeletedWaiterOptions)) error
Wait calls the waiter function for ReplicationInstanceDeleted waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationInstanceDeletedWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationInstanceDeletedWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationInstancesInput, maxWaitDur time.Duration, optFns ...func(*ReplicationInstanceDeletedWaiterOptions)) (*DescribeReplicationInstancesOutput, error)
WaitForOutput calls the waiter function for ReplicationInstanceDeleted waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationInstanceDeletedWaiterOptions ¶ added in v0.31.0
type ReplicationInstanceDeletedWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationInstanceDeletedWaiter will use default minimum delay of 15 seconds. // Note that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationInstanceDeletedWaiter will use default max delay of 120 // seconds. Note that MaxDelay must resolve to value greater than or equal to the // MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationInstancesInput, *DescribeReplicationInstancesOutput, error) (bool, error) }
ReplicationInstanceDeletedWaiterOptions are waiter options for ReplicationInstanceDeletedWaiter
type ReplicationTaskDeletedWaiter ¶ added in v0.31.0
type ReplicationTaskDeletedWaiter struct {
// contains filtered or unexported fields
}
ReplicationTaskDeletedWaiter defines the waiters for ReplicationTaskDeleted
func NewReplicationTaskDeletedWaiter ¶ added in v0.31.0
func NewReplicationTaskDeletedWaiter(client DescribeReplicationTasksAPIClient, optFns ...func(*ReplicationTaskDeletedWaiterOptions)) *ReplicationTaskDeletedWaiter
NewReplicationTaskDeletedWaiter constructs a ReplicationTaskDeletedWaiter.
func (*ReplicationTaskDeletedWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationTaskDeletedWaiter) Wait(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskDeletedWaiterOptions)) error
Wait calls the waiter function for ReplicationTaskDeleted waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationTaskDeletedWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationTaskDeletedWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskDeletedWaiterOptions)) (*DescribeReplicationTasksOutput, error)
WaitForOutput calls the waiter function for ReplicationTaskDeleted waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationTaskDeletedWaiterOptions ¶ added in v0.31.0
type ReplicationTaskDeletedWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationTaskDeletedWaiter will use default minimum delay of 15 seconds. Note // that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationTaskDeletedWaiter will use default max delay of 120 seconds. // Note that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationTasksInput, *DescribeReplicationTasksOutput, error) (bool, error) }
ReplicationTaskDeletedWaiterOptions are waiter options for ReplicationTaskDeletedWaiter
type ReplicationTaskReadyWaiter ¶ added in v0.31.0
type ReplicationTaskReadyWaiter struct {
// contains filtered or unexported fields
}
ReplicationTaskReadyWaiter defines the waiters for ReplicationTaskReady
func NewReplicationTaskReadyWaiter ¶ added in v0.31.0
func NewReplicationTaskReadyWaiter(client DescribeReplicationTasksAPIClient, optFns ...func(*ReplicationTaskReadyWaiterOptions)) *ReplicationTaskReadyWaiter
NewReplicationTaskReadyWaiter constructs a ReplicationTaskReadyWaiter.
func (*ReplicationTaskReadyWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationTaskReadyWaiter) Wait(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskReadyWaiterOptions)) error
Wait calls the waiter function for ReplicationTaskReady waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationTaskReadyWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationTaskReadyWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskReadyWaiterOptions)) (*DescribeReplicationTasksOutput, error)
WaitForOutput calls the waiter function for ReplicationTaskReady waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationTaskReadyWaiterOptions ¶ added in v0.31.0
type ReplicationTaskReadyWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationTaskReadyWaiter will use default minimum delay of 15 seconds. Note // that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationTaskReadyWaiter will use default max delay of 120 seconds. // Note that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationTasksInput, *DescribeReplicationTasksOutput, error) (bool, error) }
ReplicationTaskReadyWaiterOptions are waiter options for ReplicationTaskReadyWaiter
type ReplicationTaskRunningWaiter ¶ added in v0.31.0
type ReplicationTaskRunningWaiter struct {
// contains filtered or unexported fields
}
ReplicationTaskRunningWaiter defines the waiters for ReplicationTaskRunning
func NewReplicationTaskRunningWaiter ¶ added in v0.31.0
func NewReplicationTaskRunningWaiter(client DescribeReplicationTasksAPIClient, optFns ...func(*ReplicationTaskRunningWaiterOptions)) *ReplicationTaskRunningWaiter
NewReplicationTaskRunningWaiter constructs a ReplicationTaskRunningWaiter.
func (*ReplicationTaskRunningWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationTaskRunningWaiter) Wait(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskRunningWaiterOptions)) error
Wait calls the waiter function for ReplicationTaskRunning waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationTaskRunningWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationTaskRunningWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskRunningWaiterOptions)) (*DescribeReplicationTasksOutput, error)
WaitForOutput calls the waiter function for ReplicationTaskRunning waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationTaskRunningWaiterOptions ¶ added in v0.31.0
type ReplicationTaskRunningWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationTaskRunningWaiter will use default minimum delay of 15 seconds. Note // that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationTaskRunningWaiter will use default max delay of 120 seconds. // Note that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationTasksInput, *DescribeReplicationTasksOutput, error) (bool, error) }
ReplicationTaskRunningWaiterOptions are waiter options for ReplicationTaskRunningWaiter
type ReplicationTaskStoppedWaiter ¶ added in v0.31.0
type ReplicationTaskStoppedWaiter struct {
// contains filtered or unexported fields
}
ReplicationTaskStoppedWaiter defines the waiters for ReplicationTaskStopped
func NewReplicationTaskStoppedWaiter ¶ added in v0.31.0
func NewReplicationTaskStoppedWaiter(client DescribeReplicationTasksAPIClient, optFns ...func(*ReplicationTaskStoppedWaiterOptions)) *ReplicationTaskStoppedWaiter
NewReplicationTaskStoppedWaiter constructs a ReplicationTaskStoppedWaiter.
func (*ReplicationTaskStoppedWaiter) Wait ¶ added in v0.31.0
func (w *ReplicationTaskStoppedWaiter) Wait(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskStoppedWaiterOptions)) error
Wait calls the waiter function for ReplicationTaskStopped waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*ReplicationTaskStoppedWaiter) WaitForOutput ¶ added in v1.11.0
func (w *ReplicationTaskStoppedWaiter) WaitForOutput(ctx context.Context, params *DescribeReplicationTasksInput, maxWaitDur time.Duration, optFns ...func(*ReplicationTaskStoppedWaiterOptions)) (*DescribeReplicationTasksOutput, error)
WaitForOutput calls the waiter function for ReplicationTaskStopped waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type ReplicationTaskStoppedWaiterOptions ¶ added in v0.31.0
type ReplicationTaskStoppedWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // ReplicationTaskStoppedWaiter will use default minimum delay of 15 seconds. Note // that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, ReplicationTaskStoppedWaiter will use default max delay of 120 seconds. // Note that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeReplicationTasksInput, *DescribeReplicationTasksOutput, error) (bool, error) }
ReplicationTaskStoppedWaiterOptions are waiter options for ReplicationTaskStoppedWaiter
type ResolveEndpoint ¶
type ResolveEndpoint struct { Resolver EndpointResolver Options EndpointResolverOptions }
func (*ResolveEndpoint) HandleSerialize ¶
func (m *ResolveEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, )
func (*ResolveEndpoint) ID ¶
func (*ResolveEndpoint) ID() string
type RunFleetAdvisorLsaAnalysisInput ¶ added in v1.19.0
type RunFleetAdvisorLsaAnalysisInput struct {
// contains filtered or unexported fields
}
type RunFleetAdvisorLsaAnalysisOutput ¶ added in v1.19.0
type RunFleetAdvisorLsaAnalysisOutput struct { // The ID of the LSA analysis run. LsaAnalysisId *string // The status of the LSA analysis, for example COMPLETED. Status *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type StartReplicationTaskAssessmentInput ¶
type StartReplicationTaskAssessmentInput struct { // The Amazon Resource Name (ARN) of the replication task. // // This member is required. ReplicationTaskArn *string // contains filtered or unexported fields }
type StartReplicationTaskAssessmentOutput ¶
type StartReplicationTaskAssessmentOutput struct { // The assessed replication task. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type StartReplicationTaskAssessmentRunInput ¶
type StartReplicationTaskAssessmentRunInput struct { // Unique name to identify the assessment run. // // This member is required. AssessmentRunName *string // Amazon Resource Name (ARN) of the migration task associated with the // premigration assessment run that you want to start. // // This member is required. ReplicationTaskArn *string // Amazon S3 bucket where you want DMS to store the results of this assessment run. // // This member is required. ResultLocationBucket *string // ARN of the service role needed to start the assessment run. The role must allow // the iam:PassRole action. // // This member is required. ServiceAccessRoleArn *string // Space-separated list of names for specific individual assessments that you want // to exclude. These names come from the default list of individual assessments // that DMS supports for the associated migration task. This task is specified by // ReplicationTaskArn. You can't set a value for Exclude if you also set a value // for IncludeOnly in the API operation. To identify the names of the default // individual assessments that DMS supports for the associated migration task, run // the DescribeApplicableIndividualAssessments operation using its own // ReplicationTaskArn request parameter. Exclude []string // Space-separated list of names for specific individual assessments that you want // to include. These names come from the default list of individual assessments // that DMS supports for the associated migration task. This task is specified by // ReplicationTaskArn. You can't set a value for IncludeOnly if you also set a // value for Exclude in the API operation. To identify the names of the default // individual assessments that DMS supports for the associated migration task, run // the DescribeApplicableIndividualAssessments operation using its own // ReplicationTaskArn request parameter. IncludeOnly []string // Encryption mode that you can specify to encrypt the results of this assessment // run. If you don't specify this request parameter, DMS stores the assessment run // results without encryption. You can specify one of the options following: // // * // "SSE_S3" – The server-side encryption provided as a default by Amazon S3. // // * // "SSE_KMS" – Key Management Service (KMS) encryption. This encryption can use // either a custom KMS encryption key that you specify or the default KMS // encryption key that DMS provides. ResultEncryptionMode *string // ARN of a custom KMS encryption key that you specify when you set // ResultEncryptionMode to "SSE_KMS". ResultKmsKeyArn *string // Folder within an Amazon S3 bucket where you want DMS to store the results of // this assessment run. ResultLocationFolder *string // contains filtered or unexported fields }
type StartReplicationTaskAssessmentRunOutput ¶
type StartReplicationTaskAssessmentRunOutput struct { // The premigration assessment run that was started. ReplicationTaskAssessmentRun *types.ReplicationTaskAssessmentRun // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type StartReplicationTaskInput ¶
type StartReplicationTaskInput struct { // The Amazon Resource Name (ARN) of the replication task to be started. // // This member is required. ReplicationTaskArn *string // The type of replication task to start. When the migration type is full-load or // full-load-and-cdc, the only valid value for the first run of the task is // start-replication. You use reload-target to restart the task and // resume-processing to resume the task. When the migration type is cdc, you use // start-replication to start or restart the task, and resume-processing to resume // the task. reload-target is not a valid value for a task with migration type of // cdc. // // This member is required. StartReplicationTaskType types.StartReplicationTaskTypeValue // Indicates when you want a change data capture (CDC) operation to start. Use // either CdcStartPosition or CdcStartTime to specify when you want a CDC operation // to start. Specifying both values results in an error. The value can be in date, // checkpoint, or LSN/SCN format. Date Example: --cdc-start-position // “2018-03-08T12:12:12” Checkpoint Example: --cdc-start-position // "checkpoint:V1#27#mysql-bin-changelog.157832:1975:-1:2002:677883278264080:mysql-bin-changelog.157832:1876#0#0#*#0#93" // LSN Example: --cdc-start-position “mysql-bin-changelog.000024:373” When you use // this task setting with a source PostgreSQL database, a logical replication slot // should already be created and associated with the source endpoint. You can // verify this by setting the slotName extra connection attribute to the name of // this logical replication slot. For more information, see Extra Connection // Attributes When Using PostgreSQL as a Source for DMS // (https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib). CdcStartPosition *string // Indicates the start time for a change data capture (CDC) operation. Use either // CdcStartTime or CdcStartPosition to specify when you want a CDC operation to // start. Specifying both values results in an error. Timestamp Example: // --cdc-start-time “2018-03-08T12:12:12” CdcStartTime *time.Time // Indicates when you want a change data capture (CDC) operation to stop. The value // can be either server time or commit time. Server time example: // --cdc-stop-position “server_time:2018-02-09T12:12:12” Commit time example: // --cdc-stop-position “commit_time: 2018-02-09T12:12:12 “ CdcStopPosition *string // contains filtered or unexported fields }
type StartReplicationTaskOutput ¶
type StartReplicationTaskOutput struct { // The replication task started. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type StopReplicationTaskInput ¶
type StopReplicationTaskInput struct { // The Amazon Resource Name(ARN) of the replication task to be stopped. // // This member is required. ReplicationTaskArn *string // contains filtered or unexported fields }
type StopReplicationTaskOutput ¶
type StopReplicationTaskOutput struct { // The replication task stopped. ReplicationTask *types.ReplicationTask // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type TestConnectionInput ¶
type TestConnectionInput struct { // The Amazon Resource Name (ARN) string that uniquely identifies the endpoint. // // This member is required. EndpointArn *string // The Amazon Resource Name (ARN) of the replication instance. // // This member is required. ReplicationInstanceArn *string // contains filtered or unexported fields }
type TestConnectionOutput ¶
type TestConnectionOutput struct { // The connection tested. Connection *types.Connection // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
type TestConnectionSucceedsWaiter ¶ added in v0.31.0
type TestConnectionSucceedsWaiter struct {
// contains filtered or unexported fields
}
TestConnectionSucceedsWaiter defines the waiters for TestConnectionSucceeds
func NewTestConnectionSucceedsWaiter ¶ added in v0.31.0
func NewTestConnectionSucceedsWaiter(client DescribeConnectionsAPIClient, optFns ...func(*TestConnectionSucceedsWaiterOptions)) *TestConnectionSucceedsWaiter
NewTestConnectionSucceedsWaiter constructs a TestConnectionSucceedsWaiter.
func (*TestConnectionSucceedsWaiter) Wait ¶ added in v0.31.0
func (w *TestConnectionSucceedsWaiter) Wait(ctx context.Context, params *DescribeConnectionsInput, maxWaitDur time.Duration, optFns ...func(*TestConnectionSucceedsWaiterOptions)) error
Wait calls the waiter function for TestConnectionSucceeds waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*TestConnectionSucceedsWaiter) WaitForOutput ¶ added in v1.11.0
func (w *TestConnectionSucceedsWaiter) WaitForOutput(ctx context.Context, params *DescribeConnectionsInput, maxWaitDur time.Duration, optFns ...func(*TestConnectionSucceedsWaiterOptions)) (*DescribeConnectionsOutput, error)
WaitForOutput calls the waiter function for TestConnectionSucceeds waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type TestConnectionSucceedsWaiterOptions ¶ added in v0.31.0
type TestConnectionSucceedsWaiterOptions struct { // Set of options to modify how an operation is invoked. These apply to all // operations invoked for this client. Use functional options on operation call to // modify this list for per operation behavior. APIOptions []func(*middleware.Stack) error // MinDelay is the minimum amount of time to delay between retries. If unset, // TestConnectionSucceedsWaiter will use default minimum delay of 5 seconds. Note // that MinDelay must resolve to a value lesser than or equal to the MaxDelay. MinDelay time.Duration // MaxDelay is the maximum amount of time to delay between retries. If unset or set // to zero, TestConnectionSucceedsWaiter will use default max delay of 120 seconds. // Note that MaxDelay must resolve to value greater than or equal to the MinDelay. MaxDelay time.Duration // LogWaitAttempts is used to enable logging for waiter retry attempts LogWaitAttempts bool // Retryable is function that can be used to override the service defined // waiter-behavior based on operation output, or returned error. This function is // used by the waiter to decide if a state is retryable or a terminal state. By // default service-modeled logic will populate this option. This option can thus be // used to define a custom waiter state with fall-back to service-modeled waiter // state mutators.The function returns an error in case of a failure state. In case // of retry state, this function returns a bool value of true and nil error, while // in case of success it returns a bool value of false and nil error. Retryable func(context.Context, *DescribeConnectionsInput, *DescribeConnectionsOutput, error) (bool, error) }
TestConnectionSucceedsWaiterOptions are waiter options for TestConnectionSucceedsWaiter
type UpdateSubscriptionsToEventBridgeInput ¶ added in v1.21.0
type UpdateSubscriptionsToEventBridgeInput struct { // When set to true, this operation migrates DMS subscriptions for Amazon SNS // notifications no matter what your replication instance version is. If not set or // set to false, this operation runs only when all your replication instances are // from DMS version 3.4.6 or higher. ForceMove *bool // contains filtered or unexported fields }
type UpdateSubscriptionsToEventBridgeOutput ¶ added in v1.21.0
type UpdateSubscriptionsToEventBridgeOutput struct { // A string that indicates how many event subscriptions were migrated and how many // remain to be migrated. Result *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata // contains filtered or unexported fields }
Source Files
¶
- api_client.go
- api_op_AddTagsToResource.go
- api_op_ApplyPendingMaintenanceAction.go
- api_op_CancelReplicationTaskAssessmentRun.go
- api_op_CreateEndpoint.go
- api_op_CreateEventSubscription.go
- api_op_CreateFleetAdvisorCollector.go
- api_op_CreateReplicationInstance.go
- api_op_CreateReplicationSubnetGroup.go
- api_op_CreateReplicationTask.go
- api_op_DeleteCertificate.go
- api_op_DeleteConnection.go
- api_op_DeleteEndpoint.go
- api_op_DeleteEventSubscription.go
- api_op_DeleteFleetAdvisorCollector.go
- api_op_DeleteFleetAdvisorDatabases.go
- api_op_DeleteReplicationInstance.go
- api_op_DeleteReplicationSubnetGroup.go
- api_op_DeleteReplicationTask.go
- api_op_DeleteReplicationTaskAssessmentRun.go
- api_op_DescribeAccountAttributes.go
- api_op_DescribeApplicableIndividualAssessments.go
- api_op_DescribeCertificates.go
- api_op_DescribeConnections.go
- api_op_DescribeEndpointSettings.go
- api_op_DescribeEndpointTypes.go
- api_op_DescribeEndpoints.go
- api_op_DescribeEventCategories.go
- api_op_DescribeEventSubscriptions.go
- api_op_DescribeEvents.go
- api_op_DescribeFleetAdvisorCollectors.go
- api_op_DescribeFleetAdvisorDatabases.go
- api_op_DescribeFleetAdvisorLsaAnalysis.go
- api_op_DescribeFleetAdvisorSchemaObjectSummary.go
- api_op_DescribeFleetAdvisorSchemas.go
- api_op_DescribeOrderableReplicationInstances.go
- api_op_DescribePendingMaintenanceActions.go
- api_op_DescribeRefreshSchemasStatus.go
- api_op_DescribeReplicationInstanceTaskLogs.go
- api_op_DescribeReplicationInstances.go
- api_op_DescribeReplicationSubnetGroups.go
- api_op_DescribeReplicationTaskAssessmentResults.go
- api_op_DescribeReplicationTaskAssessmentRuns.go
- api_op_DescribeReplicationTaskIndividualAssessments.go
- api_op_DescribeReplicationTasks.go
- api_op_DescribeSchemas.go
- api_op_DescribeTableStatistics.go
- api_op_ImportCertificate.go
- api_op_ListTagsForResource.go
- api_op_ModifyEndpoint.go
- api_op_ModifyEventSubscription.go
- api_op_ModifyReplicationInstance.go
- api_op_ModifyReplicationSubnetGroup.go
- api_op_ModifyReplicationTask.go
- api_op_MoveReplicationTask.go
- api_op_RebootReplicationInstance.go
- api_op_RefreshSchemas.go
- api_op_ReloadTables.go
- api_op_RemoveTagsFromResource.go
- api_op_RunFleetAdvisorLsaAnalysis.go
- api_op_StartReplicationTask.go
- api_op_StartReplicationTaskAssessment.go
- api_op_StartReplicationTaskAssessmentRun.go
- api_op_StopReplicationTask.go
- api_op_TestConnection.go
- api_op_UpdateSubscriptionsToEventBridge.go
- deserializers.go
- doc.go
- endpoints.go
- go_module_metadata.go
- serializers.go
- validators.go