// Code generated by smithy-go-codegen DO NOT EDIT. package redshiftserverless import ( "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/redshiftserverless/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpConvertRecoveryPointToSnapshot struct { } func (*validateOpConvertRecoveryPointToSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpConvertRecoveryPointToSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ConvertRecoveryPointToSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpConvertRecoveryPointToSnapshotInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateEndpointAccess struct { } func (*validateOpCreateEndpointAccess) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEndpointAccess) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEndpointAccessInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEndpointAccessInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateNamespace struct { } func (*validateOpCreateNamespace) ID() string { return "OperationInputValidation" } func (m *validateOpCreateNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateNamespaceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateNamespaceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateSnapshot struct { } func (*validateOpCreateSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpCreateSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateSnapshotInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateUsageLimit struct { } func (*validateOpCreateUsageLimit) ID() string { return "OperationInputValidation" } func (m *validateOpCreateUsageLimit) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateUsageLimitInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateUsageLimitInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateWorkgroup struct { } func (*validateOpCreateWorkgroup) ID() string { return "OperationInputValidation" } func (m *validateOpCreateWorkgroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateWorkgroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateWorkgroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEndpointAccess struct { } func (*validateOpDeleteEndpointAccess) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEndpointAccess) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEndpointAccessInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEndpointAccessInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteNamespace struct { } func (*validateOpDeleteNamespace) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteNamespaceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteNamespaceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteResourcePolicy struct { } func (*validateOpDeleteResourcePolicy) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteResourcePolicyInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteResourcePolicyInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteSnapshot struct { } func (*validateOpDeleteSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteSnapshotInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteUsageLimit struct { } func (*validateOpDeleteUsageLimit) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteUsageLimit) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteUsageLimitInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteUsageLimitInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteWorkgroup struct { } func (*validateOpDeleteWorkgroup) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteWorkgroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteWorkgroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteWorkgroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetCredentials struct { } func (*validateOpGetCredentials) ID() string { return "OperationInputValidation" } func (m *validateOpGetCredentials) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetCredentialsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetCredentialsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetEndpointAccess struct { } func (*validateOpGetEndpointAccess) ID() string { return "OperationInputValidation" } func (m *validateOpGetEndpointAccess) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetEndpointAccessInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetEndpointAccessInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetNamespace struct { } func (*validateOpGetNamespace) ID() string { return "OperationInputValidation" } func (m *validateOpGetNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetNamespaceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetNamespaceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetRecoveryPoint struct { } func (*validateOpGetRecoveryPoint) ID() string { return "OperationInputValidation" } func (m *validateOpGetRecoveryPoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetRecoveryPointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetRecoveryPointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetResourcePolicy struct { } func (*validateOpGetResourcePolicy) ID() string { return "OperationInputValidation" } func (m *validateOpGetResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetResourcePolicyInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetResourcePolicyInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetTableRestoreStatus struct { } func (*validateOpGetTableRestoreStatus) ID() string { return "OperationInputValidation" } func (m *validateOpGetTableRestoreStatus) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetTableRestoreStatusInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetTableRestoreStatusInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetUsageLimit struct { } func (*validateOpGetUsageLimit) ID() string { return "OperationInputValidation" } func (m *validateOpGetUsageLimit) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetUsageLimitInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetUsageLimitInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetWorkgroup struct { } func (*validateOpGetWorkgroup) ID() string { return "OperationInputValidation" } func (m *validateOpGetWorkgroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetWorkgroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetWorkgroupInput(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 validateOpPutResourcePolicy struct { } func (*validateOpPutResourcePolicy) ID() string { return "OperationInputValidation" } func (m *validateOpPutResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutResourcePolicyInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutResourcePolicyInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRestoreFromRecoveryPoint struct { } func (*validateOpRestoreFromRecoveryPoint) ID() string { return "OperationInputValidation" } func (m *validateOpRestoreFromRecoveryPoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RestoreFromRecoveryPointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRestoreFromRecoveryPointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRestoreFromSnapshot struct { } func (*validateOpRestoreFromSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpRestoreFromSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RestoreFromSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRestoreFromSnapshotInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRestoreTableFromSnapshot struct { } func (*validateOpRestoreTableFromSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpRestoreTableFromSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RestoreTableFromSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRestoreTableFromSnapshotInput(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 validateOpUpdateEndpointAccess struct { } func (*validateOpUpdateEndpointAccess) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateEndpointAccess) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateEndpointAccessInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateEndpointAccessInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateNamespace struct { } func (*validateOpUpdateNamespace) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateNamespaceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateNamespaceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateSnapshot struct { } func (*validateOpUpdateSnapshot) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateSnapshot) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateSnapshotInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateSnapshotInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateUsageLimit struct { } func (*validateOpUpdateUsageLimit) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateUsageLimit) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateUsageLimitInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateUsageLimitInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateWorkgroup struct { } func (*validateOpUpdateWorkgroup) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateWorkgroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateWorkgroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateWorkgroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpConvertRecoveryPointToSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpConvertRecoveryPointToSnapshot{}, middleware.After) } func addOpCreateEndpointAccessValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEndpointAccess{}, middleware.After) } func addOpCreateNamespaceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateNamespace{}, middleware.After) } func addOpCreateSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateSnapshot{}, middleware.After) } func addOpCreateUsageLimitValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateUsageLimit{}, middleware.After) } func addOpCreateWorkgroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateWorkgroup{}, middleware.After) } func addOpDeleteEndpointAccessValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEndpointAccess{}, middleware.After) } func addOpDeleteNamespaceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteNamespace{}, middleware.After) } func addOpDeleteResourcePolicyValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteResourcePolicy{}, middleware.After) } func addOpDeleteSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteSnapshot{}, middleware.After) } func addOpDeleteUsageLimitValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteUsageLimit{}, middleware.After) } func addOpDeleteWorkgroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteWorkgroup{}, middleware.After) } func addOpGetCredentialsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetCredentials{}, middleware.After) } func addOpGetEndpointAccessValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetEndpointAccess{}, middleware.After) } func addOpGetNamespaceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetNamespace{}, middleware.After) } func addOpGetRecoveryPointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetRecoveryPoint{}, middleware.After) } func addOpGetResourcePolicyValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetResourcePolicy{}, middleware.After) } func addOpGetTableRestoreStatusValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetTableRestoreStatus{}, middleware.After) } func addOpGetUsageLimitValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetUsageLimit{}, middleware.After) } func addOpGetWorkgroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetWorkgroup{}, middleware.After) } func addOpListTagsForResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTagsForResource{}, middleware.After) } func addOpPutResourcePolicyValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutResourcePolicy{}, middleware.After) } func addOpRestoreFromRecoveryPointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRestoreFromRecoveryPoint{}, middleware.After) } func addOpRestoreFromSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRestoreFromSnapshot{}, middleware.After) } func addOpRestoreTableFromSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRestoreTableFromSnapshot{}, 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 addOpUpdateEndpointAccessValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateEndpointAccess{}, middleware.After) } func addOpUpdateNamespaceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateNamespace{}, middleware.After) } func addOpUpdateSnapshotValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateSnapshot{}, middleware.After) } func addOpUpdateUsageLimitValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateUsageLimit{}, middleware.After) } func addOpUpdateWorkgroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateWorkgroup{}, middleware.After) } func validateTag(v *types.Tag) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Tag"} if v.Key == nil { invalidParams.Add(smithy.NewErrParamRequired("Key")) } if v.Value == nil { invalidParams.Add(smithy.NewErrParamRequired("Value")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTagList(v []types.Tag) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TagList"} for i := range v { if err := validateTag(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpConvertRecoveryPointToSnapshotInput(v *ConvertRecoveryPointToSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ConvertRecoveryPointToSnapshotInput"} if v.RecoveryPointId == nil { invalidParams.Add(smithy.NewErrParamRequired("RecoveryPointId")) } if v.SnapshotName == nil { invalidParams.Add(smithy.NewErrParamRequired("SnapshotName")) } if v.Tags != nil { if err := validateTagList(v.Tags); err != nil { invalidParams.AddNested("Tags", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEndpointAccessInput(v *CreateEndpointAccessInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEndpointAccessInput"} if v.EndpointName == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointName")) } if v.SubnetIds == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetIds")) } if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateNamespaceInput(v *CreateNamespaceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateNamespaceInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.Tags != nil { if err := validateTagList(v.Tags); err != nil { invalidParams.AddNested("Tags", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateSnapshotInput(v *CreateSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateSnapshotInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.SnapshotName == nil { invalidParams.Add(smithy.NewErrParamRequired("SnapshotName")) } if v.Tags != nil { if err := validateTagList(v.Tags); err != nil { invalidParams.AddNested("Tags", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateUsageLimitInput(v *CreateUsageLimitInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateUsageLimitInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if len(v.UsageType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("UsageType")) } if v.Amount == nil { invalidParams.Add(smithy.NewErrParamRequired("Amount")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateWorkgroupInput(v *CreateWorkgroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateWorkgroupInput"} if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.Tags != nil { if err := validateTagList(v.Tags); err != nil { invalidParams.AddNested("Tags", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEndpointAccessInput(v *DeleteEndpointAccessInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEndpointAccessInput"} if v.EndpointName == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteNamespaceInput(v *DeleteNamespaceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteNamespaceInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteResourcePolicyInput(v *DeleteResourcePolicyInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteResourcePolicyInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteSnapshotInput(v *DeleteSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteSnapshotInput"} if v.SnapshotName == nil { invalidParams.Add(smithy.NewErrParamRequired("SnapshotName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteUsageLimitInput(v *DeleteUsageLimitInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteUsageLimitInput"} if v.UsageLimitId == nil { invalidParams.Add(smithy.NewErrParamRequired("UsageLimitId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteWorkgroupInput(v *DeleteWorkgroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteWorkgroupInput"} if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetCredentialsInput(v *GetCredentialsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetCredentialsInput"} if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetEndpointAccessInput(v *GetEndpointAccessInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetEndpointAccessInput"} if v.EndpointName == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetNamespaceInput(v *GetNamespaceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetNamespaceInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetRecoveryPointInput(v *GetRecoveryPointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetRecoveryPointInput"} if v.RecoveryPointId == nil { invalidParams.Add(smithy.NewErrParamRequired("RecoveryPointId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetResourcePolicyInput(v *GetResourcePolicyInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetResourcePolicyInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetTableRestoreStatusInput(v *GetTableRestoreStatusInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetTableRestoreStatusInput"} if v.TableRestoreRequestId == nil { invalidParams.Add(smithy.NewErrParamRequired("TableRestoreRequestId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetUsageLimitInput(v *GetUsageLimitInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetUsageLimitInput"} if v.UsageLimitId == nil { invalidParams.Add(smithy.NewErrParamRequired("UsageLimitId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetWorkgroupInput(v *GetWorkgroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetWorkgroupInput"} if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } 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 validateOpPutResourcePolicyInput(v *PutResourcePolicyInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutResourcePolicyInput"} if v.ResourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) } if v.Policy == nil { invalidParams.Add(smithy.NewErrParamRequired("Policy")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRestoreFromRecoveryPointInput(v *RestoreFromRecoveryPointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RestoreFromRecoveryPointInput"} if v.RecoveryPointId == nil { invalidParams.Add(smithy.NewErrParamRequired("RecoveryPointId")) } if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRestoreFromSnapshotInput(v *RestoreFromSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RestoreFromSnapshotInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRestoreTableFromSnapshotInput(v *RestoreTableFromSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RestoreTableFromSnapshotInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if v.SnapshotName == nil { invalidParams.Add(smithy.NewErrParamRequired("SnapshotName")) } if v.SourceDatabaseName == nil { invalidParams.Add(smithy.NewErrParamRequired("SourceDatabaseName")) } if v.SourceTableName == nil { invalidParams.Add(smithy.NewErrParamRequired("SourceTableName")) } if v.NewTableName == nil { invalidParams.Add(smithy.NewErrParamRequired("NewTableName")) } 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")) } else if v.Tags != nil { if err := validateTagList(v.Tags); err != nil { invalidParams.AddNested("Tags", err.(smithy.InvalidParamsError)) } } 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 validateOpUpdateEndpointAccessInput(v *UpdateEndpointAccessInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateEndpointAccessInput"} if v.EndpointName == nil { invalidParams.Add(smithy.NewErrParamRequired("EndpointName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateNamespaceInput(v *UpdateNamespaceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateNamespaceInput"} if v.NamespaceName == nil { invalidParams.Add(smithy.NewErrParamRequired("NamespaceName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateSnapshotInput(v *UpdateSnapshotInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateSnapshotInput"} if v.SnapshotName == nil { invalidParams.Add(smithy.NewErrParamRequired("SnapshotName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateUsageLimitInput(v *UpdateUsageLimitInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateUsageLimitInput"} if v.UsageLimitId == nil { invalidParams.Add(smithy.NewErrParamRequired("UsageLimitId")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateWorkgroupInput(v *UpdateWorkgroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateWorkgroupInput"} if v.WorkgroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("WorkgroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }