@Generated(value="software.amazon.awssdk:codegen") public interface DatabaseMigrationAsyncClient extends SdkClient
builder()
method.
AWS Database Migration Service (AWS 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 AWS DMS, see the AWS DMS user guide at What Is AWS Database Migration Service?
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<AddTagsToResourceResponse> |
addTagsToResource(AddTagsToResourceRequest addTagsToResourceRequest)
Adds metadata tags to a DMS resource, including replication instance, endpoint, security group, and migration
task.
|
default CompletableFuture<AddTagsToResourceResponse> |
addTagsToResource(Consumer<AddTagsToResourceRequest.Builder> addTagsToResourceRequest)
Adds metadata tags to a DMS resource, including replication instance, endpoint, security group, and migration
task.
|
static DatabaseMigrationAsyncClientBuilder |
builder()
Create a builder that can be used to configure and create a
DatabaseMigrationAsyncClient . |
static DatabaseMigrationAsyncClient |
create()
Create a
DatabaseMigrationAsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider . |
default CompletableFuture<CreateEndpointResponse> |
createEndpoint(Consumer<CreateEndpointRequest.Builder> createEndpointRequest)
Creates an endpoint using the provided settings.
|
default CompletableFuture<CreateEndpointResponse> |
createEndpoint(CreateEndpointRequest createEndpointRequest)
Creates an endpoint using the provided settings.
|
default CompletableFuture<CreateEventSubscriptionResponse> |
createEventSubscription(Consumer<CreateEventSubscriptionRequest.Builder> createEventSubscriptionRequest)
Creates an AWS DMS event notification subscription.
|
default CompletableFuture<CreateEventSubscriptionResponse> |
createEventSubscription(CreateEventSubscriptionRequest createEventSubscriptionRequest)
Creates an AWS DMS event notification subscription.
|
default CompletableFuture<CreateReplicationInstanceResponse> |
createReplicationInstance(Consumer<CreateReplicationInstanceRequest.Builder> createReplicationInstanceRequest)
Creates the replication instance using the specified parameters.
|
default CompletableFuture<CreateReplicationInstanceResponse> |
createReplicationInstance(CreateReplicationInstanceRequest createReplicationInstanceRequest)
Creates the replication instance using the specified parameters.
|
default CompletableFuture<CreateReplicationSubnetGroupResponse> |
createReplicationSubnetGroup(Consumer<CreateReplicationSubnetGroupRequest.Builder> createReplicationSubnetGroupRequest)
Creates a replication subnet group given a list of the subnet IDs in a VPC.
|
default CompletableFuture<CreateReplicationSubnetGroupResponse> |
createReplicationSubnetGroup(CreateReplicationSubnetGroupRequest createReplicationSubnetGroupRequest)
Creates a replication subnet group given a list of the subnet IDs in a VPC.
|
default CompletableFuture<CreateReplicationTaskResponse> |
createReplicationTask(Consumer<CreateReplicationTaskRequest.Builder> createReplicationTaskRequest)
Creates a replication task using the specified parameters.
|
default CompletableFuture<CreateReplicationTaskResponse> |
createReplicationTask(CreateReplicationTaskRequest createReplicationTaskRequest)
Creates a replication task using the specified parameters.
|
default CompletableFuture<DeleteCertificateResponse> |
deleteCertificate(Consumer<DeleteCertificateRequest.Builder> deleteCertificateRequest)
Deletes the specified certificate.
|
default CompletableFuture<DeleteCertificateResponse> |
deleteCertificate(DeleteCertificateRequest deleteCertificateRequest)
Deletes the specified certificate.
|
default CompletableFuture<DeleteEndpointResponse> |
deleteEndpoint(Consumer<DeleteEndpointRequest.Builder> deleteEndpointRequest)
Deletes the specified endpoint.
|
default CompletableFuture<DeleteEndpointResponse> |
deleteEndpoint(DeleteEndpointRequest deleteEndpointRequest)
Deletes the specified endpoint.
|
default CompletableFuture<DeleteEventSubscriptionResponse> |
deleteEventSubscription(Consumer<DeleteEventSubscriptionRequest.Builder> deleteEventSubscriptionRequest)
Deletes an AWS DMS event subscription.
|
default CompletableFuture<DeleteEventSubscriptionResponse> |
deleteEventSubscription(DeleteEventSubscriptionRequest deleteEventSubscriptionRequest)
Deletes an AWS DMS event subscription.
|
default CompletableFuture<DeleteReplicationInstanceResponse> |
deleteReplicationInstance(Consumer<DeleteReplicationInstanceRequest.Builder> deleteReplicationInstanceRequest)
Deletes the specified replication instance.
|
default CompletableFuture<DeleteReplicationInstanceResponse> |
deleteReplicationInstance(DeleteReplicationInstanceRequest deleteReplicationInstanceRequest)
Deletes the specified replication instance.
|
default CompletableFuture<DeleteReplicationSubnetGroupResponse> |
deleteReplicationSubnetGroup(Consumer<DeleteReplicationSubnetGroupRequest.Builder> deleteReplicationSubnetGroupRequest)
Deletes a subnet group.
|
default CompletableFuture<DeleteReplicationSubnetGroupResponse> |
deleteReplicationSubnetGroup(DeleteReplicationSubnetGroupRequest deleteReplicationSubnetGroupRequest)
Deletes a subnet group.
|
default CompletableFuture<DeleteReplicationTaskResponse> |
deleteReplicationTask(Consumer<DeleteReplicationTaskRequest.Builder> deleteReplicationTaskRequest)
Deletes the specified replication task.
|
default CompletableFuture<DeleteReplicationTaskResponse> |
deleteReplicationTask(DeleteReplicationTaskRequest deleteReplicationTaskRequest)
Deletes the specified replication task.
|
default CompletableFuture<DescribeAccountAttributesResponse> |
describeAccountAttributes()
Lists all of the AWS DMS attributes for a customer account.
|
default CompletableFuture<DescribeAccountAttributesResponse> |
describeAccountAttributes(Consumer<DescribeAccountAttributesRequest.Builder> describeAccountAttributesRequest)
Lists all of the AWS DMS attributes for a customer account.
|
default CompletableFuture<DescribeAccountAttributesResponse> |
describeAccountAttributes(DescribeAccountAttributesRequest describeAccountAttributesRequest)
Lists all of the AWS DMS attributes for a customer account.
|
default CompletableFuture<DescribeCertificatesResponse> |
describeCertificates()
Provides a description of the certificate.
|
default CompletableFuture<DescribeCertificatesResponse> |
describeCertificates(Consumer<DescribeCertificatesRequest.Builder> describeCertificatesRequest)
Provides a description of the certificate.
|
default CompletableFuture<DescribeCertificatesResponse> |
describeCertificates(DescribeCertificatesRequest describeCertificatesRequest)
Provides a description of the certificate.
|
default DescribeCertificatesPublisher |
describeCertificatesPaginator()
Provides a description of the certificate.
|
default DescribeCertificatesPublisher |
describeCertificatesPaginator(Consumer<DescribeCertificatesRequest.Builder> describeCertificatesRequest)
Provides a description of the certificate.
|
default DescribeCertificatesPublisher |
describeCertificatesPaginator(DescribeCertificatesRequest describeCertificatesRequest)
Provides a description of the certificate.
|
default CompletableFuture<DescribeConnectionsResponse> |
describeConnections()
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default CompletableFuture<DescribeConnectionsResponse> |
describeConnections(Consumer<DescribeConnectionsRequest.Builder> describeConnectionsRequest)
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default CompletableFuture<DescribeConnectionsResponse> |
describeConnections(DescribeConnectionsRequest describeConnectionsRequest)
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default DescribeConnectionsPublisher |
describeConnectionsPaginator()
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default DescribeConnectionsPublisher |
describeConnectionsPaginator(Consumer<DescribeConnectionsRequest.Builder> describeConnectionsRequest)
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default DescribeConnectionsPublisher |
describeConnectionsPaginator(DescribeConnectionsRequest describeConnectionsRequest)
Describes the status of the connections that have been made between the replication instance and an endpoint.
|
default CompletableFuture<DescribeEndpointsResponse> |
describeEndpoints()
Returns information about the endpoints for your account in the current region.
|
default CompletableFuture<DescribeEndpointsResponse> |
describeEndpoints(Consumer<DescribeEndpointsRequest.Builder> describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
|
default CompletableFuture<DescribeEndpointsResponse> |
describeEndpoints(DescribeEndpointsRequest describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
|
default DescribeEndpointsPublisher |
describeEndpointsPaginator()
Returns information about the endpoints for your account in the current region.
|
default DescribeEndpointsPublisher |
describeEndpointsPaginator(Consumer<DescribeEndpointsRequest.Builder> describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
|
default DescribeEndpointsPublisher |
describeEndpointsPaginator(DescribeEndpointsRequest describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
|
default CompletableFuture<DescribeEndpointTypesResponse> |
describeEndpointTypes()
Returns information about the type of endpoints available.
|
default CompletableFuture<DescribeEndpointTypesResponse> |
describeEndpointTypes(Consumer<DescribeEndpointTypesRequest.Builder> describeEndpointTypesRequest)
Returns information about the type of endpoints available.
|
default CompletableFuture<DescribeEndpointTypesResponse> |
describeEndpointTypes(DescribeEndpointTypesRequest describeEndpointTypesRequest)
Returns information about the type of endpoints available.
|
default DescribeEndpointTypesPublisher |
describeEndpointTypesPaginator()
Returns information about the type of endpoints available.
|
default DescribeEndpointTypesPublisher |
describeEndpointTypesPaginator(Consumer<DescribeEndpointTypesRequest.Builder> describeEndpointTypesRequest)
Returns information about the type of endpoints available.
|
default DescribeEndpointTypesPublisher |
describeEndpointTypesPaginator(DescribeEndpointTypesRequest describeEndpointTypesRequest)
Returns information about the type of endpoints available.
|
default CompletableFuture<DescribeEventCategoriesResponse> |
describeEventCategories()
Lists categories for all event source types, or, if specified, for a specified source type.
|
default CompletableFuture<DescribeEventCategoriesResponse> |
describeEventCategories(Consumer<DescribeEventCategoriesRequest.Builder> describeEventCategoriesRequest)
Lists categories for all event source types, or, if specified, for a specified source type.
|
default CompletableFuture<DescribeEventCategoriesResponse> |
describeEventCategories(DescribeEventCategoriesRequest describeEventCategoriesRequest)
Lists categories for all event source types, or, if specified, for a specified source type.
|
default CompletableFuture<DescribeEventsResponse> |
describeEvents()
Lists events for a given source identifier and source type.
|
default CompletableFuture<DescribeEventsResponse> |
describeEvents(Consumer<DescribeEventsRequest.Builder> describeEventsRequest)
Lists events for a given source identifier and source type.
|
default CompletableFuture<DescribeEventsResponse> |
describeEvents(DescribeEventsRequest describeEventsRequest)
Lists events for a given source identifier and source type.
|
default DescribeEventsPublisher |
describeEventsPaginator()
Lists events for a given source identifier and source type.
|
default DescribeEventsPublisher |
describeEventsPaginator(Consumer<DescribeEventsRequest.Builder> describeEventsRequest)
Lists events for a given source identifier and source type.
|
default DescribeEventsPublisher |
describeEventsPaginator(DescribeEventsRequest describeEventsRequest)
Lists events for a given source identifier and source type.
|
default CompletableFuture<DescribeEventSubscriptionsResponse> |
describeEventSubscriptions()
Lists all the event subscriptions for a customer account.
|
default CompletableFuture<DescribeEventSubscriptionsResponse> |
describeEventSubscriptions(Consumer<DescribeEventSubscriptionsRequest.Builder> describeEventSubscriptionsRequest)
Lists all the event subscriptions for a customer account.
|
default CompletableFuture<DescribeEventSubscriptionsResponse> |
describeEventSubscriptions(DescribeEventSubscriptionsRequest describeEventSubscriptionsRequest)
Lists all the event subscriptions for a customer account.
|
default DescribeEventSubscriptionsPublisher |
describeEventSubscriptionsPaginator()
Lists all the event subscriptions for a customer account.
|
default DescribeEventSubscriptionsPublisher |
describeEventSubscriptionsPaginator(Consumer<DescribeEventSubscriptionsRequest.Builder> describeEventSubscriptionsRequest)
Lists all the event subscriptions for a customer account.
|
default DescribeEventSubscriptionsPublisher |
describeEventSubscriptionsPaginator(DescribeEventSubscriptionsRequest describeEventSubscriptionsRequest)
Lists all the event subscriptions for a customer account.
|
default CompletableFuture<DescribeOrderableReplicationInstancesResponse> |
describeOrderableReplicationInstances()
Returns information about the replication instance types that can be created in the specified region.
|
default CompletableFuture<DescribeOrderableReplicationInstancesResponse> |
describeOrderableReplicationInstances(Consumer<DescribeOrderableReplicationInstancesRequest.Builder> describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
|
default CompletableFuture<DescribeOrderableReplicationInstancesResponse> |
describeOrderableReplicationInstances(DescribeOrderableReplicationInstancesRequest describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
|
default DescribeOrderableReplicationInstancesPublisher |
describeOrderableReplicationInstancesPaginator()
Returns information about the replication instance types that can be created in the specified region.
|
default DescribeOrderableReplicationInstancesPublisher |
describeOrderableReplicationInstancesPaginator(Consumer<DescribeOrderableReplicationInstancesRequest.Builder> describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
|
default DescribeOrderableReplicationInstancesPublisher |
describeOrderableReplicationInstancesPaginator(DescribeOrderableReplicationInstancesRequest describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
|
default CompletableFuture<DescribeRefreshSchemasStatusResponse> |
describeRefreshSchemasStatus(Consumer<DescribeRefreshSchemasStatusRequest.Builder> describeRefreshSchemasStatusRequest)
Returns the status of the RefreshSchemas operation.
|
default CompletableFuture<DescribeRefreshSchemasStatusResponse> |
describeRefreshSchemasStatus(DescribeRefreshSchemasStatusRequest describeRefreshSchemasStatusRequest)
Returns the status of the RefreshSchemas operation.
|
default CompletableFuture<DescribeReplicationInstancesResponse> |
describeReplicationInstances()
Returns information about replication instances for your account in the current region.
|
default CompletableFuture<DescribeReplicationInstancesResponse> |
describeReplicationInstances(Consumer<DescribeReplicationInstancesRequest.Builder> describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
|
default CompletableFuture<DescribeReplicationInstancesResponse> |
describeReplicationInstances(DescribeReplicationInstancesRequest describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
|
default DescribeReplicationInstancesPublisher |
describeReplicationInstancesPaginator()
Returns information about replication instances for your account in the current region.
|
default DescribeReplicationInstancesPublisher |
describeReplicationInstancesPaginator(Consumer<DescribeReplicationInstancesRequest.Builder> describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
|
default DescribeReplicationInstancesPublisher |
describeReplicationInstancesPaginator(DescribeReplicationInstancesRequest describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
|
default CompletableFuture<DescribeReplicationSubnetGroupsResponse> |
describeReplicationSubnetGroups()
Returns information about the replication subnet groups.
|
default CompletableFuture<DescribeReplicationSubnetGroupsResponse> |
describeReplicationSubnetGroups(Consumer<DescribeReplicationSubnetGroupsRequest.Builder> describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
|
default CompletableFuture<DescribeReplicationSubnetGroupsResponse> |
describeReplicationSubnetGroups(DescribeReplicationSubnetGroupsRequest describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
|
default DescribeReplicationSubnetGroupsPublisher |
describeReplicationSubnetGroupsPaginator()
Returns information about the replication subnet groups.
|
default DescribeReplicationSubnetGroupsPublisher |
describeReplicationSubnetGroupsPaginator(Consumer<DescribeReplicationSubnetGroupsRequest.Builder> describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
|
default DescribeReplicationSubnetGroupsPublisher |
describeReplicationSubnetGroupsPaginator(DescribeReplicationSubnetGroupsRequest describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
|
default CompletableFuture<DescribeReplicationTaskAssessmentResultsResponse> |
describeReplicationTaskAssessmentResults(Consumer<DescribeReplicationTaskAssessmentResultsRequest.Builder> describeReplicationTaskAssessmentResultsRequest)
Returns the task assessment results from Amazon S3.
|
default CompletableFuture<DescribeReplicationTaskAssessmentResultsResponse> |
describeReplicationTaskAssessmentResults(DescribeReplicationTaskAssessmentResultsRequest describeReplicationTaskAssessmentResultsRequest)
Returns the task assessment results from Amazon S3.
|
default CompletableFuture<DescribeReplicationTasksResponse> |
describeReplicationTasks()
Returns information about replication tasks for your account in the current region.
|
default CompletableFuture<DescribeReplicationTasksResponse> |
describeReplicationTasks(Consumer<DescribeReplicationTasksRequest.Builder> describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
|
default CompletableFuture<DescribeReplicationTasksResponse> |
describeReplicationTasks(DescribeReplicationTasksRequest describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
|
default DescribeReplicationTasksPublisher |
describeReplicationTasksPaginator()
Returns information about replication tasks for your account in the current region.
|
default DescribeReplicationTasksPublisher |
describeReplicationTasksPaginator(Consumer<DescribeReplicationTasksRequest.Builder> describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
|
default DescribeReplicationTasksPublisher |
describeReplicationTasksPaginator(DescribeReplicationTasksRequest describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
|
default CompletableFuture<DescribeSchemasResponse> |
describeSchemas(Consumer<DescribeSchemasRequest.Builder> describeSchemasRequest)
Returns information about the schema for the specified endpoint.
|
default CompletableFuture<DescribeSchemasResponse> |
describeSchemas(DescribeSchemasRequest describeSchemasRequest)
Returns information about the schema for the specified endpoint.
|
default DescribeSchemasPublisher |
describeSchemasPaginator(Consumer<DescribeSchemasRequest.Builder> describeSchemasRequest)
Returns information about the schema for the specified endpoint.
|
default DescribeSchemasPublisher |
describeSchemasPaginator(DescribeSchemasRequest describeSchemasRequest)
Returns information about the schema for the specified endpoint.
|
default CompletableFuture<DescribeTableStatisticsResponse> |
describeTableStatistics(Consumer<DescribeTableStatisticsRequest.Builder> describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and
rows deleted.
|
default CompletableFuture<DescribeTableStatisticsResponse> |
describeTableStatistics(DescribeTableStatisticsRequest describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and
rows deleted.
|
default DescribeTableStatisticsPublisher |
describeTableStatisticsPaginator(Consumer<DescribeTableStatisticsRequest.Builder> describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and
rows deleted.
|
default DescribeTableStatisticsPublisher |
describeTableStatisticsPaginator(DescribeTableStatisticsRequest describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and
rows deleted.
|
default CompletableFuture<ImportCertificateResponse> |
importCertificate(Consumer<ImportCertificateRequest.Builder> importCertificateRequest)
Uploads the specified certificate.
|
default CompletableFuture<ImportCertificateResponse> |
importCertificate(ImportCertificateRequest importCertificateRequest)
Uploads the specified certificate.
|
default CompletableFuture<ListTagsForResourceResponse> |
listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Lists all tags for an AWS DMS resource.
|
default CompletableFuture<ListTagsForResourceResponse> |
listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Lists all tags for an AWS DMS resource.
|
default CompletableFuture<ModifyEndpointResponse> |
modifyEndpoint(Consumer<ModifyEndpointRequest.Builder> modifyEndpointRequest)
Modifies the specified endpoint.
|
default CompletableFuture<ModifyEndpointResponse> |
modifyEndpoint(ModifyEndpointRequest modifyEndpointRequest)
Modifies the specified endpoint.
|
default CompletableFuture<ModifyEventSubscriptionResponse> |
modifyEventSubscription(Consumer<ModifyEventSubscriptionRequest.Builder> modifyEventSubscriptionRequest)
Modifies an existing AWS DMS event notification subscription.
|
default CompletableFuture<ModifyEventSubscriptionResponse> |
modifyEventSubscription(ModifyEventSubscriptionRequest modifyEventSubscriptionRequest)
Modifies an existing AWS DMS event notification subscription.
|
default CompletableFuture<ModifyReplicationInstanceResponse> |
modifyReplicationInstance(Consumer<ModifyReplicationInstanceRequest.Builder> modifyReplicationInstanceRequest)
Modifies the replication instance to apply new settings.
|
default CompletableFuture<ModifyReplicationInstanceResponse> |
modifyReplicationInstance(ModifyReplicationInstanceRequest modifyReplicationInstanceRequest)
Modifies the replication instance to apply new settings.
|
default CompletableFuture<ModifyReplicationSubnetGroupResponse> |
modifyReplicationSubnetGroup(Consumer<ModifyReplicationSubnetGroupRequest.Builder> modifyReplicationSubnetGroupRequest)
Modifies the settings for the specified replication subnet group.
|
default CompletableFuture<ModifyReplicationSubnetGroupResponse> |
modifyReplicationSubnetGroup(ModifyReplicationSubnetGroupRequest modifyReplicationSubnetGroupRequest)
Modifies the settings for the specified replication subnet group.
|
default CompletableFuture<ModifyReplicationTaskResponse> |
modifyReplicationTask(Consumer<ModifyReplicationTaskRequest.Builder> modifyReplicationTaskRequest)
Modifies the specified replication task.
|
default CompletableFuture<ModifyReplicationTaskResponse> |
modifyReplicationTask(ModifyReplicationTaskRequest modifyReplicationTaskRequest)
Modifies the specified replication task.
|
default CompletableFuture<RefreshSchemasResponse> |
refreshSchemas(Consumer<RefreshSchemasRequest.Builder> refreshSchemasRequest)
Populates the schema for the specified endpoint.
|
default CompletableFuture<RefreshSchemasResponse> |
refreshSchemas(RefreshSchemasRequest refreshSchemasRequest)
Populates the schema for the specified endpoint.
|
default CompletableFuture<ReloadTablesResponse> |
reloadTables(Consumer<ReloadTablesRequest.Builder> reloadTablesRequest)
Reloads the target database table with the source data.
|
default CompletableFuture<ReloadTablesResponse> |
reloadTables(ReloadTablesRequest reloadTablesRequest)
Reloads the target database table with the source data.
|
default CompletableFuture<RemoveTagsFromResourceResponse> |
removeTagsFromResource(Consumer<RemoveTagsFromResourceRequest.Builder> removeTagsFromResourceRequest)
Removes metadata tags from a DMS resource.
|
default CompletableFuture<RemoveTagsFromResourceResponse> |
removeTagsFromResource(RemoveTagsFromResourceRequest removeTagsFromResourceRequest)
Removes metadata tags from a DMS resource.
|
default CompletableFuture<StartReplicationTaskResponse> |
startReplicationTask(Consumer<StartReplicationTaskRequest.Builder> startReplicationTaskRequest)
Starts the replication task.
|
default CompletableFuture<StartReplicationTaskResponse> |
startReplicationTask(StartReplicationTaskRequest startReplicationTaskRequest)
Starts the replication task.
|
default CompletableFuture<StartReplicationTaskAssessmentResponse> |
startReplicationTaskAssessment(Consumer<StartReplicationTaskAssessmentRequest.Builder> startReplicationTaskAssessmentRequest)
Starts the replication task assessment for unsupported data types in the source database.
|
default CompletableFuture<StartReplicationTaskAssessmentResponse> |
startReplicationTaskAssessment(StartReplicationTaskAssessmentRequest startReplicationTaskAssessmentRequest)
Starts the replication task assessment for unsupported data types in the source database.
|
default CompletableFuture<StopReplicationTaskResponse> |
stopReplicationTask(Consumer<StopReplicationTaskRequest.Builder> stopReplicationTaskRequest)
Stops the replication task.
|
default CompletableFuture<StopReplicationTaskResponse> |
stopReplicationTask(StopReplicationTaskRequest stopReplicationTaskRequest)
Stops the replication task.
|
default CompletableFuture<TestConnectionResponse> |
testConnection(Consumer<TestConnectionRequest.Builder> testConnectionRequest)
Tests the connection between the replication instance and the endpoint.
|
default CompletableFuture<TestConnectionResponse> |
testConnection(TestConnectionRequest testConnectionRequest)
Tests the connection between the replication instance and the endpoint.
|
serviceName
close
static final String SERVICE_NAME
static DatabaseMigrationAsyncClient create()
DatabaseMigrationAsyncClient
with the region loaded from the
DefaultAwsRegionProviderChain
and credentials loaded from the
DefaultCredentialsProvider
.static DatabaseMigrationAsyncClientBuilder builder()
DatabaseMigrationAsyncClient
.default CompletableFuture<AddTagsToResourceResponse> addTagsToResource(AddTagsToResourceRequest addTagsToResourceRequest)
Adds metadata tags to a 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.
addTagsToResourceRequest
- default CompletableFuture<AddTagsToResourceResponse> addTagsToResource(Consumer<AddTagsToResourceRequest.Builder> addTagsToResourceRequest)
Adds metadata tags to a 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.
This is a convenience which creates an instance of the AddTagsToResourceRequest.Builder
avoiding the need
to create one manually via AddTagsToResourceRequest.builder()
addTagsToResourceRequest
- A Consumer
that will call methods on AddTagsToResourceMessage.Builder
to create a request.default CompletableFuture<CreateEndpointResponse> createEndpoint(CreateEndpointRequest createEndpointRequest)
Creates an endpoint using the provided settings.
createEndpointRequest
- default CompletableFuture<CreateEndpointResponse> createEndpoint(Consumer<CreateEndpointRequest.Builder> createEndpointRequest)
Creates an endpoint using the provided settings.
This is a convenience which creates an instance of the CreateEndpointRequest.Builder
avoiding the need to
create one manually via CreateEndpointRequest.builder()
createEndpointRequest
- A Consumer
that will call methods on CreateEndpointMessage.Builder
to create a request.default CompletableFuture<CreateEventSubscriptionResponse> createEventSubscription(CreateEventSubscriptionRequest createEventSubscriptionRequest)
Creates an AWS DMS event notification subscription.
You can specify the type of source (SourceType
) you want to be notified of, provide a list of AWS
DMS source IDs (SourceIds
) that triggers the events, and provide a list of event categories (
EventCategories
) for events you want to be notified of. If you specify both the
SourceType
and SourceIds
, such as SourceType = replication-instance
and
SourceIdentifier = my-replinstance
, you will be notified of all the replication instance events for
the specified source. If you specify a SourceType
but don't specify a SourceIdentifier
,
you receive notice of the events for that source type for all your AWS DMS sources. If you don't specify either
SourceType
nor SourceIdentifier
, you will be notified of events generated from all AWS
DMS sources belonging to your customer account.
For more information about AWS DMS events, see Working with Events and Notifications in the AWS Database MIgration Service User Guide.
createEventSubscriptionRequest
- default CompletableFuture<CreateEventSubscriptionResponse> createEventSubscription(Consumer<CreateEventSubscriptionRequest.Builder> createEventSubscriptionRequest)
Creates an AWS DMS event notification subscription.
You can specify the type of source (SourceType
) you want to be notified of, provide a list of AWS
DMS source IDs (SourceIds
) that triggers the events, and provide a list of event categories (
EventCategories
) for events you want to be notified of. If you specify both the
SourceType
and SourceIds
, such as SourceType = replication-instance
and
SourceIdentifier = my-replinstance
, you will be notified of all the replication instance events for
the specified source. If you specify a SourceType
but don't specify a SourceIdentifier
,
you receive notice of the events for that source type for all your AWS DMS sources. If you don't specify either
SourceType
nor SourceIdentifier
, you will be notified of events generated from all AWS
DMS sources belonging to your customer account.
For more information about AWS DMS events, see Working with Events and Notifications in the AWS Database MIgration Service User Guide.
This is a convenience which creates an instance of the CreateEventSubscriptionRequest.Builder
avoiding
the need to create one manually via CreateEventSubscriptionRequest.builder()
createEventSubscriptionRequest
- A Consumer
that will call methods on CreateEventSubscriptionMessage.Builder
to create a
request.default CompletableFuture<CreateReplicationInstanceResponse> createReplicationInstance(CreateReplicationInstanceRequest createReplicationInstanceRequest)
Creates the replication instance using the specified parameters.
createReplicationInstanceRequest
- default CompletableFuture<CreateReplicationInstanceResponse> createReplicationInstance(Consumer<CreateReplicationInstanceRequest.Builder> createReplicationInstanceRequest)
Creates the replication instance using the specified parameters.
This is a convenience which creates an instance of the CreateReplicationInstanceRequest.Builder
avoiding
the need to create one manually via CreateReplicationInstanceRequest.builder()
createReplicationInstanceRequest
- A Consumer
that will call methods on CreateReplicationInstanceMessage.Builder
to create a
request.default CompletableFuture<CreateReplicationSubnetGroupResponse> createReplicationSubnetGroup(CreateReplicationSubnetGroupRequest createReplicationSubnetGroupRequest)
Creates a replication subnet group given a list of the subnet IDs in a VPC.
createReplicationSubnetGroupRequest
- default CompletableFuture<CreateReplicationSubnetGroupResponse> createReplicationSubnetGroup(Consumer<CreateReplicationSubnetGroupRequest.Builder> createReplicationSubnetGroupRequest)
Creates a replication subnet group given a list of the subnet IDs in a VPC.
This is a convenience which creates an instance of the CreateReplicationSubnetGroupRequest.Builder
avoiding the need to create one manually via CreateReplicationSubnetGroupRequest.builder()
createReplicationSubnetGroupRequest
- A Consumer
that will call methods on CreateReplicationSubnetGroupMessage.Builder
to create
a request.default CompletableFuture<CreateReplicationTaskResponse> createReplicationTask(CreateReplicationTaskRequest createReplicationTaskRequest)
Creates a replication task using the specified parameters.
createReplicationTaskRequest
- default CompletableFuture<CreateReplicationTaskResponse> createReplicationTask(Consumer<CreateReplicationTaskRequest.Builder> createReplicationTaskRequest)
Creates a replication task using the specified parameters.
This is a convenience which creates an instance of the CreateReplicationTaskRequest.Builder
avoiding the
need to create one manually via CreateReplicationTaskRequest.builder()
createReplicationTaskRequest
- A Consumer
that will call methods on CreateReplicationTaskMessage.Builder
to create a
request.default CompletableFuture<DeleteCertificateResponse> deleteCertificate(DeleteCertificateRequest deleteCertificateRequest)
Deletes the specified certificate.
deleteCertificateRequest
- default CompletableFuture<DeleteCertificateResponse> deleteCertificate(Consumer<DeleteCertificateRequest.Builder> deleteCertificateRequest)
Deletes the specified certificate.
This is a convenience which creates an instance of the DeleteCertificateRequest.Builder
avoiding the need
to create one manually via DeleteCertificateRequest.builder()
deleteCertificateRequest
- A Consumer
that will call methods on DeleteCertificateMessage.Builder
to create a request.default CompletableFuture<DeleteEndpointResponse> deleteEndpoint(DeleteEndpointRequest deleteEndpointRequest)
Deletes the specified endpoint.
All tasks associated with the endpoint must be deleted before you can delete the endpoint.
deleteEndpointRequest
- default CompletableFuture<DeleteEndpointResponse> deleteEndpoint(Consumer<DeleteEndpointRequest.Builder> deleteEndpointRequest)
Deletes the specified endpoint.
All tasks associated with the endpoint must be deleted before you can delete the endpoint.
This is a convenience which creates an instance of the DeleteEndpointRequest.Builder
avoiding the need to
create one manually via DeleteEndpointRequest.builder()
deleteEndpointRequest
- A Consumer
that will call methods on DeleteEndpointMessage.Builder
to create a request.default CompletableFuture<DeleteEventSubscriptionResponse> deleteEventSubscription(DeleteEventSubscriptionRequest deleteEventSubscriptionRequest)
Deletes an AWS DMS event subscription.
deleteEventSubscriptionRequest
- default CompletableFuture<DeleteEventSubscriptionResponse> deleteEventSubscription(Consumer<DeleteEventSubscriptionRequest.Builder> deleteEventSubscriptionRequest)
Deletes an AWS DMS event subscription.
This is a convenience which creates an instance of the DeleteEventSubscriptionRequest.Builder
avoiding
the need to create one manually via DeleteEventSubscriptionRequest.builder()
deleteEventSubscriptionRequest
- A Consumer
that will call methods on DeleteEventSubscriptionMessage.Builder
to create a
request.default CompletableFuture<DeleteReplicationInstanceResponse> deleteReplicationInstance(DeleteReplicationInstanceRequest deleteReplicationInstanceRequest)
Deletes the specified replication instance.
You must delete any migration tasks that are associated with the replication instance before you can delete it.
deleteReplicationInstanceRequest
- default CompletableFuture<DeleteReplicationInstanceResponse> deleteReplicationInstance(Consumer<DeleteReplicationInstanceRequest.Builder> deleteReplicationInstanceRequest)
Deletes the specified replication instance.
You must delete any migration tasks that are associated with the replication instance before you can delete it.
This is a convenience which creates an instance of the DeleteReplicationInstanceRequest.Builder
avoiding
the need to create one manually via DeleteReplicationInstanceRequest.builder()
deleteReplicationInstanceRequest
- A Consumer
that will call methods on DeleteReplicationInstanceMessage.Builder
to create a
request.default CompletableFuture<DeleteReplicationSubnetGroupResponse> deleteReplicationSubnetGroup(DeleteReplicationSubnetGroupRequest deleteReplicationSubnetGroupRequest)
Deletes a subnet group.
deleteReplicationSubnetGroupRequest
- default CompletableFuture<DeleteReplicationSubnetGroupResponse> deleteReplicationSubnetGroup(Consumer<DeleteReplicationSubnetGroupRequest.Builder> deleteReplicationSubnetGroupRequest)
Deletes a subnet group.
This is a convenience which creates an instance of the DeleteReplicationSubnetGroupRequest.Builder
avoiding the need to create one manually via DeleteReplicationSubnetGroupRequest.builder()
deleteReplicationSubnetGroupRequest
- A Consumer
that will call methods on DeleteReplicationSubnetGroupMessage.Builder
to create
a request.default CompletableFuture<DeleteReplicationTaskResponse> deleteReplicationTask(DeleteReplicationTaskRequest deleteReplicationTaskRequest)
Deletes the specified replication task.
deleteReplicationTaskRequest
- default CompletableFuture<DeleteReplicationTaskResponse> deleteReplicationTask(Consumer<DeleteReplicationTaskRequest.Builder> deleteReplicationTaskRequest)
Deletes the specified replication task.
This is a convenience which creates an instance of the DeleteReplicationTaskRequest.Builder
avoiding the
need to create one manually via DeleteReplicationTaskRequest.builder()
deleteReplicationTaskRequest
- A Consumer
that will call methods on DeleteReplicationTaskMessage.Builder
to create a
request.default CompletableFuture<DescribeAccountAttributesResponse> describeAccountAttributes(DescribeAccountAttributesRequest describeAccountAttributesRequest)
Lists all of the AWS DMS attributes for a customer account. The attributes include AWS DMS quotas for the account, such as the number of replication instances allowed. The description for a quota includes the quota name, current usage toward that quota, and the quota's maximum value.
This command does not take any parameters.
describeAccountAttributesRequest
- default CompletableFuture<DescribeAccountAttributesResponse> describeAccountAttributes(Consumer<DescribeAccountAttributesRequest.Builder> describeAccountAttributesRequest)
Lists all of the AWS DMS attributes for a customer account. The attributes include AWS DMS quotas for the account, such as the number of replication instances allowed. The description for a quota includes the quota name, current usage toward that quota, and the quota's maximum value.
This command does not take any parameters.
This is a convenience which creates an instance of the DescribeAccountAttributesRequest.Builder
avoiding
the need to create one manually via DescribeAccountAttributesRequest.builder()
describeAccountAttributesRequest
- A Consumer
that will call methods on DescribeAccountAttributesMessage.Builder
to create a
request.default CompletableFuture<DescribeAccountAttributesResponse> describeAccountAttributes()
Lists all of the AWS DMS attributes for a customer account. The attributes include AWS DMS quotas for the account, such as the number of replication instances allowed. The description for a quota includes the quota name, current usage toward that quota, and the quota's maximum value.
This command does not take any parameters.
default CompletableFuture<DescribeCertificatesResponse> describeCertificates(DescribeCertificatesRequest describeCertificatesRequest)
Provides a description of the certificate.
describeCertificatesRequest
- default CompletableFuture<DescribeCertificatesResponse> describeCertificates(Consumer<DescribeCertificatesRequest.Builder> describeCertificatesRequest)
Provides a description of the certificate.
This is a convenience which creates an instance of the DescribeCertificatesRequest.Builder
avoiding the
need to create one manually via DescribeCertificatesRequest.builder()
describeCertificatesRequest
- A Consumer
that will call methods on DescribeCertificatesMessage.Builder
to create a
request.default CompletableFuture<DescribeCertificatesResponse> describeCertificates()
Provides a description of the certificate.
default DescribeCertificatesPublisher describeCertificatesPaginator()
Provides a description of the certificate.
This is a variant of
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation.
default DescribeCertificatesPublisher describeCertificatesPaginator(DescribeCertificatesRequest describeCertificatesRequest)
Provides a description of the certificate.
This is a variant of
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation.
describeCertificatesRequest
- default DescribeCertificatesPublisher describeCertificatesPaginator(Consumer<DescribeCertificatesRequest.Builder> describeCertificatesRequest)
Provides a description of the certificate.
This is a variant of
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeCertificatesPublisher publisher = client.describeCertificatesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeCertificates(software.amazon.awssdk.services.databasemigration.model.DescribeCertificatesRequest)
operation.
This is a convenience which creates an instance of the DescribeCertificatesRequest.Builder
avoiding the
need to create one manually via DescribeCertificatesRequest.builder()
describeCertificatesRequest
- A Consumer
that will call methods on DescribeCertificatesMessage.Builder
to create a
request.default CompletableFuture<DescribeConnectionsResponse> describeConnections(DescribeConnectionsRequest describeConnectionsRequest)
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.
describeConnectionsRequest
- default CompletableFuture<DescribeConnectionsResponse> describeConnections(Consumer<DescribeConnectionsRequest.Builder> describeConnectionsRequest)
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.
This is a convenience which creates an instance of the DescribeConnectionsRequest.Builder
avoiding the
need to create one manually via DescribeConnectionsRequest.builder()
describeConnectionsRequest
- A Consumer
that will call methods on DescribeConnectionsMessage.Builder
to create a
request.default CompletableFuture<DescribeConnectionsResponse> describeConnections()
Describes the status of the connections that have been made between the replication instance and an endpoint. Connections are created when you test an endpoint.
default DescribeConnectionsPublisher describeConnectionsPaginator()
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.
This is a variant of
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation.
default DescribeConnectionsPublisher describeConnectionsPaginator(DescribeConnectionsRequest describeConnectionsRequest)
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.
This is a variant of
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation.
describeConnectionsRequest
- default DescribeConnectionsPublisher describeConnectionsPaginator(Consumer<DescribeConnectionsRequest.Builder> describeConnectionsRequest)
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.
This is a variant of
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeConnectionsPublisher publisher = client.describeConnectionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeConnections(software.amazon.awssdk.services.databasemigration.model.DescribeConnectionsRequest)
operation.
This is a convenience which creates an instance of the DescribeConnectionsRequest.Builder
avoiding the
need to create one manually via DescribeConnectionsRequest.builder()
describeConnectionsRequest
- A Consumer
that will call methods on DescribeConnectionsMessage.Builder
to create a
request.default CompletableFuture<DescribeEndpointTypesResponse> describeEndpointTypes(DescribeEndpointTypesRequest describeEndpointTypesRequest)
Returns information about the type of endpoints available.
describeEndpointTypesRequest
- default CompletableFuture<DescribeEndpointTypesResponse> describeEndpointTypes(Consumer<DescribeEndpointTypesRequest.Builder> describeEndpointTypesRequest)
Returns information about the type of endpoints available.
This is a convenience which creates an instance of the DescribeEndpointTypesRequest.Builder
avoiding the
need to create one manually via DescribeEndpointTypesRequest.builder()
describeEndpointTypesRequest
- A Consumer
that will call methods on DescribeEndpointTypesMessage.Builder
to create a
request.default CompletableFuture<DescribeEndpointTypesResponse> describeEndpointTypes()
Returns information about the type of endpoints available.
default DescribeEndpointTypesPublisher describeEndpointTypesPaginator()
Returns information about the type of endpoints available.
This is a variant of
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation.
default DescribeEndpointTypesPublisher describeEndpointTypesPaginator(DescribeEndpointTypesRequest describeEndpointTypesRequest)
Returns information about the type of endpoints available.
This is a variant of
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation.
describeEndpointTypesRequest
- default DescribeEndpointTypesPublisher describeEndpointTypesPaginator(Consumer<DescribeEndpointTypesRequest.Builder> describeEndpointTypesRequest)
Returns information about the type of endpoints available.
This is a variant of
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointTypesPublisher publisher = client.describeEndpointTypesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpointTypes(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointTypesRequest)
operation.
This is a convenience which creates an instance of the DescribeEndpointTypesRequest.Builder
avoiding the
need to create one manually via DescribeEndpointTypesRequest.builder()
describeEndpointTypesRequest
- A Consumer
that will call methods on DescribeEndpointTypesMessage.Builder
to create a
request.default CompletableFuture<DescribeEndpointsResponse> describeEndpoints(DescribeEndpointsRequest describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
describeEndpointsRequest
- default CompletableFuture<DescribeEndpointsResponse> describeEndpoints(Consumer<DescribeEndpointsRequest.Builder> describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
This is a convenience which creates an instance of the DescribeEndpointsRequest.Builder
avoiding the need
to create one manually via DescribeEndpointsRequest.builder()
describeEndpointsRequest
- A Consumer
that will call methods on DescribeEndpointsMessage.Builder
to create a request.default CompletableFuture<DescribeEndpointsResponse> describeEndpoints()
Returns information about the endpoints for your account in the current region.
default DescribeEndpointsPublisher describeEndpointsPaginator()
Returns information about the endpoints for your account in the current region.
This is a variant of
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation.
default DescribeEndpointsPublisher describeEndpointsPaginator(DescribeEndpointsRequest describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
This is a variant of
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation.
describeEndpointsRequest
- default DescribeEndpointsPublisher describeEndpointsPaginator(Consumer<DescribeEndpointsRequest.Builder> describeEndpointsRequest)
Returns information about the endpoints for your account in the current region.
This is a variant of
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEndpointsPublisher publisher = client.describeEndpointsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEndpoints(software.amazon.awssdk.services.databasemigration.model.DescribeEndpointsRequest)
operation.
This is a convenience which creates an instance of the DescribeEndpointsRequest.Builder
avoiding the need
to create one manually via DescribeEndpointsRequest.builder()
describeEndpointsRequest
- A Consumer
that will call methods on DescribeEndpointsMessage.Builder
to create a request.default CompletableFuture<DescribeEventCategoriesResponse> describeEventCategories(DescribeEventCategoriesRequest describeEventCategoriesRequest)
Lists categories for all event source types, or, if specified, for a specified source type. You can see a list of the event categories and source types in Working with Events and Notifications in the AWS Database Migration Service User Guide.
describeEventCategoriesRequest
- default CompletableFuture<DescribeEventCategoriesResponse> describeEventCategories(Consumer<DescribeEventCategoriesRequest.Builder> describeEventCategoriesRequest)
Lists categories for all event source types, or, if specified, for a specified source type. You can see a list of the event categories and source types in Working with Events and Notifications in the AWS Database Migration Service User Guide.
This is a convenience which creates an instance of the DescribeEventCategoriesRequest.Builder
avoiding
the need to create one manually via DescribeEventCategoriesRequest.builder()
describeEventCategoriesRequest
- A Consumer
that will call methods on DescribeEventCategoriesMessage.Builder
to create a
request.default CompletableFuture<DescribeEventCategoriesResponse> describeEventCategories()
Lists categories for all event source types, or, if specified, for a specified source type. You can see a list of the event categories and source types in Working with Events and Notifications in the AWS Database Migration Service User Guide.
default CompletableFuture<DescribeEventSubscriptionsResponse> describeEventSubscriptions(DescribeEventSubscriptionsRequest describeEventSubscriptionsRequest)
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.
describeEventSubscriptionsRequest
- default CompletableFuture<DescribeEventSubscriptionsResponse> describeEventSubscriptions(Consumer<DescribeEventSubscriptionsRequest.Builder> describeEventSubscriptionsRequest)
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.
This is a convenience which creates an instance of the DescribeEventSubscriptionsRequest.Builder
avoiding
the need to create one manually via DescribeEventSubscriptionsRequest.builder()
describeEventSubscriptionsRequest
- A Consumer
that will call methods on DescribeEventSubscriptionsMessage.Builder
to create a
request.default CompletableFuture<DescribeEventSubscriptionsResponse> describeEventSubscriptions()
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.
default DescribeEventSubscriptionsPublisher describeEventSubscriptionsPaginator()
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.
This is a variant of
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation.
default DescribeEventSubscriptionsPublisher describeEventSubscriptionsPaginator(DescribeEventSubscriptionsRequest describeEventSubscriptionsRequest)
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.
This is a variant of
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation.
describeEventSubscriptionsRequest
- default DescribeEventSubscriptionsPublisher describeEventSubscriptionsPaginator(Consumer<DescribeEventSubscriptionsRequest.Builder> describeEventSubscriptionsRequest)
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.
This is a variant of
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventSubscriptionsPublisher publisher = client.describeEventSubscriptionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEventSubscriptions(software.amazon.awssdk.services.databasemigration.model.DescribeEventSubscriptionsRequest)
operation.
This is a convenience which creates an instance of the DescribeEventSubscriptionsRequest.Builder
avoiding
the need to create one manually via DescribeEventSubscriptionsRequest.builder()
describeEventSubscriptionsRequest
- A Consumer
that will call methods on DescribeEventSubscriptionsMessage.Builder
to create a
request.default CompletableFuture<DescribeEventsResponse> describeEvents(DescribeEventsRequest describeEventsRequest)
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
describeEventsRequest
- default CompletableFuture<DescribeEventsResponse> describeEvents(Consumer<DescribeEventsRequest.Builder> describeEventsRequest)
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
This is a convenience which creates an instance of the DescribeEventsRequest.Builder
avoiding the need to
create one manually via DescribeEventsRequest.builder()
describeEventsRequest
- A Consumer
that will call methods on DescribeEventsMessage.Builder
to create a request.default CompletableFuture<DescribeEventsResponse> describeEvents()
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
default DescribeEventsPublisher describeEventsPaginator()
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
This is a variant of
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
default DescribeEventsPublisher describeEventsPaginator(DescribeEventsRequest describeEventsRequest)
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
This is a variant of
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
describeEventsRequest
- default DescribeEventsPublisher describeEventsPaginator(Consumer<DescribeEventsRequest.Builder> describeEventsRequest)
Lists events for a given source identifier and source type. You can also specify a start and end time. For more information on AWS DMS events, see Working with Events and Notifications .
This is a variant of
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeEventsPublisher publisher = client.describeEventsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeEventsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeEvents(software.amazon.awssdk.services.databasemigration.model.DescribeEventsRequest)
operation.
This is a convenience which creates an instance of the DescribeEventsRequest.Builder
avoiding the need to
create one manually via DescribeEventsRequest.builder()
describeEventsRequest
- A Consumer
that will call methods on DescribeEventsMessage.Builder
to create a request.default CompletableFuture<DescribeOrderableReplicationInstancesResponse> describeOrderableReplicationInstances(DescribeOrderableReplicationInstancesRequest describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
describeOrderableReplicationInstancesRequest
- default CompletableFuture<DescribeOrderableReplicationInstancesResponse> describeOrderableReplicationInstances(Consumer<DescribeOrderableReplicationInstancesRequest.Builder> describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
This is a convenience which creates an instance of the
DescribeOrderableReplicationInstancesRequest.Builder
avoiding the need to create one manually via
DescribeOrderableReplicationInstancesRequest.builder()
describeOrderableReplicationInstancesRequest
- A Consumer
that will call methods on DescribeOrderableReplicationInstancesMessage.Builder
to create a request.default CompletableFuture<DescribeOrderableReplicationInstancesResponse> describeOrderableReplicationInstances()
Returns information about the replication instance types that can be created in the specified region.
default DescribeOrderableReplicationInstancesPublisher describeOrderableReplicationInstancesPaginator()
Returns information about the replication instance types that can be created in the specified region.
This is a variant of
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation.
default DescribeOrderableReplicationInstancesPublisher describeOrderableReplicationInstancesPaginator(DescribeOrderableReplicationInstancesRequest describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
This is a variant of
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation.
describeOrderableReplicationInstancesRequest
- default DescribeOrderableReplicationInstancesPublisher describeOrderableReplicationInstancesPaginator(Consumer<DescribeOrderableReplicationInstancesRequest.Builder> describeOrderableReplicationInstancesRequest)
Returns information about the replication instance types that can be created in the specified region.
This is a variant of
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeOrderableReplicationInstancesPublisher publisher = client.describeOrderableReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeOrderableReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeOrderableReplicationInstancesRequest)
operation.
This is a convenience which creates an instance of the
DescribeOrderableReplicationInstancesRequest.Builder
avoiding the need to create one manually via
DescribeOrderableReplicationInstancesRequest.builder()
describeOrderableReplicationInstancesRequest
- A Consumer
that will call methods on DescribeOrderableReplicationInstancesMessage.Builder
to create a request.default CompletableFuture<DescribeRefreshSchemasStatusResponse> describeRefreshSchemasStatus(DescribeRefreshSchemasStatusRequest describeRefreshSchemasStatusRequest)
Returns the status of the RefreshSchemas operation.
describeRefreshSchemasStatusRequest
- default CompletableFuture<DescribeRefreshSchemasStatusResponse> describeRefreshSchemasStatus(Consumer<DescribeRefreshSchemasStatusRequest.Builder> describeRefreshSchemasStatusRequest)
Returns the status of the RefreshSchemas operation.
This is a convenience which creates an instance of the DescribeRefreshSchemasStatusRequest.Builder
avoiding the need to create one manually via DescribeRefreshSchemasStatusRequest.builder()
describeRefreshSchemasStatusRequest
- A Consumer
that will call methods on DescribeRefreshSchemasStatusMessage.Builder
to create
a request.default CompletableFuture<DescribeReplicationInstancesResponse> describeReplicationInstances(DescribeReplicationInstancesRequest describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
describeReplicationInstancesRequest
- default CompletableFuture<DescribeReplicationInstancesResponse> describeReplicationInstances(Consumer<DescribeReplicationInstancesRequest.Builder> describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
This is a convenience which creates an instance of the DescribeReplicationInstancesRequest.Builder
avoiding the need to create one manually via DescribeReplicationInstancesRequest.builder()
describeReplicationInstancesRequest
- A Consumer
that will call methods on DescribeReplicationInstancesMessage.Builder
to create
a request.default CompletableFuture<DescribeReplicationInstancesResponse> describeReplicationInstances()
Returns information about replication instances for your account in the current region.
default DescribeReplicationInstancesPublisher describeReplicationInstancesPaginator()
Returns information about replication instances for your account in the current region.
This is a variant of
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation.
default DescribeReplicationInstancesPublisher describeReplicationInstancesPaginator(DescribeReplicationInstancesRequest describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
This is a variant of
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation.
describeReplicationInstancesRequest
- default DescribeReplicationInstancesPublisher describeReplicationInstancesPaginator(Consumer<DescribeReplicationInstancesRequest.Builder> describeReplicationInstancesRequest)
Returns information about replication instances for your account in the current region.
This is a variant of
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationInstancesPublisher publisher = client.describeReplicationInstancesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationInstances(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationInstancesRequest)
operation.
This is a convenience which creates an instance of the DescribeReplicationInstancesRequest.Builder
avoiding the need to create one manually via DescribeReplicationInstancesRequest.builder()
describeReplicationInstancesRequest
- A Consumer
that will call methods on DescribeReplicationInstancesMessage.Builder
to create
a request.default CompletableFuture<DescribeReplicationSubnetGroupsResponse> describeReplicationSubnetGroups(DescribeReplicationSubnetGroupsRequest describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
describeReplicationSubnetGroupsRequest
- default CompletableFuture<DescribeReplicationSubnetGroupsResponse> describeReplicationSubnetGroups(Consumer<DescribeReplicationSubnetGroupsRequest.Builder> describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
This is a convenience which creates an instance of the DescribeReplicationSubnetGroupsRequest.Builder
avoiding the need to create one manually via DescribeReplicationSubnetGroupsRequest.builder()
describeReplicationSubnetGroupsRequest
- A Consumer
that will call methods on DescribeReplicationSubnetGroupsMessage.Builder
to
create a request.default CompletableFuture<DescribeReplicationSubnetGroupsResponse> describeReplicationSubnetGroups()
Returns information about the replication subnet groups.
default DescribeReplicationSubnetGroupsPublisher describeReplicationSubnetGroupsPaginator()
Returns information about the replication subnet groups.
This is a variant of
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation.
default DescribeReplicationSubnetGroupsPublisher describeReplicationSubnetGroupsPaginator(DescribeReplicationSubnetGroupsRequest describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
This is a variant of
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation.
describeReplicationSubnetGroupsRequest
- default DescribeReplicationSubnetGroupsPublisher describeReplicationSubnetGroupsPaginator(Consumer<DescribeReplicationSubnetGroupsRequest.Builder> describeReplicationSubnetGroupsRequest)
Returns information about the replication subnet groups.
This is a variant of
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationSubnetGroupsPublisher publisher = client.describeReplicationSubnetGroupsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationSubnetGroups(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationSubnetGroupsRequest)
operation.
This is a convenience which creates an instance of the DescribeReplicationSubnetGroupsRequest.Builder
avoiding the need to create one manually via DescribeReplicationSubnetGroupsRequest.builder()
describeReplicationSubnetGroupsRequest
- A Consumer
that will call methods on DescribeReplicationSubnetGroupsMessage.Builder
to
create a request.default CompletableFuture<DescribeReplicationTaskAssessmentResultsResponse> describeReplicationTaskAssessmentResults(DescribeReplicationTaskAssessmentResultsRequest describeReplicationTaskAssessmentResultsRequest)
Returns the task assessment results from Amazon S3. This action always returns the latest results.
describeReplicationTaskAssessmentResultsRequest
- default CompletableFuture<DescribeReplicationTaskAssessmentResultsResponse> describeReplicationTaskAssessmentResults(Consumer<DescribeReplicationTaskAssessmentResultsRequest.Builder> describeReplicationTaskAssessmentResultsRequest)
Returns the task assessment results from Amazon S3. This action always returns the latest results.
This is a convenience which creates an instance of the
DescribeReplicationTaskAssessmentResultsRequest.Builder
avoiding the need to create one manually via
DescribeReplicationTaskAssessmentResultsRequest.builder()
describeReplicationTaskAssessmentResultsRequest
- A Consumer
that will call methods on
DescribeReplicationTaskAssessmentResultsMessage.Builder
to create a request.default CompletableFuture<DescribeReplicationTasksResponse> describeReplicationTasks(DescribeReplicationTasksRequest describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
describeReplicationTasksRequest
- default CompletableFuture<DescribeReplicationTasksResponse> describeReplicationTasks(Consumer<DescribeReplicationTasksRequest.Builder> describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
This is a convenience which creates an instance of the DescribeReplicationTasksRequest.Builder
avoiding
the need to create one manually via DescribeReplicationTasksRequest.builder()
describeReplicationTasksRequest
- A Consumer
that will call methods on DescribeReplicationTasksMessage.Builder
to create a
request.default CompletableFuture<DescribeReplicationTasksResponse> describeReplicationTasks()
Returns information about replication tasks for your account in the current region.
default DescribeReplicationTasksPublisher describeReplicationTasksPaginator()
Returns information about replication tasks for your account in the current region.
This is a variant of
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation.
default DescribeReplicationTasksPublisher describeReplicationTasksPaginator(DescribeReplicationTasksRequest describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
This is a variant of
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation.
describeReplicationTasksRequest
- default DescribeReplicationTasksPublisher describeReplicationTasksPaginator(Consumer<DescribeReplicationTasksRequest.Builder> describeReplicationTasksRequest)
Returns information about replication tasks for your account in the current region.
This is a variant of
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeReplicationTasksPublisher publisher = client.describeReplicationTasksPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeReplicationTasks(software.amazon.awssdk.services.databasemigration.model.DescribeReplicationTasksRequest)
operation.
This is a convenience which creates an instance of the DescribeReplicationTasksRequest.Builder
avoiding
the need to create one manually via DescribeReplicationTasksRequest.builder()
describeReplicationTasksRequest
- A Consumer
that will call methods on DescribeReplicationTasksMessage.Builder
to create a
request.default CompletableFuture<DescribeSchemasResponse> describeSchemas(DescribeSchemasRequest describeSchemasRequest)
Returns information about the schema for the specified endpoint.
describeSchemasRequest
- default CompletableFuture<DescribeSchemasResponse> describeSchemas(Consumer<DescribeSchemasRequest.Builder> describeSchemasRequest)
Returns information about the schema for the specified endpoint.
This is a convenience which creates an instance of the DescribeSchemasRequest.Builder
avoiding the need
to create one manually via DescribeSchemasRequest.builder()
describeSchemasRequest
- A Consumer
that will call methods on DescribeSchemasMessage.Builder
to create a request.default DescribeSchemasPublisher describeSchemasPaginator(DescribeSchemasRequest describeSchemasRequest)
Returns information about the schema for the specified endpoint.
This is a variant of
describeSchemas(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeSchemasPublisher publisher = client.describeSchemasPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeSchemasPublisher publisher = client.describeSchemasPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeSchemasResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeSchemas(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasRequest)
operation.
describeSchemasRequest
- default DescribeSchemasPublisher describeSchemasPaginator(Consumer<DescribeSchemasRequest.Builder> describeSchemasRequest)
Returns information about the schema for the specified endpoint.
This is a variant of
describeSchemas(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeSchemasPublisher publisher = client.describeSchemasPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeSchemasPublisher publisher = client.describeSchemasPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeSchemasResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeSchemas(software.amazon.awssdk.services.databasemigration.model.DescribeSchemasRequest)
operation.
This is a convenience which creates an instance of the DescribeSchemasRequest.Builder
avoiding the need
to create one manually via DescribeSchemasRequest.builder()
describeSchemasRequest
- A Consumer
that will call methods on DescribeSchemasMessage.Builder
to create a request.default CompletableFuture<DescribeTableStatisticsResponse> describeTableStatistics(DescribeTableStatisticsRequest describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.
Note that the "last updated" column the DMS console only indicates the time that AWS DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.
describeTableStatisticsRequest
- default CompletableFuture<DescribeTableStatisticsResponse> describeTableStatistics(Consumer<DescribeTableStatisticsRequest.Builder> describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.
Note that the "last updated" column the DMS console only indicates the time that AWS DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.
This is a convenience which creates an instance of the DescribeTableStatisticsRequest.Builder
avoiding
the need to create one manually via DescribeTableStatisticsRequest.builder()
describeTableStatisticsRequest
- A Consumer
that will call methods on DescribeTableStatisticsMessage.Builder
to create a
request.default DescribeTableStatisticsPublisher describeTableStatisticsPaginator(DescribeTableStatisticsRequest describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.
Note that the "last updated" column the DMS console only indicates the time that AWS DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.
This is a variant of
describeTableStatistics(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeTableStatisticsPublisher publisher = client.describeTableStatisticsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeTableStatisticsPublisher publisher = client.describeTableStatisticsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeTableStatistics(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsRequest)
operation.
describeTableStatisticsRequest
- default DescribeTableStatisticsPublisher describeTableStatisticsPaginator(Consumer<DescribeTableStatisticsRequest.Builder> describeTableStatisticsRequest)
Returns table statistics on the database migration task, including table name, rows inserted, rows updated, and rows deleted.
Note that the "last updated" column the DMS console only indicates the time that AWS DMS last updated the table statistics record for a table. It does not indicate the time of the last update to the table.
This is a variant of
describeTableStatistics(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber)
. Each call to the subscribe
method will result in a new Subscription
i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the forEach helper method
software.amazon.awssdk.services.databasemigration.paginators.DescribeTableStatisticsPublisher publisher = client.describeTableStatisticsPaginator(request);
CompletableFuture<Void> future = publisher.forEach(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.databasemigration.paginators.DescribeTableStatisticsPublisher publisher = client.describeTableStatisticsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
describeTableStatistics(software.amazon.awssdk.services.databasemigration.model.DescribeTableStatisticsRequest)
operation.
This is a convenience which creates an instance of the DescribeTableStatisticsRequest.Builder
avoiding
the need to create one manually via DescribeTableStatisticsRequest.builder()
describeTableStatisticsRequest
- A Consumer
that will call methods on DescribeTableStatisticsMessage.Builder
to create a
request.default CompletableFuture<ImportCertificateResponse> importCertificate(ImportCertificateRequest importCertificateRequest)
Uploads the specified certificate.
importCertificateRequest
- default CompletableFuture<ImportCertificateResponse> importCertificate(Consumer<ImportCertificateRequest.Builder> importCertificateRequest)
Uploads the specified certificate.
This is a convenience which creates an instance of the ImportCertificateRequest.Builder
avoiding the need
to create one manually via ImportCertificateRequest.builder()
importCertificateRequest
- A Consumer
that will call methods on ImportCertificateMessage.Builder
to create a request.default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Lists all tags for an AWS DMS resource.
listTagsForResourceRequest
- default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Lists all tags for an AWS DMS resource.
This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder
avoiding the
need to create one manually via ListTagsForResourceRequest.builder()
listTagsForResourceRequest
- A Consumer
that will call methods on ListTagsForResourceMessage.Builder
to create a
request.default CompletableFuture<ModifyEndpointResponse> modifyEndpoint(ModifyEndpointRequest modifyEndpointRequest)
Modifies the specified endpoint.
modifyEndpointRequest
- default CompletableFuture<ModifyEndpointResponse> modifyEndpoint(Consumer<ModifyEndpointRequest.Builder> modifyEndpointRequest)
Modifies the specified endpoint.
This is a convenience which creates an instance of the ModifyEndpointRequest.Builder
avoiding the need to
create one manually via ModifyEndpointRequest.builder()
modifyEndpointRequest
- A Consumer
that will call methods on ModifyEndpointMessage.Builder
to create a request.default CompletableFuture<ModifyEventSubscriptionResponse> modifyEventSubscription(ModifyEventSubscriptionRequest modifyEventSubscriptionRequest)
Modifies an existing AWS DMS event notification subscription.
modifyEventSubscriptionRequest
- default CompletableFuture<ModifyEventSubscriptionResponse> modifyEventSubscription(Consumer<ModifyEventSubscriptionRequest.Builder> modifyEventSubscriptionRequest)
Modifies an existing AWS DMS event notification subscription.
This is a convenience which creates an instance of the ModifyEventSubscriptionRequest.Builder
avoiding
the need to create one manually via ModifyEventSubscriptionRequest.builder()
modifyEventSubscriptionRequest
- A Consumer
that will call methods on ModifyEventSubscriptionMessage.Builder
to create a
request.default CompletableFuture<ModifyReplicationInstanceResponse> modifyReplicationInstance(ModifyReplicationInstanceRequest modifyReplicationInstanceRequest)
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.
modifyReplicationInstanceRequest
- default CompletableFuture<ModifyReplicationInstanceResponse> modifyReplicationInstance(Consumer<ModifyReplicationInstanceRequest.Builder> modifyReplicationInstanceRequest)
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.
This is a convenience which creates an instance of the ModifyReplicationInstanceRequest.Builder
avoiding
the need to create one manually via ModifyReplicationInstanceRequest.builder()
modifyReplicationInstanceRequest
- A Consumer
that will call methods on ModifyReplicationInstanceMessage.Builder
to create a
request.default CompletableFuture<ModifyReplicationSubnetGroupResponse> modifyReplicationSubnetGroup(ModifyReplicationSubnetGroupRequest modifyReplicationSubnetGroupRequest)
Modifies the settings for the specified replication subnet group.
modifyReplicationSubnetGroupRequest
- default CompletableFuture<ModifyReplicationSubnetGroupResponse> modifyReplicationSubnetGroup(Consumer<ModifyReplicationSubnetGroupRequest.Builder> modifyReplicationSubnetGroupRequest)
Modifies the settings for the specified replication subnet group.
This is a convenience which creates an instance of the ModifyReplicationSubnetGroupRequest.Builder
avoiding the need to create one manually via ModifyReplicationSubnetGroupRequest.builder()
modifyReplicationSubnetGroupRequest
- A Consumer
that will call methods on ModifyReplicationSubnetGroupMessage.Builder
to create
a request.default CompletableFuture<ModifyReplicationTaskResponse> modifyReplicationTask(ModifyReplicationTaskRequest modifyReplicationTaskRequest)
Modifies the specified replication task.
You can't modify the task endpoints. The task must be stopped before you can modify it.
For more information about AWS DMS tasks, see the AWS DMS user guide at Working with Migration Tasks
modifyReplicationTaskRequest
- default CompletableFuture<ModifyReplicationTaskResponse> modifyReplicationTask(Consumer<ModifyReplicationTaskRequest.Builder> modifyReplicationTaskRequest)
Modifies the specified replication task.
You can't modify the task endpoints. The task must be stopped before you can modify it.
For more information about AWS DMS tasks, see the AWS DMS user guide at Working with Migration Tasks
This is a convenience which creates an instance of the ModifyReplicationTaskRequest.Builder
avoiding the
need to create one manually via ModifyReplicationTaskRequest.builder()
modifyReplicationTaskRequest
- A Consumer
that will call methods on ModifyReplicationTaskMessage.Builder
to create a
request.default CompletableFuture<RefreshSchemasResponse> refreshSchemas(RefreshSchemasRequest refreshSchemasRequest)
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.
refreshSchemasRequest
- default CompletableFuture<RefreshSchemasResponse> refreshSchemas(Consumer<RefreshSchemasRequest.Builder> refreshSchemasRequest)
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.
This is a convenience which creates an instance of the RefreshSchemasRequest.Builder
avoiding the need to
create one manually via RefreshSchemasRequest.builder()
refreshSchemasRequest
- A Consumer
that will call methods on RefreshSchemasMessage.Builder
to create a request.default CompletableFuture<ReloadTablesResponse> reloadTables(ReloadTablesRequest reloadTablesRequest)
Reloads the target database table with the source data.
reloadTablesRequest
- default CompletableFuture<ReloadTablesResponse> reloadTables(Consumer<ReloadTablesRequest.Builder> reloadTablesRequest)
Reloads the target database table with the source data.
This is a convenience which creates an instance of the ReloadTablesRequest.Builder
avoiding the need to
create one manually via ReloadTablesRequest.builder()
reloadTablesRequest
- A Consumer
that will call methods on ReloadTablesMessage.Builder
to create a request.default CompletableFuture<RemoveTagsFromResourceResponse> removeTagsFromResource(RemoveTagsFromResourceRequest removeTagsFromResourceRequest)
Removes metadata tags from a DMS resource.
removeTagsFromResourceRequest
- default CompletableFuture<RemoveTagsFromResourceResponse> removeTagsFromResource(Consumer<RemoveTagsFromResourceRequest.Builder> removeTagsFromResourceRequest)
Removes metadata tags from a DMS resource.
This is a convenience which creates an instance of the RemoveTagsFromResourceRequest.Builder
avoiding the
need to create one manually via RemoveTagsFromResourceRequest.builder()
removeTagsFromResourceRequest
- A Consumer
that will call methods on RemoveTagsFromResourceMessage.Builder
to create a
request.default CompletableFuture<StartReplicationTaskResponse> startReplicationTask(StartReplicationTaskRequest startReplicationTaskRequest)
Starts the replication task.
For more information about AWS DMS tasks, see the AWS DMS user guide at Working with Migration Tasks
startReplicationTaskRequest
- default CompletableFuture<StartReplicationTaskResponse> startReplicationTask(Consumer<StartReplicationTaskRequest.Builder> startReplicationTaskRequest)
Starts the replication task.
For more information about AWS DMS tasks, see the AWS DMS user guide at Working with Migration Tasks
This is a convenience which creates an instance of the StartReplicationTaskRequest.Builder
avoiding the
need to create one manually via StartReplicationTaskRequest.builder()
startReplicationTaskRequest
- A Consumer
that will call methods on StartReplicationTaskMessage.Builder
to create a
request.default CompletableFuture<StartReplicationTaskAssessmentResponse> startReplicationTaskAssessment(StartReplicationTaskAssessmentRequest startReplicationTaskAssessmentRequest)
Starts the replication task assessment for unsupported data types in the source database.
startReplicationTaskAssessmentRequest
- default CompletableFuture<StartReplicationTaskAssessmentResponse> startReplicationTaskAssessment(Consumer<StartReplicationTaskAssessmentRequest.Builder> startReplicationTaskAssessmentRequest)
Starts the replication task assessment for unsupported data types in the source database.
This is a convenience which creates an instance of the StartReplicationTaskAssessmentRequest.Builder
avoiding the need to create one manually via StartReplicationTaskAssessmentRequest.builder()
startReplicationTaskAssessmentRequest
- A Consumer
that will call methods on StartReplicationTaskAssessmentMessage.Builder
to
create a request.default CompletableFuture<StopReplicationTaskResponse> stopReplicationTask(StopReplicationTaskRequest stopReplicationTaskRequest)
Stops the replication task.
stopReplicationTaskRequest
- default CompletableFuture<StopReplicationTaskResponse> stopReplicationTask(Consumer<StopReplicationTaskRequest.Builder> stopReplicationTaskRequest)
Stops the replication task.
This is a convenience which creates an instance of the StopReplicationTaskRequest.Builder
avoiding the
need to create one manually via StopReplicationTaskRequest.builder()
stopReplicationTaskRequest
- A Consumer
that will call methods on StopReplicationTaskMessage.Builder
to create a
request.default CompletableFuture<TestConnectionResponse> testConnection(TestConnectionRequest testConnectionRequest)
Tests the connection between the replication instance and the endpoint.
testConnectionRequest
- default CompletableFuture<TestConnectionResponse> testConnection(Consumer<TestConnectionRequest.Builder> testConnectionRequest)
Tests the connection between the replication instance and the endpoint.
This is a convenience which creates an instance of the TestConnectionRequest.Builder
avoiding the need to
create one manually via TestConnectionRequest.builder()
testConnectionRequest
- A Consumer
that will call methods on TestConnectionMessage.Builder
to create a request.Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.