3484 lines
102 KiB
Go
3484 lines
102 KiB
Go
// Code generated by smithy-go-codegen DO NOT EDIT.
|
|
|
|
package dynamodb
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
|
|
smithy "github.com/aws/smithy-go"
|
|
"github.com/aws/smithy-go/middleware"
|
|
)
|
|
|
|
type validateOpBatchExecuteStatement struct {
|
|
}
|
|
|
|
func (*validateOpBatchExecuteStatement) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpBatchExecuteStatement) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*BatchExecuteStatementInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpBatchExecuteStatementInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpBatchGetItem struct {
|
|
}
|
|
|
|
func (*validateOpBatchGetItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpBatchGetItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*BatchGetItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpBatchGetItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpBatchWriteItem struct {
|
|
}
|
|
|
|
func (*validateOpBatchWriteItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpBatchWriteItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*BatchWriteItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpBatchWriteItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpCreateBackup struct {
|
|
}
|
|
|
|
func (*validateOpCreateBackup) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpCreateBackup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*CreateBackupInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpCreateBackupInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpCreateGlobalTable struct {
|
|
}
|
|
|
|
func (*validateOpCreateGlobalTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpCreateGlobalTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*CreateGlobalTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpCreateGlobalTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpCreateTable struct {
|
|
}
|
|
|
|
func (*validateOpCreateTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpCreateTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*CreateTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpCreateTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDeleteBackup struct {
|
|
}
|
|
|
|
func (*validateOpDeleteBackup) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDeleteBackup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DeleteBackupInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDeleteBackupInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDeleteItem struct {
|
|
}
|
|
|
|
func (*validateOpDeleteItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDeleteItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DeleteItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDeleteItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDeleteResourcePolicy struct {
|
|
}
|
|
|
|
func (*validateOpDeleteResourcePolicy) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDeleteResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DeleteResourcePolicyInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDeleteResourcePolicyInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDeleteTable struct {
|
|
}
|
|
|
|
func (*validateOpDeleteTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDeleteTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DeleteTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDeleteTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeBackup struct {
|
|
}
|
|
|
|
func (*validateOpDescribeBackup) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeBackup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeBackupInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeBackupInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeContinuousBackups struct {
|
|
}
|
|
|
|
func (*validateOpDescribeContinuousBackups) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeContinuousBackups) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeContinuousBackupsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeContinuousBackupsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeContributorInsights struct {
|
|
}
|
|
|
|
func (*validateOpDescribeContributorInsights) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeContributorInsights) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeContributorInsightsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeContributorInsightsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeExport struct {
|
|
}
|
|
|
|
func (*validateOpDescribeExport) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeExport) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeExportInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeExportInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeGlobalTable struct {
|
|
}
|
|
|
|
func (*validateOpDescribeGlobalTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeGlobalTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeGlobalTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeGlobalTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeGlobalTableSettings struct {
|
|
}
|
|
|
|
func (*validateOpDescribeGlobalTableSettings) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeGlobalTableSettings) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeGlobalTableSettingsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeGlobalTableSettingsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeImport struct {
|
|
}
|
|
|
|
func (*validateOpDescribeImport) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeImport) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeImportInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeImportInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeKinesisStreamingDestination struct {
|
|
}
|
|
|
|
func (*validateOpDescribeKinesisStreamingDestination) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeKinesisStreamingDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeKinesisStreamingDestinationInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeKinesisStreamingDestinationInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeTable struct {
|
|
}
|
|
|
|
func (*validateOpDescribeTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeTableReplicaAutoScaling struct {
|
|
}
|
|
|
|
func (*validateOpDescribeTableReplicaAutoScaling) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeTableReplicaAutoScaling) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeTableReplicaAutoScalingInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeTableReplicaAutoScalingInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDescribeTimeToLive struct {
|
|
}
|
|
|
|
func (*validateOpDescribeTimeToLive) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDescribeTimeToLive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DescribeTimeToLiveInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDescribeTimeToLiveInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpDisableKinesisStreamingDestination struct {
|
|
}
|
|
|
|
func (*validateOpDisableKinesisStreamingDestination) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpDisableKinesisStreamingDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*DisableKinesisStreamingDestinationInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpDisableKinesisStreamingDestinationInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpEnableKinesisStreamingDestination struct {
|
|
}
|
|
|
|
func (*validateOpEnableKinesisStreamingDestination) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpEnableKinesisStreamingDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*EnableKinesisStreamingDestinationInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpEnableKinesisStreamingDestinationInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpExecuteStatement struct {
|
|
}
|
|
|
|
func (*validateOpExecuteStatement) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpExecuteStatement) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ExecuteStatementInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpExecuteStatementInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpExecuteTransaction struct {
|
|
}
|
|
|
|
func (*validateOpExecuteTransaction) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpExecuteTransaction) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ExecuteTransactionInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpExecuteTransactionInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpExportTableToPointInTime struct {
|
|
}
|
|
|
|
func (*validateOpExportTableToPointInTime) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpExportTableToPointInTime) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ExportTableToPointInTimeInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpExportTableToPointInTimeInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpGetItem struct {
|
|
}
|
|
|
|
func (*validateOpGetItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpGetItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*GetItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpGetItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpGetResourcePolicy struct {
|
|
}
|
|
|
|
func (*validateOpGetResourcePolicy) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpGetResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*GetResourcePolicyInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpGetResourcePolicyInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpImportTable struct {
|
|
}
|
|
|
|
func (*validateOpImportTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpImportTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ImportTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpImportTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpListTagsOfResource struct {
|
|
}
|
|
|
|
func (*validateOpListTagsOfResource) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpListTagsOfResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ListTagsOfResourceInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpListTagsOfResourceInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpPutItem struct {
|
|
}
|
|
|
|
func (*validateOpPutItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpPutItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*PutItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpPutItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpPutResourcePolicy struct {
|
|
}
|
|
|
|
func (*validateOpPutResourcePolicy) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpPutResourcePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*PutResourcePolicyInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpPutResourcePolicyInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpQuery struct {
|
|
}
|
|
|
|
func (*validateOpQuery) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpQuery) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*QueryInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpQueryInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpRestoreTableFromBackup struct {
|
|
}
|
|
|
|
func (*validateOpRestoreTableFromBackup) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpRestoreTableFromBackup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*RestoreTableFromBackupInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpRestoreTableFromBackupInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpRestoreTableToPointInTime struct {
|
|
}
|
|
|
|
func (*validateOpRestoreTableToPointInTime) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpRestoreTableToPointInTime) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*RestoreTableToPointInTimeInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpRestoreTableToPointInTimeInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpScan struct {
|
|
}
|
|
|
|
func (*validateOpScan) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpScan) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*ScanInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpScanInput(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 validateOpTransactGetItems struct {
|
|
}
|
|
|
|
func (*validateOpTransactGetItems) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpTransactGetItems) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*TransactGetItemsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpTransactGetItemsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpTransactWriteItems struct {
|
|
}
|
|
|
|
func (*validateOpTransactWriteItems) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpTransactWriteItems) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*TransactWriteItemsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpTransactWriteItemsInput(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 validateOpUpdateContinuousBackups struct {
|
|
}
|
|
|
|
func (*validateOpUpdateContinuousBackups) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateContinuousBackups) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateContinuousBackupsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateContinuousBackupsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateContributorInsights struct {
|
|
}
|
|
|
|
func (*validateOpUpdateContributorInsights) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateContributorInsights) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateContributorInsightsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateContributorInsightsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateGlobalTable struct {
|
|
}
|
|
|
|
func (*validateOpUpdateGlobalTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateGlobalTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateGlobalTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateGlobalTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateGlobalTableSettings struct {
|
|
}
|
|
|
|
func (*validateOpUpdateGlobalTableSettings) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateGlobalTableSettings) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateGlobalTableSettingsInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateGlobalTableSettingsInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateItem struct {
|
|
}
|
|
|
|
func (*validateOpUpdateItem) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateItem) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateItemInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateItemInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateKinesisStreamingDestination struct {
|
|
}
|
|
|
|
func (*validateOpUpdateKinesisStreamingDestination) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateKinesisStreamingDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateKinesisStreamingDestinationInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateKinesisStreamingDestinationInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateTable struct {
|
|
}
|
|
|
|
func (*validateOpUpdateTable) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateTableInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateTableInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateTableReplicaAutoScaling struct {
|
|
}
|
|
|
|
func (*validateOpUpdateTableReplicaAutoScaling) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateTableReplicaAutoScaling) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateTableReplicaAutoScalingInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateTableReplicaAutoScalingInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
type validateOpUpdateTimeToLive struct {
|
|
}
|
|
|
|
func (*validateOpUpdateTimeToLive) ID() string {
|
|
return "OperationInputValidation"
|
|
}
|
|
|
|
func (m *validateOpUpdateTimeToLive) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
|
|
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
|
|
) {
|
|
input, ok := in.Parameters.(*UpdateTimeToLiveInput)
|
|
if !ok {
|
|
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
|
|
}
|
|
if err := validateOpUpdateTimeToLiveInput(input); err != nil {
|
|
return out, metadata, err
|
|
}
|
|
return next.HandleInitialize(ctx, in)
|
|
}
|
|
|
|
func addOpBatchExecuteStatementValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpBatchExecuteStatement{}, middleware.After)
|
|
}
|
|
|
|
func addOpBatchGetItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpBatchGetItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpBatchWriteItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpBatchWriteItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpCreateBackupValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpCreateBackup{}, middleware.After)
|
|
}
|
|
|
|
func addOpCreateGlobalTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpCreateGlobalTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpCreateTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpCreateTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpDeleteBackupValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDeleteBackup{}, middleware.After)
|
|
}
|
|
|
|
func addOpDeleteItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDeleteItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpDeleteResourcePolicyValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDeleteResourcePolicy{}, middleware.After)
|
|
}
|
|
|
|
func addOpDeleteTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDeleteTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeBackupValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeBackup{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeContinuousBackupsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeContinuousBackups{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeContributorInsightsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeContributorInsights{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeExportValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeExport{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeGlobalTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeGlobalTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeGlobalTableSettingsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeGlobalTableSettings{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeImportValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeImport{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeKinesisStreamingDestinationValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeKinesisStreamingDestination{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeTableReplicaAutoScalingValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeTableReplicaAutoScaling{}, middleware.After)
|
|
}
|
|
|
|
func addOpDescribeTimeToLiveValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDescribeTimeToLive{}, middleware.After)
|
|
}
|
|
|
|
func addOpDisableKinesisStreamingDestinationValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpDisableKinesisStreamingDestination{}, middleware.After)
|
|
}
|
|
|
|
func addOpEnableKinesisStreamingDestinationValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpEnableKinesisStreamingDestination{}, middleware.After)
|
|
}
|
|
|
|
func addOpExecuteStatementValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpExecuteStatement{}, middleware.After)
|
|
}
|
|
|
|
func addOpExecuteTransactionValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpExecuteTransaction{}, middleware.After)
|
|
}
|
|
|
|
func addOpExportTableToPointInTimeValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpExportTableToPointInTime{}, middleware.After)
|
|
}
|
|
|
|
func addOpGetItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpGetItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpGetResourcePolicyValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpGetResourcePolicy{}, middleware.After)
|
|
}
|
|
|
|
func addOpImportTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpImportTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpListTagsOfResourceValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpListTagsOfResource{}, middleware.After)
|
|
}
|
|
|
|
func addOpPutItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpPutItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpPutResourcePolicyValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpPutResourcePolicy{}, middleware.After)
|
|
}
|
|
|
|
func addOpQueryValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpQuery{}, middleware.After)
|
|
}
|
|
|
|
func addOpRestoreTableFromBackupValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpRestoreTableFromBackup{}, middleware.After)
|
|
}
|
|
|
|
func addOpRestoreTableToPointInTimeValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpRestoreTableToPointInTime{}, middleware.After)
|
|
}
|
|
|
|
func addOpScanValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpScan{}, middleware.After)
|
|
}
|
|
|
|
func addOpTagResourceValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpTagResource{}, middleware.After)
|
|
}
|
|
|
|
func addOpTransactGetItemsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpTransactGetItems{}, middleware.After)
|
|
}
|
|
|
|
func addOpTransactWriteItemsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpTransactWriteItems{}, middleware.After)
|
|
}
|
|
|
|
func addOpUntagResourceValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUntagResource{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateContinuousBackupsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateContinuousBackups{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateContributorInsightsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateContributorInsights{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateGlobalTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateGlobalTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateGlobalTableSettingsValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateGlobalTableSettings{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateItemValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateItem{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateKinesisStreamingDestinationValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateKinesisStreamingDestination{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateTableValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateTable{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateTableReplicaAutoScalingValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateTableReplicaAutoScaling{}, middleware.After)
|
|
}
|
|
|
|
func addOpUpdateTimeToLiveValidationMiddleware(stack *middleware.Stack) error {
|
|
return stack.Initialize.Add(&validateOpUpdateTimeToLive{}, middleware.After)
|
|
}
|
|
|
|
func validateAttributeDefinition(v *types.AttributeDefinition) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "AttributeDefinition"}
|
|
if v.AttributeName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeName"))
|
|
}
|
|
if len(v.AttributeType) == 0 {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeType"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateAttributeDefinitions(v []types.AttributeDefinition) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "AttributeDefinitions"}
|
|
for i := range v {
|
|
if err := validateAttributeDefinition(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateAutoScalingPolicyUpdate(v *types.AutoScalingPolicyUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "AutoScalingPolicyUpdate"}
|
|
if v.TargetTrackingScalingPolicyConfiguration == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TargetTrackingScalingPolicyConfiguration"))
|
|
} else if v.TargetTrackingScalingPolicyConfiguration != nil {
|
|
if err := validateAutoScalingTargetTrackingScalingPolicyConfigurationUpdate(v.TargetTrackingScalingPolicyConfiguration); err != nil {
|
|
invalidParams.AddNested("TargetTrackingScalingPolicyConfiguration", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateAutoScalingSettingsUpdate(v *types.AutoScalingSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "AutoScalingSettingsUpdate"}
|
|
if v.ScalingPolicyUpdate != nil {
|
|
if err := validateAutoScalingPolicyUpdate(v.ScalingPolicyUpdate); err != nil {
|
|
invalidParams.AddNested("ScalingPolicyUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateAutoScalingTargetTrackingScalingPolicyConfigurationUpdate(v *types.AutoScalingTargetTrackingScalingPolicyConfigurationUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "AutoScalingTargetTrackingScalingPolicyConfigurationUpdate"}
|
|
if v.TargetValue == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TargetValue"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateBatchGetRequestMap(v map[string]types.KeysAndAttributes) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchGetRequestMap"}
|
|
for key := range v {
|
|
value := v[key]
|
|
if err := validateKeysAndAttributes(&value); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%q]", key), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateBatchStatementRequest(v *types.BatchStatementRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchStatementRequest"}
|
|
if v.Statement == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Statement"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateBatchWriteItemRequestMap(v map[string][]types.WriteRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchWriteItemRequestMap"}
|
|
for key := range v {
|
|
if err := validateWriteRequests(v[key]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%q]", key), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
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 len(v.ComparisonOperator) == 0 {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ComparisonOperator"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateConditionCheck(v *types.ConditionCheck) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ConditionCheck"}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.ConditionExpression == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ConditionExpression"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateCreateGlobalSecondaryIndexAction(v *types.CreateGlobalSecondaryIndexAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateGlobalSecondaryIndexAction"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.KeySchema == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeySchema"))
|
|
} else if v.KeySchema != nil {
|
|
if err := validateKeySchema(v.KeySchema); err != nil {
|
|
invalidParams.AddNested("KeySchema", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Projection == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Projection"))
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateCreateReplicaAction(v *types.CreateReplicaAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateReplicaAction"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateCreateReplicationGroupMemberAction(v *types.CreateReplicationGroupMemberAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateReplicationGroupMemberAction"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if v.GlobalSecondaryIndexes != nil {
|
|
if err := validateReplicaGlobalSecondaryIndexList(v.GlobalSecondaryIndexes); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexes", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateDelete(v *types.Delete) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "Delete"}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateDeleteGlobalSecondaryIndexAction(v *types.DeleteGlobalSecondaryIndexAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteGlobalSecondaryIndexAction"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateDeleteReplicaAction(v *types.DeleteReplicaAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicaAction"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateDeleteReplicationGroupMemberAction(v *types.DeleteReplicationGroupMemberAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteReplicationGroupMemberAction"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateDeleteRequest(v *types.DeleteRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteRequest"}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateFilterConditionMap(v map[string]types.Condition) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "FilterConditionMap"}
|
|
for key := range v {
|
|
value := v[key]
|
|
if err := validateCondition(&value); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%q]", key), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGet(v *types.Get) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "Get"}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndex(v *types.GlobalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndex"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.KeySchema == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeySchema"))
|
|
} else if v.KeySchema != nil {
|
|
if err := validateKeySchema(v.KeySchema); err != nil {
|
|
invalidParams.AddNested("KeySchema", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Projection == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Projection"))
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndexAutoScalingUpdate(v *types.GlobalSecondaryIndexAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndexAutoScalingUpdate"}
|
|
if v.ProvisionedWriteCapacityAutoScalingUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ProvisionedWriteCapacityAutoScalingUpdate); err != nil {
|
|
invalidParams.AddNested("ProvisionedWriteCapacityAutoScalingUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndexAutoScalingUpdateList(v []types.GlobalSecondaryIndexAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndexAutoScalingUpdateList"}
|
|
for i := range v {
|
|
if err := validateGlobalSecondaryIndexAutoScalingUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndexList(v []types.GlobalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndexList"}
|
|
for i := range v {
|
|
if err := validateGlobalSecondaryIndex(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndexUpdate(v *types.GlobalSecondaryIndexUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndexUpdate"}
|
|
if v.Update != nil {
|
|
if err := validateUpdateGlobalSecondaryIndexAction(v.Update); err != nil {
|
|
invalidParams.AddNested("Update", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Create != nil {
|
|
if err := validateCreateGlobalSecondaryIndexAction(v.Create); err != nil {
|
|
invalidParams.AddNested("Create", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Delete != nil {
|
|
if err := validateDeleteGlobalSecondaryIndexAction(v.Delete); err != nil {
|
|
invalidParams.AddNested("Delete", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalSecondaryIndexUpdateList(v []types.GlobalSecondaryIndexUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalSecondaryIndexUpdateList"}
|
|
for i := range v {
|
|
if err := validateGlobalSecondaryIndexUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalTableGlobalSecondaryIndexSettingsUpdate(v *types.GlobalTableGlobalSecondaryIndexSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalTableGlobalSecondaryIndexSettingsUpdate"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.ProvisionedWriteCapacityAutoScalingSettingsUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ProvisionedWriteCapacityAutoScalingSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("ProvisionedWriteCapacityAutoScalingSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateGlobalTableGlobalSecondaryIndexSettingsUpdateList(v []types.GlobalTableGlobalSecondaryIndexSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GlobalTableGlobalSecondaryIndexSettingsUpdateList"}
|
|
for i := range v {
|
|
if err := validateGlobalTableGlobalSecondaryIndexSettingsUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateKeyConditions(v map[string]types.Condition) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "KeyConditions"}
|
|
for key := range v {
|
|
value := v[key]
|
|
if err := validateCondition(&value); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%q]", key), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateKeysAndAttributes(v *types.KeysAndAttributes) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "KeysAndAttributes"}
|
|
if v.Keys == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Keys"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateKeySchema(v []types.KeySchemaElement) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "KeySchema"}
|
|
for i := range v {
|
|
if err := validateKeySchemaElement(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateKeySchemaElement(v *types.KeySchemaElement) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "KeySchemaElement"}
|
|
if v.AttributeName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeName"))
|
|
}
|
|
if len(v.KeyType) == 0 {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeyType"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateLocalSecondaryIndex(v *types.LocalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "LocalSecondaryIndex"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.KeySchema == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeySchema"))
|
|
} else if v.KeySchema != nil {
|
|
if err := validateKeySchema(v.KeySchema); err != nil {
|
|
invalidParams.AddNested("KeySchema", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Projection == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Projection"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateLocalSecondaryIndexList(v []types.LocalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "LocalSecondaryIndexList"}
|
|
for i := range v {
|
|
if err := validateLocalSecondaryIndex(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateParameterizedStatement(v *types.ParameterizedStatement) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ParameterizedStatement"}
|
|
if v.Statement == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Statement"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateParameterizedStatements(v []types.ParameterizedStatement) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ParameterizedStatements"}
|
|
for i := range v {
|
|
if err := validateParameterizedStatement(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validatePartiQLBatchRequest(v []types.BatchStatementRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "PartiQLBatchRequest"}
|
|
for i := range v {
|
|
if err := validateBatchStatementRequest(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validatePointInTimeRecoverySpecification(v *types.PointInTimeRecoverySpecification) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "PointInTimeRecoverySpecification"}
|
|
if v.PointInTimeRecoveryEnabled == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("PointInTimeRecoveryEnabled"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateProvisionedThroughput(v *types.ProvisionedThroughput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ProvisionedThroughput"}
|
|
if v.ReadCapacityUnits == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ReadCapacityUnits"))
|
|
}
|
|
if v.WriteCapacityUnits == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("WriteCapacityUnits"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validatePut(v *types.Put) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "Put"}
|
|
if v.Item == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Item"))
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validatePutRequest(v *types.PutRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "PutRequest"}
|
|
if v.Item == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Item"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaAutoScalingUpdate(v *types.ReplicaAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaAutoScalingUpdate"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if v.ReplicaGlobalSecondaryIndexUpdates != nil {
|
|
if err := validateReplicaGlobalSecondaryIndexAutoScalingUpdateList(v.ReplicaGlobalSecondaryIndexUpdates); err != nil {
|
|
invalidParams.AddNested("ReplicaGlobalSecondaryIndexUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ReplicaProvisionedReadCapacityAutoScalingUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ReplicaProvisionedReadCapacityAutoScalingUpdate); err != nil {
|
|
invalidParams.AddNested("ReplicaProvisionedReadCapacityAutoScalingUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaAutoScalingUpdateList(v []types.ReplicaAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaAutoScalingUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicaAutoScalingUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndex(v *types.ReplicaGlobalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndex"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndexAutoScalingUpdate(v *types.ReplicaGlobalSecondaryIndexAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndexAutoScalingUpdate"}
|
|
if v.ProvisionedReadCapacityAutoScalingUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ProvisionedReadCapacityAutoScalingUpdate); err != nil {
|
|
invalidParams.AddNested("ProvisionedReadCapacityAutoScalingUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndexAutoScalingUpdateList(v []types.ReplicaGlobalSecondaryIndexAutoScalingUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndexAutoScalingUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicaGlobalSecondaryIndexAutoScalingUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndexList(v []types.ReplicaGlobalSecondaryIndex) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndexList"}
|
|
for i := range v {
|
|
if err := validateReplicaGlobalSecondaryIndex(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndexSettingsUpdate(v *types.ReplicaGlobalSecondaryIndexSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndexSettingsUpdate"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.ProvisionedReadCapacityAutoScalingSettingsUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ProvisionedReadCapacityAutoScalingSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("ProvisionedReadCapacityAutoScalingSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaGlobalSecondaryIndexSettingsUpdateList(v []types.ReplicaGlobalSecondaryIndexSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaGlobalSecondaryIndexSettingsUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicaGlobalSecondaryIndexSettingsUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaSettingsUpdate(v *types.ReplicaSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaSettingsUpdate"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if v.ReplicaProvisionedReadCapacityAutoScalingSettingsUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ReplicaProvisionedReadCapacityAutoScalingSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("ReplicaProvisionedReadCapacityAutoScalingSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ReplicaGlobalSecondaryIndexSettingsUpdate != nil {
|
|
if err := validateReplicaGlobalSecondaryIndexSettingsUpdateList(v.ReplicaGlobalSecondaryIndexSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("ReplicaGlobalSecondaryIndexSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaSettingsUpdateList(v []types.ReplicaSettingsUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaSettingsUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicaSettingsUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicationGroupUpdate(v *types.ReplicationGroupUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicationGroupUpdate"}
|
|
if v.Create != nil {
|
|
if err := validateCreateReplicationGroupMemberAction(v.Create); err != nil {
|
|
invalidParams.AddNested("Create", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Update != nil {
|
|
if err := validateUpdateReplicationGroupMemberAction(v.Update); err != nil {
|
|
invalidParams.AddNested("Update", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Delete != nil {
|
|
if err := validateDeleteReplicationGroupMemberAction(v.Delete); err != nil {
|
|
invalidParams.AddNested("Delete", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicationGroupUpdateList(v []types.ReplicationGroupUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicationGroupUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicationGroupUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaUpdate(v *types.ReplicaUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaUpdate"}
|
|
if v.Create != nil {
|
|
if err := validateCreateReplicaAction(v.Create); err != nil {
|
|
invalidParams.AddNested("Create", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Delete != nil {
|
|
if err := validateDeleteReplicaAction(v.Delete); err != nil {
|
|
invalidParams.AddNested("Delete", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateReplicaUpdateList(v []types.ReplicaUpdate) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ReplicaUpdateList"}
|
|
for i := range v {
|
|
if err := validateReplicaUpdate(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateS3BucketSource(v *types.S3BucketSource) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "S3BucketSource"}
|
|
if v.S3Bucket == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("S3Bucket"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateStreamSpecification(v *types.StreamSpecification) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "StreamSpecification"}
|
|
if v.StreamEnabled == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("StreamEnabled"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateTableCreationParameters(v *types.TableCreationParameters) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TableCreationParameters"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.AttributeDefinitions == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeDefinitions"))
|
|
} else if v.AttributeDefinitions != nil {
|
|
if err := validateAttributeDefinitions(v.AttributeDefinitions); err != nil {
|
|
invalidParams.AddNested("AttributeDefinitions", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.KeySchema == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeySchema"))
|
|
} else if v.KeySchema != nil {
|
|
if err := validateKeySchema(v.KeySchema); err != nil {
|
|
invalidParams.AddNested("KeySchema", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.GlobalSecondaryIndexes != nil {
|
|
if err := validateGlobalSecondaryIndexList(v.GlobalSecondaryIndexes); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexes", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
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 validateTimeToLiveSpecification(v *types.TimeToLiveSpecification) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TimeToLiveSpecification"}
|
|
if v.Enabled == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Enabled"))
|
|
}
|
|
if v.AttributeName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateTransactGetItem(v *types.TransactGetItem) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactGetItem"}
|
|
if v.Get == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Get"))
|
|
} else if v.Get != nil {
|
|
if err := validateGet(v.Get); err != nil {
|
|
invalidParams.AddNested("Get", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateTransactGetItemList(v []types.TransactGetItem) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactGetItemList"}
|
|
for i := range v {
|
|
if err := validateTransactGetItem(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateTransactWriteItem(v *types.TransactWriteItem) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactWriteItem"}
|
|
if v.ConditionCheck != nil {
|
|
if err := validateConditionCheck(v.ConditionCheck); err != nil {
|
|
invalidParams.AddNested("ConditionCheck", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Put != nil {
|
|
if err := validatePut(v.Put); err != nil {
|
|
invalidParams.AddNested("Put", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Delete != nil {
|
|
if err := validateDelete(v.Delete); err != nil {
|
|
invalidParams.AddNested("Delete", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.Update != nil {
|
|
if err := validateUpdate(v.Update); err != nil {
|
|
invalidParams.AddNested("Update", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateTransactWriteItemList(v []types.TransactWriteItem) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactWriteItemList"}
|
|
for i := range v {
|
|
if err := validateTransactWriteItem(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateUpdate(v *types.Update) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "Update"}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if v.UpdateExpression == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("UpdateExpression"))
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateUpdateGlobalSecondaryIndexAction(v *types.UpdateGlobalSecondaryIndexAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateGlobalSecondaryIndexAction"}
|
|
if v.IndexName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("IndexName"))
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateUpdateReplicationGroupMemberAction(v *types.UpdateReplicationGroupMemberAction) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateReplicationGroupMemberAction"}
|
|
if v.RegionName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RegionName"))
|
|
}
|
|
if v.GlobalSecondaryIndexes != nil {
|
|
if err := validateReplicaGlobalSecondaryIndexList(v.GlobalSecondaryIndexes); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexes", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateWriteRequest(v *types.WriteRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "WriteRequest"}
|
|
if v.PutRequest != nil {
|
|
if err := validatePutRequest(v.PutRequest); err != nil {
|
|
invalidParams.AddNested("PutRequest", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.DeleteRequest != nil {
|
|
if err := validateDeleteRequest(v.DeleteRequest); err != nil {
|
|
invalidParams.AddNested("DeleteRequest", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateWriteRequests(v []types.WriteRequest) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "WriteRequests"}
|
|
for i := range v {
|
|
if err := validateWriteRequest(&v[i]); err != nil {
|
|
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpBatchExecuteStatementInput(v *BatchExecuteStatementInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchExecuteStatementInput"}
|
|
if v.Statements == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Statements"))
|
|
} else if v.Statements != nil {
|
|
if err := validatePartiQLBatchRequest(v.Statements); err != nil {
|
|
invalidParams.AddNested("Statements", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpBatchGetItemInput(v *BatchGetItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchGetItemInput"}
|
|
if v.RequestItems == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RequestItems"))
|
|
} else if v.RequestItems != nil {
|
|
if err := validateBatchGetRequestMap(v.RequestItems); err != nil {
|
|
invalidParams.AddNested("RequestItems", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpBatchWriteItemInput(v *BatchWriteItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "BatchWriteItemInput"}
|
|
if v.RequestItems == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("RequestItems"))
|
|
} else if v.RequestItems != nil {
|
|
if err := validateBatchWriteItemRequestMap(v.RequestItems); err != nil {
|
|
invalidParams.AddNested("RequestItems", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpCreateBackupInput(v *CreateBackupInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateBackupInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.BackupName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("BackupName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpCreateGlobalTableInput(v *CreateGlobalTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateGlobalTableInput"}
|
|
if v.GlobalTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("GlobalTableName"))
|
|
}
|
|
if v.ReplicationGroup == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ReplicationGroup"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpCreateTableInput(v *CreateTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "CreateTableInput"}
|
|
if v.AttributeDefinitions == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("AttributeDefinitions"))
|
|
} else if v.AttributeDefinitions != nil {
|
|
if err := validateAttributeDefinitions(v.AttributeDefinitions); err != nil {
|
|
invalidParams.AddNested("AttributeDefinitions", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.KeySchema == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("KeySchema"))
|
|
} else if v.KeySchema != nil {
|
|
if err := validateKeySchema(v.KeySchema); err != nil {
|
|
invalidParams.AddNested("KeySchema", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.LocalSecondaryIndexes != nil {
|
|
if err := validateLocalSecondaryIndexList(v.LocalSecondaryIndexes); err != nil {
|
|
invalidParams.AddNested("LocalSecondaryIndexes", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.GlobalSecondaryIndexes != nil {
|
|
if err := validateGlobalSecondaryIndexList(v.GlobalSecondaryIndexes); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexes", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.StreamSpecification != nil {
|
|
if err := validateStreamSpecification(v.StreamSpecification); err != nil {
|
|
invalidParams.AddNested("StreamSpecification", 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 validateOpDeleteBackupInput(v *DeleteBackupInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteBackupInput"}
|
|
if v.BackupArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("BackupArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDeleteItemInput(v *DeleteItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteItemInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDeleteResourcePolicyInput(v *DeleteResourcePolicyInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteResourcePolicyInput"}
|
|
if v.ResourceArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ResourceArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDeleteTableInput(v *DeleteTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DeleteTableInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeBackupInput(v *DescribeBackupInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeBackupInput"}
|
|
if v.BackupArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("BackupArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeContinuousBackupsInput(v *DescribeContinuousBackupsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeContinuousBackupsInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeContributorInsightsInput(v *DescribeContributorInsightsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeContributorInsightsInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeExportInput(v *DescribeExportInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeExportInput"}
|
|
if v.ExportArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ExportArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeGlobalTableInput(v *DescribeGlobalTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeGlobalTableInput"}
|
|
if v.GlobalTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("GlobalTableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeGlobalTableSettingsInput(v *DescribeGlobalTableSettingsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeGlobalTableSettingsInput"}
|
|
if v.GlobalTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("GlobalTableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeImportInput(v *DescribeImportInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeImportInput"}
|
|
if v.ImportArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ImportArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeKinesisStreamingDestinationInput(v *DescribeKinesisStreamingDestinationInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeKinesisStreamingDestinationInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeTableInput(v *DescribeTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeTableInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeTableReplicaAutoScalingInput(v *DescribeTableReplicaAutoScalingInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeTableReplicaAutoScalingInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDescribeTimeToLiveInput(v *DescribeTimeToLiveInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DescribeTimeToLiveInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpDisableKinesisStreamingDestinationInput(v *DisableKinesisStreamingDestinationInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "DisableKinesisStreamingDestinationInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.StreamArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("StreamArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpEnableKinesisStreamingDestinationInput(v *EnableKinesisStreamingDestinationInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "EnableKinesisStreamingDestinationInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.StreamArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("StreamArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpExecuteStatementInput(v *ExecuteStatementInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ExecuteStatementInput"}
|
|
if v.Statement == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Statement"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpExecuteTransactionInput(v *ExecuteTransactionInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ExecuteTransactionInput"}
|
|
if v.TransactStatements == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TransactStatements"))
|
|
} else if v.TransactStatements != nil {
|
|
if err := validateParameterizedStatements(v.TransactStatements); err != nil {
|
|
invalidParams.AddNested("TransactStatements", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpExportTableToPointInTimeInput(v *ExportTableToPointInTimeInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ExportTableToPointInTimeInput"}
|
|
if v.TableArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableArn"))
|
|
}
|
|
if v.S3Bucket == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("S3Bucket"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpGetItemInput(v *GetItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GetItemInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpGetResourcePolicyInput(v *GetResourcePolicyInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "GetResourcePolicyInput"}
|
|
if v.ResourceArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ResourceArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpImportTableInput(v *ImportTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ImportTableInput"}
|
|
if v.S3BucketSource == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("S3BucketSource"))
|
|
} else if v.S3BucketSource != nil {
|
|
if err := validateS3BucketSource(v.S3BucketSource); err != nil {
|
|
invalidParams.AddNested("S3BucketSource", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if len(v.InputFormat) == 0 {
|
|
invalidParams.Add(smithy.NewErrParamRequired("InputFormat"))
|
|
}
|
|
if v.TableCreationParameters == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableCreationParameters"))
|
|
} else if v.TableCreationParameters != nil {
|
|
if err := validateTableCreationParameters(v.TableCreationParameters); err != nil {
|
|
invalidParams.AddNested("TableCreationParameters", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpListTagsOfResourceInput(v *ListTagsOfResourceInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ListTagsOfResourceInput"}
|
|
if v.ResourceArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ResourceArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpPutItemInput(v *PutItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "PutItemInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.Item == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Item"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpPutResourcePolicyInput(v *PutResourcePolicyInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "PutResourcePolicyInput"}
|
|
if v.ResourceArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ResourceArn"))
|
|
}
|
|
if v.Policy == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Policy"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpQueryInput(v *QueryInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "QueryInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.KeyConditions != nil {
|
|
if err := validateKeyConditions(v.KeyConditions); err != nil {
|
|
invalidParams.AddNested("KeyConditions", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.QueryFilter != nil {
|
|
if err := validateFilterConditionMap(v.QueryFilter); err != nil {
|
|
invalidParams.AddNested("QueryFilter", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpRestoreTableFromBackupInput(v *RestoreTableFromBackupInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "RestoreTableFromBackupInput"}
|
|
if v.TargetTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TargetTableName"))
|
|
}
|
|
if v.BackupArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("BackupArn"))
|
|
}
|
|
if v.GlobalSecondaryIndexOverride != nil {
|
|
if err := validateGlobalSecondaryIndexList(v.GlobalSecondaryIndexOverride); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.LocalSecondaryIndexOverride != nil {
|
|
if err := validateLocalSecondaryIndexList(v.LocalSecondaryIndexOverride); err != nil {
|
|
invalidParams.AddNested("LocalSecondaryIndexOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ProvisionedThroughputOverride != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughputOverride); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughputOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpRestoreTableToPointInTimeInput(v *RestoreTableToPointInTimeInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "RestoreTableToPointInTimeInput"}
|
|
if v.TargetTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TargetTableName"))
|
|
}
|
|
if v.GlobalSecondaryIndexOverride != nil {
|
|
if err := validateGlobalSecondaryIndexList(v.GlobalSecondaryIndexOverride); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.LocalSecondaryIndexOverride != nil {
|
|
if err := validateLocalSecondaryIndexList(v.LocalSecondaryIndexOverride); err != nil {
|
|
invalidParams.AddNested("LocalSecondaryIndexOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ProvisionedThroughputOverride != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughputOverride); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughputOverride", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpScanInput(v *ScanInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "ScanInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.ScanFilter != nil {
|
|
if err := validateFilterConditionMap(v.ScanFilter); err != nil {
|
|
invalidParams.AddNested("ScanFilter", 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 validateOpTransactGetItemsInput(v *TransactGetItemsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactGetItemsInput"}
|
|
if v.TransactItems == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TransactItems"))
|
|
} else if v.TransactItems != nil {
|
|
if err := validateTransactGetItemList(v.TransactItems); err != nil {
|
|
invalidParams.AddNested("TransactItems", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpTransactWriteItemsInput(v *TransactWriteItemsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "TransactWriteItemsInput"}
|
|
if v.TransactItems == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TransactItems"))
|
|
} else if v.TransactItems != nil {
|
|
if err := validateTransactWriteItemList(v.TransactItems); err != nil {
|
|
invalidParams.AddNested("TransactItems", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUntagResourceInput(v *UntagResourceInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UntagResourceInput"}
|
|
if v.ResourceArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ResourceArn"))
|
|
}
|
|
if v.TagKeys == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TagKeys"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateContinuousBackupsInput(v *UpdateContinuousBackupsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateContinuousBackupsInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.PointInTimeRecoverySpecification == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("PointInTimeRecoverySpecification"))
|
|
} else if v.PointInTimeRecoverySpecification != nil {
|
|
if err := validatePointInTimeRecoverySpecification(v.PointInTimeRecoverySpecification); err != nil {
|
|
invalidParams.AddNested("PointInTimeRecoverySpecification", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateContributorInsightsInput(v *UpdateContributorInsightsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateContributorInsightsInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if len(v.ContributorInsightsAction) == 0 {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ContributorInsightsAction"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateGlobalTableInput(v *UpdateGlobalTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateGlobalTableInput"}
|
|
if v.GlobalTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("GlobalTableName"))
|
|
}
|
|
if v.ReplicaUpdates == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("ReplicaUpdates"))
|
|
} else if v.ReplicaUpdates != nil {
|
|
if err := validateReplicaUpdateList(v.ReplicaUpdates); err != nil {
|
|
invalidParams.AddNested("ReplicaUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateGlobalTableSettingsInput(v *UpdateGlobalTableSettingsInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateGlobalTableSettingsInput"}
|
|
if v.GlobalTableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("GlobalTableName"))
|
|
}
|
|
if v.GlobalTableProvisionedWriteCapacityAutoScalingSettingsUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.GlobalTableProvisionedWriteCapacityAutoScalingSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("GlobalTableProvisionedWriteCapacityAutoScalingSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.GlobalTableGlobalSecondaryIndexSettingsUpdate != nil {
|
|
if err := validateGlobalTableGlobalSecondaryIndexSettingsUpdateList(v.GlobalTableGlobalSecondaryIndexSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("GlobalTableGlobalSecondaryIndexSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ReplicaSettingsUpdate != nil {
|
|
if err := validateReplicaSettingsUpdateList(v.ReplicaSettingsUpdate); err != nil {
|
|
invalidParams.AddNested("ReplicaSettingsUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateItemInput(v *UpdateItemInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateItemInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.Key == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("Key"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateKinesisStreamingDestinationInput(v *UpdateKinesisStreamingDestinationInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateKinesisStreamingDestinationInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.StreamArn == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("StreamArn"))
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateTableInput(v *UpdateTableInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateTableInput"}
|
|
if v.AttributeDefinitions != nil {
|
|
if err := validateAttributeDefinitions(v.AttributeDefinitions); err != nil {
|
|
invalidParams.AddNested("AttributeDefinitions", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.ProvisionedThroughput != nil {
|
|
if err := validateProvisionedThroughput(v.ProvisionedThroughput); err != nil {
|
|
invalidParams.AddNested("ProvisionedThroughput", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.GlobalSecondaryIndexUpdates != nil {
|
|
if err := validateGlobalSecondaryIndexUpdateList(v.GlobalSecondaryIndexUpdates); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.StreamSpecification != nil {
|
|
if err := validateStreamSpecification(v.StreamSpecification); err != nil {
|
|
invalidParams.AddNested("StreamSpecification", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ReplicaUpdates != nil {
|
|
if err := validateReplicationGroupUpdateList(v.ReplicaUpdates); err != nil {
|
|
invalidParams.AddNested("ReplicaUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateTableReplicaAutoScalingInput(v *UpdateTableReplicaAutoScalingInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateTableReplicaAutoScalingInput"}
|
|
if v.GlobalSecondaryIndexUpdates != nil {
|
|
if err := validateGlobalSecondaryIndexAutoScalingUpdateList(v.GlobalSecondaryIndexUpdates); err != nil {
|
|
invalidParams.AddNested("GlobalSecondaryIndexUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.ProvisionedWriteCapacityAutoScalingUpdate != nil {
|
|
if err := validateAutoScalingSettingsUpdate(v.ProvisionedWriteCapacityAutoScalingUpdate); err != nil {
|
|
invalidParams.AddNested("ProvisionedWriteCapacityAutoScalingUpdate", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if v.ReplicaUpdates != nil {
|
|
if err := validateReplicaAutoScalingUpdateList(v.ReplicaUpdates); err != nil {
|
|
invalidParams.AddNested("ReplicaUpdates", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func validateOpUpdateTimeToLiveInput(v *UpdateTimeToLiveInput) error {
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
invalidParams := smithy.InvalidParamsError{Context: "UpdateTimeToLiveInput"}
|
|
if v.TableName == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TableName"))
|
|
}
|
|
if v.TimeToLiveSpecification == nil {
|
|
invalidParams.Add(smithy.NewErrParamRequired("TimeToLiveSpecification"))
|
|
} else if v.TimeToLiveSpecification != nil {
|
|
if err := validateTimeToLiveSpecification(v.TimeToLiveSpecification); err != nil {
|
|
invalidParams.AddNested("TimeToLiveSpecification", err.(smithy.InvalidParamsError))
|
|
}
|
|
}
|
|
if invalidParams.Len() > 0 {
|
|
return invalidParams
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|