// Code generated by smithy-go-codegen DO NOT EDIT. package neptune import ( "bytes" "context" "fmt" "github.com/aws/aws-sdk-go-v2/aws/protocol/query" "github.com/aws/aws-sdk-go-v2/service/neptune/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/encoding/httpbinding" "github.com/aws/smithy-go/middleware" smithytime "github.com/aws/smithy-go/time" smithyhttp "github.com/aws/smithy-go/transport/http" "math" "path" ) type awsAwsquery_serializeOpAddRoleToDBCluster struct { } func (*awsAwsquery_serializeOpAddRoleToDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpAddRoleToDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*AddRoleToDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("AddRoleToDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentAddRoleToDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpAddSourceIdentifierToSubscription struct { } func (*awsAwsquery_serializeOpAddSourceIdentifierToSubscription) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpAddSourceIdentifierToSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*AddSourceIdentifierToSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("AddSourceIdentifierToSubscription") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentAddSourceIdentifierToSubscriptionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpAddTagsToResource struct { } func (*awsAwsquery_serializeOpAddTagsToResource) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpAddTagsToResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*AddTagsToResourceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("AddTagsToResource") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentAddTagsToResourceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpApplyPendingMaintenanceAction struct { } func (*awsAwsquery_serializeOpApplyPendingMaintenanceAction) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpApplyPendingMaintenanceAction) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ApplyPendingMaintenanceActionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ApplyPendingMaintenanceAction") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentApplyPendingMaintenanceActionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCopyDBClusterParameterGroup struct { } func (*awsAwsquery_serializeOpCopyDBClusterParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCopyDBClusterParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CopyDBClusterParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CopyDBClusterParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCopyDBClusterParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCopyDBClusterSnapshot struct { } func (*awsAwsquery_serializeOpCopyDBClusterSnapshot) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCopyDBClusterSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CopyDBClusterSnapshotInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CopyDBClusterSnapshot") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCopyDBClusterSnapshotInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCopyDBParameterGroup struct { } func (*awsAwsquery_serializeOpCopyDBParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCopyDBParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CopyDBParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CopyDBParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCopyDBParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBCluster struct { } func (*awsAwsquery_serializeOpCreateDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBClusterEndpoint struct { } func (*awsAwsquery_serializeOpCreateDBClusterEndpoint) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBClusterEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBClusterEndpointInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBClusterEndpoint") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBClusterEndpointInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBClusterParameterGroup struct { } func (*awsAwsquery_serializeOpCreateDBClusterParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBClusterParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBClusterParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBClusterParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBClusterParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBClusterSnapshot struct { } func (*awsAwsquery_serializeOpCreateDBClusterSnapshot) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBClusterSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBClusterSnapshotInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBClusterSnapshot") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBClusterSnapshotInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBInstance struct { } func (*awsAwsquery_serializeOpCreateDBInstance) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBInstanceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBInstance") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBInstanceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBParameterGroup struct { } func (*awsAwsquery_serializeOpCreateDBParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateDBSubnetGroup struct { } func (*awsAwsquery_serializeOpCreateDBSubnetGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateDBSubnetGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateDBSubnetGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateDBSubnetGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateDBSubnetGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateEventSubscription struct { } func (*awsAwsquery_serializeOpCreateEventSubscription) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateEventSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateEventSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateEventSubscription") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateEventSubscriptionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpCreateGlobalCluster struct { } func (*awsAwsquery_serializeOpCreateGlobalCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpCreateGlobalCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateGlobalClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("CreateGlobalCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentCreateGlobalClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBCluster struct { } func (*awsAwsquery_serializeOpDeleteDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBClusterEndpoint struct { } func (*awsAwsquery_serializeOpDeleteDBClusterEndpoint) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBClusterEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBClusterEndpointInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBClusterEndpoint") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBClusterEndpointInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBClusterParameterGroup struct { } func (*awsAwsquery_serializeOpDeleteDBClusterParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBClusterParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBClusterParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBClusterParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBClusterParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBClusterSnapshot struct { } func (*awsAwsquery_serializeOpDeleteDBClusterSnapshot) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBClusterSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBClusterSnapshotInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBClusterSnapshot") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBClusterSnapshotInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBInstance struct { } func (*awsAwsquery_serializeOpDeleteDBInstance) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBInstanceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBInstance") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBInstanceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBParameterGroup struct { } func (*awsAwsquery_serializeOpDeleteDBParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteDBSubnetGroup struct { } func (*awsAwsquery_serializeOpDeleteDBSubnetGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteDBSubnetGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDBSubnetGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteDBSubnetGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteDBSubnetGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteEventSubscription struct { } func (*awsAwsquery_serializeOpDeleteEventSubscription) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteEventSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteEventSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteEventSubscription") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteEventSubscriptionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDeleteGlobalCluster struct { } func (*awsAwsquery_serializeOpDeleteGlobalCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDeleteGlobalCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteGlobalClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DeleteGlobalCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDeleteGlobalClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusterEndpoints struct { } func (*awsAwsquery_serializeOpDescribeDBClusterEndpoints) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusterEndpoints) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClusterEndpointsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusterEndpoints") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClusterEndpointsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusterParameterGroups struct { } func (*awsAwsquery_serializeOpDescribeDBClusterParameterGroups) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusterParameterGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClusterParameterGroupsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusterParameterGroups") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClusterParameterGroupsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusterParameters struct { } func (*awsAwsquery_serializeOpDescribeDBClusterParameters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusterParameters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClusterParametersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusterParameters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClusterParametersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusters struct { } func (*awsAwsquery_serializeOpDescribeDBClusters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClustersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClustersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusterSnapshotAttributes struct { } func (*awsAwsquery_serializeOpDescribeDBClusterSnapshotAttributes) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusterSnapshotAttributes) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClusterSnapshotAttributesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusterSnapshotAttributes") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClusterSnapshotAttributesInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBClusterSnapshots struct { } func (*awsAwsquery_serializeOpDescribeDBClusterSnapshots) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBClusterSnapshots) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBClusterSnapshotsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBClusterSnapshots") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBClusterSnapshotsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBEngineVersions struct { } func (*awsAwsquery_serializeOpDescribeDBEngineVersions) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBEngineVersions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBEngineVersionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBEngineVersions") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBEngineVersionsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBInstances struct { } func (*awsAwsquery_serializeOpDescribeDBInstances) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBInstances) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBInstancesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBInstances") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBInstancesInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBParameterGroups struct { } func (*awsAwsquery_serializeOpDescribeDBParameterGroups) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBParameterGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBParameterGroupsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBParameterGroups") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBParameterGroupsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBParameters struct { } func (*awsAwsquery_serializeOpDescribeDBParameters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBParameters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBParametersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBParameters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBParametersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeDBSubnetGroups struct { } func (*awsAwsquery_serializeOpDescribeDBSubnetGroups) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeDBSubnetGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDBSubnetGroupsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeDBSubnetGroups") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeDBSubnetGroupsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeEngineDefaultClusterParameters struct { } func (*awsAwsquery_serializeOpDescribeEngineDefaultClusterParameters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeEngineDefaultClusterParameters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeEngineDefaultClusterParametersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeEngineDefaultClusterParameters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeEngineDefaultClusterParametersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeEngineDefaultParameters struct { } func (*awsAwsquery_serializeOpDescribeEngineDefaultParameters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeEngineDefaultParameters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeEngineDefaultParametersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeEngineDefaultParameters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeEngineDefaultParametersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeEventCategories struct { } func (*awsAwsquery_serializeOpDescribeEventCategories) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeEventCategories) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeEventCategoriesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeEventCategories") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeEventCategoriesInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeEvents struct { } func (*awsAwsquery_serializeOpDescribeEvents) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeEvents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeEventsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeEvents") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeEventsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeEventSubscriptions struct { } func (*awsAwsquery_serializeOpDescribeEventSubscriptions) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeEventSubscriptions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeEventSubscriptionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeEventSubscriptions") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeEventSubscriptionsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeGlobalClusters struct { } func (*awsAwsquery_serializeOpDescribeGlobalClusters) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeGlobalClusters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeGlobalClustersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeGlobalClusters") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeGlobalClustersInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeOrderableDBInstanceOptions struct { } func (*awsAwsquery_serializeOpDescribeOrderableDBInstanceOptions) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeOrderableDBInstanceOptions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeOrderableDBInstanceOptionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeOrderableDBInstanceOptions") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeOrderableDBInstanceOptionsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribePendingMaintenanceActions struct { } func (*awsAwsquery_serializeOpDescribePendingMaintenanceActions) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribePendingMaintenanceActions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribePendingMaintenanceActionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribePendingMaintenanceActions") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribePendingMaintenanceActionsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpDescribeValidDBInstanceModifications struct { } func (*awsAwsquery_serializeOpDescribeValidDBInstanceModifications) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpDescribeValidDBInstanceModifications) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeValidDBInstanceModificationsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("DescribeValidDBInstanceModifications") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentDescribeValidDBInstanceModificationsInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpFailoverDBCluster struct { } func (*awsAwsquery_serializeOpFailoverDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpFailoverDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*FailoverDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("FailoverDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentFailoverDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpFailoverGlobalCluster struct { } func (*awsAwsquery_serializeOpFailoverGlobalCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpFailoverGlobalCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*FailoverGlobalClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("FailoverGlobalCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentFailoverGlobalClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpListTagsForResource struct { } func (*awsAwsquery_serializeOpListTagsForResource) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpListTagsForResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ListTagsForResourceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ListTagsForResource") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentListTagsForResourceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBCluster struct { } func (*awsAwsquery_serializeOpModifyDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBClusterEndpoint struct { } func (*awsAwsquery_serializeOpModifyDBClusterEndpoint) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBClusterEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBClusterEndpointInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBClusterEndpoint") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBClusterEndpointInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBClusterParameterGroup struct { } func (*awsAwsquery_serializeOpModifyDBClusterParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBClusterParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBClusterParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBClusterParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBClusterParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBClusterSnapshotAttribute struct { } func (*awsAwsquery_serializeOpModifyDBClusterSnapshotAttribute) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBClusterSnapshotAttribute) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBClusterSnapshotAttributeInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBClusterSnapshotAttribute") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBClusterSnapshotAttributeInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBInstance struct { } func (*awsAwsquery_serializeOpModifyDBInstance) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBInstanceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBInstance") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBInstanceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBParameterGroup struct { } func (*awsAwsquery_serializeOpModifyDBParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyDBSubnetGroup struct { } func (*awsAwsquery_serializeOpModifyDBSubnetGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyDBSubnetGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyDBSubnetGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyDBSubnetGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyDBSubnetGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyEventSubscription struct { } func (*awsAwsquery_serializeOpModifyEventSubscription) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyEventSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyEventSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyEventSubscription") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyEventSubscriptionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpModifyGlobalCluster struct { } func (*awsAwsquery_serializeOpModifyGlobalCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpModifyGlobalCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ModifyGlobalClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ModifyGlobalCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentModifyGlobalClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpPromoteReadReplicaDBCluster struct { } func (*awsAwsquery_serializeOpPromoteReadReplicaDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpPromoteReadReplicaDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*PromoteReadReplicaDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("PromoteReadReplicaDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentPromoteReadReplicaDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRebootDBInstance struct { } func (*awsAwsquery_serializeOpRebootDBInstance) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRebootDBInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RebootDBInstanceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RebootDBInstance") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRebootDBInstanceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRemoveFromGlobalCluster struct { } func (*awsAwsquery_serializeOpRemoveFromGlobalCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRemoveFromGlobalCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveFromGlobalClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RemoveFromGlobalCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRemoveFromGlobalClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRemoveRoleFromDBCluster struct { } func (*awsAwsquery_serializeOpRemoveRoleFromDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRemoveRoleFromDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveRoleFromDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RemoveRoleFromDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRemoveRoleFromDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRemoveSourceIdentifierFromSubscription struct { } func (*awsAwsquery_serializeOpRemoveSourceIdentifierFromSubscription) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRemoveSourceIdentifierFromSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveSourceIdentifierFromSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RemoveSourceIdentifierFromSubscription") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRemoveSourceIdentifierFromSubscriptionInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRemoveTagsFromResource struct { } func (*awsAwsquery_serializeOpRemoveTagsFromResource) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRemoveTagsFromResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveTagsFromResourceInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RemoveTagsFromResource") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRemoveTagsFromResourceInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpResetDBClusterParameterGroup struct { } func (*awsAwsquery_serializeOpResetDBClusterParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpResetDBClusterParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ResetDBClusterParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ResetDBClusterParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentResetDBClusterParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpResetDBParameterGroup struct { } func (*awsAwsquery_serializeOpResetDBParameterGroup) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpResetDBParameterGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ResetDBParameterGroupInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("ResetDBParameterGroup") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentResetDBParameterGroupInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRestoreDBClusterFromSnapshot struct { } func (*awsAwsquery_serializeOpRestoreDBClusterFromSnapshot) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRestoreDBClusterFromSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RestoreDBClusterFromSnapshotInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RestoreDBClusterFromSnapshot") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRestoreDBClusterFromSnapshotInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpRestoreDBClusterToPointInTime struct { } func (*awsAwsquery_serializeOpRestoreDBClusterToPointInTime) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpRestoreDBClusterToPointInTime) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RestoreDBClusterToPointInTimeInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("RestoreDBClusterToPointInTime") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentRestoreDBClusterToPointInTimeInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpStartDBCluster struct { } func (*awsAwsquery_serializeOpStartDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpStartDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*StartDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("StartDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentStartDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } type awsAwsquery_serializeOpStopDBCluster struct { } func (*awsAwsquery_serializeOpStopDBCluster) ID() string { return "OperationSerializer" } func (m *awsAwsquery_serializeOpStopDBCluster) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*StopDBClusterInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } operationPath := "/" if len(request.Request.URL.Path) == 0 { request.Request.URL.Path = operationPath } else { request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath) if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' { request.Request.URL.Path += "/" } } request.Request.Method = "POST" httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } httpBindingEncoder.SetHeader("Content-Type").String("application/x-www-form-urlencoded") bodyWriter := bytes.NewBuffer(nil) bodyEncoder := query.NewEncoder(bodyWriter) body := bodyEncoder.Object() body.Key("Action").String("StopDBCluster") body.Key("Version").String("2014-10-31") if err := awsAwsquery_serializeOpDocumentStopDBClusterInput(input, bodyEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } err = bodyEncoder.Encode() if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(bodyWriter.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsAwsquery_serializeDocumentAttributeValueList(v []string, value query.Value) error { array := value.Array("AttributeValue") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentAvailabilityZones(v []string, value query.Value) error { array := value.Array("AvailabilityZone") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentCloudwatchLogsExportConfiguration(v *types.CloudwatchLogsExportConfiguration, value query.Value) error { object := value.Object() _ = object if v.DisableLogTypes != nil { objectKey := object.Key("DisableLogTypes") if err := awsAwsquery_serializeDocumentLogTypeList(v.DisableLogTypes, objectKey); err != nil { return err } } if v.EnableLogTypes != nil { objectKey := object.Key("EnableLogTypes") if err := awsAwsquery_serializeDocumentLogTypeList(v.EnableLogTypes, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeDocumentDBSecurityGroupNameList(v []string, value query.Value) error { array := value.Array("DBSecurityGroupName") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentEventCategoriesList(v []string, value query.Value) error { array := value.Array("EventCategory") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentFilter(v *types.Filter, value query.Value) error { object := value.Object() _ = object if v.Name != nil { objectKey := object.Key("Name") objectKey.String(*v.Name) } if v.Values != nil { objectKey := object.Key("Values") if err := awsAwsquery_serializeDocumentFilterValueList(v.Values, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeDocumentFilterList(v []types.Filter, value query.Value) error { array := value.Array("Filter") for i := range v { av := array.Value() if err := awsAwsquery_serializeDocumentFilter(&v[i], av); err != nil { return err } } return nil } func awsAwsquery_serializeDocumentFilterValueList(v []string, value query.Value) error { array := value.Array("Value") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentKeyList(v []string, value query.Value) error { array := value.Array("member") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentLogTypeList(v []string, value query.Value) error { array := value.Array("member") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentParameter(v *types.Parameter, value query.Value) error { object := value.Object() _ = object if v.AllowedValues != nil { objectKey := object.Key("AllowedValues") objectKey.String(*v.AllowedValues) } if len(v.ApplyMethod) > 0 { objectKey := object.Key("ApplyMethod") objectKey.String(string(v.ApplyMethod)) } if v.ApplyType != nil { objectKey := object.Key("ApplyType") objectKey.String(*v.ApplyType) } if v.DataType != nil { objectKey := object.Key("DataType") objectKey.String(*v.DataType) } if v.Description != nil { objectKey := object.Key("Description") objectKey.String(*v.Description) } if v.IsModifiable { objectKey := object.Key("IsModifiable") objectKey.Boolean(v.IsModifiable) } if v.MinimumEngineVersion != nil { objectKey := object.Key("MinimumEngineVersion") objectKey.String(*v.MinimumEngineVersion) } if v.ParameterName != nil { objectKey := object.Key("ParameterName") objectKey.String(*v.ParameterName) } if v.ParameterValue != nil { objectKey := object.Key("ParameterValue") objectKey.String(*v.ParameterValue) } if v.Source != nil { objectKey := object.Key("Source") objectKey.String(*v.Source) } return nil } func awsAwsquery_serializeDocumentParametersList(v []types.Parameter, value query.Value) error { array := value.Array("Parameter") for i := range v { av := array.Value() if err := awsAwsquery_serializeDocumentParameter(&v[i], av); err != nil { return err } } return nil } func awsAwsquery_serializeDocumentServerlessV2ScalingConfiguration(v *types.ServerlessV2ScalingConfiguration, value query.Value) error { object := value.Object() _ = object if v.MaxCapacity != nil { objectKey := object.Key("MaxCapacity") switch { case math.IsNaN(*v.MaxCapacity): objectKey.String("NaN") case math.IsInf(*v.MaxCapacity, 1): objectKey.String("Infinity") case math.IsInf(*v.MaxCapacity, -1): objectKey.String("-Infinity") default: objectKey.Double(*v.MaxCapacity) } } if v.MinCapacity != nil { objectKey := object.Key("MinCapacity") switch { case math.IsNaN(*v.MinCapacity): objectKey.String("NaN") case math.IsInf(*v.MinCapacity, 1): objectKey.String("Infinity") case math.IsInf(*v.MinCapacity, -1): objectKey.String("-Infinity") default: objectKey.Double(*v.MinCapacity) } } return nil } func awsAwsquery_serializeDocumentSourceIdsList(v []string, value query.Value) error { array := value.Array("SourceId") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentStringList(v []string, value query.Value) error { array := value.Array("member") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentSubnetIdentifierList(v []string, value query.Value) error { array := value.Array("SubnetIdentifier") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeDocumentTag(v *types.Tag, value query.Value) error { object := value.Object() _ = object if v.Key != nil { objectKey := object.Key("Key") objectKey.String(*v.Key) } if v.Value != nil { objectKey := object.Key("Value") objectKey.String(*v.Value) } return nil } func awsAwsquery_serializeDocumentTagList(v []types.Tag, value query.Value) error { array := value.Array("Tag") for i := range v { av := array.Value() if err := awsAwsquery_serializeDocumentTag(&v[i], av); err != nil { return err } } return nil } func awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v []string, value query.Value) error { array := value.Array("VpcSecurityGroupId") for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsAwsquery_serializeOpDocumentAddRoleToDBClusterInput(v *AddRoleToDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.FeatureName != nil { objectKey := object.Key("FeatureName") objectKey.String(*v.FeatureName) } if v.RoleArn != nil { objectKey := object.Key("RoleArn") objectKey.String(*v.RoleArn) } return nil } func awsAwsquery_serializeOpDocumentAddSourceIdentifierToSubscriptionInput(v *AddSourceIdentifierToSubscriptionInput, value query.Value) error { object := value.Object() _ = object if v.SourceIdentifier != nil { objectKey := object.Key("SourceIdentifier") objectKey.String(*v.SourceIdentifier) } if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } return nil } func awsAwsquery_serializeOpDocumentAddTagsToResourceInput(v *AddTagsToResourceInput, value query.Value) error { object := value.Object() _ = object if v.ResourceName != nil { objectKey := object.Key("ResourceName") objectKey.String(*v.ResourceName) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentApplyPendingMaintenanceActionInput(v *ApplyPendingMaintenanceActionInput, value query.Value) error { object := value.Object() _ = object if v.ApplyAction != nil { objectKey := object.Key("ApplyAction") objectKey.String(*v.ApplyAction) } if v.OptInType != nil { objectKey := object.Key("OptInType") objectKey.String(*v.OptInType) } if v.ResourceIdentifier != nil { objectKey := object.Key("ResourceIdentifier") objectKey.String(*v.ResourceIdentifier) } return nil } func awsAwsquery_serializeOpDocumentCopyDBClusterParameterGroupInput(v *CopyDBClusterParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.SourceDBClusterParameterGroupIdentifier != nil { objectKey := object.Key("SourceDBClusterParameterGroupIdentifier") objectKey.String(*v.SourceDBClusterParameterGroupIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.TargetDBClusterParameterGroupDescription != nil { objectKey := object.Key("TargetDBClusterParameterGroupDescription") objectKey.String(*v.TargetDBClusterParameterGroupDescription) } if v.TargetDBClusterParameterGroupIdentifier != nil { objectKey := object.Key("TargetDBClusterParameterGroupIdentifier") objectKey.String(*v.TargetDBClusterParameterGroupIdentifier) } return nil } func awsAwsquery_serializeOpDocumentCopyDBClusterSnapshotInput(v *CopyDBClusterSnapshotInput, value query.Value) error { object := value.Object() _ = object if v.CopyTags != nil { objectKey := object.Key("CopyTags") objectKey.Boolean(*v.CopyTags) } if v.destinationRegion != nil { objectKey := object.Key("DestinationRegion") objectKey.String(*v.destinationRegion) } if v.KmsKeyId != nil { objectKey := object.Key("KmsKeyId") objectKey.String(*v.KmsKeyId) } if v.PreSignedUrl != nil { objectKey := object.Key("PreSignedUrl") objectKey.String(*v.PreSignedUrl) } if v.SourceDBClusterSnapshotIdentifier != nil { objectKey := object.Key("SourceDBClusterSnapshotIdentifier") objectKey.String(*v.SourceDBClusterSnapshotIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.TargetDBClusterSnapshotIdentifier != nil { objectKey := object.Key("TargetDBClusterSnapshotIdentifier") objectKey.String(*v.TargetDBClusterSnapshotIdentifier) } return nil } func awsAwsquery_serializeOpDocumentCopyDBParameterGroupInput(v *CopyDBParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.SourceDBParameterGroupIdentifier != nil { objectKey := object.Key("SourceDBParameterGroupIdentifier") objectKey.String(*v.SourceDBParameterGroupIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.TargetDBParameterGroupDescription != nil { objectKey := object.Key("TargetDBParameterGroupDescription") objectKey.String(*v.TargetDBParameterGroupDescription) } if v.TargetDBParameterGroupIdentifier != nil { objectKey := object.Key("TargetDBParameterGroupIdentifier") objectKey.String(*v.TargetDBParameterGroupIdentifier) } return nil } func awsAwsquery_serializeOpDocumentCreateDBClusterEndpointInput(v *CreateDBClusterEndpointInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterEndpointIdentifier != nil { objectKey := object.Key("DBClusterEndpointIdentifier") objectKey.String(*v.DBClusterEndpointIdentifier) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.EndpointType != nil { objectKey := object.Key("EndpointType") objectKey.String(*v.EndpointType) } if v.ExcludedMembers != nil { objectKey := object.Key("ExcludedMembers") if err := awsAwsquery_serializeDocumentStringList(v.ExcludedMembers, objectKey); err != nil { return err } } if v.StaticMembers != nil { objectKey := object.Key("StaticMembers") if err := awsAwsquery_serializeDocumentStringList(v.StaticMembers, objectKey); err != nil { return err } } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBClusterInput(v *CreateDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.AvailabilityZones != nil { objectKey := object.Key("AvailabilityZones") if err := awsAwsquery_serializeDocumentAvailabilityZones(v.AvailabilityZones, objectKey); err != nil { return err } } if v.BackupRetentionPeriod != nil { objectKey := object.Key("BackupRetentionPeriod") objectKey.Integer(*v.BackupRetentionPeriod) } if v.CharacterSetName != nil { objectKey := object.Key("CharacterSetName") objectKey.String(*v.CharacterSetName) } if v.CopyTagsToSnapshot != nil { objectKey := object.Key("CopyTagsToSnapshot") objectKey.Boolean(*v.CopyTagsToSnapshot) } if v.DatabaseName != nil { objectKey := object.Key("DatabaseName") objectKey.String(*v.DatabaseName) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.destinationRegion != nil { objectKey := object.Key("DestinationRegion") objectKey.String(*v.destinationRegion) } if v.EnableCloudwatchLogsExports != nil { objectKey := object.Key("EnableCloudwatchLogsExports") if err := awsAwsquery_serializeDocumentLogTypeList(v.EnableCloudwatchLogsExports, objectKey); err != nil { return err } } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } if v.KmsKeyId != nil { objectKey := object.Key("KmsKeyId") objectKey.String(*v.KmsKeyId) } if v.MasterUsername != nil { objectKey := object.Key("MasterUsername") objectKey.String(*v.MasterUsername) } if v.MasterUserPassword != nil { objectKey := object.Key("MasterUserPassword") objectKey.String(*v.MasterUserPassword) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.Port != nil { objectKey := object.Key("Port") objectKey.Integer(*v.Port) } if v.PreferredBackupWindow != nil { objectKey := object.Key("PreferredBackupWindow") objectKey.String(*v.PreferredBackupWindow) } if v.PreferredMaintenanceWindow != nil { objectKey := object.Key("PreferredMaintenanceWindow") objectKey.String(*v.PreferredMaintenanceWindow) } if v.PreSignedUrl != nil { objectKey := object.Key("PreSignedUrl") objectKey.String(*v.PreSignedUrl) } if v.ReplicationSourceIdentifier != nil { objectKey := object.Key("ReplicationSourceIdentifier") objectKey.String(*v.ReplicationSourceIdentifier) } if v.ServerlessV2ScalingConfiguration != nil { objectKey := object.Key("ServerlessV2ScalingConfiguration") if err := awsAwsquery_serializeDocumentServerlessV2ScalingConfiguration(v.ServerlessV2ScalingConfiguration, objectKey); err != nil { return err } } if v.StorageEncrypted != nil { objectKey := object.Key("StorageEncrypted") objectKey.Boolean(*v.StorageEncrypted) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBClusterParameterGroupInput(v *CreateDBClusterParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.DBParameterGroupFamily != nil { objectKey := object.Key("DBParameterGroupFamily") objectKey.String(*v.DBParameterGroupFamily) } if v.Description != nil { objectKey := object.Key("Description") objectKey.String(*v.Description) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBClusterSnapshotInput(v *CreateDBClusterSnapshotInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterSnapshotIdentifier != nil { objectKey := object.Key("DBClusterSnapshotIdentifier") objectKey.String(*v.DBClusterSnapshotIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBInstanceInput(v *CreateDBInstanceInput, value query.Value) error { object := value.Object() _ = object if v.AllocatedStorage != nil { objectKey := object.Key("AllocatedStorage") objectKey.Integer(*v.AllocatedStorage) } if v.AutoMinorVersionUpgrade != nil { objectKey := object.Key("AutoMinorVersionUpgrade") objectKey.Boolean(*v.AutoMinorVersionUpgrade) } if v.AvailabilityZone != nil { objectKey := object.Key("AvailabilityZone") objectKey.String(*v.AvailabilityZone) } if v.BackupRetentionPeriod != nil { objectKey := object.Key("BackupRetentionPeriod") objectKey.Integer(*v.BackupRetentionPeriod) } if v.CharacterSetName != nil { objectKey := object.Key("CharacterSetName") objectKey.String(*v.CharacterSetName) } if v.CopyTagsToSnapshot != nil { objectKey := object.Key("CopyTagsToSnapshot") objectKey.Boolean(*v.CopyTagsToSnapshot) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBInstanceClass != nil { objectKey := object.Key("DBInstanceClass") objectKey.String(*v.DBInstanceClass) } if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } if v.DBName != nil { objectKey := object.Key("DBName") objectKey.String(*v.DBName) } if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.DBSecurityGroups != nil { objectKey := object.Key("DBSecurityGroups") if err := awsAwsquery_serializeDocumentDBSecurityGroupNameList(v.DBSecurityGroups, objectKey); err != nil { return err } } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.Domain != nil { objectKey := object.Key("Domain") objectKey.String(*v.Domain) } if v.DomainIAMRoleName != nil { objectKey := object.Key("DomainIAMRoleName") objectKey.String(*v.DomainIAMRoleName) } if v.EnableCloudwatchLogsExports != nil { objectKey := object.Key("EnableCloudwatchLogsExports") if err := awsAwsquery_serializeDocumentLogTypeList(v.EnableCloudwatchLogsExports, objectKey); err != nil { return err } } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.EnablePerformanceInsights != nil { objectKey := object.Key("EnablePerformanceInsights") objectKey.Boolean(*v.EnablePerformanceInsights) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.Iops != nil { objectKey := object.Key("Iops") objectKey.Integer(*v.Iops) } if v.KmsKeyId != nil { objectKey := object.Key("KmsKeyId") objectKey.String(*v.KmsKeyId) } if v.LicenseModel != nil { objectKey := object.Key("LicenseModel") objectKey.String(*v.LicenseModel) } if v.MasterUsername != nil { objectKey := object.Key("MasterUsername") objectKey.String(*v.MasterUsername) } if v.MasterUserPassword != nil { objectKey := object.Key("MasterUserPassword") objectKey.String(*v.MasterUserPassword) } if v.MonitoringInterval != nil { objectKey := object.Key("MonitoringInterval") objectKey.Integer(*v.MonitoringInterval) } if v.MonitoringRoleArn != nil { objectKey := object.Key("MonitoringRoleArn") objectKey.String(*v.MonitoringRoleArn) } if v.MultiAZ != nil { objectKey := object.Key("MultiAZ") objectKey.Boolean(*v.MultiAZ) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.PerformanceInsightsKMSKeyId != nil { objectKey := object.Key("PerformanceInsightsKMSKeyId") objectKey.String(*v.PerformanceInsightsKMSKeyId) } if v.Port != nil { objectKey := object.Key("Port") objectKey.Integer(*v.Port) } if v.PreferredBackupWindow != nil { objectKey := object.Key("PreferredBackupWindow") objectKey.String(*v.PreferredBackupWindow) } if v.PreferredMaintenanceWindow != nil { objectKey := object.Key("PreferredMaintenanceWindow") objectKey.String(*v.PreferredMaintenanceWindow) } if v.PromotionTier != nil { objectKey := object.Key("PromotionTier") objectKey.Integer(*v.PromotionTier) } if v.PubliclyAccessible != nil { objectKey := object.Key("PubliclyAccessible") objectKey.Boolean(*v.PubliclyAccessible) } if v.StorageEncrypted != nil { objectKey := object.Key("StorageEncrypted") objectKey.Boolean(*v.StorageEncrypted) } if v.StorageType != nil { objectKey := object.Key("StorageType") objectKey.String(*v.StorageType) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.TdeCredentialArn != nil { objectKey := object.Key("TdeCredentialArn") objectKey.String(*v.TdeCredentialArn) } if v.TdeCredentialPassword != nil { objectKey := object.Key("TdeCredentialPassword") objectKey.String(*v.TdeCredentialPassword) } if v.Timezone != nil { objectKey := object.Key("Timezone") objectKey.String(*v.Timezone) } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBParameterGroupInput(v *CreateDBParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupFamily != nil { objectKey := object.Key("DBParameterGroupFamily") objectKey.String(*v.DBParameterGroupFamily) } if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.Description != nil { objectKey := object.Key("Description") objectKey.String(*v.Description) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateDBSubnetGroupInput(v *CreateDBSubnetGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBSubnetGroupDescription != nil { objectKey := object.Key("DBSubnetGroupDescription") objectKey.String(*v.DBSubnetGroupDescription) } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.SubnetIds != nil { objectKey := object.Key("SubnetIds") if err := awsAwsquery_serializeDocumentSubnetIdentifierList(v.SubnetIds, objectKey); err != nil { return err } } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateEventSubscriptionInput(v *CreateEventSubscriptionInput, value query.Value) error { object := value.Object() _ = object if v.Enabled != nil { objectKey := object.Key("Enabled") objectKey.Boolean(*v.Enabled) } if v.EventCategories != nil { objectKey := object.Key("EventCategories") if err := awsAwsquery_serializeDocumentEventCategoriesList(v.EventCategories, objectKey); err != nil { return err } } if v.SnsTopicArn != nil { objectKey := object.Key("SnsTopicArn") objectKey.String(*v.SnsTopicArn) } if v.SourceIds != nil { objectKey := object.Key("SourceIds") if err := awsAwsquery_serializeDocumentSourceIdsList(v.SourceIds, objectKey); err != nil { return err } } if v.SourceType != nil { objectKey := object.Key("SourceType") objectKey.String(*v.SourceType) } if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentCreateGlobalClusterInput(v *CreateGlobalClusterInput, value query.Value) error { object := value.Object() _ = object if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } if v.SourceDBClusterIdentifier != nil { objectKey := object.Key("SourceDBClusterIdentifier") objectKey.String(*v.SourceDBClusterIdentifier) } if v.StorageEncrypted != nil { objectKey := object.Key("StorageEncrypted") objectKey.Boolean(*v.StorageEncrypted) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBClusterEndpointInput(v *DeleteDBClusterEndpointInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterEndpointIdentifier != nil { objectKey := object.Key("DBClusterEndpointIdentifier") objectKey.String(*v.DBClusterEndpointIdentifier) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBClusterInput(v *DeleteDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.FinalDBSnapshotIdentifier != nil { objectKey := object.Key("FinalDBSnapshotIdentifier") objectKey.String(*v.FinalDBSnapshotIdentifier) } if v.SkipFinalSnapshot { objectKey := object.Key("SkipFinalSnapshot") objectKey.Boolean(v.SkipFinalSnapshot) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBClusterParameterGroupInput(v *DeleteDBClusterParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBClusterSnapshotInput(v *DeleteDBClusterSnapshotInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterSnapshotIdentifier != nil { objectKey := object.Key("DBClusterSnapshotIdentifier") objectKey.String(*v.DBClusterSnapshotIdentifier) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBInstanceInput(v *DeleteDBInstanceInput, value query.Value) error { object := value.Object() _ = object if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } if v.FinalDBSnapshotIdentifier != nil { objectKey := object.Key("FinalDBSnapshotIdentifier") objectKey.String(*v.FinalDBSnapshotIdentifier) } if v.SkipFinalSnapshot { objectKey := object.Key("SkipFinalSnapshot") objectKey.Boolean(v.SkipFinalSnapshot) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBParameterGroupInput(v *DeleteDBParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } return nil } func awsAwsquery_serializeOpDocumentDeleteDBSubnetGroupInput(v *DeleteDBSubnetGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } return nil } func awsAwsquery_serializeOpDocumentDeleteEventSubscriptionInput(v *DeleteEventSubscriptionInput, value query.Value) error { object := value.Object() _ = object if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } return nil } func awsAwsquery_serializeOpDocumentDeleteGlobalClusterInput(v *DeleteGlobalClusterInput, value query.Value) error { object := value.Object() _ = object if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClusterEndpointsInput(v *DescribeDBClusterEndpointsInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterEndpointIdentifier != nil { objectKey := object.Key("DBClusterEndpointIdentifier") objectKey.String(*v.DBClusterEndpointIdentifier) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClusterParameterGroupsInput(v *DescribeDBClusterParameterGroupsInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClusterParametersInput(v *DescribeDBClusterParametersInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.Source != nil { objectKey := object.Key("Source") objectKey.String(*v.Source) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClustersInput(v *DescribeDBClustersInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClusterSnapshotAttributesInput(v *DescribeDBClusterSnapshotAttributesInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterSnapshotIdentifier != nil { objectKey := object.Key("DBClusterSnapshotIdentifier") objectKey.String(*v.DBClusterSnapshotIdentifier) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBClusterSnapshotsInput(v *DescribeDBClusterSnapshotsInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterSnapshotIdentifier != nil { objectKey := object.Key("DBClusterSnapshotIdentifier") objectKey.String(*v.DBClusterSnapshotIdentifier) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.IncludePublic { objectKey := object.Key("IncludePublic") objectKey.Boolean(v.IncludePublic) } if v.IncludeShared { objectKey := object.Key("IncludeShared") objectKey.Boolean(v.IncludeShared) } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.SnapshotType != nil { objectKey := object.Key("SnapshotType") objectKey.String(*v.SnapshotType) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBEngineVersionsInput(v *DescribeDBEngineVersionsInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupFamily != nil { objectKey := object.Key("DBParameterGroupFamily") objectKey.String(*v.DBParameterGroupFamily) } if v.DefaultOnly { objectKey := object.Key("DefaultOnly") objectKey.Boolean(v.DefaultOnly) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.ListSupportedCharacterSets != nil { objectKey := object.Key("ListSupportedCharacterSets") objectKey.Boolean(*v.ListSupportedCharacterSets) } if v.ListSupportedTimezones != nil { objectKey := object.Key("ListSupportedTimezones") objectKey.Boolean(*v.ListSupportedTimezones) } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBInstancesInput(v *DescribeDBInstancesInput, value query.Value) error { object := value.Object() _ = object if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBParameterGroupsInput(v *DescribeDBParameterGroupsInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBParametersInput(v *DescribeDBParametersInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.Source != nil { objectKey := object.Key("Source") objectKey.String(*v.Source) } return nil } func awsAwsquery_serializeOpDocumentDescribeDBSubnetGroupsInput(v *DescribeDBSubnetGroupsInput, value query.Value) error { object := value.Object() _ = object if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeEngineDefaultClusterParametersInput(v *DescribeEngineDefaultClusterParametersInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupFamily != nil { objectKey := object.Key("DBParameterGroupFamily") objectKey.String(*v.DBParameterGroupFamily) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeEngineDefaultParametersInput(v *DescribeEngineDefaultParametersInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupFamily != nil { objectKey := object.Key("DBParameterGroupFamily") objectKey.String(*v.DBParameterGroupFamily) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeEventCategoriesInput(v *DescribeEventCategoriesInput, value query.Value) error { object := value.Object() _ = object if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.SourceType != nil { objectKey := object.Key("SourceType") objectKey.String(*v.SourceType) } return nil } func awsAwsquery_serializeOpDocumentDescribeEventsInput(v *DescribeEventsInput, value query.Value) error { object := value.Object() _ = object if v.Duration != nil { objectKey := object.Key("Duration") objectKey.Integer(*v.Duration) } if v.EndTime != nil { objectKey := object.Key("EndTime") objectKey.String(smithytime.FormatDateTime(*v.EndTime)) } if v.EventCategories != nil { objectKey := object.Key("EventCategories") if err := awsAwsquery_serializeDocumentEventCategoriesList(v.EventCategories, objectKey); err != nil { return err } } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.SourceIdentifier != nil { objectKey := object.Key("SourceIdentifier") objectKey.String(*v.SourceIdentifier) } if len(v.SourceType) > 0 { objectKey := object.Key("SourceType") objectKey.String(string(v.SourceType)) } if v.StartTime != nil { objectKey := object.Key("StartTime") objectKey.String(smithytime.FormatDateTime(*v.StartTime)) } return nil } func awsAwsquery_serializeOpDocumentDescribeEventSubscriptionsInput(v *DescribeEventSubscriptionsInput, value query.Value) error { object := value.Object() _ = object if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } return nil } func awsAwsquery_serializeOpDocumentDescribeGlobalClustersInput(v *DescribeGlobalClustersInput, value query.Value) error { object := value.Object() _ = object if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } return nil } func awsAwsquery_serializeOpDocumentDescribeOrderableDBInstanceOptionsInput(v *DescribeOrderableDBInstanceOptionsInput, value query.Value) error { object := value.Object() _ = object if v.DBInstanceClass != nil { objectKey := object.Key("DBInstanceClass") objectKey.String(*v.DBInstanceClass) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.LicenseModel != nil { objectKey := object.Key("LicenseModel") objectKey.String(*v.LicenseModel) } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.Vpc != nil { objectKey := object.Key("Vpc") objectKey.Boolean(*v.Vpc) } return nil } func awsAwsquery_serializeOpDocumentDescribePendingMaintenanceActionsInput(v *DescribePendingMaintenanceActionsInput, value query.Value) error { object := value.Object() _ = object if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.Marker != nil { objectKey := object.Key("Marker") objectKey.String(*v.Marker) } if v.MaxRecords != nil { objectKey := object.Key("MaxRecords") objectKey.Integer(*v.MaxRecords) } if v.ResourceIdentifier != nil { objectKey := object.Key("ResourceIdentifier") objectKey.String(*v.ResourceIdentifier) } return nil } func awsAwsquery_serializeOpDocumentDescribeValidDBInstanceModificationsInput(v *DescribeValidDBInstanceModificationsInput, value query.Value) error { object := value.Object() _ = object if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } return nil } func awsAwsquery_serializeOpDocumentFailoverDBClusterInput(v *FailoverDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.TargetDBInstanceIdentifier != nil { objectKey := object.Key("TargetDBInstanceIdentifier") objectKey.String(*v.TargetDBInstanceIdentifier) } return nil } func awsAwsquery_serializeOpDocumentFailoverGlobalClusterInput(v *FailoverGlobalClusterInput, value query.Value) error { object := value.Object() _ = object if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } if v.TargetDbClusterIdentifier != nil { objectKey := object.Key("TargetDbClusterIdentifier") objectKey.String(*v.TargetDbClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentListTagsForResourceInput(v *ListTagsForResourceInput, value query.Value) error { object := value.Object() _ = object if v.Filters != nil { objectKey := object.Key("Filters") if err := awsAwsquery_serializeDocumentFilterList(v.Filters, objectKey); err != nil { return err } } if v.ResourceName != nil { objectKey := object.Key("ResourceName") objectKey.String(*v.ResourceName) } return nil } func awsAwsquery_serializeOpDocumentModifyDBClusterEndpointInput(v *ModifyDBClusterEndpointInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterEndpointIdentifier != nil { objectKey := object.Key("DBClusterEndpointIdentifier") objectKey.String(*v.DBClusterEndpointIdentifier) } if v.EndpointType != nil { objectKey := object.Key("EndpointType") objectKey.String(*v.EndpointType) } if v.ExcludedMembers != nil { objectKey := object.Key("ExcludedMembers") if err := awsAwsquery_serializeDocumentStringList(v.ExcludedMembers, objectKey); err != nil { return err } } if v.StaticMembers != nil { objectKey := object.Key("StaticMembers") if err := awsAwsquery_serializeDocumentStringList(v.StaticMembers, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBClusterInput(v *ModifyDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.AllowMajorVersionUpgrade { objectKey := object.Key("AllowMajorVersionUpgrade") objectKey.Boolean(v.AllowMajorVersionUpgrade) } if v.ApplyImmediately { objectKey := object.Key("ApplyImmediately") objectKey.Boolean(v.ApplyImmediately) } if v.BackupRetentionPeriod != nil { objectKey := object.Key("BackupRetentionPeriod") objectKey.Integer(*v.BackupRetentionPeriod) } if v.CloudwatchLogsExportConfiguration != nil { objectKey := object.Key("CloudwatchLogsExportConfiguration") if err := awsAwsquery_serializeDocumentCloudwatchLogsExportConfiguration(v.CloudwatchLogsExportConfiguration, objectKey); err != nil { return err } } if v.CopyTagsToSnapshot != nil { objectKey := object.Key("CopyTagsToSnapshot") objectKey.Boolean(*v.CopyTagsToSnapshot) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.DBInstanceParameterGroupName != nil { objectKey := object.Key("DBInstanceParameterGroupName") objectKey.String(*v.DBInstanceParameterGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.MasterUserPassword != nil { objectKey := object.Key("MasterUserPassword") objectKey.String(*v.MasterUserPassword) } if v.NewDBClusterIdentifier != nil { objectKey := object.Key("NewDBClusterIdentifier") objectKey.String(*v.NewDBClusterIdentifier) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.Port != nil { objectKey := object.Key("Port") objectKey.Integer(*v.Port) } if v.PreferredBackupWindow != nil { objectKey := object.Key("PreferredBackupWindow") objectKey.String(*v.PreferredBackupWindow) } if v.PreferredMaintenanceWindow != nil { objectKey := object.Key("PreferredMaintenanceWindow") objectKey.String(*v.PreferredMaintenanceWindow) } if v.ServerlessV2ScalingConfiguration != nil { objectKey := object.Key("ServerlessV2ScalingConfiguration") if err := awsAwsquery_serializeDocumentServerlessV2ScalingConfiguration(v.ServerlessV2ScalingConfiguration, objectKey); err != nil { return err } } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBClusterParameterGroupInput(v *ModifyDBClusterParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.Parameters != nil { objectKey := object.Key("Parameters") if err := awsAwsquery_serializeDocumentParametersList(v.Parameters, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBClusterSnapshotAttributeInput(v *ModifyDBClusterSnapshotAttributeInput, value query.Value) error { object := value.Object() _ = object if v.AttributeName != nil { objectKey := object.Key("AttributeName") objectKey.String(*v.AttributeName) } if v.DBClusterSnapshotIdentifier != nil { objectKey := object.Key("DBClusterSnapshotIdentifier") objectKey.String(*v.DBClusterSnapshotIdentifier) } if v.ValuesToAdd != nil { objectKey := object.Key("ValuesToAdd") if err := awsAwsquery_serializeDocumentAttributeValueList(v.ValuesToAdd, objectKey); err != nil { return err } } if v.ValuesToRemove != nil { objectKey := object.Key("ValuesToRemove") if err := awsAwsquery_serializeDocumentAttributeValueList(v.ValuesToRemove, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBInstanceInput(v *ModifyDBInstanceInput, value query.Value) error { object := value.Object() _ = object if v.AllocatedStorage != nil { objectKey := object.Key("AllocatedStorage") objectKey.Integer(*v.AllocatedStorage) } if v.AllowMajorVersionUpgrade { objectKey := object.Key("AllowMajorVersionUpgrade") objectKey.Boolean(v.AllowMajorVersionUpgrade) } if v.ApplyImmediately { objectKey := object.Key("ApplyImmediately") objectKey.Boolean(v.ApplyImmediately) } if v.AutoMinorVersionUpgrade != nil { objectKey := object.Key("AutoMinorVersionUpgrade") objectKey.Boolean(*v.AutoMinorVersionUpgrade) } if v.BackupRetentionPeriod != nil { objectKey := object.Key("BackupRetentionPeriod") objectKey.Integer(*v.BackupRetentionPeriod) } if v.CACertificateIdentifier != nil { objectKey := object.Key("CACertificateIdentifier") objectKey.String(*v.CACertificateIdentifier) } if v.CloudwatchLogsExportConfiguration != nil { objectKey := object.Key("CloudwatchLogsExportConfiguration") if err := awsAwsquery_serializeDocumentCloudwatchLogsExportConfiguration(v.CloudwatchLogsExportConfiguration, objectKey); err != nil { return err } } if v.CopyTagsToSnapshot != nil { objectKey := object.Key("CopyTagsToSnapshot") objectKey.Boolean(*v.CopyTagsToSnapshot) } if v.DBInstanceClass != nil { objectKey := object.Key("DBInstanceClass") objectKey.String(*v.DBInstanceClass) } if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.DBPortNumber != nil { objectKey := object.Key("DBPortNumber") objectKey.Integer(*v.DBPortNumber) } if v.DBSecurityGroups != nil { objectKey := object.Key("DBSecurityGroups") if err := awsAwsquery_serializeDocumentDBSecurityGroupNameList(v.DBSecurityGroups, objectKey); err != nil { return err } } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.Domain != nil { objectKey := object.Key("Domain") objectKey.String(*v.Domain) } if v.DomainIAMRoleName != nil { objectKey := object.Key("DomainIAMRoleName") objectKey.String(*v.DomainIAMRoleName) } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.EnablePerformanceInsights != nil { objectKey := object.Key("EnablePerformanceInsights") objectKey.Boolean(*v.EnablePerformanceInsights) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.Iops != nil { objectKey := object.Key("Iops") objectKey.Integer(*v.Iops) } if v.LicenseModel != nil { objectKey := object.Key("LicenseModel") objectKey.String(*v.LicenseModel) } if v.MasterUserPassword != nil { objectKey := object.Key("MasterUserPassword") objectKey.String(*v.MasterUserPassword) } if v.MonitoringInterval != nil { objectKey := object.Key("MonitoringInterval") objectKey.Integer(*v.MonitoringInterval) } if v.MonitoringRoleArn != nil { objectKey := object.Key("MonitoringRoleArn") objectKey.String(*v.MonitoringRoleArn) } if v.MultiAZ != nil { objectKey := object.Key("MultiAZ") objectKey.Boolean(*v.MultiAZ) } if v.NewDBInstanceIdentifier != nil { objectKey := object.Key("NewDBInstanceIdentifier") objectKey.String(*v.NewDBInstanceIdentifier) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.PerformanceInsightsKMSKeyId != nil { objectKey := object.Key("PerformanceInsightsKMSKeyId") objectKey.String(*v.PerformanceInsightsKMSKeyId) } if v.PreferredBackupWindow != nil { objectKey := object.Key("PreferredBackupWindow") objectKey.String(*v.PreferredBackupWindow) } if v.PreferredMaintenanceWindow != nil { objectKey := object.Key("PreferredMaintenanceWindow") objectKey.String(*v.PreferredMaintenanceWindow) } if v.PromotionTier != nil { objectKey := object.Key("PromotionTier") objectKey.Integer(*v.PromotionTier) } if v.PubliclyAccessible != nil { objectKey := object.Key("PubliclyAccessible") objectKey.Boolean(*v.PubliclyAccessible) } if v.StorageType != nil { objectKey := object.Key("StorageType") objectKey.String(*v.StorageType) } if v.TdeCredentialArn != nil { objectKey := object.Key("TdeCredentialArn") objectKey.String(*v.TdeCredentialArn) } if v.TdeCredentialPassword != nil { objectKey := object.Key("TdeCredentialPassword") objectKey.String(*v.TdeCredentialPassword) } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBParameterGroupInput(v *ModifyDBParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.Parameters != nil { objectKey := object.Key("Parameters") if err := awsAwsquery_serializeDocumentParametersList(v.Parameters, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyDBSubnetGroupInput(v *ModifyDBSubnetGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBSubnetGroupDescription != nil { objectKey := object.Key("DBSubnetGroupDescription") objectKey.String(*v.DBSubnetGroupDescription) } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.SubnetIds != nil { objectKey := object.Key("SubnetIds") if err := awsAwsquery_serializeDocumentSubnetIdentifierList(v.SubnetIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentModifyEventSubscriptionInput(v *ModifyEventSubscriptionInput, value query.Value) error { object := value.Object() _ = object if v.Enabled != nil { objectKey := object.Key("Enabled") objectKey.Boolean(*v.Enabled) } if v.EventCategories != nil { objectKey := object.Key("EventCategories") if err := awsAwsquery_serializeDocumentEventCategoriesList(v.EventCategories, objectKey); err != nil { return err } } if v.SnsTopicArn != nil { objectKey := object.Key("SnsTopicArn") objectKey.String(*v.SnsTopicArn) } if v.SourceType != nil { objectKey := object.Key("SourceType") objectKey.String(*v.SourceType) } if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } return nil } func awsAwsquery_serializeOpDocumentModifyGlobalClusterInput(v *ModifyGlobalClusterInput, value query.Value) error { object := value.Object() _ = object if v.AllowMajorVersionUpgrade != nil { objectKey := object.Key("AllowMajorVersionUpgrade") objectKey.Boolean(*v.AllowMajorVersionUpgrade) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } if v.NewGlobalClusterIdentifier != nil { objectKey := object.Key("NewGlobalClusterIdentifier") objectKey.String(*v.NewGlobalClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentPromoteReadReplicaDBClusterInput(v *PromoteReadReplicaDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentRebootDBInstanceInput(v *RebootDBInstanceInput, value query.Value) error { object := value.Object() _ = object if v.DBInstanceIdentifier != nil { objectKey := object.Key("DBInstanceIdentifier") objectKey.String(*v.DBInstanceIdentifier) } if v.ForceFailover != nil { objectKey := object.Key("ForceFailover") objectKey.Boolean(*v.ForceFailover) } return nil } func awsAwsquery_serializeOpDocumentRemoveFromGlobalClusterInput(v *RemoveFromGlobalClusterInput, value query.Value) error { object := value.Object() _ = object if v.DbClusterIdentifier != nil { objectKey := object.Key("DbClusterIdentifier") objectKey.String(*v.DbClusterIdentifier) } if v.GlobalClusterIdentifier != nil { objectKey := object.Key("GlobalClusterIdentifier") objectKey.String(*v.GlobalClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentRemoveRoleFromDBClusterInput(v *RemoveRoleFromDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.FeatureName != nil { objectKey := object.Key("FeatureName") objectKey.String(*v.FeatureName) } if v.RoleArn != nil { objectKey := object.Key("RoleArn") objectKey.String(*v.RoleArn) } return nil } func awsAwsquery_serializeOpDocumentRemoveSourceIdentifierFromSubscriptionInput(v *RemoveSourceIdentifierFromSubscriptionInput, value query.Value) error { object := value.Object() _ = object if v.SourceIdentifier != nil { objectKey := object.Key("SourceIdentifier") objectKey.String(*v.SourceIdentifier) } if v.SubscriptionName != nil { objectKey := object.Key("SubscriptionName") objectKey.String(*v.SubscriptionName) } return nil } func awsAwsquery_serializeOpDocumentRemoveTagsFromResourceInput(v *RemoveTagsFromResourceInput, value query.Value) error { object := value.Object() _ = object if v.ResourceName != nil { objectKey := object.Key("ResourceName") objectKey.String(*v.ResourceName) } if v.TagKeys != nil { objectKey := object.Key("TagKeys") if err := awsAwsquery_serializeDocumentKeyList(v.TagKeys, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentResetDBClusterParameterGroupInput(v *ResetDBClusterParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.Parameters != nil { objectKey := object.Key("Parameters") if err := awsAwsquery_serializeDocumentParametersList(v.Parameters, objectKey); err != nil { return err } } if v.ResetAllParameters { objectKey := object.Key("ResetAllParameters") objectKey.Boolean(v.ResetAllParameters) } return nil } func awsAwsquery_serializeOpDocumentResetDBParameterGroupInput(v *ResetDBParameterGroupInput, value query.Value) error { object := value.Object() _ = object if v.DBParameterGroupName != nil { objectKey := object.Key("DBParameterGroupName") objectKey.String(*v.DBParameterGroupName) } if v.Parameters != nil { objectKey := object.Key("Parameters") if err := awsAwsquery_serializeDocumentParametersList(v.Parameters, objectKey); err != nil { return err } } if v.ResetAllParameters { objectKey := object.Key("ResetAllParameters") objectKey.Boolean(v.ResetAllParameters) } return nil } func awsAwsquery_serializeOpDocumentRestoreDBClusterFromSnapshotInput(v *RestoreDBClusterFromSnapshotInput, value query.Value) error { object := value.Object() _ = object if v.AvailabilityZones != nil { objectKey := object.Key("AvailabilityZones") if err := awsAwsquery_serializeDocumentAvailabilityZones(v.AvailabilityZones, objectKey); err != nil { return err } } if v.CopyTagsToSnapshot != nil { objectKey := object.Key("CopyTagsToSnapshot") objectKey.Boolean(*v.CopyTagsToSnapshot) } if v.DatabaseName != nil { objectKey := object.Key("DatabaseName") objectKey.String(*v.DatabaseName) } if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.EnableCloudwatchLogsExports != nil { objectKey := object.Key("EnableCloudwatchLogsExports") if err := awsAwsquery_serializeDocumentLogTypeList(v.EnableCloudwatchLogsExports, objectKey); err != nil { return err } } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.Engine != nil { objectKey := object.Key("Engine") objectKey.String(*v.Engine) } if v.EngineVersion != nil { objectKey := object.Key("EngineVersion") objectKey.String(*v.EngineVersion) } if v.KmsKeyId != nil { objectKey := object.Key("KmsKeyId") objectKey.String(*v.KmsKeyId) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.Port != nil { objectKey := object.Key("Port") objectKey.Integer(*v.Port) } if v.ServerlessV2ScalingConfiguration != nil { objectKey := object.Key("ServerlessV2ScalingConfiguration") if err := awsAwsquery_serializeDocumentServerlessV2ScalingConfiguration(v.ServerlessV2ScalingConfiguration, objectKey); err != nil { return err } } if v.SnapshotIdentifier != nil { objectKey := object.Key("SnapshotIdentifier") objectKey.String(*v.SnapshotIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentRestoreDBClusterToPointInTimeInput(v *RestoreDBClusterToPointInTimeInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } if v.DBClusterParameterGroupName != nil { objectKey := object.Key("DBClusterParameterGroupName") objectKey.String(*v.DBClusterParameterGroupName) } if v.DBSubnetGroupName != nil { objectKey := object.Key("DBSubnetGroupName") objectKey.String(*v.DBSubnetGroupName) } if v.DeletionProtection != nil { objectKey := object.Key("DeletionProtection") objectKey.Boolean(*v.DeletionProtection) } if v.EnableCloudwatchLogsExports != nil { objectKey := object.Key("EnableCloudwatchLogsExports") if err := awsAwsquery_serializeDocumentLogTypeList(v.EnableCloudwatchLogsExports, objectKey); err != nil { return err } } if v.EnableIAMDatabaseAuthentication != nil { objectKey := object.Key("EnableIAMDatabaseAuthentication") objectKey.Boolean(*v.EnableIAMDatabaseAuthentication) } if v.KmsKeyId != nil { objectKey := object.Key("KmsKeyId") objectKey.String(*v.KmsKeyId) } if v.OptionGroupName != nil { objectKey := object.Key("OptionGroupName") objectKey.String(*v.OptionGroupName) } if v.Port != nil { objectKey := object.Key("Port") objectKey.Integer(*v.Port) } if v.RestoreToTime != nil { objectKey := object.Key("RestoreToTime") objectKey.String(smithytime.FormatDateTime(*v.RestoreToTime)) } if v.RestoreType != nil { objectKey := object.Key("RestoreType") objectKey.String(*v.RestoreType) } if v.ServerlessV2ScalingConfiguration != nil { objectKey := object.Key("ServerlessV2ScalingConfiguration") if err := awsAwsquery_serializeDocumentServerlessV2ScalingConfiguration(v.ServerlessV2ScalingConfiguration, objectKey); err != nil { return err } } if v.SourceDBClusterIdentifier != nil { objectKey := object.Key("SourceDBClusterIdentifier") objectKey.String(*v.SourceDBClusterIdentifier) } if v.Tags != nil { objectKey := object.Key("Tags") if err := awsAwsquery_serializeDocumentTagList(v.Tags, objectKey); err != nil { return err } } if v.UseLatestRestorableTime { objectKey := object.Key("UseLatestRestorableTime") objectKey.Boolean(v.UseLatestRestorableTime) } if v.VpcSecurityGroupIds != nil { objectKey := object.Key("VpcSecurityGroupIds") if err := awsAwsquery_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, objectKey); err != nil { return err } } return nil } func awsAwsquery_serializeOpDocumentStartDBClusterInput(v *StartDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } return nil } func awsAwsquery_serializeOpDocumentStopDBClusterInput(v *StopDBClusterInput, value query.Value) error { object := value.Object() _ = object if v.DBClusterIdentifier != nil { objectKey := object.Key("DBClusterIdentifier") objectKey.String(*v.DBClusterIdentifier) } return nil }