// Code generated by smithy-go-codegen DO NOT EDIT. package finspace import ( "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/finspace/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpCreateEnvironment struct { } func (*validateOpCreateEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateKxChangeset struct { } func (*validateOpCreateKxChangeset) ID() string { return "OperationInputValidation" } func (m *validateOpCreateKxChangeset) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateKxChangesetInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateKxChangesetInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateKxCluster struct { } func (*validateOpCreateKxCluster) ID() string { return "OperationInputValidation" } func (m *validateOpCreateKxCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateKxClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateKxClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateKxDatabase struct { } func (*validateOpCreateKxDatabase) ID() string { return "OperationInputValidation" } func (m *validateOpCreateKxDatabase) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateKxDatabaseInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateKxDatabaseInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateKxEnvironment struct { } func (*validateOpCreateKxEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpCreateKxEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateKxEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateKxEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateKxUser struct { } func (*validateOpCreateKxUser) ID() string { return "OperationInputValidation" } func (m *validateOpCreateKxUser) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateKxUserInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateKxUserInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEnvironment struct { } func (*validateOpDeleteEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteKxCluster struct { } func (*validateOpDeleteKxCluster) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteKxCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteKxClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteKxClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteKxDatabase struct { } func (*validateOpDeleteKxDatabase) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteKxDatabase) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteKxDatabaseInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteKxDatabaseInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteKxEnvironment struct { } func (*validateOpDeleteKxEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteKxEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteKxEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteKxEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteKxUser struct { } func (*validateOpDeleteKxUser) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteKxUser) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteKxUserInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteKxUserInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetEnvironment struct { } func (*validateOpGetEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpGetEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxChangeset struct { } func (*validateOpGetKxChangeset) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxChangeset) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxChangesetInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxChangesetInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxCluster struct { } func (*validateOpGetKxCluster) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxConnectionString struct { } func (*validateOpGetKxConnectionString) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxConnectionString) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxConnectionStringInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxConnectionStringInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxDatabase struct { } func (*validateOpGetKxDatabase) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxDatabase) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxDatabaseInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxDatabaseInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxEnvironment struct { } func (*validateOpGetKxEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetKxUser struct { } func (*validateOpGetKxUser) ID() string { return "OperationInputValidation" } func (m *validateOpGetKxUser) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetKxUserInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetKxUserInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListKxChangesets struct { } func (*validateOpListKxChangesets) ID() string { return "OperationInputValidation" } func (m *validateOpListKxChangesets) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListKxChangesetsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListKxChangesetsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListKxClusterNodes struct { } func (*validateOpListKxClusterNodes) ID() string { return "OperationInputValidation" } func (m *validateOpListKxClusterNodes) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListKxClusterNodesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListKxClusterNodesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListKxClusters struct { } func (*validateOpListKxClusters) ID() string { return "OperationInputValidation" } func (m *validateOpListKxClusters) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListKxClustersInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListKxClustersInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListKxDatabases struct { } func (*validateOpListKxDatabases) ID() string { return "OperationInputValidation" } func (m *validateOpListKxDatabases) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListKxDatabasesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListKxDatabasesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListKxUsers struct { } func (*validateOpListKxUsers) ID() string { return "OperationInputValidation" } func (m *validateOpListKxUsers) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListKxUsersInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListKxUsersInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListTagsForResource struct { } func (*validateOpListTagsForResource) ID() string { return "OperationInputValidation" } func (m *validateOpListTagsForResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListTagsForResourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListTagsForResourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpTagResource struct { } func (*validateOpTagResource) ID() string { return "OperationInputValidation" } func (m *validateOpTagResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*TagResourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpTagResourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUntagResource struct { } func (*validateOpUntagResource) ID() string { return "OperationInputValidation" } func (m *validateOpUntagResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UntagResourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUntagResourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateEnvironment struct { } func (*validateOpUpdateEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateKxClusterDatabases struct { } func (*validateOpUpdateKxClusterDatabases) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateKxClusterDatabases) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateKxClusterDatabasesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateKxClusterDatabasesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateKxDatabase struct { } func (*validateOpUpdateKxDatabase) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateKxDatabase) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateKxDatabaseInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateKxDatabaseInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateKxEnvironment struct { } func (*validateOpUpdateKxEnvironment) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateKxEnvironment) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateKxEnvironmentInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateKxEnvironmentInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateKxEnvironmentNetwork struct { } func (*validateOpUpdateKxEnvironmentNetwork) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateKxEnvironmentNetwork) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateKxEnvironmentNetworkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateKxEnvironmentNetworkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateKxUser struct { } func (*validateOpUpdateKxUser) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateKxUser) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateKxUserInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateKxUserInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpCreateEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEnvironment{}, middleware.After) } func addOpCreateKxChangesetValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateKxChangeset{}, middleware.After) } func addOpCreateKxClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateKxCluster{}, middleware.After) } func addOpCreateKxDatabaseValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateKxDatabase{}, middleware.After) } func addOpCreateKxEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateKxEnvironment{}, middleware.After) } func addOpCreateKxUserValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateKxUser{}, middleware.After) } func addOpDeleteEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEnvironment{}, middleware.After) } func addOpDeleteKxClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteKxCluster{}, middleware.After) } func addOpDeleteKxDatabaseValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteKxDatabase{}, middleware.After) } func addOpDeleteKxEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteKxEnvironment{}, middleware.After) } func addOpDeleteKxUserValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteKxUser{}, middleware.After) } func addOpGetEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetEnvironment{}, middleware.After) } func addOpGetKxChangesetValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxChangeset{}, middleware.After) } func addOpGetKxClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxCluster{}, middleware.After) } func addOpGetKxConnectionStringValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxConnectionString{}, middleware.After) } func addOpGetKxDatabaseValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxDatabase{}, middleware.After) } func addOpGetKxEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxEnvironment{}, middleware.After) } func addOpGetKxUserValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetKxUser{}, middleware.After) } func addOpListKxChangesetsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListKxChangesets{}, middleware.After) } func addOpListKxClusterNodesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListKxClusterNodes{}, middleware.After) } func addOpListKxClustersValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListKxClusters{}, middleware.After) } func addOpListKxDatabasesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListKxDatabases{}, middleware.After) } func addOpListKxUsersValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListKxUsers{}, middleware.After) } func addOpListTagsForResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTagsForResource{}, middleware.After) } func addOpTagResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpTagResource{}, middleware.After) } func addOpUntagResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUntagResource{}, middleware.After) } func addOpUpdateEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateEnvironment{}, middleware.After) } func addOpUpdateKxClusterDatabasesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateKxClusterDatabases{}, middleware.After) } func addOpUpdateKxDatabaseValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateKxDatabase{}, middleware.After) } func addOpUpdateKxEnvironmentValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateKxEnvironment{}, middleware.After) } func addOpUpdateKxEnvironmentNetworkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateKxEnvironmentNetwork{}, middleware.After) } func addOpUpdateKxUserValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateKxUser{}, middleware.After) } func validateChangeRequest(v *types.ChangeRequest) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ChangeRequest"} if len(v.ChangeType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("ChangeType")) } if v.DbPath == nil { invalidParams.Add(smithy.NewErrParamRequired("DbPath")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateChangeRequests(v []types.ChangeRequest) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ChangeRequests"} for i := range v { if err := validateChangeRequest(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCustomDNSConfiguration(v []types.CustomDNSServer) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CustomDNSConfiguration"} for i := range v { if err := validateCustomDNSServer(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCustomDNSServer(v *types.CustomDNSServer) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CustomDNSServer"} if v.CustomDNSServerName == nil { invalidParams.Add(smithy.NewErrParamRequired("CustomDNSServerName")) } if v.CustomDNSServerIP == nil { invalidParams.Add(smithy.NewErrParamRequired("CustomDNSServerIP")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxCacheStorageConfiguration(v *types.KxCacheStorageConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxCacheStorageConfiguration"} if v.Type == nil { invalidParams.Add(smithy.NewErrParamRequired("Type")) } if v.Size == nil { invalidParams.Add(smithy.NewErrParamRequired("Size")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxCacheStorageConfigurations(v []types.KxCacheStorageConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxCacheStorageConfigurations"} for i := range v { if err := validateKxCacheStorageConfiguration(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxDatabaseCacheConfiguration(v *types.KxDatabaseCacheConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxDatabaseCacheConfiguration"} if v.CacheType == nil { invalidParams.Add(smithy.NewErrParamRequired("CacheType")) } if v.DbPaths == nil { invalidParams.Add(smithy.NewErrParamRequired("DbPaths")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxDatabaseCacheConfigurations(v []types.KxDatabaseCacheConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxDatabaseCacheConfigurations"} for i := range v { if err := validateKxDatabaseCacheConfiguration(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxDatabaseConfiguration(v *types.KxDatabaseConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxDatabaseConfiguration"} if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.CacheConfigurations != nil { if err := validateKxDatabaseCacheConfigurations(v.CacheConfigurations); err != nil { invalidParams.AddNested("CacheConfigurations", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxDatabaseConfigurations(v []types.KxDatabaseConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxDatabaseConfigurations"} for i := range v { if err := validateKxDatabaseConfiguration(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKxSavedownStorageConfiguration(v *types.KxSavedownStorageConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KxSavedownStorageConfiguration"} if len(v.Type) == 0 { invalidParams.Add(smithy.NewErrParamRequired("Type")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateSuperuserParameters(v *types.SuperuserParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "SuperuserParameters"} if v.EmailAddress == nil { invalidParams.Add(smithy.NewErrParamRequired("EmailAddress")) } if v.FirstName == nil { invalidParams.Add(smithy.NewErrParamRequired("FirstName")) } if v.LastName == nil { invalidParams.Add(smithy.NewErrParamRequired("LastName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTransitGatewayConfiguration(v *types.TransitGatewayConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TransitGatewayConfiguration"} if v.TransitGatewayID == nil { invalidParams.Add(smithy.NewErrParamRequired("TransitGatewayID")) } if v.RoutableCIDRSpace == nil { invalidParams.Add(smithy.NewErrParamRequired("RoutableCIDRSpace")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEnvironmentInput(v *CreateEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEnvironmentInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.SuperuserParameters != nil { if err := validateSuperuserParameters(v.SuperuserParameters); err != nil { invalidParams.AddNested("SuperuserParameters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateKxChangesetInput(v *CreateKxChangesetInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateKxChangesetInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.ChangeRequests == nil { invalidParams.Add(smithy.NewErrParamRequired("ChangeRequests")) } else if v.ChangeRequests != nil { if err := validateChangeRequests(v.ChangeRequests); err != nil { invalidParams.AddNested("ChangeRequests", err.(smithy.InvalidParamsError)) } } if v.ClientToken == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientToken")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateKxClusterInput(v *CreateKxClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateKxClusterInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if len(v.ClusterType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("ClusterType")) } if v.Databases != nil { if err := validateKxDatabaseConfigurations(v.Databases); err != nil { invalidParams.AddNested("Databases", err.(smithy.InvalidParamsError)) } } if v.CacheStorageConfigurations != nil { if err := validateKxCacheStorageConfigurations(v.CacheStorageConfigurations); err != nil { invalidParams.AddNested("CacheStorageConfigurations", err.(smithy.InvalidParamsError)) } } if v.CapacityConfiguration == nil { invalidParams.Add(smithy.NewErrParamRequired("CapacityConfiguration")) } if v.ReleaseLabel == nil { invalidParams.Add(smithy.NewErrParamRequired("ReleaseLabel")) } if v.SavedownStorageConfiguration != nil { if err := validateKxSavedownStorageConfiguration(v.SavedownStorageConfiguration); err != nil { invalidParams.AddNested("SavedownStorageConfiguration", err.(smithy.InvalidParamsError)) } } if len(v.AzMode) == 0 { invalidParams.Add(smithy.NewErrParamRequired("AzMode")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateKxDatabaseInput(v *CreateKxDatabaseInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateKxDatabaseInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.ClientToken == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientToken")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateKxEnvironmentInput(v *CreateKxEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateKxEnvironmentInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.KmsKeyId == nil { invalidParams.Add(smithy.NewErrParamRequired("KmsKeyId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateKxUserInput(v *CreateKxUserInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateKxUserInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.UserName == nil { invalidParams.Add(smithy.NewErrParamRequired("UserName")) } if v.IamRole == nil { invalidParams.Add(smithy.NewErrParamRequired("IamRole")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEnvironmentInput(v *DeleteEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteKxClusterInput(v *DeleteKxClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteKxClusterInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteKxDatabaseInput(v *DeleteKxDatabaseInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteKxDatabaseInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.ClientToken == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientToken")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteKxEnvironmentInput(v *DeleteKxEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteKxEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteKxUserInput(v *DeleteKxUserInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteKxUserInput"} if v.UserName == nil { invalidParams.Add(smithy.NewErrParamRequired("UserName")) } if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetEnvironmentInput(v *GetEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxChangesetInput(v *GetKxChangesetInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxChangesetInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.ChangesetId == nil { invalidParams.Add(smithy.NewErrParamRequired("ChangesetId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxClusterInput(v *GetKxClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxClusterInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxConnectionStringInput(v *GetKxConnectionStringInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxConnectionStringInput"} if v.UserArn == nil { invalidParams.Add(smithy.NewErrParamRequired("UserArn")) } if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxDatabaseInput(v *GetKxDatabaseInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxDatabaseInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxEnvironmentInput(v *GetKxEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetKxUserInput(v *GetKxUserInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetKxUserInput"} if v.UserName == nil { invalidParams.Add(smithy.NewErrParamRequired("UserName")) } if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListKxChangesetsInput(v *ListKxChangesetsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListKxChangesetsInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListKxClusterNodesInput(v *ListKxClusterNodesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListKxClusterNodesInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListKxClustersInput(v *ListKxClustersInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListKxClustersInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListKxDatabasesInput(v *ListKxDatabasesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListKxDatabasesInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListKxUsersInput(v *ListKxUsersInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListKxUsersInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListTagsForResourceInput(v *ListTagsForResourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListTagsForResourceInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpTagResourceInput(v *TagResourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TagResourceInput"} 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 validateOpUntagResourceInput(v *UntagResourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UntagResourceInput"} 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 validateOpUpdateEnvironmentInput(v *UpdateEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateKxClusterDatabasesInput(v *UpdateKxClusterDatabasesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateKxClusterDatabasesInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if v.Databases == nil { invalidParams.Add(smithy.NewErrParamRequired("Databases")) } else if v.Databases != nil { if err := validateKxDatabaseConfigurations(v.Databases); err != nil { invalidParams.AddNested("Databases", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateKxDatabaseInput(v *UpdateKxDatabaseInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateKxDatabaseInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.DatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("DatabaseName")) } if v.ClientToken == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientToken")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateKxEnvironmentInput(v *UpdateKxEnvironmentInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateKxEnvironmentInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateKxEnvironmentNetworkInput(v *UpdateKxEnvironmentNetworkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateKxEnvironmentNetworkInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.TransitGatewayConfiguration != nil { if err := validateTransitGatewayConfiguration(v.TransitGatewayConfiguration); err != nil { invalidParams.AddNested("TransitGatewayConfiguration", err.(smithy.InvalidParamsError)) } } if v.CustomDNSConfiguration != nil { if err := validateCustomDNSConfiguration(v.CustomDNSConfiguration); err != nil { invalidParams.AddNested("CustomDNSConfiguration", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateKxUserInput(v *UpdateKxUserInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateKxUserInput"} if v.EnvironmentId == nil { invalidParams.Add(smithy.NewErrParamRequired("EnvironmentId")) } if v.UserName == nil { invalidParams.Add(smithy.NewErrParamRequired("UserName")) } if v.IamRole == nil { invalidParams.Add(smithy.NewErrParamRequired("IamRole")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }