/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #include #include #include using namespace Aws::Kinesis::Model; using namespace Aws::Utils::Json; using namespace Aws::Utils; GetRecordsRequest::GetRecordsRequest() : m_shardIteratorHasBeenSet(false), m_limit(0), m_limitHasBeenSet(false), m_streamARNHasBeenSet(false) { } Aws::String GetRecordsRequest::SerializePayload() const { JsonValue payload; if(m_shardIteratorHasBeenSet) { payload.WithString("ShardIterator", m_shardIterator); } if(m_limitHasBeenSet) { payload.WithInteger("Limit", m_limit); } if(m_streamARNHasBeenSet) { payload.WithString("StreamARN", m_streamARN); } return payload.View().WriteReadable(); } Aws::Http::HeaderValueCollection GetRecordsRequest::GetRequestSpecificHeaders() const { Aws::Http::HeaderValueCollection headers; headers.insert(Aws::Http::HeaderValuePair("X-Amz-Target", "Kinesis_20131202.GetRecords")); return headers; } GetRecordsRequest::EndpointParameters GetRecordsRequest::GetEndpointContextParams() const { EndpointParameters parameters; // Static context parameters parameters.emplace_back(Aws::String("OperationType"), "data", Aws::Endpoint::EndpointParameter::ParameterOrigin::STATIC_CONTEXT); // Operation context parameters if (StreamARNHasBeenSet()) { parameters.emplace_back(Aws::String("StreamARN"), this->GetStreamARN(), Aws::Endpoint::EndpointParameter::ParameterOrigin::OPERATION_CONTEXT); } return parameters; }