Skip to content

Commit

Permalink
feat(client-database-migration-service): Added support for tagging in…
Browse files Browse the repository at this point in the history
… StartReplicationTaskAssessmentRun API and introduced IsLatestTaskAssessmentRun and ResultStatistic fields for enhanced tracking and assessment result statistics.
  • Loading branch information
awstools committed Oct 21, 2024
1 parent e4411e6 commit 9588015
Show file tree
Hide file tree
Showing 15 changed files with 232 additions and 28 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,14 @@ export interface CancelReplicationTaskAssessmentRunCommandOutput
* // ResultEncryptionMode: "STRING_VALUE",
* // ResultKmsKeyArn: "STRING_VALUE",
* // AssessmentRunName: "STRING_VALUE",
* // IsLatestTaskAssessmentRun: true || false,
* // ResultStatistic: { // ReplicationTaskAssessmentRunResultStatistic
* // Passed: Number("int"),
* // Failed: Number("int"),
* // Error: Number("int"),
* // Warning: Number("int"),
* // Cancelled: Number("int"),
* // },
* // },
* // };
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,6 +108,9 @@ export interface CreateDataMigrationCommandOutput extends CreateDataMigrationRes
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,9 @@ export interface DeleteDataMigrationCommandOutput extends DeleteDataMigrationRes
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,14 @@ export interface DeleteReplicationTaskAssessmentRunCommandOutput
* // ResultEncryptionMode: "STRING_VALUE",
* // ResultKmsKeyArn: "STRING_VALUE",
* // AssessmentRunName: "STRING_VALUE",
* // IsLatestTaskAssessmentRun: true || false,
* // ResultStatistic: { // ReplicationTaskAssessmentRunResultStatistic
* // Passed: Number("int"),
* // Failed: Number("int"),
* // Error: Number("int"),
* // Warning: Number("int"),
* // Cancelled: Number("int"),
* // },
* // },
* // };
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,9 @@ export interface DescribeDataMigrationsCommandOutput extends DescribeDataMigrati
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,14 @@ export interface DescribeReplicationTaskAssessmentRunsCommandOutput
* // ResultEncryptionMode: "STRING_VALUE",
* // ResultKmsKeyArn: "STRING_VALUE",
* // AssessmentRunName: "STRING_VALUE",
* // IsLatestTaskAssessmentRun: true || false,
* // ResultStatistic: { // ReplicationTaskAssessmentRunResultStatistic
* // Passed: Number("int"),
* // Failed: Number("int"),
* // Error: Number("int"),
* // Warning: Number("int"),
* // Cancelled: Number("int"),
* // },
* // },
* // ],
* // };
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,8 @@ import {
ServiceOutputTypes,
} from "../DatabaseMigrationServiceClient";
import { commonParams } from "../endpoint/EndpointParameters";
import { DescribeTableStatisticsMessage, DescribeTableStatisticsResponse } from "../models/models_0";
import { DescribeTableStatisticsMessage } from "../models/models_0";
import { DescribeTableStatisticsResponse } from "../models/models_1";
import { de_DescribeTableStatisticsCommand, se_DescribeTableStatisticsCommand } from "../protocols/Aws_json1_1";

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -101,6 +101,9 @@ export interface ModifyDataMigrationCommandOutput extends ModifyDataMigrationRes
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,9 @@ export interface StartDataMigrationCommandOutput extends StartDataMigrationRespo
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,13 @@ export interface StartReplicationTaskAssessmentRunCommandOutput
* Exclude: [ // ExcludeTestList
* "STRING_VALUE",
* ],
* Tags: [ // TagList
* { // Tag
* Key: "STRING_VALUE",
* Value: "STRING_VALUE",
* ResourceArn: "STRING_VALUE",
* },
* ],
* };
* const command = new StartReplicationTaskAssessmentRunCommand(input);
* const response = await client.send(command);
Expand All @@ -87,6 +94,14 @@ export interface StartReplicationTaskAssessmentRunCommandOutput
* // ResultEncryptionMode: "STRING_VALUE",
* // ResultKmsKeyArn: "STRING_VALUE",
* // AssessmentRunName: "STRING_VALUE",
* // IsLatestTaskAssessmentRun: true || false,
* // ResultStatistic: { // ReplicationTaskAssessmentRunResultStatistic
* // Passed: Number("int"),
* // Failed: Number("int"),
* // Error: Number("int"),
* // Warning: Number("int"),
* // Cancelled: Number("int"),
* // },
* // },
* // };
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,9 @@ export interface StopDataMigrationCommandOutput extends StopDataMigrationRespons
* // PublicIpAddresses: [ // PublicIpAddressList
* // "STRING_VALUE",
* // ],
* // DataMigrationCidrBlocks: [ // DataMigrationCidrBlock
* // "STRING_VALUE",
* // ],
* // LastFailureMessage: "STRING_VALUE",
* // StopReason: "STRING_VALUE",
* // },
Expand Down
84 changes: 58 additions & 26 deletions clients/client-database-migration-service/src/models/models_0.ts
Original file line number Diff line number Diff line change
Expand Up @@ -415,6 +415,44 @@ export interface ReplicationTaskAssessmentRunProgress {
IndividualAssessmentCompletedCount?: number;
}

/**
* <p>The object containing the result statistics for a completed assessment run.</p>
* @public
*/
export interface ReplicationTaskAssessmentRunResultStatistic {
/**
* <p>The number of individual assessments that successfully passed all checks in the assessment run.</p>
* @public
*/
Passed?: number;

/**
* <p>The number of individual assessments that failed to meet the criteria defined in the assessment run.</p>
* @public
*/
Failed?: number;

/**
* <p>The number of individual assessments that encountered a critical error and could not complete properly.</p>
* @public
*/
Error?: number;

/**
* <p>Indicates that the recent completed AssessmentRun triggered a warning.</p>
* @public
*/
Warning?: number;

/**
* <p>
* The number of individual assessments that were cancelled during the assessment run.
* </p>
* @public
*/
Cancelled?: number;
}

/**
* <p>Provides information that describes a premigration assessment run that you have started
* using the <code>StartReplicationTaskAssessmentRun</code> operation.</p>
Expand Down Expand Up @@ -550,6 +588,20 @@ export interface ReplicationTaskAssessmentRun {
* @public
*/
AssessmentRunName?: string;

/**
* <p>Indicates that the following PreflightAssessmentRun is the latest for the ReplicationTask. The status is either true or false.</p>
* @public
*/
IsLatestTaskAssessmentRun?: boolean;

/**
* <p>
* Result statistics for a completed assessment run, showing aggregated statistics of IndividualAssessments for how many assessments were passed, failed, or encountered issues such as errors or warnings.
* </p>
* @public
*/
ResultStatistic?: ReplicationTaskAssessmentRunResultStatistic;
}

/**
Expand Down Expand Up @@ -853,6 +905,12 @@ export interface DataMigration {
*/
PublicIpAddresses?: string[];

/**
* <p>The CIDR blocks of the endpoints for the data migration.</p>
* @public
*/
DataMigrationCidrBlocks?: string[];

/**
* <p>Information about the data migration's most recent error or failure.</p>
* @public
Expand Down Expand Up @@ -12679,32 +12737,6 @@ export interface DescribeTableStatisticsMessage {
Filters?: Filter[];
}

/**
* <p></p>
* @public
*/
export interface DescribeTableStatisticsResponse {
/**
* <p>The Amazon Resource Name (ARN) of the replication task.</p>
* @public
*/
ReplicationTaskArn?: string;

/**
* <p>The table statistics.</p>
* @public
*/
TableStatistics?: TableStatistics[];

/**
* <p> An optional pagination token provided by a previous request. If this parameter is
* specified, the response includes only records beyond the marker, up to the value specified
* by <code>MaxRecords</code>. </p>
* @public
*/
Marker?: string;
}

/**
* @internal
*/
Expand Down
33 changes: 33 additions & 0 deletions clients/client-database-migration-service/src/models/models_1.ts
Original file line number Diff line number Diff line change
Expand Up @@ -60,10 +60,37 @@ import {
SourceDataSetting,
SybaseSettings,
SybaseSettingsFilterSensitiveLog,
TableStatistics,
Tag,
TimestreamSettings,
} from "./models_0";

/**
* <p></p>
* @public
*/
export interface DescribeTableStatisticsResponse {
/**
* <p>The Amazon Resource Name (ARN) of the replication task.</p>
* @public
*/
ReplicationTaskArn?: string;

/**
* <p>The table statistics.</p>
* @public
*/
TableStatistics?: TableStatistics[];

/**
* <p> An optional pagination token provided by a previous request. If this parameter is
* specified, the response includes only records beyond the marker, up to the value specified
* by <code>MaxRecords</code>. </p>
* @public
*/
Marker?: string;
}

/**
* @public
* @enum
Expand Down Expand Up @@ -2139,6 +2166,12 @@ export interface StartReplicationTaskAssessmentRunMessage {
* @public
*/
Exclude?: string[];

/**
* <p>One or more tags to be assigned to the premigration assessment run that you want to start.</p>
* @public
*/
Tags?: Tag[];
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -540,7 +540,6 @@ import {
DescribeReplicationTasksResponse,
DescribeSchemasMessage,
DescribeTableStatisticsMessage,
DescribeTableStatisticsResponse,
DmsTransferSettings,
DocDbDataProviderSettings,
DocDbSettings,
Expand Down Expand Up @@ -621,6 +620,7 @@ import {
} from "../models/models_0";
import {
AssessmentReportType,
DescribeTableStatisticsResponse,
ExportMetadataModelAssessmentMessage,
ImportCertificateMessage,
ImportCertificateResponse,
Expand Down Expand Up @@ -5504,6 +5504,7 @@ const de_CreateReplicationTaskResponse = (output: any, context: __SerdeContext):
const de_DataMigration = (output: any, context: __SerdeContext): DataMigration => {
return take(output, {
DataMigrationArn: __expectString,
DataMigrationCidrBlocks: _json,
DataMigrationCreateTime: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)),
DataMigrationEndTime: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)),
DataMigrationName: __expectString,
Expand All @@ -5521,6 +5522,8 @@ const de_DataMigration = (output: any, context: __SerdeContext): DataMigration =
}) as any;
};

// de_DataMigrationCidrBlock omitted.

/**
* deserializeAws_json1_1DataMigrations
*/
Expand Down Expand Up @@ -6714,6 +6717,7 @@ const de_ReplicationTaskAssessmentRun = (output: any, context: __SerdeContext):
return take(output, {
AssessmentProgress: _json,
AssessmentRunName: __expectString,
IsLatestTaskAssessmentRun: __expectBoolean,
LastFailureMessage: __expectString,
ReplicationTaskArn: __expectString,
ReplicationTaskAssessmentRunArn: __expectString,
Expand All @@ -6722,6 +6726,7 @@ const de_ReplicationTaskAssessmentRun = (output: any, context: __SerdeContext):
ResultKmsKeyArn: __expectString,
ResultLocationBucket: __expectString,
ResultLocationFolder: __expectString,
ResultStatistic: _json,
ServiceAccessRoleArn: __expectString,
Status: __expectString,
}) as any;
Expand All @@ -6741,6 +6746,8 @@ const de_ReplicationTaskAssessmentRunList = (output: any, context: __SerdeContex

// de_ReplicationTaskAssessmentRunProgress omitted.

// de_ReplicationTaskAssessmentRunResultStatistic omitted.

/**
* deserializeAws_json1_1ReplicationTaskIndividualAssessment
*/
Expand Down
Loading

0 comments on commit 9588015

Please sign in to comment.