service/s3tables/validators.go (1,230 lines of code) (raw):
// Code generated by smithy-go-codegen DO NOT EDIT.
package s3tables
import (
"context"
"fmt"
"github.com/aws/aws-sdk-go-v2/service/s3tables/types"
smithy "github.com/aws/smithy-go"
"github.com/aws/smithy-go/middleware"
)
type validateOpCreateNamespace struct {
}
func (*validateOpCreateNamespace) ID() string {
return "OperationInputValidation"
}
func (m *validateOpCreateNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*CreateNamespaceInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpCreateNamespaceInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpCreateTableBucket struct {
}
func (*validateOpCreateTableBucket) ID() string {
return "OperationInputValidation"
}
func (m *validateOpCreateTableBucket) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*CreateTableBucketInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpCreateTableBucketInput(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 validateOpDeleteNamespace struct {
}
func (*validateOpDeleteNamespace) ID() string {
return "OperationInputValidation"
}
func (m *validateOpDeleteNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*DeleteNamespaceInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpDeleteNamespaceInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpDeleteTableBucketEncryption struct {
}
func (*validateOpDeleteTableBucketEncryption) ID() string {
return "OperationInputValidation"
}
func (m *validateOpDeleteTableBucketEncryption) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*DeleteTableBucketEncryptionInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpDeleteTableBucketEncryptionInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpDeleteTableBucket struct {
}
func (*validateOpDeleteTableBucket) ID() string {
return "OperationInputValidation"
}
func (m *validateOpDeleteTableBucket) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*DeleteTableBucketInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpDeleteTableBucketInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpDeleteTableBucketPolicy struct {
}
func (*validateOpDeleteTableBucketPolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpDeleteTableBucketPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*DeleteTableBucketPolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpDeleteTableBucketPolicyInput(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 validateOpDeleteTablePolicy struct {
}
func (*validateOpDeleteTablePolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpDeleteTablePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*DeleteTablePolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpDeleteTablePolicyInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetNamespace struct {
}
func (*validateOpGetNamespace) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetNamespace) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetNamespaceInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetNamespaceInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableBucketEncryption struct {
}
func (*validateOpGetTableBucketEncryption) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableBucketEncryption) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableBucketEncryptionInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableBucketEncryptionInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableBucket struct {
}
func (*validateOpGetTableBucket) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableBucket) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableBucketInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableBucketInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableBucketMaintenanceConfiguration struct {
}
func (*validateOpGetTableBucketMaintenanceConfiguration) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableBucketMaintenanceConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableBucketMaintenanceConfigurationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableBucketMaintenanceConfigurationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableBucketPolicy struct {
}
func (*validateOpGetTableBucketPolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableBucketPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableBucketPolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableBucketPolicyInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableEncryption struct {
}
func (*validateOpGetTableEncryption) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableEncryption) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableEncryptionInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableEncryptionInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTable struct {
}
func (*validateOpGetTable) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableMaintenanceConfiguration struct {
}
func (*validateOpGetTableMaintenanceConfiguration) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableMaintenanceConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableMaintenanceConfigurationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableMaintenanceConfigurationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableMaintenanceJobStatus struct {
}
func (*validateOpGetTableMaintenanceJobStatus) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableMaintenanceJobStatus) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableMaintenanceJobStatusInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableMaintenanceJobStatusInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTableMetadataLocation struct {
}
func (*validateOpGetTableMetadataLocation) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTableMetadataLocation) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTableMetadataLocationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTableMetadataLocationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpGetTablePolicy struct {
}
func (*validateOpGetTablePolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpGetTablePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*GetTablePolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpGetTablePolicyInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpListNamespaces struct {
}
func (*validateOpListNamespaces) ID() string {
return "OperationInputValidation"
}
func (m *validateOpListNamespaces) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*ListNamespacesInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpListNamespacesInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpListTables struct {
}
func (*validateOpListTables) ID() string {
return "OperationInputValidation"
}
func (m *validateOpListTables) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*ListTablesInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpListTablesInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpPutTableBucketEncryption struct {
}
func (*validateOpPutTableBucketEncryption) ID() string {
return "OperationInputValidation"
}
func (m *validateOpPutTableBucketEncryption) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*PutTableBucketEncryptionInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpPutTableBucketEncryptionInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpPutTableBucketMaintenanceConfiguration struct {
}
func (*validateOpPutTableBucketMaintenanceConfiguration) ID() string {
return "OperationInputValidation"
}
func (m *validateOpPutTableBucketMaintenanceConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*PutTableBucketMaintenanceConfigurationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpPutTableBucketMaintenanceConfigurationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpPutTableBucketPolicy struct {
}
func (*validateOpPutTableBucketPolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpPutTableBucketPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*PutTableBucketPolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpPutTableBucketPolicyInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpPutTableMaintenanceConfiguration struct {
}
func (*validateOpPutTableMaintenanceConfiguration) ID() string {
return "OperationInputValidation"
}
func (m *validateOpPutTableMaintenanceConfiguration) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*PutTableMaintenanceConfigurationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpPutTableMaintenanceConfigurationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpPutTablePolicy struct {
}
func (*validateOpPutTablePolicy) ID() string {
return "OperationInputValidation"
}
func (m *validateOpPutTablePolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*PutTablePolicyInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpPutTablePolicyInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpRenameTable struct {
}
func (*validateOpRenameTable) ID() string {
return "OperationInputValidation"
}
func (m *validateOpRenameTable) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*RenameTableInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpRenameTableInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
type validateOpUpdateTableMetadataLocation struct {
}
func (*validateOpUpdateTableMetadataLocation) ID() string {
return "OperationInputValidation"
}
func (m *validateOpUpdateTableMetadataLocation) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
out middleware.InitializeOutput, metadata middleware.Metadata, err error,
) {
input, ok := in.Parameters.(*UpdateTableMetadataLocationInput)
if !ok {
return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
}
if err := validateOpUpdateTableMetadataLocationInput(input); err != nil {
return out, metadata, err
}
return next.HandleInitialize(ctx, in)
}
func addOpCreateNamespaceValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpCreateNamespace{}, middleware.After)
}
func addOpCreateTableBucketValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpCreateTableBucket{}, middleware.After)
}
func addOpCreateTableValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpCreateTable{}, middleware.After)
}
func addOpDeleteNamespaceValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteNamespace{}, middleware.After)
}
func addOpDeleteTableBucketEncryptionValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteTableBucketEncryption{}, middleware.After)
}
func addOpDeleteTableBucketValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteTableBucket{}, middleware.After)
}
func addOpDeleteTableBucketPolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteTableBucketPolicy{}, middleware.After)
}
func addOpDeleteTableValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteTable{}, middleware.After)
}
func addOpDeleteTablePolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpDeleteTablePolicy{}, middleware.After)
}
func addOpGetNamespaceValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetNamespace{}, middleware.After)
}
func addOpGetTableBucketEncryptionValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableBucketEncryption{}, middleware.After)
}
func addOpGetTableBucketValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableBucket{}, middleware.After)
}
func addOpGetTableBucketMaintenanceConfigurationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableBucketMaintenanceConfiguration{}, middleware.After)
}
func addOpGetTableBucketPolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableBucketPolicy{}, middleware.After)
}
func addOpGetTableEncryptionValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableEncryption{}, middleware.After)
}
func addOpGetTableValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTable{}, middleware.After)
}
func addOpGetTableMaintenanceConfigurationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableMaintenanceConfiguration{}, middleware.After)
}
func addOpGetTableMaintenanceJobStatusValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableMaintenanceJobStatus{}, middleware.After)
}
func addOpGetTableMetadataLocationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTableMetadataLocation{}, middleware.After)
}
func addOpGetTablePolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpGetTablePolicy{}, middleware.After)
}
func addOpListNamespacesValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpListNamespaces{}, middleware.After)
}
func addOpListTablesValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpListTables{}, middleware.After)
}
func addOpPutTableBucketEncryptionValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpPutTableBucketEncryption{}, middleware.After)
}
func addOpPutTableBucketMaintenanceConfigurationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpPutTableBucketMaintenanceConfiguration{}, middleware.After)
}
func addOpPutTableBucketPolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpPutTableBucketPolicy{}, middleware.After)
}
func addOpPutTableMaintenanceConfigurationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpPutTableMaintenanceConfiguration{}, middleware.After)
}
func addOpPutTablePolicyValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpPutTablePolicy{}, middleware.After)
}
func addOpRenameTableValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpRenameTable{}, middleware.After)
}
func addOpUpdateTableMetadataLocationValidationMiddleware(stack *middleware.Stack) error {
return stack.Initialize.Add(&validateOpUpdateTableMetadataLocation{}, middleware.After)
}
func validateEncryptionConfiguration(v *types.EncryptionConfiguration) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "EncryptionConfiguration"}
if len(v.SseAlgorithm) == 0 {
invalidParams.Add(smithy.NewErrParamRequired("SseAlgorithm"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateIcebergMetadata(v *types.IcebergMetadata) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "IcebergMetadata"}
if v.Schema == nil {
invalidParams.Add(smithy.NewErrParamRequired("Schema"))
} else if v.Schema != nil {
if err := validateIcebergSchema(v.Schema); err != nil {
invalidParams.AddNested("Schema", err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateIcebergSchema(v *types.IcebergSchema) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "IcebergSchema"}
if v.Fields == nil {
invalidParams.Add(smithy.NewErrParamRequired("Fields"))
} else if v.Fields != nil {
if err := validateSchemaFieldList(v.Fields); err != nil {
invalidParams.AddNested("Fields", err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateSchemaField(v *types.SchemaField) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "SchemaField"}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if v.Type == nil {
invalidParams.Add(smithy.NewErrParamRequired("Type"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateSchemaFieldList(v []types.SchemaField) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "SchemaFieldList"}
for i := range v {
if err := validateSchemaField(&v[i]); err != nil {
invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateTableMetadata(v types.TableMetadata) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "TableMetadata"}
switch uv := v.(type) {
case *types.TableMetadataMemberIceberg:
if err := validateIcebergMetadata(&uv.Value); err != nil {
invalidParams.AddNested("[iceberg]", err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpCreateNamespaceInput(v *CreateNamespaceInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "CreateNamespaceInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpCreateTableBucketInput(v *CreateTableBucketInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "CreateTableBucketInput"}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if v.EncryptionConfiguration != nil {
if err := validateEncryptionConfiguration(v.EncryptionConfiguration); err != nil {
invalidParams.AddNested("EncryptionConfiguration", err.(smithy.InvalidParamsError))
}
}
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.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if len(v.Format) == 0 {
invalidParams.Add(smithy.NewErrParamRequired("Format"))
}
if v.Metadata != nil {
if err := validateTableMetadata(v.Metadata); err != nil {
invalidParams.AddNested("Metadata", err.(smithy.InvalidParamsError))
}
}
if v.EncryptionConfiguration != nil {
if err := validateEncryptionConfiguration(v.EncryptionConfiguration); err != nil {
invalidParams.AddNested("EncryptionConfiguration", err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpDeleteNamespaceInput(v *DeleteNamespaceInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "DeleteNamespaceInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpDeleteTableBucketEncryptionInput(v *DeleteTableBucketEncryptionInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "DeleteTableBucketEncryptionInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpDeleteTableBucketInput(v *DeleteTableBucketInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "DeleteTableBucketInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpDeleteTableBucketPolicyInput(v *DeleteTableBucketPolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "DeleteTableBucketPolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
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.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpDeleteTablePolicyInput(v *DeleteTablePolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "DeleteTablePolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetNamespaceInput(v *GetNamespaceInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetNamespaceInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableBucketEncryptionInput(v *GetTableBucketEncryptionInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableBucketEncryptionInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableBucketInput(v *GetTableBucketInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableBucketInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableBucketMaintenanceConfigurationInput(v *GetTableBucketMaintenanceConfigurationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableBucketMaintenanceConfigurationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableBucketPolicyInput(v *GetTableBucketPolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableBucketPolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableEncryptionInput(v *GetTableEncryptionInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableEncryptionInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableInput(v *GetTableInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableMaintenanceConfigurationInput(v *GetTableMaintenanceConfigurationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableMaintenanceConfigurationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableMaintenanceJobStatusInput(v *GetTableMaintenanceJobStatusInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableMaintenanceJobStatusInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTableMetadataLocationInput(v *GetTableMetadataLocationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTableMetadataLocationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpGetTablePolicyInput(v *GetTablePolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "GetTablePolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpListNamespacesInput(v *ListNamespacesInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "ListNamespacesInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpListTablesInput(v *ListTablesInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "ListTablesInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpPutTableBucketEncryptionInput(v *PutTableBucketEncryptionInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "PutTableBucketEncryptionInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.EncryptionConfiguration == nil {
invalidParams.Add(smithy.NewErrParamRequired("EncryptionConfiguration"))
} else if v.EncryptionConfiguration != nil {
if err := validateEncryptionConfiguration(v.EncryptionConfiguration); err != nil {
invalidParams.AddNested("EncryptionConfiguration", err.(smithy.InvalidParamsError))
}
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpPutTableBucketMaintenanceConfigurationInput(v *PutTableBucketMaintenanceConfigurationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "PutTableBucketMaintenanceConfigurationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if len(v.Type) == 0 {
invalidParams.Add(smithy.NewErrParamRequired("Type"))
}
if v.Value == nil {
invalidParams.Add(smithy.NewErrParamRequired("Value"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpPutTableBucketPolicyInput(v *PutTableBucketPolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "PutTableBucketPolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.ResourcePolicy == nil {
invalidParams.Add(smithy.NewErrParamRequired("ResourcePolicy"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpPutTableMaintenanceConfigurationInput(v *PutTableMaintenanceConfigurationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "PutTableMaintenanceConfigurationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if len(v.Type) == 0 {
invalidParams.Add(smithy.NewErrParamRequired("Type"))
}
if v.Value == nil {
invalidParams.Add(smithy.NewErrParamRequired("Value"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpPutTablePolicyInput(v *PutTablePolicyInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "PutTablePolicyInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if v.ResourcePolicy == nil {
invalidParams.Add(smithy.NewErrParamRequired("ResourcePolicy"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpRenameTableInput(v *RenameTableInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "RenameTableInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}
func validateOpUpdateTableMetadataLocationInput(v *UpdateTableMetadataLocationInput) error {
if v == nil {
return nil
}
invalidParams := smithy.InvalidParamsError{Context: "UpdateTableMetadataLocationInput"}
if v.TableBucketARN == nil {
invalidParams.Add(smithy.NewErrParamRequired("TableBucketARN"))
}
if v.Namespace == nil {
invalidParams.Add(smithy.NewErrParamRequired("Namespace"))
}
if v.Name == nil {
invalidParams.Add(smithy.NewErrParamRequired("Name"))
}
if v.VersionToken == nil {
invalidParams.Add(smithy.NewErrParamRequired("VersionToken"))
}
if v.MetadataLocation == nil {
invalidParams.Add(smithy.NewErrParamRequired("MetadataLocation"))
}
if invalidParams.Len() > 0 {
return invalidParams
} else {
return nil
}
}