// Code generated by smithy-go-codegen DO NOT EDIT. package eventbridge import ( "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/eventbridge/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/middleware" ) type validateOpActivateEventSource struct { } func (*validateOpActivateEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpActivateEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ActivateEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpActivateEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCancelReplay struct { } func (*validateOpCancelReplay) ID() string { return "OperationInputValidation" } func (m *validateOpCancelReplay) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CancelReplayInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCancelReplayInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateApiDestination struct { } func (*validateOpCreateApiDestination) ID() string { return "OperationInputValidation" } func (m *validateOpCreateApiDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateApiDestinationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateApiDestinationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateArchive struct { } func (*validateOpCreateArchive) ID() string { return "OperationInputValidation" } func (m *validateOpCreateArchive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateArchiveInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateArchiveInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateConnection struct { } func (*validateOpCreateConnection) ID() string { return "OperationInputValidation" } func (m *validateOpCreateConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateEndpoint struct { } func (*validateOpCreateEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreateEventBus struct { } func (*validateOpCreateEventBus) ID() string { return "OperationInputValidation" } func (m *validateOpCreateEventBus) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreateEventBusInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreateEventBusInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpCreatePartnerEventSource struct { } func (*validateOpCreatePartnerEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpCreatePartnerEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*CreatePartnerEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpCreatePartnerEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeactivateEventSource struct { } func (*validateOpDeactivateEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpDeactivateEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeactivateEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeactivateEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeauthorizeConnection struct { } func (*validateOpDeauthorizeConnection) ID() string { return "OperationInputValidation" } func (m *validateOpDeauthorizeConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeauthorizeConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeauthorizeConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteApiDestination struct { } func (*validateOpDeleteApiDestination) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteApiDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteApiDestinationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteApiDestinationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteArchive struct { } func (*validateOpDeleteArchive) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteArchive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteArchiveInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteArchiveInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteConnection struct { } func (*validateOpDeleteConnection) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEndpoint struct { } func (*validateOpDeleteEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteEventBus struct { } func (*validateOpDeleteEventBus) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteEventBus) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteEventBusInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteEventBusInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeletePartnerEventSource struct { } func (*validateOpDeletePartnerEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpDeletePartnerEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeletePartnerEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeletePartnerEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDeleteRule struct { } func (*validateOpDeleteRule) ID() string { return "OperationInputValidation" } func (m *validateOpDeleteRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DeleteRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDeleteRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeApiDestination struct { } func (*validateOpDescribeApiDestination) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeApiDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeApiDestinationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeApiDestinationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeArchive struct { } func (*validateOpDescribeArchive) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeArchive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeArchiveInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeArchiveInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeConnection struct { } func (*validateOpDescribeConnection) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEndpoint struct { } func (*validateOpDescribeEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeEventSource struct { } func (*validateOpDescribeEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribePartnerEventSource struct { } func (*validateOpDescribePartnerEventSource) ID() string { return "OperationInputValidation" } func (m *validateOpDescribePartnerEventSource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribePartnerEventSourceInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribePartnerEventSourceInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeReplay struct { } func (*validateOpDescribeReplay) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeReplay) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeReplayInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeReplayInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDescribeRule struct { } func (*validateOpDescribeRule) ID() string { return "OperationInputValidation" } func (m *validateOpDescribeRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DescribeRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDescribeRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpDisableRule struct { } func (*validateOpDisableRule) ID() string { return "OperationInputValidation" } func (m *validateOpDisableRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*DisableRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpDisableRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpEnableRule struct { } func (*validateOpEnableRule) ID() string { return "OperationInputValidation" } func (m *validateOpEnableRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*EnableRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpEnableRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListPartnerEventSourceAccounts struct { } func (*validateOpListPartnerEventSourceAccounts) ID() string { return "OperationInputValidation" } func (m *validateOpListPartnerEventSourceAccounts) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListPartnerEventSourceAccountsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListPartnerEventSourceAccountsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListPartnerEventSources struct { } func (*validateOpListPartnerEventSources) ID() string { return "OperationInputValidation" } func (m *validateOpListPartnerEventSources) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListPartnerEventSourcesInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListPartnerEventSourcesInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpListRuleNamesByTarget struct { } func (*validateOpListRuleNamesByTarget) ID() string { return "OperationInputValidation" } func (m *validateOpListRuleNamesByTarget) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListRuleNamesByTargetInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListRuleNamesByTargetInput(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 validateOpListTargetsByRule struct { } func (*validateOpListTargetsByRule) ID() string { return "OperationInputValidation" } func (m *validateOpListTargetsByRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*ListTargetsByRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpListTargetsByRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpPutEvents struct { } func (*validateOpPutEvents) ID() string { return "OperationInputValidation" } func (m *validateOpPutEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutEventsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutEventsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpPutPartnerEvents struct { } func (*validateOpPutPartnerEvents) ID() string { return "OperationInputValidation" } func (m *validateOpPutPartnerEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutPartnerEventsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutPartnerEventsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpPutPermission struct { } func (*validateOpPutPermission) ID() string { return "OperationInputValidation" } func (m *validateOpPutPermission) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutPermissionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutPermissionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpPutRule struct { } func (*validateOpPutRule) ID() string { return "OperationInputValidation" } func (m *validateOpPutRule) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutRuleInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutRuleInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpPutTargets struct { } func (*validateOpPutTargets) ID() string { return "OperationInputValidation" } func (m *validateOpPutTargets) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*PutTargetsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpPutTargetsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpRemoveTargets struct { } func (*validateOpRemoveTargets) ID() string { return "OperationInputValidation" } func (m *validateOpRemoveTargets) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*RemoveTargetsInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpRemoveTargetsInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpStartReplay struct { } func (*validateOpStartReplay) ID() string { return "OperationInputValidation" } func (m *validateOpStartReplay) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*StartReplayInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpStartReplayInput(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 validateOpTestEventPattern struct { } func (*validateOpTestEventPattern) ID() string { return "OperationInputValidation" } func (m *validateOpTestEventPattern) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*TestEventPatternInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpTestEventPatternInput(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 validateOpUpdateApiDestination struct { } func (*validateOpUpdateApiDestination) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateApiDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateApiDestinationInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateApiDestinationInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateArchive struct { } func (*validateOpUpdateArchive) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateArchive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateArchiveInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateArchiveInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateConnection struct { } func (*validateOpUpdateConnection) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateConnection) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateConnectionInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateConnectionInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } type validateOpUpdateEndpoint struct { } func (*validateOpUpdateEndpoint) ID() string { return "OperationInputValidation" } func (m *validateOpUpdateEndpoint) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { input, ok := in.Parameters.(*UpdateEndpointInput) if !ok { return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) } if err := validateOpUpdateEndpointInput(input); err != nil { return out, metadata, err } return next.HandleInitialize(ctx, in) } func addOpActivateEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpActivateEventSource{}, middleware.After) } func addOpCancelReplayValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCancelReplay{}, middleware.After) } func addOpCreateApiDestinationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateApiDestination{}, middleware.After) } func addOpCreateArchiveValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateArchive{}, middleware.After) } func addOpCreateConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateConnection{}, middleware.After) } func addOpCreateEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEndpoint{}, middleware.After) } func addOpCreateEventBusValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreateEventBus{}, middleware.After) } func addOpCreatePartnerEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpCreatePartnerEventSource{}, middleware.After) } func addOpDeactivateEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeactivateEventSource{}, middleware.After) } func addOpDeauthorizeConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeauthorizeConnection{}, middleware.After) } func addOpDeleteApiDestinationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteApiDestination{}, middleware.After) } func addOpDeleteArchiveValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteArchive{}, middleware.After) } func addOpDeleteConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteConnection{}, middleware.After) } func addOpDeleteEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEndpoint{}, middleware.After) } func addOpDeleteEventBusValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteEventBus{}, middleware.After) } func addOpDeletePartnerEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeletePartnerEventSource{}, middleware.After) } func addOpDeleteRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDeleteRule{}, middleware.After) } func addOpDescribeApiDestinationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeApiDestination{}, middleware.After) } func addOpDescribeArchiveValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeArchive{}, middleware.After) } func addOpDescribeConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeConnection{}, middleware.After) } func addOpDescribeEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEndpoint{}, middleware.After) } func addOpDescribeEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeEventSource{}, middleware.After) } func addOpDescribePartnerEventSourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribePartnerEventSource{}, middleware.After) } func addOpDescribeReplayValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeReplay{}, middleware.After) } func addOpDescribeRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDescribeRule{}, middleware.After) } func addOpDisableRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpDisableRule{}, middleware.After) } func addOpEnableRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpEnableRule{}, middleware.After) } func addOpListPartnerEventSourceAccountsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListPartnerEventSourceAccounts{}, middleware.After) } func addOpListPartnerEventSourcesValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListPartnerEventSources{}, middleware.After) } func addOpListRuleNamesByTargetValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListRuleNamesByTarget{}, middleware.After) } func addOpListTagsForResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTagsForResource{}, middleware.After) } func addOpListTargetsByRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpListTargetsByRule{}, middleware.After) } func addOpPutEventsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutEvents{}, middleware.After) } func addOpPutPartnerEventsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutPartnerEvents{}, middleware.After) } func addOpPutPermissionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutPermission{}, middleware.After) } func addOpPutRuleValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutRule{}, middleware.After) } func addOpPutTargetsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpPutTargets{}, middleware.After) } func addOpRemoveTargetsValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpRemoveTargets{}, middleware.After) } func addOpStartReplayValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpStartReplay{}, middleware.After) } func addOpTagResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpTagResource{}, middleware.After) } func addOpTestEventPatternValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpTestEventPattern{}, middleware.After) } func addOpUntagResourceValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUntagResource{}, middleware.After) } func addOpUpdateApiDestinationValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateApiDestination{}, middleware.After) } func addOpUpdateArchiveValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateArchive{}, middleware.After) } func addOpUpdateConnectionValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateConnection{}, middleware.After) } func addOpUpdateEndpointValidationMiddleware(stack *middleware.Stack) error { return stack.Initialize.Add(&validateOpUpdateEndpoint{}, middleware.After) } func validateAwsVpcConfiguration(v *types.AwsVpcConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "AwsVpcConfiguration"} if v.Subnets == nil { invalidParams.Add(smithy.NewErrParamRequired("Subnets")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateBatchParameters(v *types.BatchParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "BatchParameters"} if v.JobDefinition == nil { invalidParams.Add(smithy.NewErrParamRequired("JobDefinition")) } if v.JobName == nil { invalidParams.Add(smithy.NewErrParamRequired("JobName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCapacityProviderStrategy(v []types.CapacityProviderStrategyItem) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CapacityProviderStrategy"} for i := range v { if err := validateCapacityProviderStrategyItem(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCapacityProviderStrategyItem(v *types.CapacityProviderStrategyItem) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CapacityProviderStrategyItem"} if v.CapacityProvider == nil { invalidParams.Add(smithy.NewErrParamRequired("CapacityProvider")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCondition(v *types.Condition) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Condition"} if v.Type == nil { invalidParams.Add(smithy.NewErrParamRequired("Type")) } 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 validateCreateConnectionApiKeyAuthRequestParameters(v *types.CreateConnectionApiKeyAuthRequestParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionApiKeyAuthRequestParameters"} if v.ApiKeyName == nil { invalidParams.Add(smithy.NewErrParamRequired("ApiKeyName")) } if v.ApiKeyValue == nil { invalidParams.Add(smithy.NewErrParamRequired("ApiKeyValue")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCreateConnectionAuthRequestParameters(v *types.CreateConnectionAuthRequestParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionAuthRequestParameters"} if v.BasicAuthParameters != nil { if err := validateCreateConnectionBasicAuthRequestParameters(v.BasicAuthParameters); err != nil { invalidParams.AddNested("BasicAuthParameters", err.(smithy.InvalidParamsError)) } } if v.OAuthParameters != nil { if err := validateCreateConnectionOAuthRequestParameters(v.OAuthParameters); err != nil { invalidParams.AddNested("OAuthParameters", err.(smithy.InvalidParamsError)) } } if v.ApiKeyAuthParameters != nil { if err := validateCreateConnectionApiKeyAuthRequestParameters(v.ApiKeyAuthParameters); err != nil { invalidParams.AddNested("ApiKeyAuthParameters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCreateConnectionBasicAuthRequestParameters(v *types.CreateConnectionBasicAuthRequestParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionBasicAuthRequestParameters"} if v.Username == nil { invalidParams.Add(smithy.NewErrParamRequired("Username")) } if v.Password == nil { invalidParams.Add(smithy.NewErrParamRequired("Password")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCreateConnectionOAuthClientRequestParameters(v *types.CreateConnectionOAuthClientRequestParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionOAuthClientRequestParameters"} if v.ClientID == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientID")) } if v.ClientSecret == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientSecret")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateCreateConnectionOAuthRequestParameters(v *types.CreateConnectionOAuthRequestParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionOAuthRequestParameters"} if v.ClientParameters == nil { invalidParams.Add(smithy.NewErrParamRequired("ClientParameters")) } else if v.ClientParameters != nil { if err := validateCreateConnectionOAuthClientRequestParameters(v.ClientParameters); err != nil { invalidParams.AddNested("ClientParameters", err.(smithy.InvalidParamsError)) } } if v.AuthorizationEndpoint == nil { invalidParams.Add(smithy.NewErrParamRequired("AuthorizationEndpoint")) } if len(v.HttpMethod) == 0 { invalidParams.Add(smithy.NewErrParamRequired("HttpMethod")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateEcsParameters(v *types.EcsParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "EcsParameters"} if v.TaskDefinitionArn == nil { invalidParams.Add(smithy.NewErrParamRequired("TaskDefinitionArn")) } if v.NetworkConfiguration != nil { if err := validateNetworkConfiguration(v.NetworkConfiguration); err != nil { invalidParams.AddNested("NetworkConfiguration", err.(smithy.InvalidParamsError)) } } if v.CapacityProviderStrategy != nil { if err := validateCapacityProviderStrategy(v.CapacityProviderStrategy); err != nil { invalidParams.AddNested("CapacityProviderStrategy", err.(smithy.InvalidParamsError)) } } 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 validateEndpointEventBus(v *types.EndpointEventBus) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "EndpointEventBus"} if v.EventBusArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EventBusArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateEndpointEventBusList(v []types.EndpointEventBus) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "EndpointEventBusList"} for i := range v { if err := validateEndpointEventBus(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateFailoverConfig(v *types.FailoverConfig) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "FailoverConfig"} if v.Primary == nil { invalidParams.Add(smithy.NewErrParamRequired("Primary")) } else if v.Primary != nil { if err := validatePrimary(v.Primary); err != nil { invalidParams.AddNested("Primary", err.(smithy.InvalidParamsError)) } } if v.Secondary == nil { invalidParams.Add(smithy.NewErrParamRequired("Secondary")) } else if v.Secondary != nil { if err := validateSecondary(v.Secondary); err != nil { invalidParams.AddNested("Secondary", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateInputTransformer(v *types.InputTransformer) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "InputTransformer"} if v.InputTemplate == nil { invalidParams.Add(smithy.NewErrParamRequired("InputTemplate")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateKinesisParameters(v *types.KinesisParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "KinesisParameters"} if v.PartitionKeyPath == nil { invalidParams.Add(smithy.NewErrParamRequired("PartitionKeyPath")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateNetworkConfiguration(v *types.NetworkConfiguration) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "NetworkConfiguration"} if v.AwsvpcConfiguration != nil { if err := validateAwsVpcConfiguration(v.AwsvpcConfiguration); err != nil { invalidParams.AddNested("AwsvpcConfiguration", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validatePrimary(v *types.Primary) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Primary"} if v.HealthCheck == nil { invalidParams.Add(smithy.NewErrParamRequired("HealthCheck")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRedshiftDataParameters(v *types.RedshiftDataParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RedshiftDataParameters"} if v.Database == nil { invalidParams.Add(smithy.NewErrParamRequired("Database")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateReplayDestination(v *types.ReplayDestination) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ReplayDestination"} if v.Arn == nil { invalidParams.Add(smithy.NewErrParamRequired("Arn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRoutingConfig(v *types.RoutingConfig) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RoutingConfig"} if v.FailoverConfig == nil { invalidParams.Add(smithy.NewErrParamRequired("FailoverConfig")) } else if v.FailoverConfig != nil { if err := validateFailoverConfig(v.FailoverConfig); err != nil { invalidParams.AddNested("FailoverConfig", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRunCommandParameters(v *types.RunCommandParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RunCommandParameters"} if v.RunCommandTargets == nil { invalidParams.Add(smithy.NewErrParamRequired("RunCommandTargets")) } else if v.RunCommandTargets != nil { if err := validateRunCommandTargets(v.RunCommandTargets); err != nil { invalidParams.AddNested("RunCommandTargets", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRunCommandTarget(v *types.RunCommandTarget) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RunCommandTarget"} if v.Key == nil { invalidParams.Add(smithy.NewErrParamRequired("Key")) } if v.Values == nil { invalidParams.Add(smithy.NewErrParamRequired("Values")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateRunCommandTargets(v []types.RunCommandTarget) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RunCommandTargets"} for i := range v { if err := validateRunCommandTarget(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateSageMakerPipelineParameter(v *types.SageMakerPipelineParameter) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "SageMakerPipelineParameter"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.Value == nil { invalidParams.Add(smithy.NewErrParamRequired("Value")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateSageMakerPipelineParameterList(v []types.SageMakerPipelineParameter) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "SageMakerPipelineParameterList"} for i := range v { if err := validateSageMakerPipelineParameter(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateSageMakerPipelineParameters(v *types.SageMakerPipelineParameters) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "SageMakerPipelineParameters"} if v.PipelineParameterList != nil { if err := validateSageMakerPipelineParameterList(v.PipelineParameterList); err != nil { invalidParams.AddNested("PipelineParameterList", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateSecondary(v *types.Secondary) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Secondary"} if v.Route == nil { invalidParams.Add(smithy.NewErrParamRequired("Route")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } 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 validateTarget(v *types.Target) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "Target"} if v.Id == nil { invalidParams.Add(smithy.NewErrParamRequired("Id")) } if v.Arn == nil { invalidParams.Add(smithy.NewErrParamRequired("Arn")) } if v.InputTransformer != nil { if err := validateInputTransformer(v.InputTransformer); err != nil { invalidParams.AddNested("InputTransformer", err.(smithy.InvalidParamsError)) } } if v.KinesisParameters != nil { if err := validateKinesisParameters(v.KinesisParameters); err != nil { invalidParams.AddNested("KinesisParameters", err.(smithy.InvalidParamsError)) } } if v.RunCommandParameters != nil { if err := validateRunCommandParameters(v.RunCommandParameters); err != nil { invalidParams.AddNested("RunCommandParameters", err.(smithy.InvalidParamsError)) } } if v.EcsParameters != nil { if err := validateEcsParameters(v.EcsParameters); err != nil { invalidParams.AddNested("EcsParameters", err.(smithy.InvalidParamsError)) } } if v.BatchParameters != nil { if err := validateBatchParameters(v.BatchParameters); err != nil { invalidParams.AddNested("BatchParameters", err.(smithy.InvalidParamsError)) } } if v.RedshiftDataParameters != nil { if err := validateRedshiftDataParameters(v.RedshiftDataParameters); err != nil { invalidParams.AddNested("RedshiftDataParameters", err.(smithy.InvalidParamsError)) } } if v.SageMakerPipelineParameters != nil { if err := validateSageMakerPipelineParameters(v.SageMakerPipelineParameters); err != nil { invalidParams.AddNested("SageMakerPipelineParameters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateTargetList(v []types.Target) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TargetList"} for i := range v { if err := validateTarget(&v[i]); err != nil { invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpActivateEventSourceInput(v *ActivateEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ActivateEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCancelReplayInput(v *CancelReplayInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CancelReplayInput"} if v.ReplayName == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplayName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateApiDestinationInput(v *CreateApiDestinationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateApiDestinationInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.ConnectionArn == nil { invalidParams.Add(smithy.NewErrParamRequired("ConnectionArn")) } if v.InvocationEndpoint == nil { invalidParams.Add(smithy.NewErrParamRequired("InvocationEndpoint")) } if len(v.HttpMethod) == 0 { invalidParams.Add(smithy.NewErrParamRequired("HttpMethod")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateArchiveInput(v *CreateArchiveInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateArchiveInput"} if v.ArchiveName == nil { invalidParams.Add(smithy.NewErrParamRequired("ArchiveName")) } if v.EventSourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EventSourceArn")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateConnectionInput(v *CreateConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateConnectionInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if len(v.AuthorizationType) == 0 { invalidParams.Add(smithy.NewErrParamRequired("AuthorizationType")) } if v.AuthParameters == nil { invalidParams.Add(smithy.NewErrParamRequired("AuthParameters")) } else if v.AuthParameters != nil { if err := validateCreateConnectionAuthRequestParameters(v.AuthParameters); err != nil { invalidParams.AddNested("AuthParameters", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEndpointInput(v *CreateEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEndpointInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.RoutingConfig == nil { invalidParams.Add(smithy.NewErrParamRequired("RoutingConfig")) } else if v.RoutingConfig != nil { if err := validateRoutingConfig(v.RoutingConfig); err != nil { invalidParams.AddNested("RoutingConfig", err.(smithy.InvalidParamsError)) } } if v.EventBuses == nil { invalidParams.Add(smithy.NewErrParamRequired("EventBuses")) } else if v.EventBuses != nil { if err := validateEndpointEventBusList(v.EventBuses); err != nil { invalidParams.AddNested("EventBuses", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpCreateEventBusInput(v *CreateEventBusInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreateEventBusInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } 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 validateOpCreatePartnerEventSourceInput(v *CreatePartnerEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "CreatePartnerEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.Account == nil { invalidParams.Add(smithy.NewErrParamRequired("Account")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeactivateEventSourceInput(v *DeactivateEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeactivateEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeauthorizeConnectionInput(v *DeauthorizeConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeauthorizeConnectionInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteApiDestinationInput(v *DeleteApiDestinationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteApiDestinationInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteArchiveInput(v *DeleteArchiveInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteArchiveInput"} if v.ArchiveName == nil { invalidParams.Add(smithy.NewErrParamRequired("ArchiveName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteConnectionInput(v *DeleteConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteConnectionInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEndpointInput(v *DeleteEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEndpointInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteEventBusInput(v *DeleteEventBusInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteEventBusInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeletePartnerEventSourceInput(v *DeletePartnerEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeletePartnerEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.Account == nil { invalidParams.Add(smithy.NewErrParamRequired("Account")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDeleteRuleInput(v *DeleteRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DeleteRuleInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeApiDestinationInput(v *DescribeApiDestinationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeApiDestinationInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeArchiveInput(v *DescribeArchiveInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeArchiveInput"} if v.ArchiveName == nil { invalidParams.Add(smithy.NewErrParamRequired("ArchiveName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeConnectionInput(v *DescribeConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeConnectionInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEndpointInput(v *DescribeEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEndpointInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeEventSourceInput(v *DescribeEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribePartnerEventSourceInput(v *DescribePartnerEventSourceInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribePartnerEventSourceInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeReplayInput(v *DescribeReplayInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeReplayInput"} if v.ReplayName == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplayName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDescribeRuleInput(v *DescribeRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DescribeRuleInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpDisableRuleInput(v *DisableRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "DisableRuleInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpEnableRuleInput(v *EnableRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "EnableRuleInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListPartnerEventSourceAccountsInput(v *ListPartnerEventSourceAccountsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListPartnerEventSourceAccountsInput"} if v.EventSourceName == nil { invalidParams.Add(smithy.NewErrParamRequired("EventSourceName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListPartnerEventSourcesInput(v *ListPartnerEventSourcesInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListPartnerEventSourcesInput"} if v.NamePrefix == nil { invalidParams.Add(smithy.NewErrParamRequired("NamePrefix")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpListRuleNamesByTargetInput(v *ListRuleNamesByTargetInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListRuleNamesByTargetInput"} if v.TargetArn == nil { invalidParams.Add(smithy.NewErrParamRequired("TargetArn")) } 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 validateOpListTargetsByRuleInput(v *ListTargetsByRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "ListTargetsByRuleInput"} if v.Rule == nil { invalidParams.Add(smithy.NewErrParamRequired("Rule")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpPutEventsInput(v *PutEventsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutEventsInput"} if v.Entries == nil { invalidParams.Add(smithy.NewErrParamRequired("Entries")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpPutPartnerEventsInput(v *PutPartnerEventsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutPartnerEventsInput"} if v.Entries == nil { invalidParams.Add(smithy.NewErrParamRequired("Entries")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpPutPermissionInput(v *PutPermissionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutPermissionInput"} if v.Condition != nil { if err := validateCondition(v.Condition); err != nil { invalidParams.AddNested("Condition", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpPutRuleInput(v *PutRuleInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutRuleInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } 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 validateOpPutTargetsInput(v *PutTargetsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "PutTargetsInput"} if v.Rule == nil { invalidParams.Add(smithy.NewErrParamRequired("Rule")) } if v.Targets == nil { invalidParams.Add(smithy.NewErrParamRequired("Targets")) } else if v.Targets != nil { if err := validateTargetList(v.Targets); err != nil { invalidParams.AddNested("Targets", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpRemoveTargetsInput(v *RemoveTargetsInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "RemoveTargetsInput"} if v.Rule == nil { invalidParams.Add(smithy.NewErrParamRequired("Rule")) } if v.Ids == nil { invalidParams.Add(smithy.NewErrParamRequired("Ids")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpStartReplayInput(v *StartReplayInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "StartReplayInput"} if v.ReplayName == nil { invalidParams.Add(smithy.NewErrParamRequired("ReplayName")) } if v.EventSourceArn == nil { invalidParams.Add(smithy.NewErrParamRequired("EventSourceArn")) } if v.EventStartTime == nil { invalidParams.Add(smithy.NewErrParamRequired("EventStartTime")) } if v.EventEndTime == nil { invalidParams.Add(smithy.NewErrParamRequired("EventEndTime")) } if v.Destination == nil { invalidParams.Add(smithy.NewErrParamRequired("Destination")) } else if v.Destination != nil { if err := validateReplayDestination(v.Destination); err != nil { invalidParams.AddNested("Destination", err.(smithy.InvalidParamsError)) } } 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 validateOpTestEventPatternInput(v *TestEventPatternInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "TestEventPatternInput"} if v.EventPattern == nil { invalidParams.Add(smithy.NewErrParamRequired("EventPattern")) } if v.Event == nil { invalidParams.Add(smithy.NewErrParamRequired("Event")) } 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 validateOpUpdateApiDestinationInput(v *UpdateApiDestinationInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateApiDestinationInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateArchiveInput(v *UpdateArchiveInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateArchiveInput"} if v.ArchiveName == nil { invalidParams.Add(smithy.NewErrParamRequired("ArchiveName")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateConnectionInput(v *UpdateConnectionInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateConnectionInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if invalidParams.Len() > 0 { return invalidParams } else { return nil } } func validateOpUpdateEndpointInput(v *UpdateEndpointInput) error { if v == nil { return nil } invalidParams := smithy.InvalidParamsError{Context: "UpdateEndpointInput"} if v.Name == nil { invalidParams.Add(smithy.NewErrParamRequired("Name")) } if v.RoutingConfig != nil { if err := validateRoutingConfig(v.RoutingConfig); err != nil { invalidParams.AddNested("RoutingConfig", err.(smithy.InvalidParamsError)) } } if v.EventBuses != nil { if err := validateEndpointEventBusList(v.EventBuses); err != nil { invalidParams.AddNested("EventBuses", err.(smithy.InvalidParamsError)) } } if invalidParams.Len() > 0 { return invalidParams } else { return nil } }