AWS SDK for C++  1.9.20
AWS SDK for C++
Classes | Namespaces | Typedefs
KinesisClient.h File Reference
#include <aws/kinesis/Kinesis_EXPORTS.h>
#include <aws/kinesis/KinesisErrors.h>
#include <aws/core/client/AWSError.h>
#include <aws/core/client/ClientConfiguration.h>
#include <aws/core/client/AWSClient.h>
#include <aws/core/utils/memory/stl/AWSString.h>
#include <aws/core/utils/json/JsonSerializer.h>
#include <aws/kinesis/model/DescribeLimitsResult.h>
#include <aws/kinesis/model/DescribeStreamResult.h>
#include <aws/kinesis/model/DescribeStreamConsumerResult.h>
#include <aws/kinesis/model/DescribeStreamSummaryResult.h>
#include <aws/kinesis/model/DisableEnhancedMonitoringResult.h>
#include <aws/kinesis/model/EnableEnhancedMonitoringResult.h>
#include <aws/kinesis/model/GetRecordsResult.h>
#include <aws/kinesis/model/GetShardIteratorResult.h>
#include <aws/kinesis/model/ListShardsResult.h>
#include <aws/kinesis/model/ListStreamConsumersResult.h>
#include <aws/kinesis/model/ListStreamsResult.h>
#include <aws/kinesis/model/ListTagsForStreamResult.h>
#include <aws/kinesis/model/PutRecordResult.h>
#include <aws/kinesis/model/PutRecordsResult.h>
#include <aws/kinesis/model/RegisterStreamConsumerResult.h>
#include <aws/kinesis/model/UpdateShardCountResult.h>
#include <aws/core/NoResult.h>
#include <aws/core/client/AsyncCallerContext.h>
#include <aws/core/http/HttpTypes.h>
#include <future>
#include <functional>

Go to the source code of this file.

Classes

class  Aws::Kinesis::KinesisClient
 

Namespaces

 Aws
 
 Aws::Http
 
 Aws::Utils
 
 Aws::Utils::Threading
 
 Aws::Auth
 
 Aws::Client
 
 Aws::Kinesis
 
 Aws::Kinesis::Model
 

Typedefs

typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::AddTagsToStreamOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::CreateStreamOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::DecreaseStreamRetentionPeriodOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::DeleteStreamOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::DeregisterStreamConsumerOutcome
 
typedef Aws::Utils::Outcome< DescribeLimitsResult, KinesisError > Aws::Kinesis::Model::DescribeLimitsOutcome
 
typedef Aws::Utils::Outcome< DescribeStreamResult, KinesisError > Aws::Kinesis::Model::DescribeStreamOutcome
 
typedef Aws::Utils::Outcome< DescribeStreamConsumerResult, KinesisError > Aws::Kinesis::Model::DescribeStreamConsumerOutcome
 
typedef Aws::Utils::Outcome< DescribeStreamSummaryResult, KinesisError > Aws::Kinesis::Model::DescribeStreamSummaryOutcome
 
typedef Aws::Utils::Outcome< DisableEnhancedMonitoringResult, KinesisError > Aws::Kinesis::Model::DisableEnhancedMonitoringOutcome
 
typedef Aws::Utils::Outcome< EnableEnhancedMonitoringResult, KinesisError > Aws::Kinesis::Model::EnableEnhancedMonitoringOutcome
 
typedef Aws::Utils::Outcome< GetRecordsResult, KinesisError > Aws::Kinesis::Model::GetRecordsOutcome
 
typedef Aws::Utils::Outcome< GetShardIteratorResult, KinesisError > Aws::Kinesis::Model::GetShardIteratorOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::IncreaseStreamRetentionPeriodOutcome
 
typedef Aws::Utils::Outcome< ListShardsResult, KinesisError > Aws::Kinesis::Model::ListShardsOutcome
 
typedef Aws::Utils::Outcome< ListStreamConsumersResult, KinesisError > Aws::Kinesis::Model::ListStreamConsumersOutcome
 
typedef Aws::Utils::Outcome< ListStreamsResult, KinesisError > Aws::Kinesis::Model::ListStreamsOutcome
 
typedef Aws::Utils::Outcome< ListTagsForStreamResult, KinesisError > Aws::Kinesis::Model::ListTagsForStreamOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::MergeShardsOutcome
 
typedef Aws::Utils::Outcome< PutRecordResult, KinesisError > Aws::Kinesis::Model::PutRecordOutcome
 
typedef Aws::Utils::Outcome< PutRecordsResult, KinesisError > Aws::Kinesis::Model::PutRecordsOutcome
 
typedef Aws::Utils::Outcome< RegisterStreamConsumerResult, KinesisError > Aws::Kinesis::Model::RegisterStreamConsumerOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::RemoveTagsFromStreamOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::SplitShardOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::StartStreamEncryptionOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::StopStreamEncryptionOutcome
 
typedef Aws::Utils::Outcome< Aws::NoResult, KinesisError > Aws::Kinesis::Model::SubscribeToShardOutcome
 
typedef Aws::Utils::Outcome< UpdateShardCountResult, KinesisError > Aws::Kinesis::Model::UpdateShardCountOutcome
 
typedef std::future< AddTagsToStreamOutcome > Aws::Kinesis::Model::AddTagsToStreamOutcomeCallable
 
typedef std::future< CreateStreamOutcome > Aws::Kinesis::Model::CreateStreamOutcomeCallable
 
typedef std::future< DecreaseStreamRetentionPeriodOutcome > Aws::Kinesis::Model::DecreaseStreamRetentionPeriodOutcomeCallable
 
typedef std::future< DeleteStreamOutcome > Aws::Kinesis::Model::DeleteStreamOutcomeCallable
 
typedef std::future< DeregisterStreamConsumerOutcome > Aws::Kinesis::Model::DeregisterStreamConsumerOutcomeCallable
 
typedef std::future< DescribeLimitsOutcome > Aws::Kinesis::Model::DescribeLimitsOutcomeCallable
 
typedef std::future< DescribeStreamOutcome > Aws::Kinesis::Model::DescribeStreamOutcomeCallable
 
typedef std::future< DescribeStreamConsumerOutcome > Aws::Kinesis::Model::DescribeStreamConsumerOutcomeCallable
 
typedef std::future< DescribeStreamSummaryOutcome > Aws::Kinesis::Model::DescribeStreamSummaryOutcomeCallable
 
typedef std::future< DisableEnhancedMonitoringOutcome > Aws::Kinesis::Model::DisableEnhancedMonitoringOutcomeCallable
 
typedef std::future< EnableEnhancedMonitoringOutcome > Aws::Kinesis::Model::EnableEnhancedMonitoringOutcomeCallable
 
typedef std::future< GetRecordsOutcome > Aws::Kinesis::Model::GetRecordsOutcomeCallable
 
typedef std::future< GetShardIteratorOutcome > Aws::Kinesis::Model::GetShardIteratorOutcomeCallable
 
typedef std::future< IncreaseStreamRetentionPeriodOutcome > Aws::Kinesis::Model::IncreaseStreamRetentionPeriodOutcomeCallable
 
typedef std::future< ListShardsOutcome > Aws::Kinesis::Model::ListShardsOutcomeCallable
 
typedef std::future< ListStreamConsumersOutcome > Aws::Kinesis::Model::ListStreamConsumersOutcomeCallable
 
typedef std::future< ListStreamsOutcome > Aws::Kinesis::Model::ListStreamsOutcomeCallable
 
typedef std::future< ListTagsForStreamOutcome > Aws::Kinesis::Model::ListTagsForStreamOutcomeCallable
 
typedef std::future< MergeShardsOutcome > Aws::Kinesis::Model::MergeShardsOutcomeCallable
 
typedef std::future< PutRecordOutcome > Aws::Kinesis::Model::PutRecordOutcomeCallable
 
typedef std::future< PutRecordsOutcome > Aws::Kinesis::Model::PutRecordsOutcomeCallable
 
typedef std::future< RegisterStreamConsumerOutcome > Aws::Kinesis::Model::RegisterStreamConsumerOutcomeCallable
 
typedef std::future< RemoveTagsFromStreamOutcome > Aws::Kinesis::Model::RemoveTagsFromStreamOutcomeCallable
 
typedef std::future< SplitShardOutcome > Aws::Kinesis::Model::SplitShardOutcomeCallable
 
typedef std::future< StartStreamEncryptionOutcome > Aws::Kinesis::Model::StartStreamEncryptionOutcomeCallable
 
typedef std::future< StopStreamEncryptionOutcome > Aws::Kinesis::Model::StopStreamEncryptionOutcomeCallable
 
typedef std::future< SubscribeToShardOutcome > Aws::Kinesis::Model::SubscribeToShardOutcomeCallable
 
typedef std::future< UpdateShardCountOutcome > Aws::Kinesis::Model::UpdateShardCountOutcomeCallable
 
typedef std::function< void(const KinesisClient *, const Model::AddTagsToStreamRequest &, const Model::AddTagsToStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::AddTagsToStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::CreateStreamRequest &, const Model::CreateStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::CreateStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DecreaseStreamRetentionPeriodRequest &, const Model::DecreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DecreaseStreamRetentionPeriodResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DeleteStreamRequest &, const Model::DeleteStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DeleteStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DeregisterStreamConsumerRequest &, const Model::DeregisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DeregisterStreamConsumerResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DescribeLimitsRequest &, const Model::DescribeLimitsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DescribeLimitsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DescribeStreamRequest &, const Model::DescribeStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DescribeStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DescribeStreamConsumerRequest &, const Model::DescribeStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DescribeStreamConsumerResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DescribeStreamSummaryRequest &, const Model::DescribeStreamSummaryOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DescribeStreamSummaryResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::DisableEnhancedMonitoringRequest &, const Model::DisableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::DisableEnhancedMonitoringResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::EnableEnhancedMonitoringRequest &, const Model::EnableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::EnableEnhancedMonitoringResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::GetRecordsRequest &, const Model::GetRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::GetRecordsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::GetShardIteratorRequest &, const Model::GetShardIteratorOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::GetShardIteratorResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::IncreaseStreamRetentionPeriodRequest &, const Model::IncreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::IncreaseStreamRetentionPeriodResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::ListShardsRequest &, const Model::ListShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::ListShardsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::ListStreamConsumersRequest &, const Model::ListStreamConsumersOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::ListStreamConsumersResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::ListStreamsRequest &, const Model::ListStreamsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::ListStreamsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::ListTagsForStreamRequest &, const Model::ListTagsForStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::ListTagsForStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::MergeShardsRequest &, const Model::MergeShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::MergeShardsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::PutRecordRequest &, const Model::PutRecordOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::PutRecordResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::PutRecordsRequest &, const Model::PutRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::PutRecordsResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::RegisterStreamConsumerRequest &, const Model::RegisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::RegisterStreamConsumerResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::RemoveTagsFromStreamRequest &, const Model::RemoveTagsFromStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::RemoveTagsFromStreamResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::SplitShardRequest &, const Model::SplitShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::SplitShardResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::StartStreamEncryptionRequest &, const Model::StartStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::StartStreamEncryptionResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::StopStreamEncryptionRequest &, const Model::StopStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::StopStreamEncryptionResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::SubscribeToShardRequest &, const Model::SubscribeToShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::SubscribeToShardResponseReceivedHandler
 
typedef std::function< void(const KinesisClient *, const Model::UpdateShardCountRequest &, const Model::UpdateShardCountOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > Aws::Kinesis::UpdateShardCountResponseReceivedHandler