service/customerprofiles/serializers.go (7,564 lines of code) (raw):
// Code generated by smithy-go-codegen DO NOT EDIT.
package customerprofiles
import (
"bytes"
"context"
"fmt"
"github.com/aws/aws-sdk-go-v2/service/customerprofiles/types"
smithy "github.com/aws/smithy-go"
"github.com/aws/smithy-go/encoding/httpbinding"
smithyjson "github.com/aws/smithy-go/encoding/json"
"github.com/aws/smithy-go/middleware"
smithytime "github.com/aws/smithy-go/time"
"github.com/aws/smithy-go/tracing"
smithyhttp "github.com/aws/smithy-go/transport/http"
"math"
)
type awsRestjson1_serializeOpAddProfileKey struct {
}
func (*awsRestjson1_serializeOpAddProfileKey) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpAddProfileKey) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*AddProfileKeyInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/keys")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsAddProfileKeyInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentAddProfileKeyInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsAddProfileKeyInput(v *AddProfileKeyInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentAddProfileKeyInput(v *AddProfileKeyInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.KeyName != nil {
ok := object.Key("KeyName")
ok.String(*v.KeyName)
}
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentRequestValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpBatchGetCalculatedAttributeForProfile struct {
}
func (*awsRestjson1_serializeOpBatchGetCalculatedAttributeForProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpBatchGetCalculatedAttributeForProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*BatchGetCalculatedAttributeForProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes/{CalculatedAttributeName}/batch-get-for-profiles")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsBatchGetCalculatedAttributeForProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentBatchGetCalculatedAttributeForProfileInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsBatchGetCalculatedAttributeForProfileInput(v *BatchGetCalculatedAttributeForProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentBatchGetCalculatedAttributeForProfileInput(v *BatchGetCalculatedAttributeForProfileInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConditionOverrides != nil {
ok := object.Key("ConditionOverrides")
if err := awsRestjson1_serializeDocumentConditionOverrides(v.ConditionOverrides, ok); err != nil {
return err
}
}
if v.ProfileIds != nil {
ok := object.Key("ProfileIds")
if err := awsRestjson1_serializeDocumentBatchGetCalculatedAttributeForProfileIdList(v.ProfileIds, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpBatchGetProfile struct {
}
func (*awsRestjson1_serializeOpBatchGetProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpBatchGetProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*BatchGetProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/batch-get-profiles")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsBatchGetProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentBatchGetProfileInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsBatchGetProfileInput(v *BatchGetProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentBatchGetProfileInput(v *BatchGetProfileInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ProfileIds != nil {
ok := object.Key("ProfileIds")
if err := awsRestjson1_serializeDocumentBatchGetProfileIdList(v.ProfileIds, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateCalculatedAttributeDefinition struct {
}
func (*awsRestjson1_serializeOpCreateCalculatedAttributeDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateCalculatedAttributeDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateCalculatedAttributeDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes/{CalculatedAttributeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateCalculatedAttributeDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateCalculatedAttributeDefinitionInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateCalculatedAttributeDefinitionInput(v *CreateCalculatedAttributeDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateCalculatedAttributeDefinitionInput(v *CreateCalculatedAttributeDefinitionInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AttributeDetails != nil {
ok := object.Key("AttributeDetails")
if err := awsRestjson1_serializeDocumentAttributeDetails(v.AttributeDetails, ok); err != nil {
return err
}
}
if v.Conditions != nil {
ok := object.Key("Conditions")
if err := awsRestjson1_serializeDocumentConditions(v.Conditions, ok); err != nil {
return err
}
}
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.DisplayName != nil {
ok := object.Key("DisplayName")
ok.String(*v.DisplayName)
}
if v.Filter != nil {
ok := object.Key("Filter")
if err := awsRestjson1_serializeDocumentFilter(v.Filter, ok); err != nil {
return err
}
}
if len(v.Statistic) > 0 {
ok := object.Key("Statistic")
ok.String(string(v.Statistic))
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateDomain struct {
}
func (*awsRestjson1_serializeOpCreateDomain) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateDomain) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateDomainInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateDomainInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateDomainInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateDomainInput(v *CreateDomainInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateDomainInput(v *CreateDomainInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.DeadLetterQueueUrl != nil {
ok := object.Key("DeadLetterQueueUrl")
ok.String(*v.DeadLetterQueueUrl)
}
if v.DefaultEncryptionKey != nil {
ok := object.Key("DefaultEncryptionKey")
ok.String(*v.DefaultEncryptionKey)
}
if v.DefaultExpirationDays != nil {
ok := object.Key("DefaultExpirationDays")
ok.Integer(*v.DefaultExpirationDays)
}
if v.Matching != nil {
ok := object.Key("Matching")
if err := awsRestjson1_serializeDocumentMatchingRequest(v.Matching, ok); err != nil {
return err
}
}
if v.RuleBasedMatching != nil {
ok := object.Key("RuleBasedMatching")
if err := awsRestjson1_serializeDocumentRuleBasedMatchingRequest(v.RuleBasedMatching, ok); err != nil {
return err
}
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateEventStream struct {
}
func (*awsRestjson1_serializeOpCreateEventStream) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateEventStream) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateEventStreamInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-streams/{EventStreamName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateEventStreamInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateEventStreamInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateEventStreamInput(v *CreateEventStreamInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventStreamName == nil || len(*v.EventStreamName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventStreamName must not be empty")}
}
if v.EventStreamName != nil {
if err := encoder.SetURI("EventStreamName").String(*v.EventStreamName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateEventStreamInput(v *CreateEventStreamInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
if v.Uri != nil {
ok := object.Key("Uri")
ok.String(*v.Uri)
}
return nil
}
type awsRestjson1_serializeOpCreateEventTrigger struct {
}
func (*awsRestjson1_serializeOpCreateEventTrigger) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateEventTrigger) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateEventTriggerInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-triggers/{EventTriggerName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateEventTriggerInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateEventTriggerInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateEventTriggerInput(v *CreateEventTriggerInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventTriggerName == nil || len(*v.EventTriggerName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventTriggerName must not be empty")}
}
if v.EventTriggerName != nil {
if err := encoder.SetURI("EventTriggerName").String(*v.EventTriggerName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateEventTriggerInput(v *CreateEventTriggerInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.EventTriggerConditions != nil {
ok := object.Key("EventTriggerConditions")
if err := awsRestjson1_serializeDocumentEventTriggerConditions(v.EventTriggerConditions, ok); err != nil {
return err
}
}
if v.EventTriggerLimits != nil {
ok := object.Key("EventTriggerLimits")
if err := awsRestjson1_serializeDocumentEventTriggerLimits(v.EventTriggerLimits, ok); err != nil {
return err
}
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.SegmentFilter != nil {
ok := object.Key("SegmentFilter")
ok.String(*v.SegmentFilter)
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateIntegrationWorkflow struct {
}
func (*awsRestjson1_serializeOpCreateIntegrationWorkflow) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateIntegrationWorkflow) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateIntegrationWorkflowInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/workflows/integrations")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateIntegrationWorkflowInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateIntegrationWorkflowInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateIntegrationWorkflowInput(v *CreateIntegrationWorkflowInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateIntegrationWorkflowInput(v *CreateIntegrationWorkflowInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.IntegrationConfig != nil {
ok := object.Key("IntegrationConfig")
if err := awsRestjson1_serializeDocumentIntegrationConfig(v.IntegrationConfig, ok); err != nil {
return err
}
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.RoleArn != nil {
ok := object.Key("RoleArn")
ok.String(*v.RoleArn)
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
if len(v.WorkflowType) > 0 {
ok := object.Key("WorkflowType")
ok.String(string(v.WorkflowType))
}
return nil
}
type awsRestjson1_serializeOpCreateProfile struct {
}
func (*awsRestjson1_serializeOpCreateProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateProfileInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateProfileInput(v *CreateProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateProfileInput(v *CreateProfileInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AccountNumber != nil {
ok := object.Key("AccountNumber")
ok.String(*v.AccountNumber)
}
if v.AdditionalInformation != nil {
ok := object.Key("AdditionalInformation")
ok.String(*v.AdditionalInformation)
}
if v.Address != nil {
ok := object.Key("Address")
if err := awsRestjson1_serializeDocumentAddress(v.Address, ok); err != nil {
return err
}
}
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentAttributes(v.Attributes, ok); err != nil {
return err
}
}
if v.BillingAddress != nil {
ok := object.Key("BillingAddress")
if err := awsRestjson1_serializeDocumentAddress(v.BillingAddress, ok); err != nil {
return err
}
}
if v.BirthDate != nil {
ok := object.Key("BirthDate")
ok.String(*v.BirthDate)
}
if v.BusinessEmailAddress != nil {
ok := object.Key("BusinessEmailAddress")
ok.String(*v.BusinessEmailAddress)
}
if v.BusinessName != nil {
ok := object.Key("BusinessName")
ok.String(*v.BusinessName)
}
if v.BusinessPhoneNumber != nil {
ok := object.Key("BusinessPhoneNumber")
ok.String(*v.BusinessPhoneNumber)
}
if v.EmailAddress != nil {
ok := object.Key("EmailAddress")
ok.String(*v.EmailAddress)
}
if v.FirstName != nil {
ok := object.Key("FirstName")
ok.String(*v.FirstName)
}
if len(v.Gender) > 0 {
ok := object.Key("Gender")
ok.String(string(v.Gender))
}
if v.GenderString != nil {
ok := object.Key("GenderString")
ok.String(*v.GenderString)
}
if v.HomePhoneNumber != nil {
ok := object.Key("HomePhoneNumber")
ok.String(*v.HomePhoneNumber)
}
if v.LastName != nil {
ok := object.Key("LastName")
ok.String(*v.LastName)
}
if v.MailingAddress != nil {
ok := object.Key("MailingAddress")
if err := awsRestjson1_serializeDocumentAddress(v.MailingAddress, ok); err != nil {
return err
}
}
if v.MiddleName != nil {
ok := object.Key("MiddleName")
ok.String(*v.MiddleName)
}
if v.MobilePhoneNumber != nil {
ok := object.Key("MobilePhoneNumber")
ok.String(*v.MobilePhoneNumber)
}
if len(v.PartyType) > 0 {
ok := object.Key("PartyType")
ok.String(string(v.PartyType))
}
if v.PartyTypeString != nil {
ok := object.Key("PartyTypeString")
ok.String(*v.PartyTypeString)
}
if v.PersonalEmailAddress != nil {
ok := object.Key("PersonalEmailAddress")
ok.String(*v.PersonalEmailAddress)
}
if v.PhoneNumber != nil {
ok := object.Key("PhoneNumber")
ok.String(*v.PhoneNumber)
}
if v.ShippingAddress != nil {
ok := object.Key("ShippingAddress")
if err := awsRestjson1_serializeDocumentAddress(v.ShippingAddress, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateSegmentDefinition struct {
}
func (*awsRestjson1_serializeOpCreateSegmentDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateSegmentDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateSegmentDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-definitions/{SegmentDefinitionName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateSegmentDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateSegmentDefinitionInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateSegmentDefinitionInput(v *CreateSegmentDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateSegmentDefinitionInput(v *CreateSegmentDefinitionInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.DisplayName != nil {
ok := object.Key("DisplayName")
ok.String(*v.DisplayName)
}
if v.SegmentGroups != nil {
ok := object.Key("SegmentGroups")
if err := awsRestjson1_serializeDocumentSegmentGroup(v.SegmentGroups, ok); err != nil {
return err
}
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateSegmentEstimate struct {
}
func (*awsRestjson1_serializeOpCreateSegmentEstimate) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateSegmentEstimate) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateSegmentEstimateInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-estimates")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateSegmentEstimateInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateSegmentEstimateInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateSegmentEstimateInput(v *CreateSegmentEstimateInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateSegmentEstimateInput(v *CreateSegmentEstimateInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.SegmentQuery != nil {
ok := object.Key("SegmentQuery")
if err := awsRestjson1_serializeDocumentSegmentGroupStructure(v.SegmentQuery, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpCreateSegmentSnapshot struct {
}
func (*awsRestjson1_serializeOpCreateSegmentSnapshot) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpCreateSegmentSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*CreateSegmentSnapshotInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segments/{SegmentDefinitionName}/snapshots")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsCreateSegmentSnapshotInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentCreateSegmentSnapshotInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsCreateSegmentSnapshotInput(v *CreateSegmentSnapshotInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentCreateSegmentSnapshotInput(v *CreateSegmentSnapshotInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DataFormat) > 0 {
ok := object.Key("DataFormat")
ok.String(string(v.DataFormat))
}
if v.DestinationUri != nil {
ok := object.Key("DestinationUri")
ok.String(*v.DestinationUri)
}
if v.EncryptionKey != nil {
ok := object.Key("EncryptionKey")
ok.String(*v.EncryptionKey)
}
if v.RoleArn != nil {
ok := object.Key("RoleArn")
ok.String(*v.RoleArn)
}
return nil
}
type awsRestjson1_serializeOpDeleteCalculatedAttributeDefinition struct {
}
func (*awsRestjson1_serializeOpDeleteCalculatedAttributeDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteCalculatedAttributeDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteCalculatedAttributeDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes/{CalculatedAttributeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteCalculatedAttributeDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteCalculatedAttributeDefinitionInput(v *DeleteCalculatedAttributeDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteDomain struct {
}
func (*awsRestjson1_serializeOpDeleteDomain) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteDomain) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteDomainInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteDomainInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteDomainInput(v *DeleteDomainInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteEventStream struct {
}
func (*awsRestjson1_serializeOpDeleteEventStream) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteEventStream) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteEventStreamInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-streams/{EventStreamName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteEventStreamInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteEventStreamInput(v *DeleteEventStreamInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventStreamName == nil || len(*v.EventStreamName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventStreamName must not be empty")}
}
if v.EventStreamName != nil {
if err := encoder.SetURI("EventStreamName").String(*v.EventStreamName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteEventTrigger struct {
}
func (*awsRestjson1_serializeOpDeleteEventTrigger) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteEventTrigger) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteEventTriggerInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-triggers/{EventTriggerName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteEventTriggerInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteEventTriggerInput(v *DeleteEventTriggerInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventTriggerName == nil || len(*v.EventTriggerName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventTriggerName must not be empty")}
}
if v.EventTriggerName != nil {
if err := encoder.SetURI("EventTriggerName").String(*v.EventTriggerName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteIntegration struct {
}
func (*awsRestjson1_serializeOpDeleteIntegration) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteIntegration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteIntegrationInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/integrations/delete")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteIntegrationInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentDeleteIntegrationInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteIntegrationInput(v *DeleteIntegrationInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentDeleteIntegrationInput(v *DeleteIntegrationInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Uri != nil {
ok := object.Key("Uri")
ok.String(*v.Uri)
}
return nil
}
type awsRestjson1_serializeOpDeleteProfile struct {
}
func (*awsRestjson1_serializeOpDeleteProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/delete")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentDeleteProfileInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteProfileInput(v *DeleteProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentDeleteProfileInput(v *DeleteProfileInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
return nil
}
type awsRestjson1_serializeOpDeleteProfileKey struct {
}
func (*awsRestjson1_serializeOpDeleteProfileKey) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteProfileKey) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteProfileKeyInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/keys/delete")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteProfileKeyInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentDeleteProfileKeyInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteProfileKeyInput(v *DeleteProfileKeyInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentDeleteProfileKeyInput(v *DeleteProfileKeyInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.KeyName != nil {
ok := object.Key("KeyName")
ok.String(*v.KeyName)
}
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentRequestValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteProfileObject struct {
}
func (*awsRestjson1_serializeOpDeleteProfileObject) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteProfileObject) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteProfileObjectInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/objects/delete")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteProfileObjectInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentDeleteProfileObjectInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteProfileObjectInput(v *DeleteProfileObjectInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentDeleteProfileObjectInput(v *DeleteProfileObjectInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
if v.ProfileObjectUniqueKey != nil {
ok := object.Key("ProfileObjectUniqueKey")
ok.String(*v.ProfileObjectUniqueKey)
}
return nil
}
type awsRestjson1_serializeOpDeleteProfileObjectType struct {
}
func (*awsRestjson1_serializeOpDeleteProfileObjectType) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteProfileObjectType) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteProfileObjectTypeInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/object-types/{ObjectTypeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteProfileObjectTypeInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteProfileObjectTypeInput(v *DeleteProfileObjectTypeInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.ObjectTypeName == nil || len(*v.ObjectTypeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ObjectTypeName must not be empty")}
}
if v.ObjectTypeName != nil {
if err := encoder.SetURI("ObjectTypeName").String(*v.ObjectTypeName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteSegmentDefinition struct {
}
func (*awsRestjson1_serializeOpDeleteSegmentDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteSegmentDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteSegmentDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-definitions/{SegmentDefinitionName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteSegmentDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteSegmentDefinitionInput(v *DeleteSegmentDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDeleteWorkflow struct {
}
func (*awsRestjson1_serializeOpDeleteWorkflow) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDeleteWorkflow) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DeleteWorkflowInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/workflows/{WorkflowId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDeleteWorkflowInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDeleteWorkflowInput(v *DeleteWorkflowInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.WorkflowId == nil || len(*v.WorkflowId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member WorkflowId must not be empty")}
}
if v.WorkflowId != nil {
if err := encoder.SetURI("WorkflowId").String(*v.WorkflowId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpDetectProfileObjectType struct {
}
func (*awsRestjson1_serializeOpDetectProfileObjectType) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpDetectProfileObjectType) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*DetectProfileObjectTypeInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/detect/object-types")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsDetectProfileObjectTypeInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentDetectProfileObjectTypeInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsDetectProfileObjectTypeInput(v *DetectProfileObjectTypeInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentDetectProfileObjectTypeInput(v *DetectProfileObjectTypeInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Objects != nil {
ok := object.Key("Objects")
if err := awsRestjson1_serializeDocumentObjects(v.Objects, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetAutoMergingPreview struct {
}
func (*awsRestjson1_serializeOpGetAutoMergingPreview) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetAutoMergingPreview) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetAutoMergingPreviewInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/identity-resolution-jobs/auto-merging-preview")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetAutoMergingPreviewInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentGetAutoMergingPreviewInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetAutoMergingPreviewInput(v *GetAutoMergingPreviewInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentGetAutoMergingPreviewInput(v *GetAutoMergingPreviewInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConflictResolution != nil {
ok := object.Key("ConflictResolution")
if err := awsRestjson1_serializeDocumentConflictResolution(v.ConflictResolution, ok); err != nil {
return err
}
}
if v.Consolidation != nil {
ok := object.Key("Consolidation")
if err := awsRestjson1_serializeDocumentConsolidation(v.Consolidation, ok); err != nil {
return err
}
}
if v.MinAllowedConfidenceScoreForMerging != nil {
ok := object.Key("MinAllowedConfidenceScoreForMerging")
switch {
case math.IsNaN(*v.MinAllowedConfidenceScoreForMerging):
ok.String("NaN")
case math.IsInf(*v.MinAllowedConfidenceScoreForMerging, 1):
ok.String("Infinity")
case math.IsInf(*v.MinAllowedConfidenceScoreForMerging, -1):
ok.String("-Infinity")
default:
ok.Double(*v.MinAllowedConfidenceScoreForMerging)
}
}
return nil
}
type awsRestjson1_serializeOpGetCalculatedAttributeDefinition struct {
}
func (*awsRestjson1_serializeOpGetCalculatedAttributeDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetCalculatedAttributeDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetCalculatedAttributeDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes/{CalculatedAttributeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetCalculatedAttributeDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetCalculatedAttributeDefinitionInput(v *GetCalculatedAttributeDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetCalculatedAttributeForProfile struct {
}
func (*awsRestjson1_serializeOpGetCalculatedAttributeForProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetCalculatedAttributeForProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetCalculatedAttributeForProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profile/{ProfileId}/calculated-attributes/{CalculatedAttributeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetCalculatedAttributeForProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetCalculatedAttributeForProfileInput(v *GetCalculatedAttributeForProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.ProfileId == nil || len(*v.ProfileId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ProfileId must not be empty")}
}
if v.ProfileId != nil {
if err := encoder.SetURI("ProfileId").String(*v.ProfileId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetDomain struct {
}
func (*awsRestjson1_serializeOpGetDomain) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetDomain) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetDomainInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetDomainInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetDomainInput(v *GetDomainInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetEventStream struct {
}
func (*awsRestjson1_serializeOpGetEventStream) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetEventStream) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetEventStreamInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-streams/{EventStreamName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetEventStreamInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetEventStreamInput(v *GetEventStreamInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventStreamName == nil || len(*v.EventStreamName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventStreamName must not be empty")}
}
if v.EventStreamName != nil {
if err := encoder.SetURI("EventStreamName").String(*v.EventStreamName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetEventTrigger struct {
}
func (*awsRestjson1_serializeOpGetEventTrigger) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetEventTrigger) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetEventTriggerInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-triggers/{EventTriggerName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetEventTriggerInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetEventTriggerInput(v *GetEventTriggerInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventTriggerName == nil || len(*v.EventTriggerName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventTriggerName must not be empty")}
}
if v.EventTriggerName != nil {
if err := encoder.SetURI("EventTriggerName").String(*v.EventTriggerName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetIdentityResolutionJob struct {
}
func (*awsRestjson1_serializeOpGetIdentityResolutionJob) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetIdentityResolutionJob) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetIdentityResolutionJobInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/identity-resolution-jobs/{JobId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetIdentityResolutionJobInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetIdentityResolutionJobInput(v *GetIdentityResolutionJobInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.JobId == nil || len(*v.JobId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member JobId must not be empty")}
}
if v.JobId != nil {
if err := encoder.SetURI("JobId").String(*v.JobId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetIntegration struct {
}
func (*awsRestjson1_serializeOpGetIntegration) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetIntegration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetIntegrationInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/integrations")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetIntegrationInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentGetIntegrationInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetIntegrationInput(v *GetIntegrationInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentGetIntegrationInput(v *GetIntegrationInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Uri != nil {
ok := object.Key("Uri")
ok.String(*v.Uri)
}
return nil
}
type awsRestjson1_serializeOpGetMatches struct {
}
func (*awsRestjson1_serializeOpGetMatches) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetMatches) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetMatchesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/matches")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetMatchesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetMatchesInput(v *GetMatchesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpGetProfileObjectType struct {
}
func (*awsRestjson1_serializeOpGetProfileObjectType) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetProfileObjectType) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetProfileObjectTypeInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/object-types/{ObjectTypeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetProfileObjectTypeInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetProfileObjectTypeInput(v *GetProfileObjectTypeInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.ObjectTypeName == nil || len(*v.ObjectTypeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ObjectTypeName must not be empty")}
}
if v.ObjectTypeName != nil {
if err := encoder.SetURI("ObjectTypeName").String(*v.ObjectTypeName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetProfileObjectTypeTemplate struct {
}
func (*awsRestjson1_serializeOpGetProfileObjectTypeTemplate) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetProfileObjectTypeTemplate) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetProfileObjectTypeTemplateInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/templates/{TemplateId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetProfileObjectTypeTemplateInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetProfileObjectTypeTemplateInput(v *GetProfileObjectTypeTemplateInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.TemplateId == nil || len(*v.TemplateId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member TemplateId must not be empty")}
}
if v.TemplateId != nil {
if err := encoder.SetURI("TemplateId").String(*v.TemplateId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetSegmentDefinition struct {
}
func (*awsRestjson1_serializeOpGetSegmentDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetSegmentDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetSegmentDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-definitions/{SegmentDefinitionName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetSegmentDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetSegmentDefinitionInput(v *GetSegmentDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetSegmentEstimate struct {
}
func (*awsRestjson1_serializeOpGetSegmentEstimate) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetSegmentEstimate) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetSegmentEstimateInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-estimates/{EstimateId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetSegmentEstimateInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetSegmentEstimateInput(v *GetSegmentEstimateInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EstimateId == nil || len(*v.EstimateId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EstimateId must not be empty")}
}
if v.EstimateId != nil {
if err := encoder.SetURI("EstimateId").String(*v.EstimateId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetSegmentMembership struct {
}
func (*awsRestjson1_serializeOpGetSegmentMembership) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetSegmentMembership) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetSegmentMembershipInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segments/{SegmentDefinitionName}/membership")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetSegmentMembershipInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentGetSegmentMembershipInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetSegmentMembershipInput(v *GetSegmentMembershipInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentGetSegmentMembershipInput(v *GetSegmentMembershipInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ProfileIds != nil {
ok := object.Key("ProfileIds")
if err := awsRestjson1_serializeDocumentProfileIds(v.ProfileIds, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetSegmentSnapshot struct {
}
func (*awsRestjson1_serializeOpGetSegmentSnapshot) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetSegmentSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetSegmentSnapshotInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segments/{SegmentDefinitionName}/snapshots/{SnapshotId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetSegmentSnapshotInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetSegmentSnapshotInput(v *GetSegmentSnapshotInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.SegmentDefinitionName == nil || len(*v.SegmentDefinitionName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SegmentDefinitionName must not be empty")}
}
if v.SegmentDefinitionName != nil {
if err := encoder.SetURI("SegmentDefinitionName").String(*v.SegmentDefinitionName); err != nil {
return err
}
}
if v.SnapshotId == nil || len(*v.SnapshotId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member SnapshotId must not be empty")}
}
if v.SnapshotId != nil {
if err := encoder.SetURI("SnapshotId").String(*v.SnapshotId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetSimilarProfiles struct {
}
func (*awsRestjson1_serializeOpGetSimilarProfiles) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetSimilarProfiles) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetSimilarProfilesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/matches")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetSimilarProfilesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentGetSimilarProfilesInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetSimilarProfilesInput(v *GetSimilarProfilesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
func awsRestjson1_serializeOpDocumentGetSimilarProfilesInput(v *GetSimilarProfilesInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.MatchType) > 0 {
ok := object.Key("MatchType")
ok.String(string(v.MatchType))
}
if v.SearchKey != nil {
ok := object.Key("SearchKey")
ok.String(*v.SearchKey)
}
if v.SearchValue != nil {
ok := object.Key("SearchValue")
ok.String(*v.SearchValue)
}
return nil
}
type awsRestjson1_serializeOpGetWorkflow struct {
}
func (*awsRestjson1_serializeOpGetWorkflow) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetWorkflow) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetWorkflowInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/workflows/{WorkflowId}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetWorkflowInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetWorkflowInput(v *GetWorkflowInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.WorkflowId == nil || len(*v.WorkflowId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member WorkflowId must not be empty")}
}
if v.WorkflowId != nil {
if err := encoder.SetURI("WorkflowId").String(*v.WorkflowId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpGetWorkflowSteps struct {
}
func (*awsRestjson1_serializeOpGetWorkflowSteps) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpGetWorkflowSteps) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*GetWorkflowStepsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/workflows/{WorkflowId}/steps")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsGetWorkflowStepsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsGetWorkflowStepsInput(v *GetWorkflowStepsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
if v.WorkflowId == nil || len(*v.WorkflowId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member WorkflowId must not be empty")}
}
if v.WorkflowId != nil {
if err := encoder.SetURI("WorkflowId").String(*v.WorkflowId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpListAccountIntegrations struct {
}
func (*awsRestjson1_serializeOpListAccountIntegrations) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListAccountIntegrations) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListAccountIntegrationsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/integrations")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListAccountIntegrationsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentListAccountIntegrationsInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListAccountIntegrationsInput(v *ListAccountIntegrationsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.IncludeHidden != nil {
encoder.SetQuery("include-hidden").Boolean(*v.IncludeHidden)
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
func awsRestjson1_serializeOpDocumentListAccountIntegrationsInput(v *ListAccountIntegrationsInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Uri != nil {
ok := object.Key("Uri")
ok.String(*v.Uri)
}
return nil
}
type awsRestjson1_serializeOpListCalculatedAttributeDefinitions struct {
}
func (*awsRestjson1_serializeOpListCalculatedAttributeDefinitions) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListCalculatedAttributeDefinitions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListCalculatedAttributeDefinitionsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListCalculatedAttributeDefinitionsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListCalculatedAttributeDefinitionsInput(v *ListCalculatedAttributeDefinitionsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListCalculatedAttributesForProfile struct {
}
func (*awsRestjson1_serializeOpListCalculatedAttributesForProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListCalculatedAttributesForProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListCalculatedAttributesForProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profile/{ProfileId}/calculated-attributes")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListCalculatedAttributesForProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListCalculatedAttributesForProfileInput(v *ListCalculatedAttributesForProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
if v.ProfileId == nil || len(*v.ProfileId) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ProfileId must not be empty")}
}
if v.ProfileId != nil {
if err := encoder.SetURI("ProfileId").String(*v.ProfileId); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpListDomains struct {
}
func (*awsRestjson1_serializeOpListDomains) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListDomains) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListDomainsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListDomainsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListDomainsInput(v *ListDomainsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListEventStreams struct {
}
func (*awsRestjson1_serializeOpListEventStreams) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListEventStreams) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListEventStreamsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-streams")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListEventStreamsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListEventStreamsInput(v *ListEventStreamsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListEventTriggers struct {
}
func (*awsRestjson1_serializeOpListEventTriggers) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListEventTriggers) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListEventTriggersInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-triggers")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListEventTriggersInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListEventTriggersInput(v *ListEventTriggersInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListIdentityResolutionJobs struct {
}
func (*awsRestjson1_serializeOpListIdentityResolutionJobs) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListIdentityResolutionJobs) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListIdentityResolutionJobsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/identity-resolution-jobs")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListIdentityResolutionJobsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListIdentityResolutionJobsInput(v *ListIdentityResolutionJobsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListIntegrations struct {
}
func (*awsRestjson1_serializeOpListIntegrations) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListIntegrations) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListIntegrationsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/integrations")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListIntegrationsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListIntegrationsInput(v *ListIntegrationsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.IncludeHidden != nil {
encoder.SetQuery("include-hidden").Boolean(*v.IncludeHidden)
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListObjectTypeAttributes struct {
}
func (*awsRestjson1_serializeOpListObjectTypeAttributes) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListObjectTypeAttributes) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListObjectTypeAttributesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/object-types/{ObjectTypeName}/attributes")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListObjectTypeAttributesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListObjectTypeAttributesInput(v *ListObjectTypeAttributesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
if v.ObjectTypeName == nil || len(*v.ObjectTypeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ObjectTypeName must not be empty")}
}
if v.ObjectTypeName != nil {
if err := encoder.SetURI("ObjectTypeName").String(*v.ObjectTypeName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpListProfileAttributeValues struct {
}
func (*awsRestjson1_serializeOpListProfileAttributeValues) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListProfileAttributeValues) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListProfileAttributeValuesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profile-attributes/{AttributeName}/values")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListProfileAttributeValuesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListProfileAttributeValuesInput(v *ListProfileAttributeValuesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.AttributeName == nil || len(*v.AttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member AttributeName must not be empty")}
}
if v.AttributeName != nil {
if err := encoder.SetURI("AttributeName").String(*v.AttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpListProfileObjects struct {
}
func (*awsRestjson1_serializeOpListProfileObjects) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListProfileObjects) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListProfileObjectsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/objects")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListProfileObjectsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentListProfileObjectsInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListProfileObjectsInput(v *ListProfileObjectsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
func awsRestjson1_serializeOpDocumentListProfileObjectsInput(v *ListProfileObjectsInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ObjectFilter != nil {
ok := object.Key("ObjectFilter")
if err := awsRestjson1_serializeDocumentObjectFilter(v.ObjectFilter, ok); err != nil {
return err
}
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
return nil
}
type awsRestjson1_serializeOpListProfileObjectTypes struct {
}
func (*awsRestjson1_serializeOpListProfileObjectTypes) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListProfileObjectTypes) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListProfileObjectTypesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/object-types")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListProfileObjectTypesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListProfileObjectTypesInput(v *ListProfileObjectTypesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListProfileObjectTypeTemplates struct {
}
func (*awsRestjson1_serializeOpListProfileObjectTypeTemplates) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListProfileObjectTypeTemplates) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListProfileObjectTypeTemplatesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/templates")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListProfileObjectTypeTemplatesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListProfileObjectTypeTemplatesInput(v *ListProfileObjectTypeTemplatesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListRuleBasedMatches struct {
}
func (*awsRestjson1_serializeOpListRuleBasedMatches) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListRuleBasedMatches) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListRuleBasedMatchesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/ruleBasedMatches")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListRuleBasedMatchesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListRuleBasedMatchesInput(v *ListRuleBasedMatchesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListSegmentDefinitions struct {
}
func (*awsRestjson1_serializeOpListSegmentDefinitions) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListSegmentDefinitions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListSegmentDefinitionsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/segment-definitions")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListSegmentDefinitionsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListSegmentDefinitionsInput(v *ListSegmentDefinitionsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
type awsRestjson1_serializeOpListTagsForResource struct {
}
func (*awsRestjson1_serializeOpListTagsForResource) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListTagsForResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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)}
}
opPath, opQuery := httpbinding.SplitURI("/tags/{resourceArn}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "GET"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListTagsForResourceInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListTagsForResourceInput(v *ListTagsForResourceInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.ResourceArn == nil || len(*v.ResourceArn) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member resourceArn must not be empty")}
}
if v.ResourceArn != nil {
if err := encoder.SetURI("resourceArn").String(*v.ResourceArn); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpListWorkflows struct {
}
func (*awsRestjson1_serializeOpListWorkflows) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpListWorkflows) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*ListWorkflowsInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/workflows")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsListWorkflowsInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentListWorkflowsInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsListWorkflowsInput(v *ListWorkflowsInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
func awsRestjson1_serializeOpDocumentListWorkflowsInput(v *ListWorkflowsInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.QueryEndDate != nil {
ok := object.Key("QueryEndDate")
ok.Double(smithytime.FormatEpochSeconds(*v.QueryEndDate))
}
if v.QueryStartDate != nil {
ok := object.Key("QueryStartDate")
ok.Double(smithytime.FormatEpochSeconds(*v.QueryStartDate))
}
if len(v.Status) > 0 {
ok := object.Key("Status")
ok.String(string(v.Status))
}
if len(v.WorkflowType) > 0 {
ok := object.Key("WorkflowType")
ok.String(string(v.WorkflowType))
}
return nil
}
type awsRestjson1_serializeOpMergeProfiles struct {
}
func (*awsRestjson1_serializeOpMergeProfiles) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpMergeProfiles) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*MergeProfilesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/objects/merge")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsMergeProfilesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentMergeProfilesInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsMergeProfilesInput(v *MergeProfilesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentMergeProfilesInput(v *MergeProfilesInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.FieldSourceProfileIds != nil {
ok := object.Key("FieldSourceProfileIds")
if err := awsRestjson1_serializeDocumentFieldSourceProfileIds(v.FieldSourceProfileIds, ok); err != nil {
return err
}
}
if v.MainProfileId != nil {
ok := object.Key("MainProfileId")
ok.String(*v.MainProfileId)
}
if v.ProfileIdsToBeMerged != nil {
ok := object.Key("ProfileIdsToBeMerged")
if err := awsRestjson1_serializeDocumentProfileIdToBeMergedList(v.ProfileIdsToBeMerged, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpPutIntegration struct {
}
func (*awsRestjson1_serializeOpPutIntegration) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpPutIntegration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*PutIntegrationInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/integrations")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsPutIntegrationInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentPutIntegrationInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsPutIntegrationInput(v *PutIntegrationInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentPutIntegrationInput(v *PutIntegrationInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.EventTriggerNames != nil {
ok := object.Key("EventTriggerNames")
if err := awsRestjson1_serializeDocumentEventTriggerNames(v.EventTriggerNames, ok); err != nil {
return err
}
}
if v.FlowDefinition != nil {
ok := object.Key("FlowDefinition")
if err := awsRestjson1_serializeDocumentFlowDefinition(v.FlowDefinition, ok); err != nil {
return err
}
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.ObjectTypeNames != nil {
ok := object.Key("ObjectTypeNames")
if err := awsRestjson1_serializeDocumentObjectTypeNames(v.ObjectTypeNames, ok); err != nil {
return err
}
}
if v.RoleArn != nil {
ok := object.Key("RoleArn")
ok.String(*v.RoleArn)
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
if v.Uri != nil {
ok := object.Key("Uri")
ok.String(*v.Uri)
}
return nil
}
type awsRestjson1_serializeOpPutProfileObject struct {
}
func (*awsRestjson1_serializeOpPutProfileObject) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpPutProfileObject) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*PutProfileObjectInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/objects")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsPutProfileObjectInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentPutProfileObjectInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsPutProfileObjectInput(v *PutProfileObjectInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentPutProfileObjectInput(v *PutProfileObjectInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Object != nil {
ok := object.Key("Object")
ok.String(*v.Object)
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
return nil
}
type awsRestjson1_serializeOpPutProfileObjectType struct {
}
func (*awsRestjson1_serializeOpPutProfileObjectType) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpPutProfileObjectType) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*PutProfileObjectTypeInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/object-types/{ObjectTypeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsPutProfileObjectTypeInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentPutProfileObjectTypeInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsPutProfileObjectTypeInput(v *PutProfileObjectTypeInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.ObjectTypeName == nil || len(*v.ObjectTypeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member ObjectTypeName must not be empty")}
}
if v.ObjectTypeName != nil {
if err := encoder.SetURI("ObjectTypeName").String(*v.ObjectTypeName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentPutProfileObjectTypeInput(v *PutProfileObjectTypeInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AllowProfileCreation {
ok := object.Key("AllowProfileCreation")
ok.Boolean(v.AllowProfileCreation)
}
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.EncryptionKey != nil {
ok := object.Key("EncryptionKey")
ok.String(*v.EncryptionKey)
}
if v.ExpirationDays != nil {
ok := object.Key("ExpirationDays")
ok.Integer(*v.ExpirationDays)
}
if v.Fields != nil {
ok := object.Key("Fields")
if err := awsRestjson1_serializeDocumentFieldMap(v.Fields, ok); err != nil {
return err
}
}
if v.Keys != nil {
ok := object.Key("Keys")
if err := awsRestjson1_serializeDocumentKeyMap(v.Keys, ok); err != nil {
return err
}
}
if v.MaxProfileObjectCount != nil {
ok := object.Key("MaxProfileObjectCount")
ok.Integer(*v.MaxProfileObjectCount)
}
if v.SourceLastUpdatedTimestampFormat != nil {
ok := object.Key("SourceLastUpdatedTimestampFormat")
ok.String(*v.SourceLastUpdatedTimestampFormat)
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
if v.TemplateId != nil {
ok := object.Key("TemplateId")
ok.String(*v.TemplateId)
}
return nil
}
type awsRestjson1_serializeOpSearchProfiles struct {
}
func (*awsRestjson1_serializeOpSearchProfiles) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpSearchProfiles) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*SearchProfilesInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles/search")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsSearchProfilesInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentSearchProfilesInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsSearchProfilesInput(v *SearchProfilesInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.MaxResults != nil {
encoder.SetQuery("max-results").Integer(*v.MaxResults)
}
if v.NextToken != nil {
encoder.SetQuery("next-token").String(*v.NextToken)
}
return nil
}
func awsRestjson1_serializeOpDocumentSearchProfilesInput(v *SearchProfilesInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AdditionalSearchKeys != nil {
ok := object.Key("AdditionalSearchKeys")
if err := awsRestjson1_serializeDocumentAdditionalSearchKeysList(v.AdditionalSearchKeys, ok); err != nil {
return err
}
}
if v.KeyName != nil {
ok := object.Key("KeyName")
ok.String(*v.KeyName)
}
if len(v.LogicalOperator) > 0 {
ok := object.Key("LogicalOperator")
ok.String(string(v.LogicalOperator))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentRequestValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpTagResource struct {
}
func (*awsRestjson1_serializeOpTagResource) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpTagResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*TagResourceInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/tags/{resourceArn}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "POST"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsTagResourceInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentTagResourceInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsTagResourceInput(v *TagResourceInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.ResourceArn == nil || len(*v.ResourceArn) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member resourceArn must not be empty")}
}
if v.ResourceArn != nil {
if err := encoder.SetURI("resourceArn").String(*v.ResourceArn); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentTagResourceInput(v *TagResourceInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Tags != nil {
ok := object.Key("tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpUntagResource struct {
}
func (*awsRestjson1_serializeOpUntagResource) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpUntagResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*UntagResourceInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/tags/{resourceArn}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "DELETE"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsUntagResourceInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsUntagResourceInput(v *UntagResourceInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.ResourceArn == nil || len(*v.ResourceArn) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member resourceArn must not be empty")}
}
if v.ResourceArn != nil {
if err := encoder.SetURI("resourceArn").String(*v.ResourceArn); err != nil {
return err
}
}
if v.TagKeys != nil {
for i := range v.TagKeys {
encoder.AddQuery("tagKeys").String(v.TagKeys[i])
}
}
return nil
}
type awsRestjson1_serializeOpUpdateCalculatedAttributeDefinition struct {
}
func (*awsRestjson1_serializeOpUpdateCalculatedAttributeDefinition) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpUpdateCalculatedAttributeDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*UpdateCalculatedAttributeDefinitionInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/calculated-attributes/{CalculatedAttributeName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsUpdateCalculatedAttributeDefinitionInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentUpdateCalculatedAttributeDefinitionInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsUpdateCalculatedAttributeDefinitionInput(v *UpdateCalculatedAttributeDefinitionInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.CalculatedAttributeName == nil || len(*v.CalculatedAttributeName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member CalculatedAttributeName must not be empty")}
}
if v.CalculatedAttributeName != nil {
if err := encoder.SetURI("CalculatedAttributeName").String(*v.CalculatedAttributeName); err != nil {
return err
}
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentUpdateCalculatedAttributeDefinitionInput(v *UpdateCalculatedAttributeDefinitionInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Conditions != nil {
ok := object.Key("Conditions")
if err := awsRestjson1_serializeDocumentConditions(v.Conditions, ok); err != nil {
return err
}
}
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.DisplayName != nil {
ok := object.Key("DisplayName")
ok.String(*v.DisplayName)
}
return nil
}
type awsRestjson1_serializeOpUpdateDomain struct {
}
func (*awsRestjson1_serializeOpUpdateDomain) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpUpdateDomain) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*UpdateDomainInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsUpdateDomainInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentUpdateDomainInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsUpdateDomainInput(v *UpdateDomainInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentUpdateDomainInput(v *UpdateDomainInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.DeadLetterQueueUrl != nil {
ok := object.Key("DeadLetterQueueUrl")
ok.String(*v.DeadLetterQueueUrl)
}
if v.DefaultEncryptionKey != nil {
ok := object.Key("DefaultEncryptionKey")
ok.String(*v.DefaultEncryptionKey)
}
if v.DefaultExpirationDays != nil {
ok := object.Key("DefaultExpirationDays")
ok.Integer(*v.DefaultExpirationDays)
}
if v.Matching != nil {
ok := object.Key("Matching")
if err := awsRestjson1_serializeDocumentMatchingRequest(v.Matching, ok); err != nil {
return err
}
}
if v.RuleBasedMatching != nil {
ok := object.Key("RuleBasedMatching")
if err := awsRestjson1_serializeDocumentRuleBasedMatchingRequest(v.RuleBasedMatching, ok); err != nil {
return err
}
}
if v.Tags != nil {
ok := object.Key("Tags")
if err := awsRestjson1_serializeDocumentTagMap(v.Tags, ok); err != nil {
return err
}
}
return nil
}
type awsRestjson1_serializeOpUpdateEventTrigger struct {
}
func (*awsRestjson1_serializeOpUpdateEventTrigger) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpUpdateEventTrigger) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*UpdateEventTriggerInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/event-triggers/{EventTriggerName}")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsUpdateEventTriggerInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentUpdateEventTriggerInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsUpdateEventTriggerInput(v *UpdateEventTriggerInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
if v.EventTriggerName == nil || len(*v.EventTriggerName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member EventTriggerName must not be empty")}
}
if v.EventTriggerName != nil {
if err := encoder.SetURI("EventTriggerName").String(*v.EventTriggerName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentUpdateEventTriggerInput(v *UpdateEventTriggerInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.EventTriggerConditions != nil {
ok := object.Key("EventTriggerConditions")
if err := awsRestjson1_serializeDocumentEventTriggerConditions(v.EventTriggerConditions, ok); err != nil {
return err
}
}
if v.EventTriggerLimits != nil {
ok := object.Key("EventTriggerLimits")
if err := awsRestjson1_serializeDocumentEventTriggerLimits(v.EventTriggerLimits, ok); err != nil {
return err
}
}
if v.ObjectTypeName != nil {
ok := object.Key("ObjectTypeName")
ok.String(*v.ObjectTypeName)
}
if v.SegmentFilter != nil {
ok := object.Key("SegmentFilter")
ok.String(*v.SegmentFilter)
}
return nil
}
type awsRestjson1_serializeOpUpdateProfile struct {
}
func (*awsRestjson1_serializeOpUpdateProfile) ID() string {
return "OperationSerializer"
}
func (m *awsRestjson1_serializeOpUpdateProfile) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
out middleware.SerializeOutput, metadata middleware.Metadata, err error,
) {
_, span := tracing.StartSpan(ctx, "OperationSerializer")
endTimer := startMetricTimer(ctx, "client.call.serialization_duration")
defer endTimer()
defer span.End()
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.(*UpdateProfileInput)
_ = input
if !ok {
return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
}
opPath, opQuery := httpbinding.SplitURI("/domains/{DomainName}/profiles")
request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath)
request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery)
request.Method = "PUT"
var restEncoder *httpbinding.Encoder
if request.URL.RawPath == "" {
restEncoder, err = httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
} else {
request.URL.RawPath = smithyhttp.JoinPath(request.URL.RawPath, opPath)
restEncoder, err = httpbinding.NewEncoderWithRawPath(request.URL.Path, request.URL.RawPath, request.URL.RawQuery, request.Header)
}
if err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if err := awsRestjson1_serializeOpHttpBindingsUpdateProfileInput(input, restEncoder); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
restEncoder.SetHeader("Content-Type").String("application/json")
jsonEncoder := smithyjson.NewEncoder()
if err := awsRestjson1_serializeOpDocumentUpdateProfileInput(input, jsonEncoder.Value); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
if request.Request, err = restEncoder.Encode(request.Request); err != nil {
return out, metadata, &smithy.SerializationError{Err: err}
}
in.Request = request
endTimer()
span.End()
return next.HandleSerialize(ctx, in)
}
func awsRestjson1_serializeOpHttpBindingsUpdateProfileInput(v *UpdateProfileInput, encoder *httpbinding.Encoder) error {
if v == nil {
return fmt.Errorf("unsupported serialization of nil %T", v)
}
if v.DomainName == nil || len(*v.DomainName) == 0 {
return &smithy.SerializationError{Err: fmt.Errorf("input member DomainName must not be empty")}
}
if v.DomainName != nil {
if err := encoder.SetURI("DomainName").String(*v.DomainName); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeOpDocumentUpdateProfileInput(v *UpdateProfileInput, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AccountNumber != nil {
ok := object.Key("AccountNumber")
ok.String(*v.AccountNumber)
}
if v.AdditionalInformation != nil {
ok := object.Key("AdditionalInformation")
ok.String(*v.AdditionalInformation)
}
if v.Address != nil {
ok := object.Key("Address")
if err := awsRestjson1_serializeDocumentUpdateAddress(v.Address, ok); err != nil {
return err
}
}
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentUpdateAttributes(v.Attributes, ok); err != nil {
return err
}
}
if v.BillingAddress != nil {
ok := object.Key("BillingAddress")
if err := awsRestjson1_serializeDocumentUpdateAddress(v.BillingAddress, ok); err != nil {
return err
}
}
if v.BirthDate != nil {
ok := object.Key("BirthDate")
ok.String(*v.BirthDate)
}
if v.BusinessEmailAddress != nil {
ok := object.Key("BusinessEmailAddress")
ok.String(*v.BusinessEmailAddress)
}
if v.BusinessName != nil {
ok := object.Key("BusinessName")
ok.String(*v.BusinessName)
}
if v.BusinessPhoneNumber != nil {
ok := object.Key("BusinessPhoneNumber")
ok.String(*v.BusinessPhoneNumber)
}
if v.EmailAddress != nil {
ok := object.Key("EmailAddress")
ok.String(*v.EmailAddress)
}
if v.FirstName != nil {
ok := object.Key("FirstName")
ok.String(*v.FirstName)
}
if len(v.Gender) > 0 {
ok := object.Key("Gender")
ok.String(string(v.Gender))
}
if v.GenderString != nil {
ok := object.Key("GenderString")
ok.String(*v.GenderString)
}
if v.HomePhoneNumber != nil {
ok := object.Key("HomePhoneNumber")
ok.String(*v.HomePhoneNumber)
}
if v.LastName != nil {
ok := object.Key("LastName")
ok.String(*v.LastName)
}
if v.MailingAddress != nil {
ok := object.Key("MailingAddress")
if err := awsRestjson1_serializeDocumentUpdateAddress(v.MailingAddress, ok); err != nil {
return err
}
}
if v.MiddleName != nil {
ok := object.Key("MiddleName")
ok.String(*v.MiddleName)
}
if v.MobilePhoneNumber != nil {
ok := object.Key("MobilePhoneNumber")
ok.String(*v.MobilePhoneNumber)
}
if len(v.PartyType) > 0 {
ok := object.Key("PartyType")
ok.String(string(v.PartyType))
}
if v.PartyTypeString != nil {
ok := object.Key("PartyTypeString")
ok.String(*v.PartyTypeString)
}
if v.PersonalEmailAddress != nil {
ok := object.Key("PersonalEmailAddress")
ok.String(*v.PersonalEmailAddress)
}
if v.PhoneNumber != nil {
ok := object.Key("PhoneNumber")
ok.String(*v.PhoneNumber)
}
if v.ProfileId != nil {
ok := object.Key("ProfileId")
ok.String(*v.ProfileId)
}
if v.ShippingAddress != nil {
ok := object.Key("ShippingAddress")
if err := awsRestjson1_serializeDocumentUpdateAddress(v.ShippingAddress, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAdditionalSearchKey(v *types.AdditionalSearchKey, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.KeyName != nil {
ok := object.Key("KeyName")
ok.String(*v.KeyName)
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentRequestValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAdditionalSearchKeysList(v []types.AdditionalSearchKey, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentAdditionalSearchKey(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAddress(v *types.Address, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Address1 != nil {
ok := object.Key("Address1")
ok.String(*v.Address1)
}
if v.Address2 != nil {
ok := object.Key("Address2")
ok.String(*v.Address2)
}
if v.Address3 != nil {
ok := object.Key("Address3")
ok.String(*v.Address3)
}
if v.Address4 != nil {
ok := object.Key("Address4")
ok.String(*v.Address4)
}
if v.City != nil {
ok := object.Key("City")
ok.String(*v.City)
}
if v.Country != nil {
ok := object.Key("Country")
ok.String(*v.Country)
}
if v.County != nil {
ok := object.Key("County")
ok.String(*v.County)
}
if v.PostalCode != nil {
ok := object.Key("PostalCode")
ok.String(*v.PostalCode)
}
if v.Province != nil {
ok := object.Key("Province")
ok.String(*v.Province)
}
if v.State != nil {
ok := object.Key("State")
ok.String(*v.State)
}
return nil
}
func awsRestjson1_serializeDocumentAddressDimension(v *types.AddressDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.City != nil {
ok := object.Key("City")
if err := awsRestjson1_serializeDocumentProfileDimension(v.City, ok); err != nil {
return err
}
}
if v.Country != nil {
ok := object.Key("Country")
if err := awsRestjson1_serializeDocumentProfileDimension(v.Country, ok); err != nil {
return err
}
}
if v.County != nil {
ok := object.Key("County")
if err := awsRestjson1_serializeDocumentProfileDimension(v.County, ok); err != nil {
return err
}
}
if v.PostalCode != nil {
ok := object.Key("PostalCode")
if err := awsRestjson1_serializeDocumentProfileDimension(v.PostalCode, ok); err != nil {
return err
}
}
if v.Province != nil {
ok := object.Key("Province")
if err := awsRestjson1_serializeDocumentProfileDimension(v.Province, ok); err != nil {
return err
}
}
if v.State != nil {
ok := object.Key("State")
if err := awsRestjson1_serializeDocumentProfileDimension(v.State, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAddressList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentAppflowIntegration(v *types.AppflowIntegration, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Batches != nil {
ok := object.Key("Batches")
if err := awsRestjson1_serializeDocumentBatches(v.Batches, ok); err != nil {
return err
}
}
if v.FlowDefinition != nil {
ok := object.Key("FlowDefinition")
if err := awsRestjson1_serializeDocumentFlowDefinition(v.FlowDefinition, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAttributeDetails(v *types.AttributeDetails, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentAttributeList(v.Attributes, ok); err != nil {
return err
}
}
if v.Expression != nil {
ok := object.Key("Expression")
ok.String(*v.Expression)
}
return nil
}
func awsRestjson1_serializeDocumentAttributeDimension(v *types.AttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAttributeItem(v *types.AttributeItem, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Name != nil {
ok := object.Key("Name")
ok.String(*v.Name)
}
return nil
}
func awsRestjson1_serializeDocumentAttributeList(v []types.AttributeItem, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentAttributeItem(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAttributeMap(v map[string]types.FilterAttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
mapVar := v[key]
if err := awsRestjson1_serializeDocumentFilterAttributeDimension(&mapVar, om); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAttributes(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentAttributeSourceIdMap(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentAttributeTypesSelector(v *types.AttributeTypesSelector, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Address != nil {
ok := object.Key("Address")
if err := awsRestjson1_serializeDocumentAddressList(v.Address, ok); err != nil {
return err
}
}
if len(v.AttributeMatchingModel) > 0 {
ok := object.Key("AttributeMatchingModel")
ok.String(string(v.AttributeMatchingModel))
}
if v.EmailAddress != nil {
ok := object.Key("EmailAddress")
if err := awsRestjson1_serializeDocumentEmailList(v.EmailAddress, ok); err != nil {
return err
}
}
if v.PhoneNumber != nil {
ok := object.Key("PhoneNumber")
if err := awsRestjson1_serializeDocumentPhoneNumberList(v.PhoneNumber, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentAutoMerging(v *types.AutoMerging, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConflictResolution != nil {
ok := object.Key("ConflictResolution")
if err := awsRestjson1_serializeDocumentConflictResolution(v.ConflictResolution, ok); err != nil {
return err
}
}
if v.Consolidation != nil {
ok := object.Key("Consolidation")
if err := awsRestjson1_serializeDocumentConsolidation(v.Consolidation, ok); err != nil {
return err
}
}
if v.Enabled != nil {
ok := object.Key("Enabled")
ok.Boolean(*v.Enabled)
}
if v.MinAllowedConfidenceScoreForMerging != nil {
ok := object.Key("MinAllowedConfidenceScoreForMerging")
switch {
case math.IsNaN(*v.MinAllowedConfidenceScoreForMerging):
ok.String("NaN")
case math.IsInf(*v.MinAllowedConfidenceScoreForMerging, 1):
ok.String("Infinity")
case math.IsInf(*v.MinAllowedConfidenceScoreForMerging, -1):
ok.String("-Infinity")
default:
ok.Double(*v.MinAllowedConfidenceScoreForMerging)
}
}
return nil
}
func awsRestjson1_serializeDocumentBatch(v *types.Batch, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.EndTime != nil {
ok := object.Key("EndTime")
ok.Double(smithytime.FormatEpochSeconds(*v.EndTime))
}
if v.StartTime != nil {
ok := object.Key("StartTime")
ok.Double(smithytime.FormatEpochSeconds(*v.StartTime))
}
return nil
}
func awsRestjson1_serializeDocumentBatches(v []types.Batch, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentBatch(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentBatchGetCalculatedAttributeForProfileIdList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentBatchGetProfileIdList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentCalculatedAttributeDimension(v *types.CalculatedAttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConditionOverrides != nil {
ok := object.Key("ConditionOverrides")
if err := awsRestjson1_serializeDocumentConditionOverrides(v.ConditionOverrides, ok); err != nil {
return err
}
}
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentCalculatedCustomAttributes(v map[string]types.CalculatedAttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
mapVar := v[key]
if err := awsRestjson1_serializeDocumentCalculatedAttributeDimension(&mapVar, om); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentConditionOverrides(v *types.ConditionOverrides, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Range != nil {
ok := object.Key("Range")
if err := awsRestjson1_serializeDocumentRangeOverride(v.Range, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentConditions(v *types.Conditions, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ObjectCount != nil {
ok := object.Key("ObjectCount")
ok.Integer(*v.ObjectCount)
}
if v.Range != nil {
ok := object.Key("Range")
if err := awsRestjson1_serializeDocumentRange(v.Range, ok); err != nil {
return err
}
}
if v.Threshold != nil {
ok := object.Key("Threshold")
if err := awsRestjson1_serializeDocumentThreshold(v.Threshold, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentConflictResolution(v *types.ConflictResolution, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.ConflictResolvingModel) > 0 {
ok := object.Key("ConflictResolvingModel")
ok.String(string(v.ConflictResolvingModel))
}
if v.SourceName != nil {
ok := object.Key("SourceName")
ok.String(*v.SourceName)
}
return nil
}
func awsRestjson1_serializeDocumentConnectorOperator(v *types.ConnectorOperator, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.Marketo) > 0 {
ok := object.Key("Marketo")
ok.String(string(v.Marketo))
}
if len(v.S3) > 0 {
ok := object.Key("S3")
ok.String(string(v.S3))
}
if len(v.Salesforce) > 0 {
ok := object.Key("Salesforce")
ok.String(string(v.Salesforce))
}
if len(v.ServiceNow) > 0 {
ok := object.Key("ServiceNow")
ok.String(string(v.ServiceNow))
}
if len(v.Zendesk) > 0 {
ok := object.Key("Zendesk")
ok.String(string(v.Zendesk))
}
return nil
}
func awsRestjson1_serializeDocumentConsolidation(v *types.Consolidation, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.MatchingAttributesList != nil {
ok := object.Key("MatchingAttributesList")
if err := awsRestjson1_serializeDocumentMatchingAttributesList(v.MatchingAttributesList, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentCustomAttributes(v map[string]types.AttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
mapVar := v[key]
if err := awsRestjson1_serializeDocumentAttributeDimension(&mapVar, om); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentDateDimension(v *types.DateDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentDateValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentDateValues(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentDimension(v types.Dimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
switch uv := v.(type) {
case *types.DimensionMemberCalculatedAttributes:
av := object.Key("CalculatedAttributes")
if err := awsRestjson1_serializeDocumentCalculatedCustomAttributes(uv.Value, av); err != nil {
return err
}
case *types.DimensionMemberProfileAttributes:
av := object.Key("ProfileAttributes")
if err := awsRestjson1_serializeDocumentProfileAttributes(&uv.Value, av); err != nil {
return err
}
default:
return fmt.Errorf("attempted to serialize unknown member type %T for union %T", uv, v)
}
return nil
}
func awsRestjson1_serializeDocumentDimensionList(v []types.Dimension, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if vv := v[i]; vv == nil {
continue
}
if err := awsRestjson1_serializeDocumentDimension(v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentEmailList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerCondition(v *types.EventTriggerCondition, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.EventTriggerDimensions != nil {
ok := object.Key("EventTriggerDimensions")
if err := awsRestjson1_serializeDocumentEventTriggerDimensions(v.EventTriggerDimensions, ok); err != nil {
return err
}
}
if len(v.LogicalOperator) > 0 {
ok := object.Key("LogicalOperator")
ok.String(string(v.LogicalOperator))
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerConditions(v []types.EventTriggerCondition, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentEventTriggerCondition(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerDimension(v *types.EventTriggerDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ObjectAttributes != nil {
ok := object.Key("ObjectAttributes")
if err := awsRestjson1_serializeDocumentObjectAttributes(v.ObjectAttributes, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerDimensions(v []types.EventTriggerDimension, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentEventTriggerDimension(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerLimits(v *types.EventTriggerLimits, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.EventExpiration != nil {
ok := object.Key("EventExpiration")
ok.Long(*v.EventExpiration)
}
if v.Periods != nil {
ok := object.Key("Periods")
if err := awsRestjson1_serializeDocumentPeriods(v.Periods, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerNames(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentEventTriggerValues(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentExportingConfig(v *types.ExportingConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.S3Exporting != nil {
ok := object.Key("S3Exporting")
if err := awsRestjson1_serializeDocumentS3ExportingConfig(v.S3Exporting, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentExtraLengthValueProfileDimension(v *types.ExtraLengthValueProfileDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentExtraLengthValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentExtraLengthValues(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentFieldMap(v map[string]types.ObjectTypeField, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
mapVar := v[key]
if err := awsRestjson1_serializeDocumentObjectTypeField(&mapVar, om); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentFieldNameList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentFieldSourceProfileIds(v *types.FieldSourceProfileIds, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AccountNumber != nil {
ok := object.Key("AccountNumber")
ok.String(*v.AccountNumber)
}
if v.AdditionalInformation != nil {
ok := object.Key("AdditionalInformation")
ok.String(*v.AdditionalInformation)
}
if v.Address != nil {
ok := object.Key("Address")
ok.String(*v.Address)
}
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentAttributeSourceIdMap(v.Attributes, ok); err != nil {
return err
}
}
if v.BillingAddress != nil {
ok := object.Key("BillingAddress")
ok.String(*v.BillingAddress)
}
if v.BirthDate != nil {
ok := object.Key("BirthDate")
ok.String(*v.BirthDate)
}
if v.BusinessEmailAddress != nil {
ok := object.Key("BusinessEmailAddress")
ok.String(*v.BusinessEmailAddress)
}
if v.BusinessName != nil {
ok := object.Key("BusinessName")
ok.String(*v.BusinessName)
}
if v.BusinessPhoneNumber != nil {
ok := object.Key("BusinessPhoneNumber")
ok.String(*v.BusinessPhoneNumber)
}
if v.EmailAddress != nil {
ok := object.Key("EmailAddress")
ok.String(*v.EmailAddress)
}
if v.FirstName != nil {
ok := object.Key("FirstName")
ok.String(*v.FirstName)
}
if v.Gender != nil {
ok := object.Key("Gender")
ok.String(*v.Gender)
}
if v.HomePhoneNumber != nil {
ok := object.Key("HomePhoneNumber")
ok.String(*v.HomePhoneNumber)
}
if v.LastName != nil {
ok := object.Key("LastName")
ok.String(*v.LastName)
}
if v.MailingAddress != nil {
ok := object.Key("MailingAddress")
ok.String(*v.MailingAddress)
}
if v.MiddleName != nil {
ok := object.Key("MiddleName")
ok.String(*v.MiddleName)
}
if v.MobilePhoneNumber != nil {
ok := object.Key("MobilePhoneNumber")
ok.String(*v.MobilePhoneNumber)
}
if v.PartyType != nil {
ok := object.Key("PartyType")
ok.String(*v.PartyType)
}
if v.PersonalEmailAddress != nil {
ok := object.Key("PersonalEmailAddress")
ok.String(*v.PersonalEmailAddress)
}
if v.PhoneNumber != nil {
ok := object.Key("PhoneNumber")
ok.String(*v.PhoneNumber)
}
if v.ShippingAddress != nil {
ok := object.Key("ShippingAddress")
ok.String(*v.ShippingAddress)
}
return nil
}
func awsRestjson1_serializeDocumentFilter(v *types.Filter, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Groups != nil {
ok := object.Key("Groups")
if err := awsRestjson1_serializeDocumentGroupList(v.Groups, ok); err != nil {
return err
}
}
if len(v.Include) > 0 {
ok := object.Key("Include")
ok.String(string(v.Include))
}
return nil
}
func awsRestjson1_serializeDocumentFilterAttributeDimension(v *types.FilterAttributeDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentFilterDimension(v *types.FilterDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentAttributeMap(v.Attributes, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentFilterDimensionList(v []types.FilterDimension, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentFilterDimension(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentFilterGroup(v *types.FilterGroup, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Dimensions != nil {
ok := object.Key("Dimensions")
if err := awsRestjson1_serializeDocumentFilterDimensionList(v.Dimensions, ok); err != nil {
return err
}
}
if len(v.Type) > 0 {
ok := object.Key("Type")
ok.String(string(v.Type))
}
return nil
}
func awsRestjson1_serializeDocumentFlowDefinition(v *types.FlowDefinition, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Description != nil {
ok := object.Key("Description")
ok.String(*v.Description)
}
if v.FlowName != nil {
ok := object.Key("FlowName")
ok.String(*v.FlowName)
}
if v.KmsArn != nil {
ok := object.Key("KmsArn")
ok.String(*v.KmsArn)
}
if v.SourceFlowConfig != nil {
ok := object.Key("SourceFlowConfig")
if err := awsRestjson1_serializeDocumentSourceFlowConfig(v.SourceFlowConfig, ok); err != nil {
return err
}
}
if v.Tasks != nil {
ok := object.Key("Tasks")
if err := awsRestjson1_serializeDocumentTasks(v.Tasks, ok); err != nil {
return err
}
}
if v.TriggerConfig != nil {
ok := object.Key("TriggerConfig")
if err := awsRestjson1_serializeDocumentTriggerConfig(v.TriggerConfig, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentGroup(v *types.Group, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Dimensions != nil {
ok := object.Key("Dimensions")
if err := awsRestjson1_serializeDocumentDimensionList(v.Dimensions, ok); err != nil {
return err
}
}
if v.SourceSegments != nil {
ok := object.Key("SourceSegments")
if err := awsRestjson1_serializeDocumentSourceSegmentList(v.SourceSegments, ok); err != nil {
return err
}
}
if len(v.SourceType) > 0 {
ok := object.Key("SourceType")
ok.String(string(v.SourceType))
}
if len(v.Type) > 0 {
ok := object.Key("Type")
ok.String(string(v.Type))
}
return nil
}
func awsRestjson1_serializeDocumentGroupList(v []types.FilterGroup, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentFilterGroup(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentIncrementalPullConfig(v *types.IncrementalPullConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.DatetimeTypeFieldName != nil {
ok := object.Key("DatetimeTypeFieldName")
ok.String(*v.DatetimeTypeFieldName)
}
return nil
}
func awsRestjson1_serializeDocumentIntegrationConfig(v *types.IntegrationConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AppflowIntegration != nil {
ok := object.Key("AppflowIntegration")
if err := awsRestjson1_serializeDocumentAppflowIntegration(v.AppflowIntegration, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentJobSchedule(v *types.JobSchedule, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DayOfTheWeek) > 0 {
ok := object.Key("DayOfTheWeek")
ok.String(string(v.DayOfTheWeek))
}
if v.Time != nil {
ok := object.Key("Time")
ok.String(*v.Time)
}
return nil
}
func awsRestjson1_serializeDocumentKeyMap(v map[string][]types.ObjectTypeKey, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
if vv := v[key]; vv == nil {
continue
}
if err := awsRestjson1_serializeDocumentObjectTypeKeyList(v[key], om); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentMarketoSourceProperties(v *types.MarketoSourceProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Object != nil {
ok := object.Key("Object")
ok.String(*v.Object)
}
return nil
}
func awsRestjson1_serializeDocumentMatchingAttributes(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentMatchingAttributesList(v [][]string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if vv := v[i]; vv == nil {
continue
}
if err := awsRestjson1_serializeDocumentMatchingAttributes(v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentMatchingRequest(v *types.MatchingRequest, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AutoMerging != nil {
ok := object.Key("AutoMerging")
if err := awsRestjson1_serializeDocumentAutoMerging(v.AutoMerging, ok); err != nil {
return err
}
}
if v.Enabled != nil {
ok := object.Key("Enabled")
ok.Boolean(*v.Enabled)
}
if v.ExportingConfig != nil {
ok := object.Key("ExportingConfig")
if err := awsRestjson1_serializeDocumentExportingConfig(v.ExportingConfig, ok); err != nil {
return err
}
}
if v.JobSchedule != nil {
ok := object.Key("JobSchedule")
if err := awsRestjson1_serializeDocumentJobSchedule(v.JobSchedule, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentMatchingRule(v *types.MatchingRule, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Rule != nil {
ok := object.Key("Rule")
if err := awsRestjson1_serializeDocumentMatchingRuleAttributeList(v.Rule, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentMatchingRuleAttributeList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentMatchingRules(v []types.MatchingRule, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentMatchingRule(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjectAttribute(v *types.ObjectAttribute, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.ComparisonOperator) > 0 {
ok := object.Key("ComparisonOperator")
ok.String(string(v.ComparisonOperator))
}
if v.FieldName != nil {
ok := object.Key("FieldName")
ok.String(*v.FieldName)
}
if v.Source != nil {
ok := object.Key("Source")
ok.String(*v.Source)
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentEventTriggerValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjectAttributes(v []types.ObjectAttribute, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentObjectAttribute(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjectFilter(v *types.ObjectFilter, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.KeyName != nil {
ok := object.Key("KeyName")
ok.String(*v.KeyName)
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentRequestValueList(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjects(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentObjectTypeField(v *types.ObjectTypeField, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.ContentType) > 0 {
ok := object.Key("ContentType")
ok.String(string(v.ContentType))
}
if v.Source != nil {
ok := object.Key("Source")
ok.String(*v.Source)
}
if v.Target != nil {
ok := object.Key("Target")
ok.String(*v.Target)
}
return nil
}
func awsRestjson1_serializeDocumentObjectTypeKey(v *types.ObjectTypeKey, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.FieldNames != nil {
ok := object.Key("FieldNames")
if err := awsRestjson1_serializeDocumentFieldNameList(v.FieldNames, ok); err != nil {
return err
}
}
if v.StandardIdentifiers != nil {
ok := object.Key("StandardIdentifiers")
if err := awsRestjson1_serializeDocumentStandardIdentifierList(v.StandardIdentifiers, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjectTypeKeyList(v []types.ObjectTypeKey, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentObjectTypeKey(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentObjectTypeNames(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentPeriod(v *types.Period, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.MaxInvocationsPerProfile != nil {
ok := object.Key("MaxInvocationsPerProfile")
ok.Integer(*v.MaxInvocationsPerProfile)
}
if len(v.Unit) > 0 {
ok := object.Key("Unit")
ok.String(string(v.Unit))
}
if v.Unlimited {
ok := object.Key("Unlimited")
ok.Boolean(v.Unlimited)
}
if v.Value != nil {
ok := object.Key("Value")
ok.Integer(*v.Value)
}
return nil
}
func awsRestjson1_serializeDocumentPeriods(v []types.Period, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentPeriod(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentPhoneNumberList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentProfileAttributes(v *types.ProfileAttributes, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AccountNumber != nil {
ok := object.Key("AccountNumber")
if err := awsRestjson1_serializeDocumentProfileDimension(v.AccountNumber, ok); err != nil {
return err
}
}
if v.AdditionalInformation != nil {
ok := object.Key("AdditionalInformation")
if err := awsRestjson1_serializeDocumentExtraLengthValueProfileDimension(v.AdditionalInformation, ok); err != nil {
return err
}
}
if v.Address != nil {
ok := object.Key("Address")
if err := awsRestjson1_serializeDocumentAddressDimension(v.Address, ok); err != nil {
return err
}
}
if v.Attributes != nil {
ok := object.Key("Attributes")
if err := awsRestjson1_serializeDocumentCustomAttributes(v.Attributes, ok); err != nil {
return err
}
}
if v.BillingAddress != nil {
ok := object.Key("BillingAddress")
if err := awsRestjson1_serializeDocumentAddressDimension(v.BillingAddress, ok); err != nil {
return err
}
}
if v.BirthDate != nil {
ok := object.Key("BirthDate")
if err := awsRestjson1_serializeDocumentDateDimension(v.BirthDate, ok); err != nil {
return err
}
}
if v.BusinessEmailAddress != nil {
ok := object.Key("BusinessEmailAddress")
if err := awsRestjson1_serializeDocumentProfileDimension(v.BusinessEmailAddress, ok); err != nil {
return err
}
}
if v.BusinessName != nil {
ok := object.Key("BusinessName")
if err := awsRestjson1_serializeDocumentProfileDimension(v.BusinessName, ok); err != nil {
return err
}
}
if v.BusinessPhoneNumber != nil {
ok := object.Key("BusinessPhoneNumber")
if err := awsRestjson1_serializeDocumentProfileDimension(v.BusinessPhoneNumber, ok); err != nil {
return err
}
}
if v.EmailAddress != nil {
ok := object.Key("EmailAddress")
if err := awsRestjson1_serializeDocumentProfileDimension(v.EmailAddress, ok); err != nil {
return err
}
}
if v.FirstName != nil {
ok := object.Key("FirstName")
if err := awsRestjson1_serializeDocumentProfileDimension(v.FirstName, ok); err != nil {
return err
}
}
if v.GenderString != nil {
ok := object.Key("GenderString")
if err := awsRestjson1_serializeDocumentProfileDimension(v.GenderString, ok); err != nil {
return err
}
}
if v.HomePhoneNumber != nil {
ok := object.Key("HomePhoneNumber")
if err := awsRestjson1_serializeDocumentProfileDimension(v.HomePhoneNumber, ok); err != nil {
return err
}
}
if v.LastName != nil {
ok := object.Key("LastName")
if err := awsRestjson1_serializeDocumentProfileDimension(v.LastName, ok); err != nil {
return err
}
}
if v.MailingAddress != nil {
ok := object.Key("MailingAddress")
if err := awsRestjson1_serializeDocumentAddressDimension(v.MailingAddress, ok); err != nil {
return err
}
}
if v.MiddleName != nil {
ok := object.Key("MiddleName")
if err := awsRestjson1_serializeDocumentProfileDimension(v.MiddleName, ok); err != nil {
return err
}
}
if v.MobilePhoneNumber != nil {
ok := object.Key("MobilePhoneNumber")
if err := awsRestjson1_serializeDocumentProfileDimension(v.MobilePhoneNumber, ok); err != nil {
return err
}
}
if v.PartyTypeString != nil {
ok := object.Key("PartyTypeString")
if err := awsRestjson1_serializeDocumentProfileDimension(v.PartyTypeString, ok); err != nil {
return err
}
}
if v.PersonalEmailAddress != nil {
ok := object.Key("PersonalEmailAddress")
if err := awsRestjson1_serializeDocumentProfileDimension(v.PersonalEmailAddress, ok); err != nil {
return err
}
}
if v.PhoneNumber != nil {
ok := object.Key("PhoneNumber")
if err := awsRestjson1_serializeDocumentProfileDimension(v.PhoneNumber, ok); err != nil {
return err
}
}
if v.ShippingAddress != nil {
ok := object.Key("ShippingAddress")
if err := awsRestjson1_serializeDocumentAddressDimension(v.ShippingAddress, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentProfileDimension(v *types.ProfileDimension, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DimensionType) > 0 {
ok := object.Key("DimensionType")
ok.String(string(v.DimensionType))
}
if v.Values != nil {
ok := object.Key("Values")
if err := awsRestjson1_serializeDocumentValues(v.Values, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentProfileIds(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentProfileIdToBeMergedList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentRange(v *types.Range, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.Unit) > 0 {
ok := object.Key("Unit")
ok.String(string(v.Unit))
}
if v.Value != nil {
ok := object.Key("Value")
ok.Integer(*v.Value)
}
return nil
}
func awsRestjson1_serializeDocumentRangeOverride(v *types.RangeOverride, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.End != 0 {
ok := object.Key("End")
ok.Integer(v.End)
}
if v.Start != nil {
ok := object.Key("Start")
ok.Integer(*v.Start)
}
if len(v.Unit) > 0 {
ok := object.Key("Unit")
ok.String(string(v.Unit))
}
return nil
}
func awsRestjson1_serializeDocumentRequestValueList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentRuleBasedMatchingRequest(v *types.RuleBasedMatchingRequest, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.AttributeTypesSelector != nil {
ok := object.Key("AttributeTypesSelector")
if err := awsRestjson1_serializeDocumentAttributeTypesSelector(v.AttributeTypesSelector, ok); err != nil {
return err
}
}
if v.ConflictResolution != nil {
ok := object.Key("ConflictResolution")
if err := awsRestjson1_serializeDocumentConflictResolution(v.ConflictResolution, ok); err != nil {
return err
}
}
if v.Enabled != nil {
ok := object.Key("Enabled")
ok.Boolean(*v.Enabled)
}
if v.ExportingConfig != nil {
ok := object.Key("ExportingConfig")
if err := awsRestjson1_serializeDocumentExportingConfig(v.ExportingConfig, ok); err != nil {
return err
}
}
if v.MatchingRules != nil {
ok := object.Key("MatchingRules")
if err := awsRestjson1_serializeDocumentMatchingRules(v.MatchingRules, ok); err != nil {
return err
}
}
if v.MaxAllowedRuleLevelForMatching != nil {
ok := object.Key("MaxAllowedRuleLevelForMatching")
ok.Integer(*v.MaxAllowedRuleLevelForMatching)
}
if v.MaxAllowedRuleLevelForMerging != nil {
ok := object.Key("MaxAllowedRuleLevelForMerging")
ok.Integer(*v.MaxAllowedRuleLevelForMerging)
}
return nil
}
func awsRestjson1_serializeDocumentS3ExportingConfig(v *types.S3ExportingConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.S3BucketName != nil {
ok := object.Key("S3BucketName")
ok.String(*v.S3BucketName)
}
if v.S3KeyName != nil {
ok := object.Key("S3KeyName")
ok.String(*v.S3KeyName)
}
return nil
}
func awsRestjson1_serializeDocumentS3SourceProperties(v *types.S3SourceProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.BucketName != nil {
ok := object.Key("BucketName")
ok.String(*v.BucketName)
}
if v.BucketPrefix != nil {
ok := object.Key("BucketPrefix")
ok.String(*v.BucketPrefix)
}
return nil
}
func awsRestjson1_serializeDocumentSalesforceSourceProperties(v *types.SalesforceSourceProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.EnableDynamicFieldUpdate {
ok := object.Key("EnableDynamicFieldUpdate")
ok.Boolean(v.EnableDynamicFieldUpdate)
}
if v.IncludeDeletedRecords {
ok := object.Key("IncludeDeletedRecords")
ok.Boolean(v.IncludeDeletedRecords)
}
if v.Object != nil {
ok := object.Key("Object")
ok.String(*v.Object)
}
return nil
}
func awsRestjson1_serializeDocumentScheduledTriggerProperties(v *types.ScheduledTriggerProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.DataPullMode) > 0 {
ok := object.Key("DataPullMode")
ok.String(string(v.DataPullMode))
}
if v.FirstExecutionFrom != nil {
ok := object.Key("FirstExecutionFrom")
ok.Double(smithytime.FormatEpochSeconds(*v.FirstExecutionFrom))
}
if v.ScheduleEndTime != nil {
ok := object.Key("ScheduleEndTime")
ok.Double(smithytime.FormatEpochSeconds(*v.ScheduleEndTime))
}
if v.ScheduleExpression != nil {
ok := object.Key("ScheduleExpression")
ok.String(*v.ScheduleExpression)
}
if v.ScheduleOffset != nil {
ok := object.Key("ScheduleOffset")
ok.Long(*v.ScheduleOffset)
}
if v.ScheduleStartTime != nil {
ok := object.Key("ScheduleStartTime")
ok.Double(smithytime.FormatEpochSeconds(*v.ScheduleStartTime))
}
if v.Timezone != nil {
ok := object.Key("Timezone")
ok.String(*v.Timezone)
}
return nil
}
func awsRestjson1_serializeDocumentSegmentGroup(v *types.SegmentGroup, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Groups != nil {
ok := object.Key("Groups")
if err := awsRestjson1_serializeDocumentSegmentGroupList(v.Groups, ok); err != nil {
return err
}
}
if len(v.Include) > 0 {
ok := object.Key("Include")
ok.String(string(v.Include))
}
return nil
}
func awsRestjson1_serializeDocumentSegmentGroupList(v []types.Group, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentGroup(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentSegmentGroupStructure(v *types.SegmentGroupStructure, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Groups != nil {
ok := object.Key("Groups")
if err := awsRestjson1_serializeDocumentSegmentGroupList(v.Groups, ok); err != nil {
return err
}
}
if len(v.Include) > 0 {
ok := object.Key("Include")
ok.String(string(v.Include))
}
return nil
}
func awsRestjson1_serializeDocumentServiceNowSourceProperties(v *types.ServiceNowSourceProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Object != nil {
ok := object.Key("Object")
ok.String(*v.Object)
}
return nil
}
func awsRestjson1_serializeDocumentSourceConnectorProperties(v *types.SourceConnectorProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Marketo != nil {
ok := object.Key("Marketo")
if err := awsRestjson1_serializeDocumentMarketoSourceProperties(v.Marketo, ok); err != nil {
return err
}
}
if v.S3 != nil {
ok := object.Key("S3")
if err := awsRestjson1_serializeDocumentS3SourceProperties(v.S3, ok); err != nil {
return err
}
}
if v.Salesforce != nil {
ok := object.Key("Salesforce")
if err := awsRestjson1_serializeDocumentSalesforceSourceProperties(v.Salesforce, ok); err != nil {
return err
}
}
if v.ServiceNow != nil {
ok := object.Key("ServiceNow")
if err := awsRestjson1_serializeDocumentServiceNowSourceProperties(v.ServiceNow, ok); err != nil {
return err
}
}
if v.Zendesk != nil {
ok := object.Key("Zendesk")
if err := awsRestjson1_serializeDocumentZendeskSourceProperties(v.Zendesk, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentSourceFields(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentSourceFlowConfig(v *types.SourceFlowConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConnectorProfileName != nil {
ok := object.Key("ConnectorProfileName")
ok.String(*v.ConnectorProfileName)
}
if len(v.ConnectorType) > 0 {
ok := object.Key("ConnectorType")
ok.String(string(v.ConnectorType))
}
if v.IncrementalPullConfig != nil {
ok := object.Key("IncrementalPullConfig")
if err := awsRestjson1_serializeDocumentIncrementalPullConfig(v.IncrementalPullConfig, ok); err != nil {
return err
}
}
if v.SourceConnectorProperties != nil {
ok := object.Key("SourceConnectorProperties")
if err := awsRestjson1_serializeDocumentSourceConnectorProperties(v.SourceConnectorProperties, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentSourceSegment(v *types.SourceSegment, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.SegmentDefinitionName != nil {
ok := object.Key("SegmentDefinitionName")
ok.String(*v.SegmentDefinitionName)
}
return nil
}
func awsRestjson1_serializeDocumentSourceSegmentList(v []types.SourceSegment, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentSourceSegment(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentStandardIdentifierList(v []types.StandardIdentifier, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(string(v[i]))
}
return nil
}
func awsRestjson1_serializeDocumentTagMap(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentTask(v *types.Task, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.ConnectorOperator != nil {
ok := object.Key("ConnectorOperator")
if err := awsRestjson1_serializeDocumentConnectorOperator(v.ConnectorOperator, ok); err != nil {
return err
}
}
if v.DestinationField != nil {
ok := object.Key("DestinationField")
ok.String(*v.DestinationField)
}
if v.SourceFields != nil {
ok := object.Key("SourceFields")
if err := awsRestjson1_serializeDocumentSourceFields(v.SourceFields, ok); err != nil {
return err
}
}
if v.TaskProperties != nil {
ok := object.Key("TaskProperties")
if err := awsRestjson1_serializeDocumentTaskPropertiesMap(v.TaskProperties, ok); err != nil {
return err
}
}
if len(v.TaskType) > 0 {
ok := object.Key("TaskType")
ok.String(string(v.TaskType))
}
return nil
}
func awsRestjson1_serializeDocumentTaskPropertiesMap(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentTasks(v []types.Task, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
if err := awsRestjson1_serializeDocumentTask(&v[i], av); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentThreshold(v *types.Threshold, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if len(v.Operator) > 0 {
ok := object.Key("Operator")
ok.String(string(v.Operator))
}
if v.Value != nil {
ok := object.Key("Value")
ok.String(*v.Value)
}
return nil
}
func awsRestjson1_serializeDocumentTriggerConfig(v *types.TriggerConfig, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.TriggerProperties != nil {
ok := object.Key("TriggerProperties")
if err := awsRestjson1_serializeDocumentTriggerProperties(v.TriggerProperties, ok); err != nil {
return err
}
}
if len(v.TriggerType) > 0 {
ok := object.Key("TriggerType")
ok.String(string(v.TriggerType))
}
return nil
}
func awsRestjson1_serializeDocumentTriggerProperties(v *types.TriggerProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Scheduled != nil {
ok := object.Key("Scheduled")
if err := awsRestjson1_serializeDocumentScheduledTriggerProperties(v.Scheduled, ok); err != nil {
return err
}
}
return nil
}
func awsRestjson1_serializeDocumentUpdateAddress(v *types.UpdateAddress, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Address1 != nil {
ok := object.Key("Address1")
ok.String(*v.Address1)
}
if v.Address2 != nil {
ok := object.Key("Address2")
ok.String(*v.Address2)
}
if v.Address3 != nil {
ok := object.Key("Address3")
ok.String(*v.Address3)
}
if v.Address4 != nil {
ok := object.Key("Address4")
ok.String(*v.Address4)
}
if v.City != nil {
ok := object.Key("City")
ok.String(*v.City)
}
if v.Country != nil {
ok := object.Key("Country")
ok.String(*v.Country)
}
if v.County != nil {
ok := object.Key("County")
ok.String(*v.County)
}
if v.PostalCode != nil {
ok := object.Key("PostalCode")
ok.String(*v.PostalCode)
}
if v.Province != nil {
ok := object.Key("Province")
ok.String(*v.Province)
}
if v.State != nil {
ok := object.Key("State")
ok.String(*v.State)
}
return nil
}
func awsRestjson1_serializeDocumentUpdateAttributes(v map[string]string, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
for key := range v {
om := object.Key(key)
om.String(v[key])
}
return nil
}
func awsRestjson1_serializeDocumentValueList(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentValues(v []string, value smithyjson.Value) error {
array := value.Array()
defer array.Close()
for i := range v {
av := array.Value()
av.String(v[i])
}
return nil
}
func awsRestjson1_serializeDocumentZendeskSourceProperties(v *types.ZendeskSourceProperties, value smithyjson.Value) error {
object := value.Object()
defer object.Close()
if v.Object != nil {
ok := object.Key("Object")
ok.String(*v.Object)
}
return nil
}