service/databasemigrationservice/validators.go (4,030 lines of code) (raw):

// Code generated by smithy-go-codegen DO NOT EDIT. package databasemigrationservice import ( "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/databasemigrationservice/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpAddTagsToResource struct { } func (*validateOpAddTagsToResource) ID() string { return "OperationInputValidation" } func (m *validateOpAddTagsToResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*AddTagsToResourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpAddTagsToResourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpApplyPendingMaintenanceAction struct { } func (*validateOpApplyPendingMaintenanceAction) ID() string { return "OperationInputValidation" } func (m *validateOpApplyPendingMaintenanceAction) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ApplyPendingMaintenanceActionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpApplyPendingMaintenanceActionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpBatchStartRecommendations struct { } func (*validateOpBatchStartRecommendations) ID() string { return "OperationInputValidation" } func (m *validateOpBatchStartRecommendations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*BatchStartRecommendationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpBatchStartRecommendationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCancelReplicationTaskAssessmentRun struct { } func (*validateOpCancelReplicationTaskAssessmentRun) ID() string { return "OperationInputValidation" } func (m *validateOpCancelReplicationTaskAssessmentRun) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CancelReplicationTaskAssessmentRunInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCancelReplicationTaskAssessmentRunInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateDataMigration struct { } func (*validateOpCreateDataMigration) ID() string { return "OperationInputValidation" } func (m *validateOpCreateDataMigration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateDataMigrationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateDataMigrationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateDataProvider struct { } func (*validateOpCreateDataProvider) ID() string { return "OperationInputValidation" } func (m *validateOpCreateDataProvider) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateDataProviderInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateDataProviderInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateEndpoint struct { } func (*validateOpCreateEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateEventSubscription struct { } func (*validateOpCreateEventSubscription) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEventSubscription) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEventSubscriptionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEventSubscriptionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateFleetAdvisorCollector struct { } func (*validateOpCreateFleetAdvisorCollector) ID() string { return "OperationInputValidation" } func (m *validateOpCreateFleetAdvisorCollector) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateFleetAdvisorCollectorInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateFleetAdvisorCollectorInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateMigrationProject struct { } func (*validateOpCreateMigrationProject) ID() string { return "OperationInputValidation" } func (m *validateOpCreateMigrationProject) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateMigrationProjectInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateMigrationProjectInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateReplicationConfig struct { } func (*validateOpCreateReplicationConfig) ID() string { return "OperationInputValidation" } func (m *validateOpCreateReplicationConfig) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateReplicationConfigInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateReplicationConfigInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateReplicationInstance struct { } func (*validateOpCreateReplicationInstance) ID() string { return "OperationInputValidation" } func (m *validateOpCreateReplicationInstance) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateReplicationInstanceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateReplicationInstanceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateReplicationSubnetGroup struct { } func (*validateOpCreateReplicationSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpCreateReplicationSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateReplicationSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateReplicationSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateReplicationTask struct { } func (*validateOpCreateReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpCreateReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteCertificate struct { } func (*validateOpDeleteCertificate) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteCertificate) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteCertificateInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteCertificateInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteConnection struct { } func (*validateOpDeleteConnection) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteDataMigration struct { } func (*validateOpDeleteDataMigration) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteDataMigration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteDataMigrationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteDataMigrationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteDataProvider struct { } func (*validateOpDeleteDataProvider) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteDataProvider) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteDataProviderInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteDataProviderInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEndpoint struct { } func (*validateOpDeleteEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEventSubscription struct { } func (*validateOpDeleteEventSubscription) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEventSubscription) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEventSubscriptionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEventSubscriptionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteFleetAdvisorCollector struct { } func (*validateOpDeleteFleetAdvisorCollector) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteFleetAdvisorCollector) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteFleetAdvisorCollectorInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteFleetAdvisorCollectorInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteFleetAdvisorDatabases struct { } func (*validateOpDeleteFleetAdvisorDatabases) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteFleetAdvisorDatabases) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteFleetAdvisorDatabasesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteFleetAdvisorDatabasesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteInstanceProfile struct { } func (*validateOpDeleteInstanceProfile) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteInstanceProfile) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteInstanceProfileInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteInstanceProfileInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteMigrationProject struct { } func (*validateOpDeleteMigrationProject) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteMigrationProject) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteMigrationProjectInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteMigrationProjectInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteReplicationConfig struct { } func (*validateOpDeleteReplicationConfig) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteReplicationConfig) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteReplicationConfigInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteReplicationConfigInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteReplicationInstance struct { } func (*validateOpDeleteReplicationInstance) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteReplicationInstance) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteReplicationInstanceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteReplicationInstanceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteReplicationSubnetGroup struct { } func (*validateOpDeleteReplicationSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteReplicationSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteReplicationSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteReplicationSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteReplicationTaskAssessmentRun struct { } func (*validateOpDeleteReplicationTaskAssessmentRun) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteReplicationTaskAssessmentRun) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteReplicationTaskAssessmentRunInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteReplicationTaskAssessmentRunInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteReplicationTask struct { } func (*validateOpDeleteReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeCertificates struct { } func (*validateOpDescribeCertificates) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeCertificates) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeCertificatesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeCertificatesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeConnections struct { } func (*validateOpDescribeConnections) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeConnections) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeConnectionsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeConnectionsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeConversionConfiguration struct { } func (*validateOpDescribeConversionConfiguration) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeConversionConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeConversionConfigurationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeConversionConfigurationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeDataMigrations struct { } func (*validateOpDescribeDataMigrations) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeDataMigrations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeDataMigrationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeDataMigrationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeDataProviders struct { } func (*validateOpDescribeDataProviders) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeDataProviders) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeDataProvidersInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeDataProvidersInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEndpointSettings struct { } func (*validateOpDescribeEndpointSettings) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEndpointSettings) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEndpointSettingsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEndpointSettingsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEndpoints struct { } func (*validateOpDescribeEndpoints) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEndpoints) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEndpointsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEndpointsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEndpointTypes struct { } func (*validateOpDescribeEndpointTypes) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEndpointTypes) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEndpointTypesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEndpointTypesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEventCategories struct { } func (*validateOpDescribeEventCategories) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEventCategories) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEventCategoriesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEventCategoriesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEvents struct { } func (*validateOpDescribeEvents) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEventsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEventsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEventSubscriptions struct { } func (*validateOpDescribeEventSubscriptions) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEventSubscriptions) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEventSubscriptionsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEventSubscriptionsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeExtensionPackAssociations struct { } func (*validateOpDescribeExtensionPackAssociations) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeExtensionPackAssociations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeExtensionPackAssociationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeExtensionPackAssociationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeFleetAdvisorCollectors struct { } func (*validateOpDescribeFleetAdvisorCollectors) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeFleetAdvisorCollectors) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeFleetAdvisorCollectorsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeFleetAdvisorCollectorsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeFleetAdvisorDatabases struct { } func (*validateOpDescribeFleetAdvisorDatabases) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeFleetAdvisorDatabases) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeFleetAdvisorDatabasesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeFleetAdvisorDatabasesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeFleetAdvisorSchemaObjectSummary struct { } func (*validateOpDescribeFleetAdvisorSchemaObjectSummary) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeFleetAdvisorSchemaObjectSummary) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeFleetAdvisorSchemaObjectSummaryInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeFleetAdvisorSchemaObjectSummaryInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeFleetAdvisorSchemas struct { } func (*validateOpDescribeFleetAdvisorSchemas) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeFleetAdvisorSchemas) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeFleetAdvisorSchemasInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeFleetAdvisorSchemasInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeInstanceProfiles struct { } func (*validateOpDescribeInstanceProfiles) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeInstanceProfiles) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeInstanceProfilesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeInstanceProfilesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMetadataModelAssessments struct { } func (*validateOpDescribeMetadataModelAssessments) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMetadataModelAssessments) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMetadataModelAssessmentsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMetadataModelAssessmentsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMetadataModelConversions struct { } func (*validateOpDescribeMetadataModelConversions) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMetadataModelConversions) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMetadataModelConversionsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMetadataModelConversionsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMetadataModelExportsAsScript struct { } func (*validateOpDescribeMetadataModelExportsAsScript) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMetadataModelExportsAsScript) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMetadataModelExportsAsScriptInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMetadataModelExportsAsScriptInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMetadataModelExportsToTarget struct { } func (*validateOpDescribeMetadataModelExportsToTarget) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMetadataModelExportsToTarget) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMetadataModelExportsToTargetInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMetadataModelExportsToTargetInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMetadataModelImports struct { } func (*validateOpDescribeMetadataModelImports) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMetadataModelImports) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMetadataModelImportsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMetadataModelImportsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeMigrationProjects struct { } func (*validateOpDescribeMigrationProjects) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeMigrationProjects) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeMigrationProjectsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeMigrationProjectsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribePendingMaintenanceActions struct { } func (*validateOpDescribePendingMaintenanceActions) ID() string { return "OperationInputValidation" } func (m *validateOpDescribePendingMaintenanceActions) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribePendingMaintenanceActionsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribePendingMaintenanceActionsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeRecommendationLimitations struct { } func (*validateOpDescribeRecommendationLimitations) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeRecommendationLimitations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeRecommendationLimitationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeRecommendationLimitationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeRecommendations struct { } func (*validateOpDescribeRecommendations) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeRecommendations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeRecommendationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeRecommendationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeRefreshSchemasStatus struct { } func (*validateOpDescribeRefreshSchemasStatus) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeRefreshSchemasStatus) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeRefreshSchemasStatusInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeRefreshSchemasStatusInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationConfigs struct { } func (*validateOpDescribeReplicationConfigs) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationConfigs) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationConfigsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationConfigsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationInstances struct { } func (*validateOpDescribeReplicationInstances) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationInstances) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationInstancesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationInstancesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationInstanceTaskLogs struct { } func (*validateOpDescribeReplicationInstanceTaskLogs) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationInstanceTaskLogs) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationInstanceTaskLogsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationInstanceTaskLogsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplications struct { } func (*validateOpDescribeReplications) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplications) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationSubnetGroups struct { } func (*validateOpDescribeReplicationSubnetGroups) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationSubnetGroups) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationSubnetGroupsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationSubnetGroupsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationTableStatistics struct { } func (*validateOpDescribeReplicationTableStatistics) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationTableStatistics) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationTableStatisticsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationTableStatisticsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationTaskAssessmentRuns struct { } func (*validateOpDescribeReplicationTaskAssessmentRuns) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationTaskAssessmentRuns) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationTaskAssessmentRunsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationTaskAssessmentRunsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationTaskIndividualAssessments struct { } func (*validateOpDescribeReplicationTaskIndividualAssessments) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationTaskIndividualAssessments) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationTaskIndividualAssessmentsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationTaskIndividualAssessmentsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplicationTasks struct { } func (*validateOpDescribeReplicationTasks) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplicationTasks) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplicationTasksInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplicationTasksInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeSchemas struct { } func (*validateOpDescribeSchemas) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeSchemas) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeSchemasInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeSchemasInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeTableStatistics struct { } func (*validateOpDescribeTableStatistics) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeTableStatistics) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeTableStatisticsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeTableStatisticsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpExportMetadataModelAssessment struct { } func (*validateOpExportMetadataModelAssessment) ID() string { return "OperationInputValidation" } func (m *validateOpExportMetadataModelAssessment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ExportMetadataModelAssessmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpExportMetadataModelAssessmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpImportCertificate struct { } func (*validateOpImportCertificate) ID() string { return "OperationInputValidation" } func (m *validateOpImportCertificate) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ImportCertificateInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpImportCertificateInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyConversionConfiguration struct { } func (*validateOpModifyConversionConfiguration) ID() string { return "OperationInputValidation" } func (m *validateOpModifyConversionConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyConversionConfigurationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyConversionConfigurationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyDataMigration struct { } func (*validateOpModifyDataMigration) ID() string { return "OperationInputValidation" } func (m *validateOpModifyDataMigration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyDataMigrationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyDataMigrationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyDataProvider struct { } func (*validateOpModifyDataProvider) ID() string { return "OperationInputValidation" } func (m *validateOpModifyDataProvider) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyDataProviderInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyDataProviderInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyEndpoint struct { } func (*validateOpModifyEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpModifyEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyEventSubscription struct { } func (*validateOpModifyEventSubscription) ID() string { return "OperationInputValidation" } func (m *validateOpModifyEventSubscription) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyEventSubscriptionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyEventSubscriptionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyInstanceProfile struct { } func (*validateOpModifyInstanceProfile) ID() string { return "OperationInputValidation" } func (m *validateOpModifyInstanceProfile) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyInstanceProfileInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyInstanceProfileInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyMigrationProject struct { } func (*validateOpModifyMigrationProject) ID() string { return "OperationInputValidation" } func (m *validateOpModifyMigrationProject) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyMigrationProjectInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyMigrationProjectInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyReplicationConfig struct { } func (*validateOpModifyReplicationConfig) ID() string { return "OperationInputValidation" } func (m *validateOpModifyReplicationConfig) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyReplicationConfigInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyReplicationConfigInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyReplicationInstance struct { } func (*validateOpModifyReplicationInstance) ID() string { return "OperationInputValidation" } func (m *validateOpModifyReplicationInstance) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyReplicationInstanceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyReplicationInstanceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyReplicationSubnetGroup struct { } func (*validateOpModifyReplicationSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpModifyReplicationSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyReplicationSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyReplicationSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpModifyReplicationTask struct { } func (*validateOpModifyReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpModifyReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ModifyReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpModifyReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpMoveReplicationTask struct { } func (*validateOpMoveReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpMoveReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*MoveReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpMoveReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRebootReplicationInstance struct { } func (*validateOpRebootReplicationInstance) ID() string { return "OperationInputValidation" } func (m *validateOpRebootReplicationInstance) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RebootReplicationInstanceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRebootReplicationInstanceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRefreshSchemas struct { } func (*validateOpRefreshSchemas) ID() string { return "OperationInputValidation" } func (m *validateOpRefreshSchemas) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RefreshSchemasInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRefreshSchemasInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpReloadReplicationTables struct { } func (*validateOpReloadReplicationTables) ID() string { return "OperationInputValidation" } func (m *validateOpReloadReplicationTables) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ReloadReplicationTablesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpReloadReplicationTablesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpReloadTables struct { } func (*validateOpReloadTables) ID() string { return "OperationInputValidation" } func (m *validateOpReloadTables) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ReloadTablesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpReloadTablesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRemoveTagsFromResource struct { } func (*validateOpRemoveTagsFromResource) ID() string { return "OperationInputValidation" } func (m *validateOpRemoveTagsFromResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RemoveTagsFromResourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRemoveTagsFromResourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartDataMigration struct { } func (*validateOpStartDataMigration) ID() string { return "OperationInputValidation" } func (m *validateOpStartDataMigration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartDataMigrationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartDataMigrationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartExtensionPackAssociation struct { } func (*validateOpStartExtensionPackAssociation) ID() string { return "OperationInputValidation" } func (m *validateOpStartExtensionPackAssociation) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartExtensionPackAssociationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartExtensionPackAssociationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartMetadataModelAssessment struct { } func (*validateOpStartMetadataModelAssessment) ID() string { return "OperationInputValidation" } func (m *validateOpStartMetadataModelAssessment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartMetadataModelAssessmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartMetadataModelAssessmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartMetadataModelConversion struct { } func (*validateOpStartMetadataModelConversion) ID() string { return "OperationInputValidation" } func (m *validateOpStartMetadataModelConversion) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartMetadataModelConversionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartMetadataModelConversionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartMetadataModelExportAsScript struct { } func (*validateOpStartMetadataModelExportAsScript) ID() string { return "OperationInputValidation" } func (m *validateOpStartMetadataModelExportAsScript) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartMetadataModelExportAsScriptInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartMetadataModelExportAsScriptInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartMetadataModelExportToTarget struct { } func (*validateOpStartMetadataModelExportToTarget) ID() string { return "OperationInputValidation" } func (m *validateOpStartMetadataModelExportToTarget) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartMetadataModelExportToTargetInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartMetadataModelExportToTargetInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartMetadataModelImport struct { } func (*validateOpStartMetadataModelImport) ID() string { return "OperationInputValidation" } func (m *validateOpStartMetadataModelImport) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartMetadataModelImportInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartMetadataModelImportInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartRecommendations struct { } func (*validateOpStartRecommendations) ID() string { return "OperationInputValidation" } func (m *validateOpStartRecommendations) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartRecommendationsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartRecommendationsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartReplication struct { } func (*validateOpStartReplication) ID() string { return "OperationInputValidation" } func (m *validateOpStartReplication) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartReplicationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartReplicationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartReplicationTaskAssessment struct { } func (*validateOpStartReplicationTaskAssessment) ID() string { return "OperationInputValidation" } func (m *validateOpStartReplicationTaskAssessment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartReplicationTaskAssessmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartReplicationTaskAssessmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartReplicationTaskAssessmentRun struct { } func (*validateOpStartReplicationTaskAssessmentRun) ID() string { return "OperationInputValidation" } func (m *validateOpStartReplicationTaskAssessmentRun) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartReplicationTaskAssessmentRunInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartReplicationTaskAssessmentRunInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartReplicationTask struct { } func (*validateOpStartReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpStartReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStopDataMigration struct { } func (*validateOpStopDataMigration) ID() string { return "OperationInputValidation" } func (m *validateOpStopDataMigration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StopDataMigrationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStopDataMigrationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStopReplication struct { } func (*validateOpStopReplication) ID() string { return "OperationInputValidation" } func (m *validateOpStopReplication) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StopReplicationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStopReplicationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStopReplicationTask struct { } func (*validateOpStopReplicationTask) ID() string { return "OperationInputValidation" } func (m *validateOpStopReplicationTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StopReplicationTaskInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStopReplicationTaskInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpTestConnection struct { } func (*validateOpTestConnection) ID() string { return "OperationInputValidation" } func (m *validateOpTestConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*TestConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpTestConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpAddTagsToResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpAddTagsToResource{}, middleware.After) } func addOpApplyPendingMaintenanceActionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpApplyPendingMaintenanceAction{}, middleware.After) } func addOpBatchStartRecommendationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpBatchStartRecommendations{}, middleware.After) } func addOpCancelReplicationTaskAssessmentRunValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCancelReplicationTaskAssessmentRun{}, middleware.After) } func addOpCreateDataMigrationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateDataMigration{}, middleware.After) } func addOpCreateDataProviderValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateDataProvider{}, middleware.After) } func addOpCreateEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEndpoint{}, middleware.After) } func addOpCreateEventSubscriptionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEventSubscription{}, middleware.After) } func addOpCreateFleetAdvisorCollectorValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateFleetAdvisorCollector{}, middleware.After) } func addOpCreateMigrationProjectValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateMigrationProject{}, middleware.After) } func addOpCreateReplicationConfigValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateReplicationConfig{}, middleware.After) } func addOpCreateReplicationInstanceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateReplicationInstance{}, middleware.After) } func addOpCreateReplicationSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateReplicationSubnetGroup{}, middleware.After) } func addOpCreateReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateReplicationTask{}, middleware.After) } func addOpDeleteCertificateValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteCertificate{}, middleware.After) } func addOpDeleteConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteConnection{}, middleware.After) } func addOpDeleteDataMigrationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteDataMigration{}, middleware.After) } func addOpDeleteDataProviderValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteDataProvider{}, middleware.After) } func addOpDeleteEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEndpoint{}, middleware.After) } func addOpDeleteEventSubscriptionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEventSubscription{}, middleware.After) } func addOpDeleteFleetAdvisorCollectorValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteFleetAdvisorCollector{}, middleware.After) } func addOpDeleteFleetAdvisorDatabasesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteFleetAdvisorDatabases{}, middleware.After) } func addOpDeleteInstanceProfileValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteInstanceProfile{}, middleware.After) } func addOpDeleteMigrationProjectValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteMigrationProject{}, middleware.After) } func addOpDeleteReplicationConfigValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteReplicationConfig{}, middleware.After) } func addOpDeleteReplicationInstanceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteReplicationInstance{}, middleware.After) } func addOpDeleteReplicationSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteReplicationSubnetGroup{}, middleware.After) } func addOpDeleteReplicationTaskAssessmentRunValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteReplicationTaskAssessmentRun{}, middleware.After) } func addOpDeleteReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteReplicationTask{}, middleware.After) } func addOpDescribeCertificatesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeCertificates{}, middleware.After) } func addOpDescribeConnectionsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeConnections{}, middleware.After) } func addOpDescribeConversionConfigurationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeConversionConfiguration{}, middleware.After) } func addOpDescribeDataMigrationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeDataMigrations{}, middleware.After) } func addOpDescribeDataProvidersValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeDataProviders{}, middleware.After) } func addOpDescribeEndpointSettingsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEndpointSettings{}, middleware.After) } func addOpDescribeEndpointsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEndpoints{}, middleware.After) } func addOpDescribeEndpointTypesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEndpointTypes{}, middleware.After) } func addOpDescribeEventCategoriesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEventCategories{}, middleware.After) } func addOpDescribeEventsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEvents{}, middleware.After) } func addOpDescribeEventSubscriptionsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEventSubscriptions{}, middleware.After) } func addOpDescribeExtensionPackAssociationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeExtensionPackAssociations{}, middleware.After) } func addOpDescribeFleetAdvisorCollectorsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeFleetAdvisorCollectors{}, middleware.After) } func addOpDescribeFleetAdvisorDatabasesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeFleetAdvisorDatabases{}, middleware.After) } func addOpDescribeFleetAdvisorSchemaObjectSummaryValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeFleetAdvisorSchemaObjectSummary{}, middleware.After) } func addOpDescribeFleetAdvisorSchemasValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeFleetAdvisorSchemas{}, middleware.After) } func addOpDescribeInstanceProfilesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeInstanceProfiles{}, middleware.After) } func addOpDescribeMetadataModelAssessmentsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMetadataModelAssessments{}, middleware.After) } func addOpDescribeMetadataModelConversionsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMetadataModelConversions{}, middleware.After) } func addOpDescribeMetadataModelExportsAsScriptValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMetadataModelExportsAsScript{}, middleware.After) } func addOpDescribeMetadataModelExportsToTargetValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMetadataModelExportsToTarget{}, middleware.After) } func addOpDescribeMetadataModelImportsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMetadataModelImports{}, middleware.After) } func addOpDescribeMigrationProjectsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeMigrationProjects{}, middleware.After) } func addOpDescribePendingMaintenanceActionsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribePendingMaintenanceActions{}, middleware.After) } func addOpDescribeRecommendationLimitationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeRecommendationLimitations{}, middleware.After) } func addOpDescribeRecommendationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeRecommendations{}, middleware.After) } func addOpDescribeRefreshSchemasStatusValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeRefreshSchemasStatus{}, middleware.After) } func addOpDescribeReplicationConfigsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationConfigs{}, middleware.After) } func addOpDescribeReplicationInstancesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationInstances{}, middleware.After) } func addOpDescribeReplicationInstanceTaskLogsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationInstanceTaskLogs{}, middleware.After) } func addOpDescribeReplicationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplications{}, middleware.After) } func addOpDescribeReplicationSubnetGroupsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationSubnetGroups{}, middleware.After) } func addOpDescribeReplicationTableStatisticsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationTableStatistics{}, middleware.After) } func addOpDescribeReplicationTaskAssessmentRunsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationTaskAssessmentRuns{}, middleware.After) } func addOpDescribeReplicationTaskIndividualAssessmentsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationTaskIndividualAssessments{}, middleware.After) } func addOpDescribeReplicationTasksValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplicationTasks{}, middleware.After) } func addOpDescribeSchemasValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeSchemas{}, middleware.After) } func addOpDescribeTableStatisticsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeTableStatistics{}, middleware.After) } func addOpExportMetadataModelAssessmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpExportMetadataModelAssessment{}, middleware.After) } func addOpImportCertificateValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpImportCertificate{}, middleware.After) } func addOpModifyConversionConfigurationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyConversionConfiguration{}, middleware.After) } func addOpModifyDataMigrationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyDataMigration{}, middleware.After) } func addOpModifyDataProviderValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyDataProvider{}, middleware.After) } func addOpModifyEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyEndpoint{}, middleware.After) } func addOpModifyEventSubscriptionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyEventSubscription{}, middleware.After) } func addOpModifyInstanceProfileValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyInstanceProfile{}, middleware.After) } func addOpModifyMigrationProjectValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyMigrationProject{}, middleware.After) } func addOpModifyReplicationConfigValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyReplicationConfig{}, middleware.After) } func addOpModifyReplicationInstanceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyReplicationInstance{}, middleware.After) } func addOpModifyReplicationSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyReplicationSubnetGroup{}, middleware.After) } func addOpModifyReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpModifyReplicationTask{}, middleware.After) } func addOpMoveReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpMoveReplicationTask{}, middleware.After) } func addOpRebootReplicationInstanceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRebootReplicationInstance{}, middleware.After) } func addOpRefreshSchemasValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRefreshSchemas{}, middleware.After) } func addOpReloadReplicationTablesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpReloadReplicationTables{}, middleware.After) } func addOpReloadTablesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpReloadTables{}, middleware.After) } func addOpRemoveTagsFromResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRemoveTagsFromResource{}, middleware.After) } func addOpStartDataMigrationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartDataMigration{}, middleware.After) } func addOpStartExtensionPackAssociationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartExtensionPackAssociation{}, middleware.After) } func addOpStartMetadataModelAssessmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartMetadataModelAssessment{}, middleware.After) } func addOpStartMetadataModelConversionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartMetadataModelConversion{}, middleware.After) } func addOpStartMetadataModelExportAsScriptValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartMetadataModelExportAsScript{}, middleware.After) } func addOpStartMetadataModelExportToTargetValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartMetadataModelExportToTarget{}, middleware.After) } func addOpStartMetadataModelImportValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartMetadataModelImport{}, middleware.After) } func addOpStartRecommendationsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartRecommendations{}, middleware.After) } func addOpStartReplicationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartReplication{}, middleware.After) } func addOpStartReplicationTaskAssessmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartReplicationTaskAssessment{}, middleware.After) } func addOpStartReplicationTaskAssessmentRunValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartReplicationTaskAssessmentRun{}, middleware.After) } func addOpStartReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartReplicationTask{}, middleware.After) } func addOpStopDataMigrationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStopDataMigration{}, middleware.After) } func addOpStopReplicationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStopReplication{}, middleware.After) } func addOpStopReplicationTaskValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStopReplicationTask{}, middleware.After) } func addOpTestConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpTestConnection{}, middleware.After) } func validateDataProviderDescriptorDefinition(v *types.DataProviderDescriptorDefinition) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DataProviderDescriptorDefinition"} if v.DataProviderIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataProviderIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateDataProviderDescriptorDefinitionList(v []types.DataProviderDescriptorDefinition) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DataProviderDescriptorDefinitionList"} for i := range v { if err := validateDataProviderDescriptorDefinition(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateDynamoDbSettings(v *types.DynamoDbSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DynamoDbSettings"} if v.ServiceAccessRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ServiceAccessRoleArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateElasticsearchSettings(v *types.ElasticsearchSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ElasticsearchSettings"} if v.ServiceAccessRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ServiceAccessRoleArn")) } if v.EndpointUri == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointUri")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateFilter(v *types.Filter) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Filter"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.Values == nil { invalidParams.Add(smithy.NewErrParamRequired("Values")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateFilterList(v []types.Filter) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "FilterList"} for i := range v { if err := validateFilter(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateNeptuneSettings(v *types.NeptuneSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "NeptuneSettings"} if v.S3BucketName == nil { invalidParams.Add(smithy.NewErrParamRequired("S3BucketName")) } if v.S3BucketFolder == nil { invalidParams.Add(smithy.NewErrParamRequired("S3BucketFolder")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRecommendationSettings(v *types.RecommendationSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RecommendationSettings"} if v.InstanceSizingType == nil { invalidParams.Add(smithy.NewErrParamRequired("InstanceSizingType")) } if v.WorkloadType == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkloadType")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRedisSettings(v *types.RedisSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RedisSettings"} if v.ServerName == nil { invalidParams.Add(smithy.NewErrParamRequired("ServerName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateStartRecommendationsRequestEntry(v *types.StartRecommendationsRequestEntry) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartRecommendationsRequestEntry"} if v.DatabaseId == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseId")) } if v.Settings == nil { invalidParams.Add(smithy.NewErrParamRequired("Settings")) } else if v.Settings != nil { if err := validateRecommendationSettings(v.Settings); err != nil { invalidParams.AddNested("Settings", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateStartRecommendationsRequestEntryList(v []types.StartRecommendationsRequestEntry) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartRecommendationsRequestEntryList"} for i := range v { if err := validateStartRecommendationsRequestEntry(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTableListToReload(v []types.TableToReload) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TableListToReload"} for i := range v { if err := validateTableToReload(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTableToReload(v *types.TableToReload) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TableToReload"} if v.SchemaName == nil { invalidParams.Add(smithy.NewErrParamRequired("SchemaName")) } if v.TableName == nil { invalidParams.Add(smithy.NewErrParamRequired("TableName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTimestreamSettings(v *types.TimestreamSettings) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TimestreamSettings"} if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.MemoryDuration == nil { invalidParams.Add(smithy.NewErrParamRequired("MemoryDuration")) } if v.MagneticDuration == nil { invalidParams.Add(smithy.NewErrParamRequired("MagneticDuration")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpAddTagsToResourceInput(v *AddTagsToResourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "AddTagsToResourceInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if v.Tags == nil { invalidParams.Add(smithy.NewErrParamRequired("Tags")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpApplyPendingMaintenanceActionInput(v *ApplyPendingMaintenanceActionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ApplyPendingMaintenanceActionInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if v.ApplyAction == nil { invalidParams.Add(smithy.NewErrParamRequired("ApplyAction")) } if v.OptInType == nil { invalidParams.Add(smithy.NewErrParamRequired("OptInType")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpBatchStartRecommendationsInput(v *BatchStartRecommendationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "BatchStartRecommendationsInput"} if v.Data != nil { if err := validateStartRecommendationsRequestEntryList(v.Data); err != nil { invalidParams.AddNested("Data", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCancelReplicationTaskAssessmentRunInput(v *CancelReplicationTaskAssessmentRunInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CancelReplicationTaskAssessmentRunInput"} if v.ReplicationTaskAssessmentRunArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskAssessmentRunArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateDataMigrationInput(v *CreateDataMigrationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateDataMigrationInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if len(v.DataMigrationType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("DataMigrationType")) } if v.ServiceAccessRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ServiceAccessRoleArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateDataProviderInput(v *CreateDataProviderInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateDataProviderInput"} if v.Engine == nil { invalidParams.Add(smithy.NewErrParamRequired("Engine")) } if v.Settings == nil { invalidParams.Add(smithy.NewErrParamRequired("Settings")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEndpointInput(v *CreateEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEndpointInput"} if v.EndpointIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointIdentifier")) } if len(v.EndpointType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("EndpointType")) } if v.EngineName == nil { invalidParams.Add(smithy.NewErrParamRequired("EngineName")) } if v.DynamoDbSettings != nil { if err := validateDynamoDbSettings(v.DynamoDbSettings); err != nil { invalidParams.AddNested("DynamoDbSettings", err.(smithy.InvalidParamsError)) } } if v.ElasticsearchSettings != nil { if err := validateElasticsearchSettings(v.ElasticsearchSettings); err != nil { invalidParams.AddNested("ElasticsearchSettings", err.(smithy.InvalidParamsError)) } } if v.NeptuneSettings != nil { if err := validateNeptuneSettings(v.NeptuneSettings); err != nil { invalidParams.AddNested("NeptuneSettings", err.(smithy.InvalidParamsError)) } } if v.RedisSettings != nil { if err := validateRedisSettings(v.RedisSettings); err != nil { invalidParams.AddNested("RedisSettings", err.(smithy.InvalidParamsError)) } } if v.TimestreamSettings != nil { if err := validateTimestreamSettings(v.TimestreamSettings); err != nil { invalidParams.AddNested("TimestreamSettings", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEventSubscriptionInput(v *CreateEventSubscriptionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEventSubscriptionInput"} if v.SubscriptionName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubscriptionName")) } if v.SnsTopicArn == nil { invalidParams.Add(smithy.NewErrParamRequired("SnsTopicArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateFleetAdvisorCollectorInput(v *CreateFleetAdvisorCollectorInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateFleetAdvisorCollectorInput"} if v.CollectorName == nil { invalidParams.Add(smithy.NewErrParamRequired("CollectorName")) } if v.ServiceAccessRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ServiceAccessRoleArn")) } if v.S3BucketName == nil { invalidParams.Add(smithy.NewErrParamRequired("S3BucketName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateMigrationProjectInput(v *CreateMigrationProjectInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateMigrationProjectInput"} if v.SourceDataProviderDescriptors == nil { invalidParams.Add(smithy.NewErrParamRequired("SourceDataProviderDescriptors")) } else if v.SourceDataProviderDescriptors != nil { if err := validateDataProviderDescriptorDefinitionList(v.SourceDataProviderDescriptors); err != nil { invalidParams.AddNested("SourceDataProviderDescriptors", err.(smithy.InvalidParamsError)) } } if v.TargetDataProviderDescriptors == nil { invalidParams.Add(smithy.NewErrParamRequired("TargetDataProviderDescriptors")) } else if v.TargetDataProviderDescriptors != nil { if err := validateDataProviderDescriptorDefinitionList(v.TargetDataProviderDescriptors); err != nil { invalidParams.AddNested("TargetDataProviderDescriptors", err.(smithy.InvalidParamsError)) } } if v.InstanceProfileIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("InstanceProfileIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateReplicationConfigInput(v *CreateReplicationConfigInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateReplicationConfigInput"} if v.ReplicationConfigIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigIdentifier")) } if v.SourceEndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("SourceEndpointArn")) } if v.TargetEndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("TargetEndpointArn")) } if v.ComputeConfig == nil { invalidParams.Add(smithy.NewErrParamRequired("ComputeConfig")) } if len(v.ReplicationType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("ReplicationType")) } if v.TableMappings == nil { invalidParams.Add(smithy.NewErrParamRequired("TableMappings")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateReplicationInstanceInput(v *CreateReplicationInstanceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateReplicationInstanceInput"} if v.ReplicationInstanceIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceIdentifier")) } if v.ReplicationInstanceClass == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceClass")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateReplicationSubnetGroupInput(v *CreateReplicationSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateReplicationSubnetGroupInput"} if v.ReplicationSubnetGroupIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationSubnetGroupIdentifier")) } if v.ReplicationSubnetGroupDescription == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationSubnetGroupDescription")) } if v.SubnetIds == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetIds")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateReplicationTaskInput(v *CreateReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateReplicationTaskInput"} if v.ReplicationTaskIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskIdentifier")) } if v.SourceEndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("SourceEndpointArn")) } if v.TargetEndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("TargetEndpointArn")) } if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if len(v.MigrationType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("MigrationType")) } if v.TableMappings == nil { invalidParams.Add(smithy.NewErrParamRequired("TableMappings")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteCertificateInput(v *DeleteCertificateInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteCertificateInput"} if v.CertificateArn == nil { invalidParams.Add(smithy.NewErrParamRequired("CertificateArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteConnectionInput(v *DeleteConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteConnectionInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteDataMigrationInput(v *DeleteDataMigrationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteDataMigrationInput"} if v.DataMigrationIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataMigrationIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteDataProviderInput(v *DeleteDataProviderInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteDataProviderInput"} if v.DataProviderIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataProviderIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEndpointInput(v *DeleteEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEndpointInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEventSubscriptionInput(v *DeleteEventSubscriptionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEventSubscriptionInput"} if v.SubscriptionName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubscriptionName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteFleetAdvisorCollectorInput(v *DeleteFleetAdvisorCollectorInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteFleetAdvisorCollectorInput"} if v.CollectorReferencedId == nil { invalidParams.Add(smithy.NewErrParamRequired("CollectorReferencedId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteFleetAdvisorDatabasesInput(v *DeleteFleetAdvisorDatabasesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteFleetAdvisorDatabasesInput"} if v.DatabaseIds == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseIds")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteInstanceProfileInput(v *DeleteInstanceProfileInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteInstanceProfileInput"} if v.InstanceProfileIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("InstanceProfileIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteMigrationProjectInput(v *DeleteMigrationProjectInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteMigrationProjectInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteReplicationConfigInput(v *DeleteReplicationConfigInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationConfigInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteReplicationInstanceInput(v *DeleteReplicationInstanceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationInstanceInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteReplicationSubnetGroupInput(v *DeleteReplicationSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationSubnetGroupInput"} if v.ReplicationSubnetGroupIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationSubnetGroupIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteReplicationTaskAssessmentRunInput(v *DeleteReplicationTaskAssessmentRunInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationTaskAssessmentRunInput"} if v.ReplicationTaskAssessmentRunArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskAssessmentRunArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteReplicationTaskInput(v *DeleteReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationTaskInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeCertificatesInput(v *DescribeCertificatesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeCertificatesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeConnectionsInput(v *DescribeConnectionsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeConnectionsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeConversionConfigurationInput(v *DescribeConversionConfigurationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeConversionConfigurationInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeDataMigrationsInput(v *DescribeDataMigrationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeDataMigrationsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeDataProvidersInput(v *DescribeDataProvidersInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeDataProvidersInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEndpointSettingsInput(v *DescribeEndpointSettingsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEndpointSettingsInput"} if v.EngineName == nil { invalidParams.Add(smithy.NewErrParamRequired("EngineName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEndpointsInput(v *DescribeEndpointsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEndpointsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEndpointTypesInput(v *DescribeEndpointTypesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEndpointTypesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEventCategoriesInput(v *DescribeEventCategoriesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEventCategoriesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEventsInput(v *DescribeEventsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEventsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEventSubscriptionsInput(v *DescribeEventSubscriptionsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEventSubscriptionsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeExtensionPackAssociationsInput(v *DescribeExtensionPackAssociationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeExtensionPackAssociationsInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeFleetAdvisorCollectorsInput(v *DescribeFleetAdvisorCollectorsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeFleetAdvisorCollectorsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeFleetAdvisorDatabasesInput(v *DescribeFleetAdvisorDatabasesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeFleetAdvisorDatabasesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeFleetAdvisorSchemaObjectSummaryInput(v *DescribeFleetAdvisorSchemaObjectSummaryInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeFleetAdvisorSchemaObjectSummaryInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeFleetAdvisorSchemasInput(v *DescribeFleetAdvisorSchemasInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeFleetAdvisorSchemasInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeInstanceProfilesInput(v *DescribeInstanceProfilesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeInstanceProfilesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMetadataModelAssessmentsInput(v *DescribeMetadataModelAssessmentsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMetadataModelAssessmentsInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMetadataModelConversionsInput(v *DescribeMetadataModelConversionsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMetadataModelConversionsInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMetadataModelExportsAsScriptInput(v *DescribeMetadataModelExportsAsScriptInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMetadataModelExportsAsScriptInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMetadataModelExportsToTargetInput(v *DescribeMetadataModelExportsToTargetInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMetadataModelExportsToTargetInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMetadataModelImportsInput(v *DescribeMetadataModelImportsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMetadataModelImportsInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeMigrationProjectsInput(v *DescribeMigrationProjectsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeMigrationProjectsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribePendingMaintenanceActionsInput(v *DescribePendingMaintenanceActionsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribePendingMaintenanceActionsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeRecommendationLimitationsInput(v *DescribeRecommendationLimitationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeRecommendationLimitationsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeRecommendationsInput(v *DescribeRecommendationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeRecommendationsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeRefreshSchemasStatusInput(v *DescribeRefreshSchemasStatusInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeRefreshSchemasStatusInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationConfigsInput(v *DescribeReplicationConfigsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationConfigsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationInstancesInput(v *DescribeReplicationInstancesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationInstancesInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationInstanceTaskLogsInput(v *DescribeReplicationInstanceTaskLogsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationInstanceTaskLogsInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationsInput(v *DescribeReplicationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationSubnetGroupsInput(v *DescribeReplicationSubnetGroupsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationSubnetGroupsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationTableStatisticsInput(v *DescribeReplicationTableStatisticsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationTableStatisticsInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationTaskAssessmentRunsInput(v *DescribeReplicationTaskAssessmentRunsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationTaskAssessmentRunsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationTaskIndividualAssessmentsInput(v *DescribeReplicationTaskIndividualAssessmentsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationTaskIndividualAssessmentsInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplicationTasksInput(v *DescribeReplicationTasksInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplicationTasksInput"} if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeSchemasInput(v *DescribeSchemasInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeSchemasInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeTableStatisticsInput(v *DescribeTableStatisticsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeTableStatisticsInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if v.Filters != nil { if err := validateFilterList(v.Filters); err != nil { invalidParams.AddNested("Filters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpExportMetadataModelAssessmentInput(v *ExportMetadataModelAssessmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ExportMetadataModelAssessmentInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpImportCertificateInput(v *ImportCertificateInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ImportCertificateInput"} if v.CertificateIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("CertificateIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyConversionConfigurationInput(v *ModifyConversionConfigurationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyConversionConfigurationInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.ConversionConfiguration == nil { invalidParams.Add(smithy.NewErrParamRequired("ConversionConfiguration")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyDataMigrationInput(v *ModifyDataMigrationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyDataMigrationInput"} if v.DataMigrationIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataMigrationIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyDataProviderInput(v *ModifyDataProviderInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyDataProviderInput"} if v.DataProviderIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataProviderIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyEndpointInput(v *ModifyEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyEndpointInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if v.DynamoDbSettings != nil { if err := validateDynamoDbSettings(v.DynamoDbSettings); err != nil { invalidParams.AddNested("DynamoDbSettings", err.(smithy.InvalidParamsError)) } } if v.ElasticsearchSettings != nil { if err := validateElasticsearchSettings(v.ElasticsearchSettings); err != nil { invalidParams.AddNested("ElasticsearchSettings", err.(smithy.InvalidParamsError)) } } if v.NeptuneSettings != nil { if err := validateNeptuneSettings(v.NeptuneSettings); err != nil { invalidParams.AddNested("NeptuneSettings", err.(smithy.InvalidParamsError)) } } if v.RedisSettings != nil { if err := validateRedisSettings(v.RedisSettings); err != nil { invalidParams.AddNested("RedisSettings", err.(smithy.InvalidParamsError)) } } if v.TimestreamSettings != nil { if err := validateTimestreamSettings(v.TimestreamSettings); err != nil { invalidParams.AddNested("TimestreamSettings", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyEventSubscriptionInput(v *ModifyEventSubscriptionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyEventSubscriptionInput"} if v.SubscriptionName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubscriptionName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyInstanceProfileInput(v *ModifyInstanceProfileInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyInstanceProfileInput"} if v.InstanceProfileIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("InstanceProfileIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyMigrationProjectInput(v *ModifyMigrationProjectInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyMigrationProjectInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SourceDataProviderDescriptors != nil { if err := validateDataProviderDescriptorDefinitionList(v.SourceDataProviderDescriptors); err != nil { invalidParams.AddNested("SourceDataProviderDescriptors", err.(smithy.InvalidParamsError)) } } if v.TargetDataProviderDescriptors != nil { if err := validateDataProviderDescriptorDefinitionList(v.TargetDataProviderDescriptors); err != nil { invalidParams.AddNested("TargetDataProviderDescriptors", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyReplicationConfigInput(v *ModifyReplicationConfigInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyReplicationConfigInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyReplicationInstanceInput(v *ModifyReplicationInstanceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyReplicationInstanceInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyReplicationSubnetGroupInput(v *ModifyReplicationSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyReplicationSubnetGroupInput"} if v.ReplicationSubnetGroupIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationSubnetGroupIdentifier")) } if v.SubnetIds == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetIds")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpModifyReplicationTaskInput(v *ModifyReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ModifyReplicationTaskInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpMoveReplicationTaskInput(v *MoveReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "MoveReplicationTaskInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if v.TargetReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("TargetReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRebootReplicationInstanceInput(v *RebootReplicationInstanceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RebootReplicationInstanceInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRefreshSchemasInput(v *RefreshSchemasInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RefreshSchemasInput"} if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpReloadReplicationTablesInput(v *ReloadReplicationTablesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ReloadReplicationTablesInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if v.TablesToReload == nil { invalidParams.Add(smithy.NewErrParamRequired("TablesToReload")) } else if v.TablesToReload != nil { if err := validateTableListToReload(v.TablesToReload); err != nil { invalidParams.AddNested("TablesToReload", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpReloadTablesInput(v *ReloadTablesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ReloadTablesInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if v.TablesToReload == nil { invalidParams.Add(smithy.NewErrParamRequired("TablesToReload")) } else if v.TablesToReload != nil { if err := validateTableListToReload(v.TablesToReload); err != nil { invalidParams.AddNested("TablesToReload", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRemoveTagsFromResourceInput(v *RemoveTagsFromResourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RemoveTagsFromResourceInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if v.TagKeys == nil { invalidParams.Add(smithy.NewErrParamRequired("TagKeys")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartDataMigrationInput(v *StartDataMigrationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartDataMigrationInput"} if v.DataMigrationIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataMigrationIdentifier")) } if len(v.StartType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("StartType")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartExtensionPackAssociationInput(v *StartExtensionPackAssociationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartExtensionPackAssociationInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartMetadataModelAssessmentInput(v *StartMetadataModelAssessmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartMetadataModelAssessmentInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartMetadataModelConversionInput(v *StartMetadataModelConversionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartMetadataModelConversionInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartMetadataModelExportAsScriptInput(v *StartMetadataModelExportAsScriptInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartMetadataModelExportAsScriptInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if len(v.Origin) == 0 { invalidParams.Add(smithy.NewErrParamRequired("Origin")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartMetadataModelExportToTargetInput(v *StartMetadataModelExportToTargetInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartMetadataModelExportToTargetInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartMetadataModelImportInput(v *StartMetadataModelImportInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartMetadataModelImportInput"} if v.MigrationProjectIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("MigrationProjectIdentifier")) } if v.SelectionRules == nil { invalidParams.Add(smithy.NewErrParamRequired("SelectionRules")) } if len(v.Origin) == 0 { invalidParams.Add(smithy.NewErrParamRequired("Origin")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartRecommendationsInput(v *StartRecommendationsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartRecommendationsInput"} if v.DatabaseId == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseId")) } if v.Settings == nil { invalidParams.Add(smithy.NewErrParamRequired("Settings")) } else if v.Settings != nil { if err := validateRecommendationSettings(v.Settings); err != nil { invalidParams.AddNested("Settings", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartReplicationInput(v *StartReplicationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartReplicationInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if v.StartReplicationType == nil { invalidParams.Add(smithy.NewErrParamRequired("StartReplicationType")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartReplicationTaskAssessmentInput(v *StartReplicationTaskAssessmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartReplicationTaskAssessmentInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartReplicationTaskAssessmentRunInput(v *StartReplicationTaskAssessmentRunInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartReplicationTaskAssessmentRunInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if v.ServiceAccessRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ServiceAccessRoleArn")) } if v.ResultLocationBucket == nil { invalidParams.Add(smithy.NewErrParamRequired("ResultLocationBucket")) } if v.AssessmentRunName == nil { invalidParams.Add(smithy.NewErrParamRequired("AssessmentRunName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartReplicationTaskInput(v *StartReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartReplicationTaskInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if len(v.StartReplicationTaskType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("StartReplicationTaskType")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStopDataMigrationInput(v *StopDataMigrationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StopDataMigrationInput"} if v.DataMigrationIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("DataMigrationIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStopReplicationInput(v *StopReplicationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StopReplicationInput"} if v.ReplicationConfigArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationConfigArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStopReplicationTaskInput(v *StopReplicationTaskInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StopReplicationTaskInput"} if v.ReplicationTaskArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationTaskArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpTestConnectionInput(v *TestConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TestConnectionInput"} if v.ReplicationInstanceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplicationInstanceArn")) } if v.EndpointArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }