// Code generated by smithy-go-codegen DO NOT EDIT. package chimesdkmediapipelines import ( "bytes" "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/chimesdkmediapipelines/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" smithyhttp "github.com/aws/smithy-go/transport/http" ) type awsRestjson1_serializeOpCreateMediaCapturePipeline struct { } func (*awsRestjson1_serializeOpCreateMediaCapturePipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateMediaCapturePipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateMediaCapturePipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-capture-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateMediaCapturePipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateMediaCapturePipelineInput(v *CreateMediaCapturePipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } return nil } func awsRestjson1_serializeOpDocumentCreateMediaCapturePipelineInput(v *CreateMediaCapturePipelineInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ChimeSdkMeetingConfiguration != nil { ok := object.Key("ChimeSdkMeetingConfiguration") if err := awsRestjson1_serializeDocumentChimeSdkMeetingConfiguration(v.ChimeSdkMeetingConfiguration, ok); err != nil { return err } } if v.ClientRequestToken != nil { ok := object.Key("ClientRequestToken") ok.String(*v.ClientRequestToken) } if v.SinkArn != nil { ok := object.Key("SinkArn") ok.String(*v.SinkArn) } if len(v.SinkType) > 0 { ok := object.Key("SinkType") ok.String(string(v.SinkType)) } if v.SourceArn != nil { ok := object.Key("SourceArn") ok.String(*v.SourceArn) } if len(v.SourceType) > 0 { ok := object.Key("SourceType") ok.String(string(v.SourceType)) } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(v.Tags, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateMediaConcatenationPipeline struct { } func (*awsRestjson1_serializeOpCreateMediaConcatenationPipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateMediaConcatenationPipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateMediaConcatenationPipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-concatenation-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateMediaConcatenationPipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateMediaConcatenationPipelineInput(v *CreateMediaConcatenationPipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } return nil } func awsRestjson1_serializeOpDocumentCreateMediaConcatenationPipelineInput(v *CreateMediaConcatenationPipelineInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ClientRequestToken != nil { ok := object.Key("ClientRequestToken") ok.String(*v.ClientRequestToken) } if v.Sinks != nil { ok := object.Key("Sinks") if err := awsRestjson1_serializeDocumentConcatenationSinkList(v.Sinks, ok); err != nil { return err } } if v.Sources != nil { ok := object.Key("Sources") if err := awsRestjson1_serializeDocumentConcatenationSourceList(v.Sources, ok); err != nil { return err } } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(v.Tags, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateMediaInsightsPipeline struct { } func (*awsRestjson1_serializeOpCreateMediaInsightsPipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateMediaInsightsPipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateMediaInsightsPipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateMediaInsightsPipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateMediaInsightsPipelineInput(v *CreateMediaInsightsPipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } return nil } func awsRestjson1_serializeOpDocumentCreateMediaInsightsPipelineInput(v *CreateMediaInsightsPipelineInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ClientRequestToken != nil { ok := object.Key("ClientRequestToken") ok.String(*v.ClientRequestToken) } if v.KinesisVideoStreamRecordingSourceRuntimeConfiguration != nil { ok := object.Key("KinesisVideoStreamRecordingSourceRuntimeConfiguration") if err := awsRestjson1_serializeDocumentKinesisVideoStreamRecordingSourceRuntimeConfiguration(v.KinesisVideoStreamRecordingSourceRuntimeConfiguration, ok); err != nil { return err } } if v.KinesisVideoStreamSourceRuntimeConfiguration != nil { ok := object.Key("KinesisVideoStreamSourceRuntimeConfiguration") if err := awsRestjson1_serializeDocumentKinesisVideoStreamSourceRuntimeConfiguration(v.KinesisVideoStreamSourceRuntimeConfiguration, ok); err != nil { return err } } if v.MediaInsightsPipelineConfigurationArn != nil { ok := object.Key("MediaInsightsPipelineConfigurationArn") ok.String(*v.MediaInsightsPipelineConfigurationArn) } if v.MediaInsightsRuntimeMetadata != nil { ok := object.Key("MediaInsightsRuntimeMetadata") if err := awsRestjson1_serializeDocumentMediaInsightsRuntimeMetadata(v.MediaInsightsRuntimeMetadata, ok); err != nil { return err } } if v.S3RecordingSinkRuntimeConfiguration != nil { ok := object.Key("S3RecordingSinkRuntimeConfiguration") if err := awsRestjson1_serializeDocumentS3RecordingSinkRuntimeConfiguration(v.S3RecordingSinkRuntimeConfiguration, ok); err != nil { return err } } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(v.Tags, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateMediaInsightsPipelineConfiguration struct { } func (*awsRestjson1_serializeOpCreateMediaInsightsPipelineConfiguration) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateMediaInsightsPipelineConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateMediaInsightsPipelineConfigurationInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-configurations") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateMediaInsightsPipelineConfigurationInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateMediaInsightsPipelineConfigurationInput(v *CreateMediaInsightsPipelineConfigurationInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } return nil } func awsRestjson1_serializeOpDocumentCreateMediaInsightsPipelineConfigurationInput(v *CreateMediaInsightsPipelineConfigurationInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ClientRequestToken != nil { ok := object.Key("ClientRequestToken") ok.String(*v.ClientRequestToken) } if v.Elements != nil { ok := object.Key("Elements") if err := awsRestjson1_serializeDocumentMediaInsightsPipelineConfigurationElements(v.Elements, ok); err != nil { return err } } if v.MediaInsightsPipelineConfigurationName != nil { ok := object.Key("MediaInsightsPipelineConfigurationName") ok.String(*v.MediaInsightsPipelineConfigurationName) } if v.RealTimeAlertConfiguration != nil { ok := object.Key("RealTimeAlertConfiguration") if err := awsRestjson1_serializeDocumentRealTimeAlertConfiguration(v.RealTimeAlertConfiguration, ok); err != nil { return err } } if v.ResourceAccessRoleArn != nil { ok := object.Key("ResourceAccessRoleArn") ok.String(*v.ResourceAccessRoleArn) } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(v.Tags, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateMediaLiveConnectorPipeline struct { } func (*awsRestjson1_serializeOpCreateMediaLiveConnectorPipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateMediaLiveConnectorPipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateMediaLiveConnectorPipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-live-connector-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateMediaLiveConnectorPipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateMediaLiveConnectorPipelineInput(v *CreateMediaLiveConnectorPipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } return nil } func awsRestjson1_serializeOpDocumentCreateMediaLiveConnectorPipelineInput(v *CreateMediaLiveConnectorPipelineInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ClientRequestToken != nil { ok := object.Key("ClientRequestToken") ok.String(*v.ClientRequestToken) } if v.Sinks != nil { ok := object.Key("Sinks") if err := awsRestjson1_serializeDocumentLiveConnectorSinkList(v.Sinks, ok); err != nil { return err } } if v.Sources != nil { ok := object.Key("Sources") if err := awsRestjson1_serializeDocumentLiveConnectorSourceList(v.Sources, ok); err != nil { return err } } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(v.Tags, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteMediaCapturePipeline struct { } func (*awsRestjson1_serializeOpDeleteMediaCapturePipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteMediaCapturePipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteMediaCapturePipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-capture-pipelines/{MediaPipelineId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteMediaCapturePipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteMediaCapturePipelineInput(v *DeleteMediaCapturePipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.MediaPipelineId == nil || len(*v.MediaPipelineId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member MediaPipelineId must not be empty")} } if v.MediaPipelineId != nil { if err := encoder.SetURI("MediaPipelineId").String(*v.MediaPipelineId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteMediaInsightsPipelineConfiguration struct { } func (*awsRestjson1_serializeOpDeleteMediaInsightsPipelineConfiguration) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteMediaInsightsPipelineConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteMediaInsightsPipelineConfigurationInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-configurations/{Identifier}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteMediaInsightsPipelineConfigurationInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteMediaInsightsPipelineConfigurationInput(v *DeleteMediaInsightsPipelineConfigurationInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.Identifier == nil || len(*v.Identifier) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member Identifier must not be empty")} } if v.Identifier != nil { if err := encoder.SetURI("Identifier").String(*v.Identifier); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteMediaPipeline struct { } func (*awsRestjson1_serializeOpDeleteMediaPipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteMediaPipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteMediaPipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-pipelines/{MediaPipelineId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteMediaPipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteMediaPipelineInput(v *DeleteMediaPipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.MediaPipelineId == nil || len(*v.MediaPipelineId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member MediaPipelineId must not be empty")} } if v.MediaPipelineId != nil { if err := encoder.SetURI("MediaPipelineId").String(*v.MediaPipelineId); err != nil { return err } } return nil } type awsRestjson1_serializeOpGetMediaCapturePipeline struct { } func (*awsRestjson1_serializeOpGetMediaCapturePipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetMediaCapturePipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetMediaCapturePipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-capture-pipelines/{MediaPipelineId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetMediaCapturePipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetMediaCapturePipelineInput(v *GetMediaCapturePipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.MediaPipelineId == nil || len(*v.MediaPipelineId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member MediaPipelineId must not be empty")} } if v.MediaPipelineId != nil { if err := encoder.SetURI("MediaPipelineId").String(*v.MediaPipelineId); err != nil { return err } } return nil } type awsRestjson1_serializeOpGetMediaInsightsPipelineConfiguration struct { } func (*awsRestjson1_serializeOpGetMediaInsightsPipelineConfiguration) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetMediaInsightsPipelineConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetMediaInsightsPipelineConfigurationInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-configurations/{Identifier}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetMediaInsightsPipelineConfigurationInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetMediaInsightsPipelineConfigurationInput(v *GetMediaInsightsPipelineConfigurationInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.Identifier == nil || len(*v.Identifier) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member Identifier must not be empty")} } if v.Identifier != nil { if err := encoder.SetURI("Identifier").String(*v.Identifier); err != nil { return err } } return nil } type awsRestjson1_serializeOpGetMediaPipeline struct { } func (*awsRestjson1_serializeOpGetMediaPipeline) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetMediaPipeline) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetMediaPipelineInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-pipelines/{MediaPipelineId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetMediaPipelineInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetMediaPipelineInput(v *GetMediaPipelineInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.MediaPipelineId == nil || len(*v.MediaPipelineId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member MediaPipelineId must not be empty")} } if v.MediaPipelineId != nil { if err := encoder.SetURI("MediaPipelineId").String(*v.MediaPipelineId); err != nil { return err } } return nil } type awsRestjson1_serializeOpListMediaCapturePipelines struct { } func (*awsRestjson1_serializeOpListMediaCapturePipelines) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpListMediaCapturePipelines) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ListMediaCapturePipelinesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-capture-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsListMediaCapturePipelinesInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsListMediaCapturePipelinesInput(v *ListMediaCapturePipelinesInput, 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_serializeOpListMediaInsightsPipelineConfigurations struct { } func (*awsRestjson1_serializeOpListMediaInsightsPipelineConfigurations) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpListMediaInsightsPipelineConfigurations) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ListMediaInsightsPipelineConfigurationsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-configurations") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsListMediaInsightsPipelineConfigurationsInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsListMediaInsightsPipelineConfigurationsInput(v *ListMediaInsightsPipelineConfigurationsInput, 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_serializeOpListMediaPipelines struct { } func (*awsRestjson1_serializeOpListMediaPipelines) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpListMediaPipelines) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ListMediaPipelinesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/sdk-media-pipelines") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsListMediaPipelinesInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsListMediaPipelinesInput(v *ListMediaPipelinesInput, 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_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, ) { 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") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, 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 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 { encoder.SetQuery("arn").String(*v.ResourceARN) } 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, ) { 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?operation=tag-resource") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if 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 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) } return nil } func awsRestjson1_serializeOpDocumentTagResourceInput(v *TagResourceInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ResourceARN != nil { ok := object.Key("ResourceARN") ok.String(*v.ResourceARN) } if v.Tags != nil { ok := object.Key("Tags") if err := awsRestjson1_serializeDocumentTagList(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, ) { 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?operation=untag-resource") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUntagResourceInput(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 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) } return nil } func awsRestjson1_serializeOpDocumentUntagResourceInput(v *UntagResourceInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ResourceARN != nil { ok := object.Key("ResourceARN") ok.String(*v.ResourceARN) } if v.TagKeys != nil { ok := object.Key("TagKeys") if err := awsRestjson1_serializeDocumentTagKeyList(v.TagKeys, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpUpdateMediaInsightsPipelineConfiguration struct { } func (*awsRestjson1_serializeOpUpdateMediaInsightsPipelineConfiguration) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateMediaInsightsPipelineConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateMediaInsightsPipelineConfigurationInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-configurations/{Identifier}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PUT" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateMediaInsightsPipelineConfigurationInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateMediaInsightsPipelineConfigurationInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateMediaInsightsPipelineConfigurationInput(v *UpdateMediaInsightsPipelineConfigurationInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.Identifier == nil || len(*v.Identifier) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member Identifier must not be empty")} } if v.Identifier != nil { if err := encoder.SetURI("Identifier").String(*v.Identifier); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateMediaInsightsPipelineConfigurationInput(v *UpdateMediaInsightsPipelineConfigurationInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Elements != nil { ok := object.Key("Elements") if err := awsRestjson1_serializeDocumentMediaInsightsPipelineConfigurationElements(v.Elements, ok); err != nil { return err } } if v.RealTimeAlertConfiguration != nil { ok := object.Key("RealTimeAlertConfiguration") if err := awsRestjson1_serializeDocumentRealTimeAlertConfiguration(v.RealTimeAlertConfiguration, ok); err != nil { return err } } if v.ResourceAccessRoleArn != nil { ok := object.Key("ResourceAccessRoleArn") ok.String(*v.ResourceAccessRoleArn) } return nil } type awsRestjson1_serializeOpUpdateMediaInsightsPipelineStatus struct { } func (*awsRestjson1_serializeOpUpdateMediaInsightsPipelineStatus) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateMediaInsightsPipelineStatus) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateMediaInsightsPipelineStatusInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/media-insights-pipeline-status/{Identifier}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PUT" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateMediaInsightsPipelineStatusInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateMediaInsightsPipelineStatusInput(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 return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateMediaInsightsPipelineStatusInput(v *UpdateMediaInsightsPipelineStatusInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.Identifier == nil || len(*v.Identifier) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member Identifier must not be empty")} } if v.Identifier != nil { if err := encoder.SetURI("Identifier").String(*v.Identifier); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateMediaInsightsPipelineStatusInput(v *UpdateMediaInsightsPipelineStatusInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.UpdateStatus) > 0 { ok := object.Key("UpdateStatus") ok.String(string(v.UpdateStatus)) } return nil } func awsRestjson1_serializeDocumentActiveSpeakerOnlyConfiguration(v *types.ActiveSpeakerOnlyConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.ActiveSpeakerPosition) > 0 { ok := object.Key("ActiveSpeakerPosition") ok.String(string(v.ActiveSpeakerPosition)) } return nil } func awsRestjson1_serializeDocumentAmazonTranscribeCallAnalyticsProcessorConfiguration(v *types.AmazonTranscribeCallAnalyticsProcessorConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.CallAnalyticsStreamCategories != nil { ok := object.Key("CallAnalyticsStreamCategories") if err := awsRestjson1_serializeDocumentCategoryNameList(v.CallAnalyticsStreamCategories, ok); err != nil { return err } } if len(v.ContentIdentificationType) > 0 { ok := object.Key("ContentIdentificationType") ok.String(string(v.ContentIdentificationType)) } if len(v.ContentRedactionType) > 0 { ok := object.Key("ContentRedactionType") ok.String(string(v.ContentRedactionType)) } if v.EnablePartialResultsStabilization { ok := object.Key("EnablePartialResultsStabilization") ok.Boolean(v.EnablePartialResultsStabilization) } if v.FilterPartialResults { ok := object.Key("FilterPartialResults") ok.Boolean(v.FilterPartialResults) } if len(v.LanguageCode) > 0 { ok := object.Key("LanguageCode") ok.String(string(v.LanguageCode)) } if v.LanguageModelName != nil { ok := object.Key("LanguageModelName") ok.String(*v.LanguageModelName) } if len(v.PartialResultsStability) > 0 { ok := object.Key("PartialResultsStability") ok.String(string(v.PartialResultsStability)) } if v.PiiEntityTypes != nil { ok := object.Key("PiiEntityTypes") ok.String(*v.PiiEntityTypes) } if v.PostCallAnalyticsSettings != nil { ok := object.Key("PostCallAnalyticsSettings") if err := awsRestjson1_serializeDocumentPostCallAnalyticsSettings(v.PostCallAnalyticsSettings, ok); err != nil { return err } } if len(v.VocabularyFilterMethod) > 0 { ok := object.Key("VocabularyFilterMethod") ok.String(string(v.VocabularyFilterMethod)) } if v.VocabularyFilterName != nil { ok := object.Key("VocabularyFilterName") ok.String(*v.VocabularyFilterName) } if v.VocabularyName != nil { ok := object.Key("VocabularyName") ok.String(*v.VocabularyName) } return nil } func awsRestjson1_serializeDocumentAmazonTranscribeProcessorConfiguration(v *types.AmazonTranscribeProcessorConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.ContentIdentificationType) > 0 { ok := object.Key("ContentIdentificationType") ok.String(string(v.ContentIdentificationType)) } if len(v.ContentRedactionType) > 0 { ok := object.Key("ContentRedactionType") ok.String(string(v.ContentRedactionType)) } if v.EnablePartialResultsStabilization { ok := object.Key("EnablePartialResultsStabilization") ok.Boolean(v.EnablePartialResultsStabilization) } if v.FilterPartialResults { ok := object.Key("FilterPartialResults") ok.Boolean(v.FilterPartialResults) } if v.IdentifyLanguage { ok := object.Key("IdentifyLanguage") ok.Boolean(v.IdentifyLanguage) } if len(v.LanguageCode) > 0 { ok := object.Key("LanguageCode") ok.String(string(v.LanguageCode)) } if v.LanguageModelName != nil { ok := object.Key("LanguageModelName") ok.String(*v.LanguageModelName) } if v.LanguageOptions != nil { ok := object.Key("LanguageOptions") ok.String(*v.LanguageOptions) } if len(v.PartialResultsStability) > 0 { ok := object.Key("PartialResultsStability") ok.String(string(v.PartialResultsStability)) } if v.PiiEntityTypes != nil { ok := object.Key("PiiEntityTypes") ok.String(*v.PiiEntityTypes) } if len(v.PreferredLanguage) > 0 { ok := object.Key("PreferredLanguage") ok.String(string(v.PreferredLanguage)) } if v.ShowSpeakerLabel { ok := object.Key("ShowSpeakerLabel") ok.Boolean(v.ShowSpeakerLabel) } if len(v.VocabularyFilterMethod) > 0 { ok := object.Key("VocabularyFilterMethod") ok.String(string(v.VocabularyFilterMethod)) } if v.VocabularyFilterName != nil { ok := object.Key("VocabularyFilterName") ok.String(*v.VocabularyFilterName) } if v.VocabularyFilterNames != nil { ok := object.Key("VocabularyFilterNames") ok.String(*v.VocabularyFilterNames) } if v.VocabularyName != nil { ok := object.Key("VocabularyName") ok.String(*v.VocabularyName) } if v.VocabularyNames != nil { ok := object.Key("VocabularyNames") ok.String(*v.VocabularyNames) } return nil } func awsRestjson1_serializeDocumentArtifactsConcatenationConfiguration(v *types.ArtifactsConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Audio != nil { ok := object.Key("Audio") if err := awsRestjson1_serializeDocumentAudioConcatenationConfiguration(v.Audio, ok); err != nil { return err } } if v.CompositedVideo != nil { ok := object.Key("CompositedVideo") if err := awsRestjson1_serializeDocumentCompositedVideoConcatenationConfiguration(v.CompositedVideo, ok); err != nil { return err } } if v.Content != nil { ok := object.Key("Content") if err := awsRestjson1_serializeDocumentContentConcatenationConfiguration(v.Content, ok); err != nil { return err } } if v.DataChannel != nil { ok := object.Key("DataChannel") if err := awsRestjson1_serializeDocumentDataChannelConcatenationConfiguration(v.DataChannel, ok); err != nil { return err } } if v.MeetingEvents != nil { ok := object.Key("MeetingEvents") if err := awsRestjson1_serializeDocumentMeetingEventsConcatenationConfiguration(v.MeetingEvents, ok); err != nil { return err } } if v.TranscriptionMessages != nil { ok := object.Key("TranscriptionMessages") if err := awsRestjson1_serializeDocumentTranscriptionMessagesConcatenationConfiguration(v.TranscriptionMessages, ok); err != nil { return err } } if v.Video != nil { ok := object.Key("Video") if err := awsRestjson1_serializeDocumentVideoConcatenationConfiguration(v.Video, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentArtifactsConfiguration(v *types.ArtifactsConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Audio != nil { ok := object.Key("Audio") if err := awsRestjson1_serializeDocumentAudioArtifactsConfiguration(v.Audio, ok); err != nil { return err } } if v.CompositedVideo != nil { ok := object.Key("CompositedVideo") if err := awsRestjson1_serializeDocumentCompositedVideoArtifactsConfiguration(v.CompositedVideo, ok); err != nil { return err } } if v.Content != nil { ok := object.Key("Content") if err := awsRestjson1_serializeDocumentContentArtifactsConfiguration(v.Content, ok); err != nil { return err } } if v.Video != nil { ok := object.Key("Video") if err := awsRestjson1_serializeDocumentVideoArtifactsConfiguration(v.Video, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentAttendeeIdList(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_serializeDocumentAudioArtifactsConfiguration(v *types.AudioArtifactsConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.MuxType) > 0 { ok := object.Key("MuxType") ok.String(string(v.MuxType)) } return nil } func awsRestjson1_serializeDocumentAudioConcatenationConfiguration(v *types.AudioConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentCategoryNameList(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_serializeDocumentChannelDefinition(v *types.ChannelDefinition, value smithyjson.Value) error { object := value.Object() defer object.Close() { ok := object.Key("ChannelId") ok.Integer(v.ChannelId) } if len(v.ParticipantRole) > 0 { ok := object.Key("ParticipantRole") ok.String(string(v.ParticipantRole)) } return nil } func awsRestjson1_serializeDocumentChannelDefinitions(v []types.ChannelDefinition, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentChannelDefinition(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentChimeSdkMeetingConcatenationConfiguration(v *types.ChimeSdkMeetingConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ArtifactsConfiguration != nil { ok := object.Key("ArtifactsConfiguration") if err := awsRestjson1_serializeDocumentArtifactsConcatenationConfiguration(v.ArtifactsConfiguration, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentChimeSdkMeetingConfiguration(v *types.ChimeSdkMeetingConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ArtifactsConfiguration != nil { ok := object.Key("ArtifactsConfiguration") if err := awsRestjson1_serializeDocumentArtifactsConfiguration(v.ArtifactsConfiguration, ok); err != nil { return err } } if v.SourceConfiguration != nil { ok := object.Key("SourceConfiguration") if err := awsRestjson1_serializeDocumentSourceConfiguration(v.SourceConfiguration, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentChimeSdkMeetingLiveConnectorConfiguration(v *types.ChimeSdkMeetingLiveConnectorConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Arn != nil { ok := object.Key("Arn") ok.String(*v.Arn) } if v.CompositedVideo != nil { ok := object.Key("CompositedVideo") if err := awsRestjson1_serializeDocumentCompositedVideoArtifactsConfiguration(v.CompositedVideo, ok); err != nil { return err } } if len(v.MuxType) > 0 { ok := object.Key("MuxType") ok.String(string(v.MuxType)) } if v.SourceConfiguration != nil { ok := object.Key("SourceConfiguration") if err := awsRestjson1_serializeDocumentSourceConfiguration(v.SourceConfiguration, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentCompositedVideoArtifactsConfiguration(v *types.CompositedVideoArtifactsConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.GridViewConfiguration != nil { ok := object.Key("GridViewConfiguration") if err := awsRestjson1_serializeDocumentGridViewConfiguration(v.GridViewConfiguration, ok); err != nil { return err } } if len(v.Layout) > 0 { ok := object.Key("Layout") ok.String(string(v.Layout)) } if len(v.Resolution) > 0 { ok := object.Key("Resolution") ok.String(string(v.Resolution)) } return nil } func awsRestjson1_serializeDocumentCompositedVideoConcatenationConfiguration(v *types.CompositedVideoConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentConcatenationSink(v *types.ConcatenationSink, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.S3BucketSinkConfiguration != nil { ok := object.Key("S3BucketSinkConfiguration") if err := awsRestjson1_serializeDocumentS3BucketSinkConfiguration(v.S3BucketSinkConfiguration, ok); err != nil { return err } } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } return nil } func awsRestjson1_serializeDocumentConcatenationSinkList(v []types.ConcatenationSink, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentConcatenationSink(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentConcatenationSource(v *types.ConcatenationSource, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.MediaCapturePipelineSourceConfiguration != nil { ok := object.Key("MediaCapturePipelineSourceConfiguration") if err := awsRestjson1_serializeDocumentMediaCapturePipelineSourceConfiguration(v.MediaCapturePipelineSourceConfiguration, ok); err != nil { return err } } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } return nil } func awsRestjson1_serializeDocumentConcatenationSourceList(v []types.ConcatenationSource, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentConcatenationSource(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentContentArtifactsConfiguration(v *types.ContentArtifactsConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.MuxType) > 0 { ok := object.Key("MuxType") ok.String(string(v.MuxType)) } if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentContentConcatenationConfiguration(v *types.ContentConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentDataChannelConcatenationConfiguration(v *types.DataChannelConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentExternalUserIdList(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_serializeDocumentFragmentSelector(v *types.FragmentSelector, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.FragmentSelectorType) > 0 { ok := object.Key("FragmentSelectorType") ok.String(string(v.FragmentSelectorType)) } if v.TimestampRange != nil { ok := object.Key("TimestampRange") if err := awsRestjson1_serializeDocumentTimestampRange(v.TimestampRange, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentGridViewConfiguration(v *types.GridViewConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ActiveSpeakerOnlyConfiguration != nil { ok := object.Key("ActiveSpeakerOnlyConfiguration") if err := awsRestjson1_serializeDocumentActiveSpeakerOnlyConfiguration(v.ActiveSpeakerOnlyConfiguration, ok); err != nil { return err } } if len(v.CanvasOrientation) > 0 { ok := object.Key("CanvasOrientation") ok.String(string(v.CanvasOrientation)) } if len(v.ContentShareLayout) > 0 { ok := object.Key("ContentShareLayout") ok.String(string(v.ContentShareLayout)) } if v.HorizontalLayoutConfiguration != nil { ok := object.Key("HorizontalLayoutConfiguration") if err := awsRestjson1_serializeDocumentHorizontalLayoutConfiguration(v.HorizontalLayoutConfiguration, ok); err != nil { return err } } if v.PresenterOnlyConfiguration != nil { ok := object.Key("PresenterOnlyConfiguration") if err := awsRestjson1_serializeDocumentPresenterOnlyConfiguration(v.PresenterOnlyConfiguration, ok); err != nil { return err } } if v.VerticalLayoutConfiguration != nil { ok := object.Key("VerticalLayoutConfiguration") if err := awsRestjson1_serializeDocumentVerticalLayoutConfiguration(v.VerticalLayoutConfiguration, ok); err != nil { return err } } if v.VideoAttribute != nil { ok := object.Key("VideoAttribute") if err := awsRestjson1_serializeDocumentVideoAttribute(v.VideoAttribute, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentHorizontalLayoutConfiguration(v *types.HorizontalLayoutConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.TileAspectRatio != nil { ok := object.Key("TileAspectRatio") ok.String(*v.TileAspectRatio) } if v.TileCount != nil { ok := object.Key("TileCount") ok.Integer(*v.TileCount) } if len(v.TileOrder) > 0 { ok := object.Key("TileOrder") ok.String(string(v.TileOrder)) } if len(v.TilePosition) > 0 { ok := object.Key("TilePosition") ok.String(string(v.TilePosition)) } return nil } func awsRestjson1_serializeDocumentIssueDetectionConfiguration(v *types.IssueDetectionConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.RuleName != nil { ok := object.Key("RuleName") ok.String(*v.RuleName) } return nil } func awsRestjson1_serializeDocumentKeywordMatchConfiguration(v *types.KeywordMatchConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Keywords != nil { ok := object.Key("Keywords") if err := awsRestjson1_serializeDocumentKeywordMatchWordList(v.Keywords, ok); err != nil { return err } } if v.Negate { ok := object.Key("Negate") ok.Boolean(v.Negate) } if v.RuleName != nil { ok := object.Key("RuleName") ok.String(*v.RuleName) } return nil } func awsRestjson1_serializeDocumentKeywordMatchWordList(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_serializeDocumentKinesisDataStreamSinkConfiguration(v *types.KinesisDataStreamSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.InsightsTarget != nil { ok := object.Key("InsightsTarget") ok.String(*v.InsightsTarget) } return nil } func awsRestjson1_serializeDocumentKinesisVideoStreamRecordingSourceRuntimeConfiguration(v *types.KinesisVideoStreamRecordingSourceRuntimeConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.FragmentSelector != nil { ok := object.Key("FragmentSelector") if err := awsRestjson1_serializeDocumentFragmentSelector(v.FragmentSelector, ok); err != nil { return err } } if v.Streams != nil { ok := object.Key("Streams") if err := awsRestjson1_serializeDocumentRecordingStreamList(v.Streams, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentKinesisVideoStreamSourceRuntimeConfiguration(v *types.KinesisVideoStreamSourceRuntimeConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.MediaEncoding) > 0 { ok := object.Key("MediaEncoding") ok.String(string(v.MediaEncoding)) } if v.MediaSampleRate != nil { ok := object.Key("MediaSampleRate") ok.Integer(*v.MediaSampleRate) } if v.Streams != nil { ok := object.Key("Streams") if err := awsRestjson1_serializeDocumentStreams(v.Streams, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentLambdaFunctionSinkConfiguration(v *types.LambdaFunctionSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.InsightsTarget != nil { ok := object.Key("InsightsTarget") ok.String(*v.InsightsTarget) } return nil } func awsRestjson1_serializeDocumentLiveConnectorRTMPConfiguration(v *types.LiveConnectorRTMPConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.AudioChannels) > 0 { ok := object.Key("AudioChannels") ok.String(string(v.AudioChannels)) } if v.AudioSampleRate != nil { ok := object.Key("AudioSampleRate") ok.String(*v.AudioSampleRate) } if v.Url != nil { ok := object.Key("Url") ok.String(*v.Url) } return nil } func awsRestjson1_serializeDocumentLiveConnectorSinkConfiguration(v *types.LiveConnectorSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.RTMPConfiguration != nil { ok := object.Key("RTMPConfiguration") if err := awsRestjson1_serializeDocumentLiveConnectorRTMPConfiguration(v.RTMPConfiguration, ok); err != nil { return err } } if len(v.SinkType) > 0 { ok := object.Key("SinkType") ok.String(string(v.SinkType)) } return nil } func awsRestjson1_serializeDocumentLiveConnectorSinkList(v []types.LiveConnectorSinkConfiguration, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentLiveConnectorSinkConfiguration(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentLiveConnectorSourceConfiguration(v *types.LiveConnectorSourceConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ChimeSdkMeetingLiveConnectorConfiguration != nil { ok := object.Key("ChimeSdkMeetingLiveConnectorConfiguration") if err := awsRestjson1_serializeDocumentChimeSdkMeetingLiveConnectorConfiguration(v.ChimeSdkMeetingLiveConnectorConfiguration, ok); err != nil { return err } } if len(v.SourceType) > 0 { ok := object.Key("SourceType") ok.String(string(v.SourceType)) } return nil } func awsRestjson1_serializeDocumentLiveConnectorSourceList(v []types.LiveConnectorSourceConfiguration, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentLiveConnectorSourceConfiguration(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentMediaCapturePipelineSourceConfiguration(v *types.MediaCapturePipelineSourceConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ChimeSdkMeetingConfiguration != nil { ok := object.Key("ChimeSdkMeetingConfiguration") if err := awsRestjson1_serializeDocumentChimeSdkMeetingConcatenationConfiguration(v.ChimeSdkMeetingConfiguration, ok); err != nil { return err } } if v.MediaPipelineArn != nil { ok := object.Key("MediaPipelineArn") ok.String(*v.MediaPipelineArn) } return nil } func awsRestjson1_serializeDocumentMediaInsightsPipelineConfigurationElement(v *types.MediaInsightsPipelineConfigurationElement, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.AmazonTranscribeCallAnalyticsProcessorConfiguration != nil { ok := object.Key("AmazonTranscribeCallAnalyticsProcessorConfiguration") if err := awsRestjson1_serializeDocumentAmazonTranscribeCallAnalyticsProcessorConfiguration(v.AmazonTranscribeCallAnalyticsProcessorConfiguration, ok); err != nil { return err } } if v.AmazonTranscribeProcessorConfiguration != nil { ok := object.Key("AmazonTranscribeProcessorConfiguration") if err := awsRestjson1_serializeDocumentAmazonTranscribeProcessorConfiguration(v.AmazonTranscribeProcessorConfiguration, ok); err != nil { return err } } if v.KinesisDataStreamSinkConfiguration != nil { ok := object.Key("KinesisDataStreamSinkConfiguration") if err := awsRestjson1_serializeDocumentKinesisDataStreamSinkConfiguration(v.KinesisDataStreamSinkConfiguration, ok); err != nil { return err } } if v.LambdaFunctionSinkConfiguration != nil { ok := object.Key("LambdaFunctionSinkConfiguration") if err := awsRestjson1_serializeDocumentLambdaFunctionSinkConfiguration(v.LambdaFunctionSinkConfiguration, ok); err != nil { return err } } if v.S3RecordingSinkConfiguration != nil { ok := object.Key("S3RecordingSinkConfiguration") if err := awsRestjson1_serializeDocumentS3RecordingSinkConfiguration(v.S3RecordingSinkConfiguration, ok); err != nil { return err } } if v.SnsTopicSinkConfiguration != nil { ok := object.Key("SnsTopicSinkConfiguration") if err := awsRestjson1_serializeDocumentSnsTopicSinkConfiguration(v.SnsTopicSinkConfiguration, ok); err != nil { return err } } if v.SqsQueueSinkConfiguration != nil { ok := object.Key("SqsQueueSinkConfiguration") if err := awsRestjson1_serializeDocumentSqsQueueSinkConfiguration(v.SqsQueueSinkConfiguration, ok); err != nil { return err } } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } if v.VoiceAnalyticsProcessorConfiguration != nil { ok := object.Key("VoiceAnalyticsProcessorConfiguration") if err := awsRestjson1_serializeDocumentVoiceAnalyticsProcessorConfiguration(v.VoiceAnalyticsProcessorConfiguration, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentMediaInsightsPipelineConfigurationElements(v []types.MediaInsightsPipelineConfigurationElement, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentMediaInsightsPipelineConfigurationElement(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentMediaInsightsRuntimeMetadata(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_serializeDocumentMeetingEventsConcatenationConfiguration(v *types.MeetingEventsConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentPostCallAnalyticsSettings(v *types.PostCallAnalyticsSettings, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.ContentRedactionOutput) > 0 { ok := object.Key("ContentRedactionOutput") ok.String(string(v.ContentRedactionOutput)) } if v.DataAccessRoleArn != nil { ok := object.Key("DataAccessRoleArn") ok.String(*v.DataAccessRoleArn) } if v.OutputEncryptionKMSKeyId != nil { ok := object.Key("OutputEncryptionKMSKeyId") ok.String(*v.OutputEncryptionKMSKeyId) } if v.OutputLocation != nil { ok := object.Key("OutputLocation") ok.String(*v.OutputLocation) } return nil } func awsRestjson1_serializeDocumentPresenterOnlyConfiguration(v *types.PresenterOnlyConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.PresenterPosition) > 0 { ok := object.Key("PresenterPosition") ok.String(string(v.PresenterPosition)) } return nil } func awsRestjson1_serializeDocumentRealTimeAlertConfiguration(v *types.RealTimeAlertConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Disabled { ok := object.Key("Disabled") ok.Boolean(v.Disabled) } if v.Rules != nil { ok := object.Key("Rules") if err := awsRestjson1_serializeDocumentRealTimeAlertRuleList(v.Rules, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentRealTimeAlertRule(v *types.RealTimeAlertRule, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.IssueDetectionConfiguration != nil { ok := object.Key("IssueDetectionConfiguration") if err := awsRestjson1_serializeDocumentIssueDetectionConfiguration(v.IssueDetectionConfiguration, ok); err != nil { return err } } if v.KeywordMatchConfiguration != nil { ok := object.Key("KeywordMatchConfiguration") if err := awsRestjson1_serializeDocumentKeywordMatchConfiguration(v.KeywordMatchConfiguration, ok); err != nil { return err } } if v.SentimentConfiguration != nil { ok := object.Key("SentimentConfiguration") if err := awsRestjson1_serializeDocumentSentimentConfiguration(v.SentimentConfiguration, ok); err != nil { return err } } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } return nil } func awsRestjson1_serializeDocumentRealTimeAlertRuleList(v []types.RealTimeAlertRule, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentRealTimeAlertRule(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentRecordingStreamConfiguration(v *types.RecordingStreamConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.StreamArn != nil { ok := object.Key("StreamArn") ok.String(*v.StreamArn) } return nil } func awsRestjson1_serializeDocumentRecordingStreamList(v []types.RecordingStreamConfiguration, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentRecordingStreamConfiguration(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentS3BucketSinkConfiguration(v *types.S3BucketSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Destination != nil { ok := object.Key("Destination") ok.String(*v.Destination) } return nil } func awsRestjson1_serializeDocumentS3RecordingSinkConfiguration(v *types.S3RecordingSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Destination != nil { ok := object.Key("Destination") ok.String(*v.Destination) } if len(v.RecordingFileFormat) > 0 { ok := object.Key("RecordingFileFormat") ok.String(string(v.RecordingFileFormat)) } return nil } func awsRestjson1_serializeDocumentS3RecordingSinkRuntimeConfiguration(v *types.S3RecordingSinkRuntimeConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Destination != nil { ok := object.Key("Destination") ok.String(*v.Destination) } if len(v.RecordingFileFormat) > 0 { ok := object.Key("RecordingFileFormat") ok.String(string(v.RecordingFileFormat)) } return nil } func awsRestjson1_serializeDocumentSelectedVideoStreams(v *types.SelectedVideoStreams, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.AttendeeIds != nil { ok := object.Key("AttendeeIds") if err := awsRestjson1_serializeDocumentAttendeeIdList(v.AttendeeIds, ok); err != nil { return err } } if v.ExternalUserIds != nil { ok := object.Key("ExternalUserIds") if err := awsRestjson1_serializeDocumentExternalUserIdList(v.ExternalUserIds, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentSentimentConfiguration(v *types.SentimentConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.RuleName != nil { ok := object.Key("RuleName") ok.String(*v.RuleName) } if len(v.SentimentType) > 0 { ok := object.Key("SentimentType") ok.String(string(v.SentimentType)) } { ok := object.Key("TimePeriod") ok.Integer(v.TimePeriod) } return nil } func awsRestjson1_serializeDocumentSnsTopicSinkConfiguration(v *types.SnsTopicSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.InsightsTarget != nil { ok := object.Key("InsightsTarget") ok.String(*v.InsightsTarget) } return nil } func awsRestjson1_serializeDocumentSourceConfiguration(v *types.SourceConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.SelectedVideoStreams != nil { ok := object.Key("SelectedVideoStreams") if err := awsRestjson1_serializeDocumentSelectedVideoStreams(v.SelectedVideoStreams, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentSqsQueueSinkConfiguration(v *types.SqsQueueSinkConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.InsightsTarget != nil { ok := object.Key("InsightsTarget") ok.String(*v.InsightsTarget) } return nil } func awsRestjson1_serializeDocumentStreamChannelDefinition(v *types.StreamChannelDefinition, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ChannelDefinitions != nil { ok := object.Key("ChannelDefinitions") if err := awsRestjson1_serializeDocumentChannelDefinitions(v.ChannelDefinitions, ok); err != nil { return err } } if v.NumberOfChannels != nil { ok := object.Key("NumberOfChannels") ok.Integer(*v.NumberOfChannels) } return nil } func awsRestjson1_serializeDocumentStreamConfiguration(v *types.StreamConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.FragmentNumber != nil { ok := object.Key("FragmentNumber") ok.String(*v.FragmentNumber) } if v.StreamArn != nil { ok := object.Key("StreamArn") ok.String(*v.StreamArn) } if v.StreamChannelDefinition != nil { ok := object.Key("StreamChannelDefinition") if err := awsRestjson1_serializeDocumentStreamChannelDefinition(v.StreamChannelDefinition, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentStreams(v []types.StreamConfiguration, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentStreamConfiguration(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Key != nil { ok := object.Key("Key") ok.String(*v.Key) } if v.Value != nil { ok := object.Key("Value") ok.String(*v.Value) } return nil } func awsRestjson1_serializeDocumentTagKeyList(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_serializeDocumentTagList(v []types.Tag, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentTag(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentTimestampRange(v *types.TimestampRange, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.EndTimestamp != nil { ok := object.Key("EndTimestamp") ok.Double(smithytime.FormatEpochSeconds(*v.EndTimestamp)) } if v.StartTimestamp != nil { ok := object.Key("StartTimestamp") ok.Double(smithytime.FormatEpochSeconds(*v.StartTimestamp)) } return nil } func awsRestjson1_serializeDocumentTranscriptionMessagesConcatenationConfiguration(v *types.TranscriptionMessagesConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentVerticalLayoutConfiguration(v *types.VerticalLayoutConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.TileAspectRatio != nil { ok := object.Key("TileAspectRatio") ok.String(*v.TileAspectRatio) } if v.TileCount != nil { ok := object.Key("TileCount") ok.Integer(*v.TileCount) } if len(v.TileOrder) > 0 { ok := object.Key("TileOrder") ok.String(string(v.TileOrder)) } if len(v.TilePosition) > 0 { ok := object.Key("TilePosition") ok.String(string(v.TilePosition)) } return nil } func awsRestjson1_serializeDocumentVideoArtifactsConfiguration(v *types.VideoArtifactsConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.MuxType) > 0 { ok := object.Key("MuxType") ok.String(string(v.MuxType)) } if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentVideoAttribute(v *types.VideoAttribute, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.BorderColor) > 0 { ok := object.Key("BorderColor") ok.String(string(v.BorderColor)) } if v.BorderThickness != nil { ok := object.Key("BorderThickness") ok.Integer(*v.BorderThickness) } if v.CornerRadius != nil { ok := object.Key("CornerRadius") ok.Integer(*v.CornerRadius) } if len(v.HighlightColor) > 0 { ok := object.Key("HighlightColor") ok.String(string(v.HighlightColor)) } return nil } func awsRestjson1_serializeDocumentVideoConcatenationConfiguration(v *types.VideoConcatenationConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.State) > 0 { ok := object.Key("State") ok.String(string(v.State)) } return nil } func awsRestjson1_serializeDocumentVoiceAnalyticsProcessorConfiguration(v *types.VoiceAnalyticsProcessorConfiguration, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.SpeakerSearchStatus) > 0 { ok := object.Key("SpeakerSearchStatus") ok.String(string(v.SpeakerSearchStatus)) } if len(v.VoiceToneAnalysisStatus) > 0 { ok := object.Key("VoiceToneAnalysisStatus") ok.String(string(v.VoiceToneAnalysisStatus)) } return nil }