// Code generated by smithy-go-codegen DO NOT EDIT. package oam import ( "context" "fmt" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpCreateLink struct { } func (*validateOpCreateLink) ID() string { return "OperationInputValidation" } func (m *validateOpCreateLink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateLinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateLinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateSink struct { } func (*validateOpCreateSink) ID() string { return "OperationInputValidation" } func (m *validateOpCreateSink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateSinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateSinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteLink struct { } func (*validateOpDeleteLink) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteLink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteLinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteLinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteSink struct { } func (*validateOpDeleteSink) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteSink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteSinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteSinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetLink struct { } func (*validateOpGetLink) ID() string { return "OperationInputValidation" } func (m *validateOpGetLink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetLinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetLinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetSink struct { } func (*validateOpGetSink) ID() string { return "OperationInputValidation" } func (m *validateOpGetSink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetSinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetSinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpGetSinkPolicy struct { } func (*validateOpGetSinkPolicy) ID() string { return "OperationInputValidation" } func (m *validateOpGetSinkPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*GetSinkPolicyInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpGetSinkPolicyInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListAttachedLinks struct { } func (*validateOpListAttachedLinks) ID() string { return "OperationInputValidation" } func (m *validateOpListAttachedLinks) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListAttachedLinksInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListAttachedLinksInput(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 validateOpPutSinkPolicy struct { } func (*validateOpPutSinkPolicy) ID() string { return "OperationInputValidation" } func (m *validateOpPutSinkPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutSinkPolicyInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutSinkPolicyInput(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 validateOpUpdateLink struct { } func (*validateOpUpdateLink) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateLink) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateLinkInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateLinkInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpCreateLinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateLink{}, middleware.After) } func addOpCreateSinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateSink{}, middleware.After) } func addOpDeleteLinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteLink{}, middleware.After) } func addOpDeleteSinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteSink{}, middleware.After) } func addOpGetLinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetLink{}, middleware.After) } func addOpGetSinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetSink{}, middleware.After) } func addOpGetSinkPolicyValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpGetSinkPolicy{}, middleware.After) } func addOpListAttachedLinksValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListAttachedLinks{}, middleware.After) } func addOpListTagsForResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTagsForResource{}, middleware.After) } func addOpPutSinkPolicyValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutSinkPolicy{}, 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 addOpUpdateLinkValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateLink{}, middleware.After) } func validateOpCreateLinkInput(v *CreateLinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateLinkInput"} if v.LabelTemplate == nil { invalidParams.Add(smithy.NewErrParamRequired("LabelTemplate")) } if v.ResourceTypes == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceTypes")) } if v.SinkIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("SinkIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateSinkInput(v *CreateSinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateSinkInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteLinkInput(v *DeleteLinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteLinkInput"} if v.Identifier == nil { invalidParams.Add(smithy.NewErrParamRequired("Identifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteSinkInput(v *DeleteSinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteSinkInput"} if v.Identifier == nil { invalidParams.Add(smithy.NewErrParamRequired("Identifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetLinkInput(v *GetLinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetLinkInput"} if v.Identifier == nil { invalidParams.Add(smithy.NewErrParamRequired("Identifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetSinkInput(v *GetSinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetSinkInput"} if v.Identifier == nil { invalidParams.Add(smithy.NewErrParamRequired("Identifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpGetSinkPolicyInput(v *GetSinkPolicyInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "GetSinkPolicyInput"} if v.SinkIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("SinkIdentifier")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListAttachedLinksInput(v *ListAttachedLinksInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListAttachedLinksInput"} if v.SinkIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("SinkIdentifier")) } 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 validateOpPutSinkPolicyInput(v *PutSinkPolicyInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutSinkPolicyInput"} if v.SinkIdentifier == nil { invalidParams.Add(smithy.NewErrParamRequired("SinkIdentifier")) } if v.Policy == nil { invalidParams.Add(smithy.NewErrParamRequired("Policy")) } 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 validateOpUpdateLinkInput(v *UpdateLinkInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateLinkInput"} if v.Identifier == nil { invalidParams.Add(smithy.NewErrParamRequired("Identifier")) } if v.ResourceTypes == nil { invalidParams.Add(smithy.NewErrParamRequired("ResourceTypes")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }