// Code generated by smithy-go-codegen DO NOT EDIT. package dax import ( "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/dax/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpCreateCluster struct { } func (*validateOpCreateCluster) ID() string { return "OperationInputValidation" } func (m *validateOpCreateCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateParameterGroup struct { } func (*validateOpCreateParameterGroup) ID() string { return "OperationInputValidation" } func (m *validateOpCreateParameterGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateParameterGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateParameterGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateSubnetGroup struct { } func (*validateOpCreateSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpCreateSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDecreaseReplicationFactor struct { } func (*validateOpDecreaseReplicationFactor) ID() string { return "OperationInputValidation" } func (m *validateOpDecreaseReplicationFactor) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DecreaseReplicationFactorInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDecreaseReplicationFactorInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteCluster struct { } func (*validateOpDeleteCluster) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteParameterGroup struct { } func (*validateOpDeleteParameterGroup) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteParameterGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteParameterGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteParameterGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteSubnetGroup struct { } func (*validateOpDeleteSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeParameters struct { } func (*validateOpDescribeParameters) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeParameters) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeParametersInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeParametersInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpIncreaseReplicationFactor struct { } func (*validateOpIncreaseReplicationFactor) ID() string { return "OperationInputValidation" } func (m *validateOpIncreaseReplicationFactor) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*IncreaseReplicationFactorInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpIncreaseReplicationFactorInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListTags struct { } func (*validateOpListTags) ID() string { return "OperationInputValidation" } func (m *validateOpListTags) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListTagsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListTagsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRebootNode struct { } func (*validateOpRebootNode) ID() string { return "OperationInputValidation" } func (m *validateOpRebootNode) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RebootNodeInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRebootNodeInput(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 validateOpUpdateCluster struct { } func (*validateOpUpdateCluster) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateCluster) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateClusterInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateClusterInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateParameterGroup struct { } func (*validateOpUpdateParameterGroup) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateParameterGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateParameterGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateParameterGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateSubnetGroup struct { } func (*validateOpUpdateSubnetGroup) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateSubnetGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateSubnetGroupInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateSubnetGroupInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpCreateClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateCluster{}, middleware.After) } func addOpCreateParameterGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateParameterGroup{}, middleware.After) } func addOpCreateSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateSubnetGroup{}, middleware.After) } func addOpDecreaseReplicationFactorValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDecreaseReplicationFactor{}, middleware.After) } func addOpDeleteClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteCluster{}, middleware.After) } func addOpDeleteParameterGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteParameterGroup{}, middleware.After) } func addOpDeleteSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteSubnetGroup{}, middleware.After) } func addOpDescribeParametersValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeParameters{}, middleware.After) } func addOpIncreaseReplicationFactorValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpIncreaseReplicationFactor{}, middleware.After) } func addOpListTagsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTags{}, middleware.After) } func addOpRebootNodeValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRebootNode{}, 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 addOpUpdateClusterValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateCluster{}, middleware.After) } func addOpUpdateParameterGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateParameterGroup{}, middleware.After) } func addOpUpdateSubnetGroupValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateSubnetGroup{}, middleware.After) } func validateSSESpecification(v *types.SSESpecification) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "SSESpecification"} if v.Enabled == nil { invalidParams.Add(smithy.NewErrParamRequired("Enabled")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateClusterInput(v *CreateClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateClusterInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if v.NodeType == nil { invalidParams.Add(smithy.NewErrParamRequired("NodeType")) } if v.IamRoleArn == nil { invalidParams.Add(smithy.NewErrParamRequired("IamRoleArn")) } if v.SSESpecification != nil { if err := validateSSESpecification(v.SSESpecification); err != nil { invalidParams.AddNested("SSESpecification", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateParameterGroupInput(v *CreateParameterGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateParameterGroupInput"} if v.ParameterGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("ParameterGroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateSubnetGroupInput(v *CreateSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateSubnetGroupInput"} if v.SubnetGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetGroupName")) } if v.SubnetIds == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetIds")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDecreaseReplicationFactorInput(v *DecreaseReplicationFactorInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DecreaseReplicationFactorInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteClusterInput(v *DeleteClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteClusterInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteParameterGroupInput(v *DeleteParameterGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteParameterGroupInput"} if v.ParameterGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("ParameterGroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteSubnetGroupInput(v *DeleteSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteSubnetGroupInput"} if v.SubnetGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetGroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeParametersInput(v *DescribeParametersInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeParametersInput"} if v.ParameterGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("ParameterGroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpIncreaseReplicationFactorInput(v *IncreaseReplicationFactorInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "IncreaseReplicationFactorInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListTagsInput(v *ListTagsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListTagsInput"} if v.ResourceName == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRebootNodeInput(v *RebootNodeInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RebootNodeInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if v.NodeId == nil { invalidParams.Add(smithy.NewErrParamRequired("NodeId")) } 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.ResourceName == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceName")) } 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.ResourceName == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceName")) } if v.TagKeys == nil { invalidParams.Add(smithy.NewErrParamRequired("TagKeys")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateClusterInput(v *UpdateClusterInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateClusterInput"} if v.ClusterName == nil { invalidParams.Add(smithy.NewErrParamRequired("ClusterName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateParameterGroupInput(v *UpdateParameterGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateParameterGroupInput"} if v.ParameterGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("ParameterGroupName")) } if v.ParameterNameValues == nil { invalidParams.Add(smithy.NewErrParamRequired("ParameterNameValues")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateSubnetGroupInput(v *UpdateSubnetGroupInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateSubnetGroupInput"} if v.SubnetGroupName == nil { invalidParams.Add(smithy.NewErrParamRequired("SubnetGroupName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }