/* * Copyright 2010-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. * A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ /* * Do not modify this file. This file is generated from the firehose-2015-08-04.normal.json service model. */ using System; using System.Collections.Generic; using System.Globalization; using System.IO; using System.Text; using System.Xml.Serialization; using Amazon.KinesisFirehose.Model; using Amazon.Runtime; using Amazon.Runtime.Internal; using Amazon.Runtime.Internal.Transform; using Amazon.Runtime.Internal.Util; using ThirdParty.Json.LitJson; namespace Amazon.KinesisFirehose.Model.Internal.MarshallTransformations { /// /// CreateDeliveryStream Request Marshaller /// public class CreateDeliveryStreamRequestMarshaller : IMarshaller , IMarshaller { /// /// Marshaller the request object to the HTTP request. /// /// /// public IRequest Marshall(AmazonWebServiceRequest input) { return this.Marshall((CreateDeliveryStreamRequest)input); } /// /// Marshaller the request object to the HTTP request. /// /// /// public IRequest Marshall(CreateDeliveryStreamRequest publicRequest) { IRequest request = new DefaultRequest(publicRequest, "Amazon.KinesisFirehose"); string target = "Firehose_20150804.CreateDeliveryStream"; request.Headers["X-Amz-Target"] = target; request.Headers["Content-Type"] = "application/x-amz-json-1.1"; request.Headers[Amazon.Util.HeaderKeys.XAmzApiVersion] = "2015-08-04"; request.HttpMethod = "POST"; request.ResourcePath = "/"; request.MarshallerVersion = 2; using (StringWriter stringWriter = new StringWriter(CultureInfo.InvariantCulture)) { JsonWriter writer = new JsonWriter(stringWriter); writer.WriteObjectStart(); var context = new JsonMarshallerContext(request, writer); if(publicRequest.IsSetDeliveryStreamEncryptionConfigurationInput()) { context.Writer.WritePropertyName("DeliveryStreamEncryptionConfigurationInput"); context.Writer.WriteObjectStart(); var marshaller = DeliveryStreamEncryptionConfigurationInputMarshaller.Instance; marshaller.Marshall(publicRequest.DeliveryStreamEncryptionConfigurationInput, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetDeliveryStreamName()) { context.Writer.WritePropertyName("DeliveryStreamName"); context.Writer.Write(publicRequest.DeliveryStreamName); } if(publicRequest.IsSetDeliveryStreamType()) { context.Writer.WritePropertyName("DeliveryStreamType"); context.Writer.Write(publicRequest.DeliveryStreamType); } if(publicRequest.IsSetElasticsearchDestinationConfiguration()) { context.Writer.WritePropertyName("ElasticsearchDestinationConfiguration"); context.Writer.WriteObjectStart(); var marshaller = ElasticsearchDestinationConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.ElasticsearchDestinationConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetExtendedS3DestinationConfiguration()) { context.Writer.WritePropertyName("ExtendedS3DestinationConfiguration"); context.Writer.WriteObjectStart(); var marshaller = ExtendedS3DestinationConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.ExtendedS3DestinationConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetKinesisStreamSourceConfiguration()) { context.Writer.WritePropertyName("KinesisStreamSourceConfiguration"); context.Writer.WriteObjectStart(); var marshaller = KinesisStreamSourceConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.KinesisStreamSourceConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetRedshiftDestinationConfiguration()) { context.Writer.WritePropertyName("RedshiftDestinationConfiguration"); context.Writer.WriteObjectStart(); var marshaller = RedshiftDestinationConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.RedshiftDestinationConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetS3DestinationConfiguration()) { context.Writer.WritePropertyName("S3DestinationConfiguration"); context.Writer.WriteObjectStart(); var marshaller = S3DestinationConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.S3DestinationConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetSplunkDestinationConfiguration()) { context.Writer.WritePropertyName("SplunkDestinationConfiguration"); context.Writer.WriteObjectStart(); var marshaller = SplunkDestinationConfigurationMarshaller.Instance; marshaller.Marshall(publicRequest.SplunkDestinationConfiguration, context); context.Writer.WriteObjectEnd(); } if(publicRequest.IsSetTags()) { context.Writer.WritePropertyName("Tags"); context.Writer.WriteArrayStart(); foreach(var publicRequestTagsListValue in publicRequest.Tags) { context.Writer.WriteObjectStart(); var marshaller = TagMarshaller.Instance; marshaller.Marshall(publicRequestTagsListValue, context); context.Writer.WriteObjectEnd(); } context.Writer.WriteArrayEnd(); } writer.WriteObjectEnd(); string snippet = stringWriter.ToString(); request.Content = System.Text.Encoding.UTF8.GetBytes(snippet); } return request; } private static CreateDeliveryStreamRequestMarshaller _instance = new CreateDeliveryStreamRequestMarshaller(); internal static CreateDeliveryStreamRequestMarshaller GetInstance() { return _instance; } /// /// Gets the singleton. /// public static CreateDeliveryStreamRequestMarshaller Instance { get { return _instance; } } } }