Skip to content

Commit

Permalink
feat(client-database-migration-service): This release adds DMS Fleet …
Browse files Browse the repository at this point in the history
…Advisor APIs and exposes functionality for DMS Fleet Advisor. It adds functionality to create and modify fleet advisor instances, and to collect and analyze information about the local data infrastructure.
  • Loading branch information
awstools committed Jun 8, 2022
1 parent 3ae95d3 commit 9d1b69c
Show file tree
Hide file tree
Showing 21 changed files with 5,212 additions and 271 deletions.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,10 @@ import {
CreateEventSubscriptionCommandInput,
CreateEventSubscriptionCommandOutput,
} from "./commands/CreateEventSubscriptionCommand";
import {
CreateFleetAdvisorCollectorCommandInput,
CreateFleetAdvisorCollectorCommandOutput,
} from "./commands/CreateFleetAdvisorCollectorCommand";
import {
CreateReplicationInstanceCommandInput,
CreateReplicationInstanceCommandOutput,
Expand All @@ -86,6 +90,14 @@ import {
DeleteEventSubscriptionCommandInput,
DeleteEventSubscriptionCommandOutput,
} from "./commands/DeleteEventSubscriptionCommand";
import {
DeleteFleetAdvisorCollectorCommandInput,
DeleteFleetAdvisorCollectorCommandOutput,
} from "./commands/DeleteFleetAdvisorCollectorCommand";
import {
DeleteFleetAdvisorDatabasesCommandInput,
DeleteFleetAdvisorDatabasesCommandOutput,
} from "./commands/DeleteFleetAdvisorDatabasesCommand";
import {
DeleteReplicationInstanceCommandInput,
DeleteReplicationInstanceCommandOutput,
Expand Down Expand Up @@ -136,6 +148,26 @@ import {
DescribeEventSubscriptionsCommandInput,
DescribeEventSubscriptionsCommandOutput,
} from "./commands/DescribeEventSubscriptionsCommand";
import {
DescribeFleetAdvisorCollectorsCommandInput,
DescribeFleetAdvisorCollectorsCommandOutput,
} from "./commands/DescribeFleetAdvisorCollectorsCommand";
import {
DescribeFleetAdvisorDatabasesCommandInput,
DescribeFleetAdvisorDatabasesCommandOutput,
} from "./commands/DescribeFleetAdvisorDatabasesCommand";
import {
DescribeFleetAdvisorLsaAnalysisCommandInput,
DescribeFleetAdvisorLsaAnalysisCommandOutput,
} from "./commands/DescribeFleetAdvisorLsaAnalysisCommand";
import {
DescribeFleetAdvisorSchemaObjectSummaryCommandInput,
DescribeFleetAdvisorSchemaObjectSummaryCommandOutput,
} from "./commands/DescribeFleetAdvisorSchemaObjectSummaryCommand";
import {
DescribeFleetAdvisorSchemasCommandInput,
DescribeFleetAdvisorSchemasCommandOutput,
} from "./commands/DescribeFleetAdvisorSchemasCommand";
import {
DescribeOrderableReplicationInstancesCommandInput,
DescribeOrderableReplicationInstancesCommandOutput,
Expand Down Expand Up @@ -217,6 +249,10 @@ import {
RemoveTagsFromResourceCommandInput,
RemoveTagsFromResourceCommandOutput,
} from "./commands/RemoveTagsFromResourceCommand";
import {
RunFleetAdvisorLsaAnalysisCommandInput,
RunFleetAdvisorLsaAnalysisCommandOutput,
} from "./commands/RunFleetAdvisorLsaAnalysisCommand";
import {
StartReplicationTaskAssessmentCommandInput,
StartReplicationTaskAssessmentCommandOutput,
Expand All @@ -242,13 +278,16 @@ export type ServiceInputTypes =
| CancelReplicationTaskAssessmentRunCommandInput
| CreateEndpointCommandInput
| CreateEventSubscriptionCommandInput
| CreateFleetAdvisorCollectorCommandInput
| CreateReplicationInstanceCommandInput
| CreateReplicationSubnetGroupCommandInput
| CreateReplicationTaskCommandInput
| DeleteCertificateCommandInput
| DeleteConnectionCommandInput
| DeleteEndpointCommandInput
| DeleteEventSubscriptionCommandInput
| DeleteFleetAdvisorCollectorCommandInput
| DeleteFleetAdvisorDatabasesCommandInput
| DeleteReplicationInstanceCommandInput
| DeleteReplicationSubnetGroupCommandInput
| DeleteReplicationTaskAssessmentRunCommandInput
Expand All @@ -263,6 +302,11 @@ export type ServiceInputTypes =
| DescribeEventCategoriesCommandInput
| DescribeEventSubscriptionsCommandInput
| DescribeEventsCommandInput
| DescribeFleetAdvisorCollectorsCommandInput
| DescribeFleetAdvisorDatabasesCommandInput
| DescribeFleetAdvisorLsaAnalysisCommandInput
| DescribeFleetAdvisorSchemaObjectSummaryCommandInput
| DescribeFleetAdvisorSchemasCommandInput
| DescribeOrderableReplicationInstancesCommandInput
| DescribePendingMaintenanceActionsCommandInput
| DescribeRefreshSchemasStatusCommandInput
Expand All @@ -287,6 +331,7 @@ export type ServiceInputTypes =
| RefreshSchemasCommandInput
| ReloadTablesCommandInput
| RemoveTagsFromResourceCommandInput
| RunFleetAdvisorLsaAnalysisCommandInput
| StartReplicationTaskAssessmentCommandInput
| StartReplicationTaskAssessmentRunCommandInput
| StartReplicationTaskCommandInput
Expand All @@ -299,13 +344,16 @@ export type ServiceOutputTypes =
| CancelReplicationTaskAssessmentRunCommandOutput
| CreateEndpointCommandOutput
| CreateEventSubscriptionCommandOutput
| CreateFleetAdvisorCollectorCommandOutput
| CreateReplicationInstanceCommandOutput
| CreateReplicationSubnetGroupCommandOutput
| CreateReplicationTaskCommandOutput
| DeleteCertificateCommandOutput
| DeleteConnectionCommandOutput
| DeleteEndpointCommandOutput
| DeleteEventSubscriptionCommandOutput
| DeleteFleetAdvisorCollectorCommandOutput
| DeleteFleetAdvisorDatabasesCommandOutput
| DeleteReplicationInstanceCommandOutput
| DeleteReplicationSubnetGroupCommandOutput
| DeleteReplicationTaskAssessmentRunCommandOutput
Expand All @@ -320,6 +368,11 @@ export type ServiceOutputTypes =
| DescribeEventCategoriesCommandOutput
| DescribeEventSubscriptionsCommandOutput
| DescribeEventsCommandOutput
| DescribeFleetAdvisorCollectorsCommandOutput
| DescribeFleetAdvisorDatabasesCommandOutput
| DescribeFleetAdvisorLsaAnalysisCommandOutput
| DescribeFleetAdvisorSchemaObjectSummaryCommandOutput
| DescribeFleetAdvisorSchemasCommandOutput
| DescribeOrderableReplicationInstancesCommandOutput
| DescribePendingMaintenanceActionsCommandOutput
| DescribeRefreshSchemasStatusCommandOutput
Expand All @@ -344,6 +397,7 @@ export type ServiceOutputTypes =
| RefreshSchemasCommandOutput
| ReloadTablesCommandOutput
| RemoveTagsFromResourceCommandOutput
| RunFleetAdvisorLsaAnalysisCommandOutput
| StartReplicationTaskAssessmentCommandOutput
| StartReplicationTaskAssessmentRunCommandOutput
| StartReplicationTaskCommandOutput
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,105 @@
// smithy-typescript generated code
import { getSerdePlugin } from "@aws-sdk/middleware-serde";
import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@aws-sdk/protocol-http";
import { Command as $Command } from "@aws-sdk/smithy-client";
import {
FinalizeHandlerArguments,
Handler,
HandlerExecutionContext,
HttpHandlerOptions as __HttpHandlerOptions,
MetadataBearer as __MetadataBearer,
MiddlewareStack,
SerdeContext as __SerdeContext,
} from "@aws-sdk/types";

import {
DatabaseMigrationServiceClientResolvedConfig,
ServiceInputTypes,
ServiceOutputTypes,
} from "../DatabaseMigrationServiceClient";
import { CreateFleetAdvisorCollectorRequest, CreateFleetAdvisorCollectorResponse } from "../models/models_0";
import {
deserializeAws_json1_1CreateFleetAdvisorCollectorCommand,
serializeAws_json1_1CreateFleetAdvisorCollectorCommand,
} from "../protocols/Aws_json1_1";

export interface CreateFleetAdvisorCollectorCommandInput extends CreateFleetAdvisorCollectorRequest {}
export interface CreateFleetAdvisorCollectorCommandOutput
extends CreateFleetAdvisorCollectorResponse,
__MetadataBearer {}

/**
* <p>Creates a Fleet Advisor collector using the specified parameters.</p>
* @example
* Use a bare-bones client and the command you need to make an API call.
* ```javascript
* import { DatabaseMigrationServiceClient, CreateFleetAdvisorCollectorCommand } from "@aws-sdk/client-database-migration-service"; // ES Modules import
* // const { DatabaseMigrationServiceClient, CreateFleetAdvisorCollectorCommand } = require("@aws-sdk/client-database-migration-service"); // CommonJS import
* const client = new DatabaseMigrationServiceClient(config);
* const command = new CreateFleetAdvisorCollectorCommand(input);
* const response = await client.send(command);
* ```
*
* @see {@link CreateFleetAdvisorCollectorCommandInput} for command's `input` shape.
* @see {@link CreateFleetAdvisorCollectorCommandOutput} for command's `response` shape.
* @see {@link DatabaseMigrationServiceClientResolvedConfig | config} for DatabaseMigrationServiceClient's `config` shape.
*
*/
export class CreateFleetAdvisorCollectorCommand extends $Command<
CreateFleetAdvisorCollectorCommandInput,
CreateFleetAdvisorCollectorCommandOutput,
DatabaseMigrationServiceClientResolvedConfig
> {
// Start section: command_properties
// End section: command_properties

constructor(readonly input: CreateFleetAdvisorCollectorCommandInput) {
// Start section: command_constructor
super();
// End section: command_constructor
}

/**
* @internal
*/
resolveMiddleware(
clientStack: MiddlewareStack<ServiceInputTypes, ServiceOutputTypes>,
configuration: DatabaseMigrationServiceClientResolvedConfig,
options?: __HttpHandlerOptions
): Handler<CreateFleetAdvisorCollectorCommandInput, CreateFleetAdvisorCollectorCommandOutput> {
this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize));

const stack = clientStack.concat(this.middlewareStack);

const { logger } = configuration;
const clientName = "DatabaseMigrationServiceClient";
const commandName = "CreateFleetAdvisorCollectorCommand";
const handlerExecutionContext: HandlerExecutionContext = {
logger,
clientName,
commandName,
inputFilterSensitiveLog: CreateFleetAdvisorCollectorRequest.filterSensitiveLog,
outputFilterSensitiveLog: CreateFleetAdvisorCollectorResponse.filterSensitiveLog,
};
const { requestHandler } = configuration;
return stack.resolve(
(request: FinalizeHandlerArguments<any>) =>
requestHandler.handle(request.request as __HttpRequest, options || {}),
handlerExecutionContext
);
}

private serialize(input: CreateFleetAdvisorCollectorCommandInput, context: __SerdeContext): Promise<__HttpRequest> {
return serializeAws_json1_1CreateFleetAdvisorCollectorCommand(input, context);
}

private deserialize(
output: __HttpResponse,
context: __SerdeContext
): Promise<CreateFleetAdvisorCollectorCommandOutput> {
return deserializeAws_json1_1CreateFleetAdvisorCollectorCommand(output, context);
}

// Start section: command_body_extra
// End section: command_body_extra
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,103 @@
// smithy-typescript generated code
import { getSerdePlugin } from "@aws-sdk/middleware-serde";
import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@aws-sdk/protocol-http";
import { Command as $Command } from "@aws-sdk/smithy-client";
import {
FinalizeHandlerArguments,
Handler,
HandlerExecutionContext,
HttpHandlerOptions as __HttpHandlerOptions,
MetadataBearer as __MetadataBearer,
MiddlewareStack,
SerdeContext as __SerdeContext,
} from "@aws-sdk/types";

import {
DatabaseMigrationServiceClientResolvedConfig,
ServiceInputTypes,
ServiceOutputTypes,
} from "../DatabaseMigrationServiceClient";
import { DeleteCollectorRequest } from "../models/models_0";
import {
deserializeAws_json1_1DeleteFleetAdvisorCollectorCommand,
serializeAws_json1_1DeleteFleetAdvisorCollectorCommand,
} from "../protocols/Aws_json1_1";

export interface DeleteFleetAdvisorCollectorCommandInput extends DeleteCollectorRequest {}
export interface DeleteFleetAdvisorCollectorCommandOutput extends __MetadataBearer {}

/**
* <p>Deletes the specified Fleet Advisor collector.</p>
* @example
* Use a bare-bones client and the command you need to make an API call.
* ```javascript
* import { DatabaseMigrationServiceClient, DeleteFleetAdvisorCollectorCommand } from "@aws-sdk/client-database-migration-service"; // ES Modules import
* // const { DatabaseMigrationServiceClient, DeleteFleetAdvisorCollectorCommand } = require("@aws-sdk/client-database-migration-service"); // CommonJS import
* const client = new DatabaseMigrationServiceClient(config);
* const command = new DeleteFleetAdvisorCollectorCommand(input);
* const response = await client.send(command);
* ```
*
* @see {@link DeleteFleetAdvisorCollectorCommandInput} for command's `input` shape.
* @see {@link DeleteFleetAdvisorCollectorCommandOutput} for command's `response` shape.
* @see {@link DatabaseMigrationServiceClientResolvedConfig | config} for DatabaseMigrationServiceClient's `config` shape.
*
*/
export class DeleteFleetAdvisorCollectorCommand extends $Command<
DeleteFleetAdvisorCollectorCommandInput,
DeleteFleetAdvisorCollectorCommandOutput,
DatabaseMigrationServiceClientResolvedConfig
> {
// Start section: command_properties
// End section: command_properties

constructor(readonly input: DeleteFleetAdvisorCollectorCommandInput) {
// Start section: command_constructor
super();
// End section: command_constructor
}

/**
* @internal
*/
resolveMiddleware(
clientStack: MiddlewareStack<ServiceInputTypes, ServiceOutputTypes>,
configuration: DatabaseMigrationServiceClientResolvedConfig,
options?: __HttpHandlerOptions
): Handler<DeleteFleetAdvisorCollectorCommandInput, DeleteFleetAdvisorCollectorCommandOutput> {
this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize));

const stack = clientStack.concat(this.middlewareStack);

const { logger } = configuration;
const clientName = "DatabaseMigrationServiceClient";
const commandName = "DeleteFleetAdvisorCollectorCommand";
const handlerExecutionContext: HandlerExecutionContext = {
logger,
clientName,
commandName,
inputFilterSensitiveLog: DeleteCollectorRequest.filterSensitiveLog,
outputFilterSensitiveLog: (output: any) => output,
};
const { requestHandler } = configuration;
return stack.resolve(
(request: FinalizeHandlerArguments<any>) =>
requestHandler.handle(request.request as __HttpRequest, options || {}),
handlerExecutionContext
);
}

private serialize(input: DeleteFleetAdvisorCollectorCommandInput, context: __SerdeContext): Promise<__HttpRequest> {
return serializeAws_json1_1DeleteFleetAdvisorCollectorCommand(input, context);
}

private deserialize(
output: __HttpResponse,
context: __SerdeContext
): Promise<DeleteFleetAdvisorCollectorCommandOutput> {
return deserializeAws_json1_1DeleteFleetAdvisorCollectorCommand(output, context);
}

// Start section: command_body_extra
// End section: command_body_extra
}
Loading

0 comments on commit 9d1b69c

Please sign in to comment.