AWS SDK for C++  1.9.16
AWS SDK for C++
KinesisClient.h
Go to the documentation of this file.
1 
6 #pragma once
30 #include <aws/core/NoResult.h>
33 #include <future>
34 #include <functional>
35 
36 namespace Aws
37 {
38 
39 namespace Http
40 {
41  class HttpClient;
42  class HttpClientFactory;
43 } // namespace Http
44 
45 namespace Utils
46 {
47  template< typename R, typename E> class Outcome;
48 namespace Threading
49 {
50  class Executor;
51 } // namespace Threading
52 } // namespace Utils
53 
54 namespace Auth
55 {
56  class AWSCredentials;
57  class AWSCredentialsProvider;
58 } // namespace Auth
59 
60 namespace Client
61 {
62  class RetryStrategy;
63 } // namespace Client
64 
65 namespace Kinesis
66 {
67 
68 namespace Model
69 {
71  class CreateStreamRequest;
73  class DeleteStreamRequest;
81  class GetRecordsRequest;
84  class ListShardsRequest;
86  class ListStreamsRequest;
88  class MergeShardsRequest;
89  class PutRecordRequest;
90  class PutRecordsRequest;
93  class SplitShardRequest;
98 
127 
128  typedef std::future<AddTagsToStreamOutcome> AddTagsToStreamOutcomeCallable;
129  typedef std::future<CreateStreamOutcome> CreateStreamOutcomeCallable;
130  typedef std::future<DecreaseStreamRetentionPeriodOutcome> DecreaseStreamRetentionPeriodOutcomeCallable;
131  typedef std::future<DeleteStreamOutcome> DeleteStreamOutcomeCallable;
132  typedef std::future<DeregisterStreamConsumerOutcome> DeregisterStreamConsumerOutcomeCallable;
133  typedef std::future<DescribeLimitsOutcome> DescribeLimitsOutcomeCallable;
134  typedef std::future<DescribeStreamOutcome> DescribeStreamOutcomeCallable;
135  typedef std::future<DescribeStreamConsumerOutcome> DescribeStreamConsumerOutcomeCallable;
136  typedef std::future<DescribeStreamSummaryOutcome> DescribeStreamSummaryOutcomeCallable;
137  typedef std::future<DisableEnhancedMonitoringOutcome> DisableEnhancedMonitoringOutcomeCallable;
138  typedef std::future<EnableEnhancedMonitoringOutcome> EnableEnhancedMonitoringOutcomeCallable;
139  typedef std::future<GetRecordsOutcome> GetRecordsOutcomeCallable;
140  typedef std::future<GetShardIteratorOutcome> GetShardIteratorOutcomeCallable;
141  typedef std::future<IncreaseStreamRetentionPeriodOutcome> IncreaseStreamRetentionPeriodOutcomeCallable;
142  typedef std::future<ListShardsOutcome> ListShardsOutcomeCallable;
143  typedef std::future<ListStreamConsumersOutcome> ListStreamConsumersOutcomeCallable;
144  typedef std::future<ListStreamsOutcome> ListStreamsOutcomeCallable;
145  typedef std::future<ListTagsForStreamOutcome> ListTagsForStreamOutcomeCallable;
146  typedef std::future<MergeShardsOutcome> MergeShardsOutcomeCallable;
147  typedef std::future<PutRecordOutcome> PutRecordOutcomeCallable;
148  typedef std::future<PutRecordsOutcome> PutRecordsOutcomeCallable;
149  typedef std::future<RegisterStreamConsumerOutcome> RegisterStreamConsumerOutcomeCallable;
150  typedef std::future<RemoveTagsFromStreamOutcome> RemoveTagsFromStreamOutcomeCallable;
151  typedef std::future<SplitShardOutcome> SplitShardOutcomeCallable;
152  typedef std::future<StartStreamEncryptionOutcome> StartStreamEncryptionOutcomeCallable;
153  typedef std::future<StopStreamEncryptionOutcome> StopStreamEncryptionOutcomeCallable;
154  typedef std::future<SubscribeToShardOutcome> SubscribeToShardOutcomeCallable;
155  typedef std::future<UpdateShardCountOutcome> UpdateShardCountOutcomeCallable;
156 } // namespace Model
157 
158  class KinesisClient;
159 
160  typedef std::function<void(const KinesisClient*, const Model::AddTagsToStreamRequest&, const Model::AddTagsToStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > AddTagsToStreamResponseReceivedHandler;
161  typedef std::function<void(const KinesisClient*, const Model::CreateStreamRequest&, const Model::CreateStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > CreateStreamResponseReceivedHandler;
162  typedef std::function<void(const KinesisClient*, const Model::DecreaseStreamRetentionPeriodRequest&, const Model::DecreaseStreamRetentionPeriodOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DecreaseStreamRetentionPeriodResponseReceivedHandler;
163  typedef std::function<void(const KinesisClient*, const Model::DeleteStreamRequest&, const Model::DeleteStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DeleteStreamResponseReceivedHandler;
164  typedef std::function<void(const KinesisClient*, const Model::DeregisterStreamConsumerRequest&, const Model::DeregisterStreamConsumerOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DeregisterStreamConsumerResponseReceivedHandler;
165  typedef std::function<void(const KinesisClient*, const Model::DescribeLimitsRequest&, const Model::DescribeLimitsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeLimitsResponseReceivedHandler;
166  typedef std::function<void(const KinesisClient*, const Model::DescribeStreamRequest&, const Model::DescribeStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeStreamResponseReceivedHandler;
167  typedef std::function<void(const KinesisClient*, const Model::DescribeStreamConsumerRequest&, const Model::DescribeStreamConsumerOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeStreamConsumerResponseReceivedHandler;
168  typedef std::function<void(const KinesisClient*, const Model::DescribeStreamSummaryRequest&, const Model::DescribeStreamSummaryOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeStreamSummaryResponseReceivedHandler;
169  typedef std::function<void(const KinesisClient*, const Model::DisableEnhancedMonitoringRequest&, const Model::DisableEnhancedMonitoringOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DisableEnhancedMonitoringResponseReceivedHandler;
170  typedef std::function<void(const KinesisClient*, const Model::EnableEnhancedMonitoringRequest&, const Model::EnableEnhancedMonitoringOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > EnableEnhancedMonitoringResponseReceivedHandler;
171  typedef std::function<void(const KinesisClient*, const Model::GetRecordsRequest&, const Model::GetRecordsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > GetRecordsResponseReceivedHandler;
172  typedef std::function<void(const KinesisClient*, const Model::GetShardIteratorRequest&, const Model::GetShardIteratorOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > GetShardIteratorResponseReceivedHandler;
173  typedef std::function<void(const KinesisClient*, const Model::IncreaseStreamRetentionPeriodRequest&, const Model::IncreaseStreamRetentionPeriodOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > IncreaseStreamRetentionPeriodResponseReceivedHandler;
174  typedef std::function<void(const KinesisClient*, const Model::ListShardsRequest&, const Model::ListShardsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListShardsResponseReceivedHandler;
175  typedef std::function<void(const KinesisClient*, const Model::ListStreamConsumersRequest&, const Model::ListStreamConsumersOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListStreamConsumersResponseReceivedHandler;
176  typedef std::function<void(const KinesisClient*, const Model::ListStreamsRequest&, const Model::ListStreamsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListStreamsResponseReceivedHandler;
177  typedef std::function<void(const KinesisClient*, const Model::ListTagsForStreamRequest&, const Model::ListTagsForStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListTagsForStreamResponseReceivedHandler;
178  typedef std::function<void(const KinesisClient*, const Model::MergeShardsRequest&, const Model::MergeShardsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > MergeShardsResponseReceivedHandler;
179  typedef std::function<void(const KinesisClient*, const Model::PutRecordRequest&, const Model::PutRecordOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > PutRecordResponseReceivedHandler;
180  typedef std::function<void(const KinesisClient*, const Model::PutRecordsRequest&, const Model::PutRecordsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > PutRecordsResponseReceivedHandler;
181  typedef std::function<void(const KinesisClient*, const Model::RegisterStreamConsumerRequest&, const Model::RegisterStreamConsumerOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > RegisterStreamConsumerResponseReceivedHandler;
182  typedef std::function<void(const KinesisClient*, const Model::RemoveTagsFromStreamRequest&, const Model::RemoveTagsFromStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > RemoveTagsFromStreamResponseReceivedHandler;
183  typedef std::function<void(const KinesisClient*, const Model::SplitShardRequest&, const Model::SplitShardOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > SplitShardResponseReceivedHandler;
184  typedef std::function<void(const KinesisClient*, const Model::StartStreamEncryptionRequest&, const Model::StartStreamEncryptionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > StartStreamEncryptionResponseReceivedHandler;
185  typedef std::function<void(const KinesisClient*, const Model::StopStreamEncryptionRequest&, const Model::StopStreamEncryptionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > StopStreamEncryptionResponseReceivedHandler;
186  typedef std::function<void(const KinesisClient*, const Model::SubscribeToShardRequest&, const Model::SubscribeToShardOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > SubscribeToShardResponseReceivedHandler;
187  typedef std::function<void(const KinesisClient*, const Model::UpdateShardCountRequest&, const Model::UpdateShardCountOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > UpdateShardCountResponseReceivedHandler;
188 
195  {
196  public:
198 
204 
210 
215  KinesisClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
217 
218  virtual ~KinesisClient();
219 
220 
234 
250 
265  virtual void AddTagsToStreamAsync(const Model::AddTagsToStreamRequest& request, const AddTagsToStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
266 
304 
344 
383  virtual void CreateStreamAsync(const Model::CreateStreamRequest& request, const CreateStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
384 
396 
410 
423  virtual void DecreaseStreamRetentionPeriodAsync(const Model::DecreaseStreamRetentionPeriodRequest& request, const DecreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
424 
445 
468 
490  virtual void DeleteStreamAsync(const Model::DeleteStreamRequest& request, const DeleteStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
491 
506 
523 
539  virtual void DeregisterStreamConsumerAsync(const Model::DeregisterStreamConsumerRequest& request, const DeregisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
540 
550 
562 
573  virtual void DescribeLimitsAsync(const Model::DescribeLimitsRequest& request, const DescribeLimitsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
574 
594 
616 
637  virtual void DescribeStreamAsync(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
638 
653 
670 
686  virtual void DescribeStreamConsumerAsync(const Model::DescribeStreamConsumerRequest& request, const DescribeStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
687 
699 
713 
726  virtual void DescribeStreamSummaryAsync(const Model::DescribeStreamSummaryRequest& request, const DescribeStreamSummaryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
727 
734 
743 
751  virtual void DisableEnhancedMonitoringAsync(const Model::DisableEnhancedMonitoringRequest& request, const DisableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
752 
760 
770 
779  virtual void EnableEnhancedMonitoringAsync(const Model::EnableEnhancedMonitoringRequest& request, const EnableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
780 
838 
898 
957  virtual void GetRecordsAsync(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
958 
999 
1042 
1084  virtual void GetShardIteratorAsync(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1085 
1101 
1119 
1136  virtual void IncreaseStreamRetentionPeriodAsync(const Model::IncreaseStreamRetentionPeriodRequest& request, const IncreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1137 
1152 
1169 
1185  virtual void ListShardsAsync(const Model::ListShardsRequest& request, const ListShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1186 
1195 
1206 
1216  virtual void ListStreamConsumersAsync(const Model::ListStreamConsumersRequest& request, const ListStreamConsumersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1217 
1237 
1259 
1280  virtual void ListStreamsAsync(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1281 
1289 
1299 
1308  virtual void ListTagsForStreamAsync(const Model::ListTagsForStreamRequest& request, const ListTagsForStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1309 
1349 
1391 
1432  virtual void MergeShardsAsync(const Model::MergeShardsRequest& request, const MergeShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1433 
1477 
1523 
1568  virtual void PutRecordAsync(const Model::PutRecordRequest& request, const PutRecordResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1569 
1634 
1701 
1767  virtual void PutRecordsAsync(const Model::PutRecordsRequest& request, const PutRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1768 
1788 
1810 
1831  virtual void RegisterStreamConsumerAsync(const Model::RegisterStreamConsumerRequest& request, const RegisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1832 
1843 
1856 
1868  virtual void RemoveTagsFromStreamAsync(const Model::RemoveTagsFromStreamRequest& request, const RemoveTagsFromStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1869 
1919 
1971 
2022  virtual void SplitShardAsync(const Model::SplitShardRequest& request, const SplitShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2023 
2044 
2067 
2089  virtual void StartStreamEncryptionAsync(const Model::StartStreamEncryptionRequest& request, const StartStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2090 
2111 
2134 
2156  virtual void StopStreamEncryptionAsync(const Model::StopStreamEncryptionRequest& request, const StopStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2157 
2187 
2219 
2250  virtual void SubscribeToShardAsync(Model::SubscribeToShardRequest& request, const SubscribeToShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2251 
2287 
2325 
2362  virtual void UpdateShardCountAsync(const Model::UpdateShardCountRequest& request, const UpdateShardCountResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2363 
2364 
2365  void OverrideEndpoint(const Aws::String& endpoint);
2366  private:
2367  void init(const Aws::Client::ClientConfiguration& clientConfiguration);
2368  void AddTagsToStreamAsyncHelper(const Model::AddTagsToStreamRequest& request, const AddTagsToStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2369  void CreateStreamAsyncHelper(const Model::CreateStreamRequest& request, const CreateStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2370  void DecreaseStreamRetentionPeriodAsyncHelper(const Model::DecreaseStreamRetentionPeriodRequest& request, const DecreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2371  void DeleteStreamAsyncHelper(const Model::DeleteStreamRequest& request, const DeleteStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2372  void DeregisterStreamConsumerAsyncHelper(const Model::DeregisterStreamConsumerRequest& request, const DeregisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2373  void DescribeLimitsAsyncHelper(const Model::DescribeLimitsRequest& request, const DescribeLimitsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2374  void DescribeStreamAsyncHelper(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2375  void DescribeStreamConsumerAsyncHelper(const Model::DescribeStreamConsumerRequest& request, const DescribeStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2376  void DescribeStreamSummaryAsyncHelper(const Model::DescribeStreamSummaryRequest& request, const DescribeStreamSummaryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2377  void DisableEnhancedMonitoringAsyncHelper(const Model::DisableEnhancedMonitoringRequest& request, const DisableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2378  void EnableEnhancedMonitoringAsyncHelper(const Model::EnableEnhancedMonitoringRequest& request, const EnableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2379  void GetRecordsAsyncHelper(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2380  void GetShardIteratorAsyncHelper(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2381  void IncreaseStreamRetentionPeriodAsyncHelper(const Model::IncreaseStreamRetentionPeriodRequest& request, const IncreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2382  void ListShardsAsyncHelper(const Model::ListShardsRequest& request, const ListShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2383  void ListStreamConsumersAsyncHelper(const Model::ListStreamConsumersRequest& request, const ListStreamConsumersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2384  void ListStreamsAsyncHelper(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2385  void ListTagsForStreamAsyncHelper(const Model::ListTagsForStreamRequest& request, const ListTagsForStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2386  void MergeShardsAsyncHelper(const Model::MergeShardsRequest& request, const MergeShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2387  void PutRecordAsyncHelper(const Model::PutRecordRequest& request, const PutRecordResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2388  void PutRecordsAsyncHelper(const Model::PutRecordsRequest& request, const PutRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2389  void RegisterStreamConsumerAsyncHelper(const Model::RegisterStreamConsumerRequest& request, const RegisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2390  void RemoveTagsFromStreamAsyncHelper(const Model::RemoveTagsFromStreamRequest& request, const RemoveTagsFromStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2391  void SplitShardAsyncHelper(const Model::SplitShardRequest& request, const SplitShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2392  void StartStreamEncryptionAsyncHelper(const Model::StartStreamEncryptionRequest& request, const StartStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2393  void StopStreamEncryptionAsyncHelper(const Model::StopStreamEncryptionRequest& request, const StopStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2394  void SubscribeToShardAsyncHelper(Model::SubscribeToShardRequest& request, const SubscribeToShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2395  void UpdateShardCountAsyncHelper(const Model::UpdateShardCountRequest& request, const UpdateShardCountResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2396 
2397  Aws::String m_uri;
2398  Aws::String m_configScheme;
2399  std::shared_ptr<Aws::Utils::Threading::Executor> m_executor;
2400  };
2401 
2402 } // namespace Kinesis
2403 } // namespace Aws
Aws::Kinesis::KinesisClient::DescribeStreamSummaryAsync
virtual void DescribeStreamSummaryAsync(const Model::DescribeStreamSummaryRequest &request, const DescribeStreamSummaryResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient
Definition: KinesisClient.h:195
Aws::DirectoryService::Model::LDAPSType::NOT_SET
@ NOT_SET
Aws::Kinesis::KinesisClient::SubscribeToShardCallable
virtual Model::SubscribeToShardOutcomeCallable SubscribeToShardCallable(Model::SubscribeToShardRequest &request) const
Aws::Kinesis::Model::PutRecordsRequest
Definition: PutRecordsRequest.h:27
Aws::Kinesis::Model::StartStreamEncryptionOutcomeCallable
std::future< StartStreamEncryptionOutcome > StartStreamEncryptionOutcomeCallable
Definition: KinesisClient.h:152
Aws::Kinesis::EnableEnhancedMonitoringResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::EnableEnhancedMonitoringRequest &, const Model::EnableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > EnableEnhancedMonitoringResponseReceivedHandler
Definition: KinesisClient.h:170
KinesisErrors.h
Aws::Kinesis::KinesisClient::SubscribeToShardAsync
virtual void SubscribeToShardAsync(Model::SubscribeToShardRequest &request, const SubscribeToShardResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::PutRecordsOutcome
Aws::Utils::Outcome< PutRecordsResult, KinesisError > PutRecordsOutcome
Definition: KinesisClient.h:119
Aws::Kinesis::KinesisClient::CreateStreamAsync
virtual void CreateStreamAsync(const Model::CreateStreamRequest &request, const CreateStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::BASECLASS
Aws::Client::AWSJsonClient BASECLASS
Definition: KinesisClient.h:197
Aws::Kinesis::Model::UpdateShardCountOutcome
Aws::Utils::Outcome< UpdateShardCountResult, KinesisError > UpdateShardCountOutcome
Definition: KinesisClient.h:126
Aws::Kinesis::Model::StartStreamEncryptionOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > StartStreamEncryptionOutcome
Definition: KinesisClient.h:123
Aws::Kinesis::KinesisClient::GetShardIterator
virtual Model::GetShardIteratorOutcome GetShardIterator(const Model::GetShardIteratorRequest &request) const
Aws::Kinesis::Model::ListStreamConsumersOutcomeCallable
std::future< ListStreamConsumersOutcome > ListStreamConsumersOutcomeCallable
Definition: KinesisClient.h:143
Aws::Kinesis::KinesisClient::ListStreamConsumersCallable
virtual Model::ListStreamConsumersOutcomeCallable ListStreamConsumersCallable(const Model::ListStreamConsumersRequest &request) const
Aws::Kinesis::KinesisClient::DescribeLimitsAsync
virtual void DescribeLimitsAsync(const Model::DescribeLimitsRequest &request, const DescribeLimitsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::IncreaseStreamRetentionPeriodOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > IncreaseStreamRetentionPeriodOutcome
Definition: KinesisClient.h:112
Aws::Kinesis::KinesisClient::DescribeStreamAsync
virtual void DescribeStreamAsync(const Model::DescribeStreamRequest &request, const DescribeStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::PutRecordRequest
Definition: PutRecordRequest.h:27
Aws::Kinesis::KinesisClient::PutRecord
virtual Model::PutRecordOutcome PutRecord(const Model::PutRecordRequest &request) const
Aws::Kinesis::KinesisClient::SplitShardAsync
virtual void SplitShardAsync(const Model::SplitShardRequest &request, const SplitShardResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::GetRecordsRequest
Definition: GetRecordsRequest.h:25
Aws::Kinesis::Model::AddTagsToStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > AddTagsToStreamOutcome
Definition: KinesisClient.h:97
Aws::Kinesis::KinesisClient::DecreaseStreamRetentionPeriodCallable
virtual Model::DecreaseStreamRetentionPeriodOutcomeCallable DecreaseStreamRetentionPeriodCallable(const Model::DecreaseStreamRetentionPeriodRequest &request) const
AWSError.h
Aws::Kinesis::Model::AddTagsToStreamOutcomeCallable
std::future< AddTagsToStreamOutcome > AddTagsToStreamOutcomeCallable
Definition: KinesisClient.h:128
Aws::Kinesis::MergeShardsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::MergeShardsRequest &, const Model::MergeShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > MergeShardsResponseReceivedHandler
Definition: KinesisClient.h:178
Aws::Kinesis::DescribeLimitsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DescribeLimitsRequest &, const Model::DescribeLimitsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeLimitsResponseReceivedHandler
Definition: KinesisClient.h:165
Aws::Kinesis::Model::RegisterStreamConsumerRequest
Definition: RegisterStreamConsumerRequest.h:22
Aws::Kinesis::Model::ListShardsRequest
Definition: ListShardsRequest.h:24
Aws::Kinesis::IncreaseStreamRetentionPeriodResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::IncreaseStreamRetentionPeriodRequest &, const Model::IncreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > IncreaseStreamRetentionPeriodResponseReceivedHandler
Definition: KinesisClient.h:173
Aws::Kinesis::KinesisClient::MergeShardsAsync
virtual void MergeShardsAsync(const Model::MergeShardsRequest &request, const MergeShardsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::MergeShards
virtual Model::MergeShardsOutcome MergeShards(const Model::MergeShardsRequest &request) const
Aws::Kinesis::KinesisClient::IncreaseStreamRetentionPeriodCallable
virtual Model::IncreaseStreamRetentionPeriodOutcomeCallable IncreaseStreamRetentionPeriodCallable(const Model::IncreaseStreamRetentionPeriodRequest &request) const
Aws::Kinesis::KinesisClient::PutRecordsAsync
virtual void PutRecordsAsync(const Model::PutRecordsRequest &request, const PutRecordsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::DeleteStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DeleteStreamOutcome
Definition: KinesisClient.h:102
Aws::Kinesis::Model::DescribeStreamSummaryOutcomeCallable
std::future< DescribeStreamSummaryOutcome > DescribeStreamSummaryOutcomeCallable
Definition: KinesisClient.h:136
Aws::Kinesis::KinesisClient::EnableEnhancedMonitoring
virtual Model::EnableEnhancedMonitoringOutcome EnableEnhancedMonitoring(const Model::EnableEnhancedMonitoringRequest &request) const
Aws::Kinesis::PutRecordsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::PutRecordsRequest &, const Model::PutRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordsResponseReceivedHandler
Definition: KinesisClient.h:180
EnableEnhancedMonitoringResult.h
Aws::Kinesis::KinesisClient::AddTagsToStreamCallable
virtual Model::AddTagsToStreamOutcomeCallable AddTagsToStreamCallable(const Model::AddTagsToStreamRequest &request) const
Aws::Kinesis::KinesisClient::ListStreamConsumers
virtual Model::ListStreamConsumersOutcome ListStreamConsumers(const Model::ListStreamConsumersRequest &request) const
Aws::Kinesis::KinesisClient::UpdateShardCountCallable
virtual Model::UpdateShardCountOutcomeCallable UpdateShardCountCallable(const Model::UpdateShardCountRequest &request) const
Aws::Kinesis::Model::EnableEnhancedMonitoringRequest
Definition: EnableEnhancedMonitoringRequest.h:28
Aws::Kinesis::Model::SplitShardRequest
Definition: SplitShardRequest.h:26
Aws::Kinesis::KinesisClient::DisableEnhancedMonitoring
virtual Model::DisableEnhancedMonitoringOutcome DisableEnhancedMonitoring(const Model::DisableEnhancedMonitoringRequest &request) const
Aws::Kinesis::Model::ListShardsOutcomeCallable
std::future< ListShardsOutcome > ListShardsOutcomeCallable
Definition: KinesisClient.h:142
Aws::Kinesis::KinesisClient::GetRecordsCallable
virtual Model::GetRecordsOutcomeCallable GetRecordsCallable(const Model::GetRecordsRequest &request) const
Aws::Kinesis::KinesisClient::KinesisClient
KinesisClient(const Aws::Auth::AWSCredentials &credentials, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::Kinesis::KinesisClient::GetRecords
virtual Model::GetRecordsOutcome GetRecords(const Model::GetRecordsRequest &request) const
Aws::Kinesis::KinesisClient::DisableEnhancedMonitoringAsync
virtual void DisableEnhancedMonitoringAsync(const Model::DisableEnhancedMonitoringRequest &request, const DisableEnhancedMonitoringResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::GetShardIteratorOutcomeCallable
std::future< GetShardIteratorOutcome > GetShardIteratorOutcomeCallable
Definition: KinesisClient.h:140
Aws::Kinesis::Model::ListStreamConsumersRequest
Definition: ListStreamConsumersRequest.h:23
PutRecordsResult.h
Aws::Kinesis::ListStreamsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListStreamsRequest &, const Model::ListStreamsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListStreamsResponseReceivedHandler
Definition: KinesisClient.h:176
Aws::Kinesis::Model::RemoveTagsFromStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > RemoveTagsFromStreamOutcome
Definition: KinesisClient.h:121
Aws::Kinesis::Model::ListStreamsOutcomeCallable
std::future< ListStreamsOutcome > ListStreamsOutcomeCallable
Definition: KinesisClient.h:144
Aws::Kinesis::StopStreamEncryptionResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::StopStreamEncryptionRequest &, const Model::StopStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StopStreamEncryptionResponseReceivedHandler
Definition: KinesisClient.h:185
Aws::Kinesis::StartStreamEncryptionResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::StartStreamEncryptionRequest &, const Model::StartStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StartStreamEncryptionResponseReceivedHandler
Definition: KinesisClient.h:184
Aws::Kinesis::KinesisClient::DescribeStreamConsumerAsync
virtual void DescribeStreamConsumerAsync(const Model::DescribeStreamConsumerRequest &request, const DescribeStreamConsumerResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::DescribeStreamConsumer
virtual Model::DescribeStreamConsumerOutcome DescribeStreamConsumer(const Model::DescribeStreamConsumerRequest &request) const
Aws::Kinesis::Model::SplitShardOutcomeCallable
std::future< SplitShardOutcome > SplitShardOutcomeCallable
Definition: KinesisClient.h:151
DescribeStreamResult.h
Aws::Kinesis::KinesisClient::KinesisClient
KinesisClient(const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::Kinesis::Model::DescribeStreamConsumerOutcomeCallable
std::future< DescribeStreamConsumerOutcome > DescribeStreamConsumerOutcomeCallable
Definition: KinesisClient.h:135
Aws::Kinesis::Model::DisableEnhancedMonitoringOutcome
Aws::Utils::Outcome< DisableEnhancedMonitoringResult, KinesisError > DisableEnhancedMonitoringOutcome
Definition: KinesisClient.h:108
Aws::Kinesis::Model::GetShardIteratorRequest
Definition: GetShardIteratorRequest.h:28
Aws::Kinesis::Model::ListStreamConsumersOutcome
Aws::Utils::Outcome< ListStreamConsumersResult, KinesisError > ListStreamConsumersOutcome
Definition: KinesisClient.h:114
Aws::Kinesis::Model::DisableEnhancedMonitoringRequest
Definition: DisableEnhancedMonitoringRequest.h:28
Aws::Kinesis::UpdateShardCountResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::UpdateShardCountRequest &, const Model::UpdateShardCountOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > UpdateShardCountResponseReceivedHandler
Definition: KinesisClient.h:187
Aws::Kinesis::KinesisClient::RegisterStreamConsumerCallable
virtual Model::RegisterStreamConsumerOutcomeCallable RegisterStreamConsumerCallable(const Model::RegisterStreamConsumerRequest &request) const
Aws::Kinesis::KinesisClient::ListStreamConsumersAsync
virtual void ListStreamConsumersAsync(const Model::ListStreamConsumersRequest &request, const ListStreamConsumersResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::IncreaseStreamRetentionPeriodRequest
Definition: IncreaseStreamRetentionPeriodRequest.h:26
Aws::Kinesis::ListTagsForStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListTagsForStreamRequest &, const Model::ListTagsForStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListTagsForStreamResponseReceivedHandler
Definition: KinesisClient.h:177
Aws::Kinesis::RegisterStreamConsumerResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::RegisterStreamConsumerRequest &, const Model::RegisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > RegisterStreamConsumerResponseReceivedHandler
Definition: KinesisClient.h:181
Aws::Kinesis::KinesisClient::DescribeStreamSummaryCallable
virtual Model::DescribeStreamSummaryOutcomeCallable DescribeStreamSummaryCallable(const Model::DescribeStreamSummaryRequest &request) const
Aws::Kinesis::KinesisClient::SubscribeToShard
virtual Model::SubscribeToShardOutcome SubscribeToShard(Model::SubscribeToShardRequest &request) const
Aws::Kinesis::KinesisClient::ListStreamsCallable
virtual Model::ListStreamsOutcomeCallable ListStreamsCallable(const Model::ListStreamsRequest &request) const
PutRecordResult.h
GetShardIteratorResult.h
Aws::Kinesis::KinesisClient::DeleteStreamCallable
virtual Model::DeleteStreamOutcomeCallable DeleteStreamCallable(const Model::DeleteStreamRequest &request) const
Aws::Kinesis::KinesisClient::DeregisterStreamConsumer
virtual Model::DeregisterStreamConsumerOutcome DeregisterStreamConsumer(const Model::DeregisterStreamConsumerRequest &request) const
AsyncCallerContext.h
Aws::Kinesis::DescribeStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DescribeStreamRequest &, const Model::DescribeStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamResponseReceivedHandler
Definition: KinesisClient.h:166
Aws::Kinesis::Model::GetRecordsOutcomeCallable
std::future< GetRecordsOutcome > GetRecordsOutcomeCallable
Definition: KinesisClient.h:139
Aws::Kinesis::PutRecordResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::PutRecordRequest &, const Model::PutRecordOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordResponseReceivedHandler
Definition: KinesisClient.h:179
Aws::Kinesis::Model::DescribeStreamSummaryOutcome
Aws::Utils::Outcome< DescribeStreamSummaryResult, KinesisError > DescribeStreamSummaryOutcome
Definition: KinesisClient.h:107
Aws::Kinesis::ListShardsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListShardsRequest &, const Model::ListShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListShardsResponseReceivedHandler
Definition: KinesisClient.h:174
Aws::Kinesis::SubscribeToShardResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::SubscribeToShardRequest &, const Model::SubscribeToShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SubscribeToShardResponseReceivedHandler
Definition: KinesisClient.h:186
Aws::Kinesis::KinesisClient::OverrideEndpoint
void OverrideEndpoint(const Aws::String &endpoint)
AWS_KINESIS_API
#define AWS_KINESIS_API
Definition: Kinesis_EXPORTS.h:28
Aws::Kinesis::KinesisClient::GetShardIteratorAsync
virtual void GetShardIteratorAsync(const Model::GetShardIteratorRequest &request, const GetShardIteratorResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::ListStreamsRequest
Definition: ListStreamsRequest.h:26
Aws::Kinesis::KinesisClient::DecreaseStreamRetentionPeriodAsync
virtual void DecreaseStreamRetentionPeriodAsync(const Model::DecreaseStreamRetentionPeriodRequest &request, const DecreaseStreamRetentionPeriodResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::ListStreamConsumersResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListStreamConsumersRequest &, const Model::ListStreamConsumersOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListStreamConsumersResponseReceivedHandler
Definition: KinesisClient.h:175
DescribeStreamConsumerResult.h
Aws::Kinesis::Model::StopStreamEncryptionOutcomeCallable
std::future< StopStreamEncryptionOutcome > StopStreamEncryptionOutcomeCallable
Definition: KinesisClient.h:153
Aws::Kinesis::Model::StopStreamEncryptionRequest
Definition: StopStreamEncryptionRequest.h:23
Aws::Kinesis::DecreaseStreamRetentionPeriodResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DecreaseStreamRetentionPeriodRequest &, const Model::DecreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DecreaseStreamRetentionPeriodResponseReceivedHandler
Definition: KinesisClient.h:162
Aws::Kinesis::Model::PutRecordOutcomeCallable
std::future< PutRecordOutcome > PutRecordOutcomeCallable
Definition: KinesisClient.h:147
ListShardsResult.h
Aws::Kinesis::Model::GetShardIteratorOutcome
Aws::Utils::Outcome< GetShardIteratorResult, KinesisError > GetShardIteratorOutcome
Definition: KinesisClient.h:111
Aws::Kinesis::Model::UpdateShardCountRequest
Definition: UpdateShardCountRequest.h:23
Aws::Kinesis::KinesisClient::EnableEnhancedMonitoringCallable
virtual Model::EnableEnhancedMonitoringOutcomeCallable EnableEnhancedMonitoringCallable(const Model::EnableEnhancedMonitoringRequest &request) const
NoResult.h
Aws::Kinesis::KinesisClient::DeregisterStreamConsumerCallable
virtual Model::DeregisterStreamConsumerOutcomeCallable DeregisterStreamConsumerCallable(const Model::DeregisterStreamConsumerRequest &request) const
Aws::Kinesis::KinesisClient::KinesisClient
KinesisClient(const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::Kinesis::KinesisClient::DeregisterStreamConsumerAsync
virtual void DeregisterStreamConsumerAsync(const Model::DeregisterStreamConsumerRequest &request, const DeregisterStreamConsumerResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::ListTagsForStream
virtual Model::ListTagsForStreamOutcome ListTagsForStream(const Model::ListTagsForStreamRequest &request) const
Aws::Kinesis::KinesisClient::StartStreamEncryptionCallable
virtual Model::StartStreamEncryptionOutcomeCallable StartStreamEncryptionCallable(const Model::StartStreamEncryptionRequest &request) const
Aws::Kinesis::Model::DescribeStreamOutcome
Aws::Utils::Outcome< DescribeStreamResult, KinesisError > DescribeStreamOutcome
Definition: KinesisClient.h:105
Aws::Kinesis::KinesisClient::GetShardIteratorCallable
virtual Model::GetShardIteratorOutcomeCallable GetShardIteratorCallable(const Model::GetShardIteratorRequest &request) const
Aws::Kinesis::KinesisClient::SplitShardCallable
virtual Model::SplitShardOutcomeCallable SplitShardCallable(const Model::SplitShardRequest &request) const
Aws::Kinesis::Model::ListShardsOutcome
Aws::Utils::Outcome< ListShardsResult, KinesisError > ListShardsOutcome
Definition: KinesisClient.h:113
Aws::Kinesis::Model::DeleteStreamOutcomeCallable
std::future< DeleteStreamOutcome > DeleteStreamOutcomeCallable
Definition: KinesisClient.h:131
Aws::Kinesis::Model::DescribeStreamConsumerRequest
Definition: DescribeStreamConsumerRequest.h:22
Aws::Kinesis::Model::SplitShardOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > SplitShardOutcome
Definition: KinesisClient.h:122
Aws::Client::ClientConfiguration
Definition: ClientConfiguration.h:53
Aws::Kinesis::KinesisClient::DescribeLimitsCallable
virtual Model::DescribeLimitsOutcomeCallable DescribeLimitsCallable(const Model::DescribeLimitsRequest &request) const
Aws::Kinesis::KinesisClient::UpdateShardCount
virtual Model::UpdateShardCountOutcome UpdateShardCount(const Model::UpdateShardCountRequest &request) const
Aws::Kinesis::KinesisClient::ListStreamsAsync
virtual void ListStreamsAsync(const Model::ListStreamsRequest &request, const ListStreamsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::AddTagsToStream
virtual Model::AddTagsToStreamOutcome AddTagsToStream(const Model::AddTagsToStreamRequest &request) const
Aws::Kinesis::KinesisClient::StopStreamEncryptionAsync
virtual void StopStreamEncryptionAsync(const Model::StopStreamEncryptionRequest &request, const StopStreamEncryptionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::DecreaseStreamRetentionPeriodOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DecreaseStreamRetentionPeriodOutcome
Definition: KinesisClient.h:101
Aws::Kinesis::Model::ListTagsForStreamRequest
Definition: ListTagsForStreamRequest.h:26
Aws::Kinesis::Model::DeleteStreamRequest
Definition: DeleteStreamRequest.h:25
Aws::Kinesis::Model::DescribeLimitsOutcome
Aws::Utils::Outcome< DescribeLimitsResult, KinesisError > DescribeLimitsOutcome
Definition: KinesisClient.h:104
Aws::Kinesis::Model::UpdateShardCountOutcomeCallable
std::future< UpdateShardCountOutcome > UpdateShardCountOutcomeCallable
Definition: KinesisClient.h:155
Aws::Kinesis::KinesisClient::CreateStreamCallable
virtual Model::CreateStreamOutcomeCallable CreateStreamCallable(const Model::CreateStreamRequest &request) const
Aws::Kinesis::KinesisClient::PutRecords
virtual Model::PutRecordsOutcome PutRecords(const Model::PutRecordsRequest &request) const
Aws::Kinesis::KinesisClient::PutRecordsCallable
virtual Model::PutRecordsOutcomeCallable PutRecordsCallable(const Model::PutRecordsRequest &request) const
Aws::Kinesis::KinesisClient::ListTagsForStreamCallable
virtual Model::ListTagsForStreamOutcomeCallable ListTagsForStreamCallable(const Model::ListTagsForStreamRequest &request) const
DescribeStreamSummaryResult.h
UpdateShardCountResult.h
Aws::Kinesis::KinesisClient::DeleteStream
virtual Model::DeleteStreamOutcome DeleteStream(const Model::DeleteStreamRequest &request) const
Aws::Kinesis::KinesisClient::IncreaseStreamRetentionPeriod
virtual Model::IncreaseStreamRetentionPeriodOutcome IncreaseStreamRetentionPeriod(const Model::IncreaseStreamRetentionPeriodRequest &request) const
Aws::Kinesis::KinesisClient::ListShardsCallable
virtual Model::ListShardsOutcomeCallable ListShardsCallable(const Model::ListShardsRequest &request) const
Aws::Auth::AWSCredentials
Definition: AWSCredentials.h:19
Aws::Kinesis::KinesisClient::ListShardsAsync
virtual void ListShardsAsync(const Model::ListShardsRequest &request, const ListShardsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::GetShardIteratorResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::GetShardIteratorRequest &, const Model::GetShardIteratorOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetShardIteratorResponseReceivedHandler
Definition: KinesisClient.h:172
Aws::Kinesis::KinesisClient::CreateStream
virtual Model::CreateStreamOutcome CreateStream(const Model::CreateStreamRequest &request) const
Aws::Kinesis::DisableEnhancedMonitoringResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DisableEnhancedMonitoringRequest &, const Model::DisableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DisableEnhancedMonitoringResponseReceivedHandler
Definition: KinesisClient.h:169
Aws::Kinesis::KinesisClient::MergeShardsCallable
virtual Model::MergeShardsOutcomeCallable MergeShardsCallable(const Model::MergeShardsRequest &request) const
Aws::Kinesis::KinesisClient::ListShards
virtual Model::ListShardsOutcome ListShards(const Model::ListShardsRequest &request) const
Aws::Kinesis::KinesisClient::GetRecordsAsync
virtual void GetRecordsAsync(const Model::GetRecordsRequest &request, const GetRecordsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::StopStreamEncryptionCallable
virtual Model::StopStreamEncryptionOutcomeCallable StopStreamEncryptionCallable(const Model::StopStreamEncryptionRequest &request) const
Aws::Kinesis::Model::RemoveTagsFromStreamOutcomeCallable
std::future< RemoveTagsFromStreamOutcome > RemoveTagsFromStreamOutcomeCallable
Definition: KinesisClient.h:150
Aws::Kinesis::RemoveTagsFromStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::RemoveTagsFromStreamRequest &, const Model::RemoveTagsFromStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > RemoveTagsFromStreamResponseReceivedHandler
Definition: KinesisClient.h:182
Aws::Kinesis::KinesisClient::ListTagsForStreamAsync
virtual void ListTagsForStreamAsync(const Model::ListTagsForStreamRequest &request, const ListTagsForStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::DescribeStreamCallable
virtual Model::DescribeStreamOutcomeCallable DescribeStreamCallable(const Model::DescribeStreamRequest &request) const
AWSString.h
Aws::Kinesis::Model::ListTagsForStreamOutcome
Aws::Utils::Outcome< ListTagsForStreamResult, KinesisError > ListTagsForStreamOutcome
Definition: KinesisClient.h:116
Aws::Kinesis::Model::SubscribeToShardRequest
Definition: SubscribeToShardRequest.h:25
Aws::Kinesis::KinesisClient::DecreaseStreamRetentionPeriod
virtual Model::DecreaseStreamRetentionPeriodOutcome DecreaseStreamRetentionPeriod(const Model::DecreaseStreamRetentionPeriodRequest &request) const
Aws::Kinesis::KinesisClient::RemoveTagsFromStreamCallable
virtual Model::RemoveTagsFromStreamOutcomeCallable RemoveTagsFromStreamCallable(const Model::RemoveTagsFromStreamRequest &request) const
Aws::Client::AWSJsonClient
Definition: AWSClient.h:323
Aws::Kinesis::Model::DeregisterStreamConsumerOutcomeCallable
std::future< DeregisterStreamConsumerOutcome > DeregisterStreamConsumerOutcomeCallable
Definition: KinesisClient.h:132
Aws::Kinesis::KinesisClient::~KinesisClient
virtual ~KinesisClient()
Aws::Kinesis::KinesisClient::RemoveTagsFromStream
virtual Model::RemoveTagsFromStreamOutcome RemoveTagsFromStream(const Model::RemoveTagsFromStreamRequest &request) const
Aws::Kinesis::Model::MergeShardsOutcomeCallable
std::future< MergeShardsOutcome > MergeShardsOutcomeCallable
Definition: KinesisClient.h:146
Aws::Kinesis::Model::ListStreamsOutcome
Aws::Utils::Outcome< ListStreamsResult, KinesisError > ListStreamsOutcome
Definition: KinesisClient.h:115
ListStreamConsumersResult.h
Aws::Kinesis::Model::ListTagsForStreamOutcomeCallable
std::future< ListTagsForStreamOutcome > ListTagsForStreamOutcomeCallable
Definition: KinesisClient.h:145
Aws::Kinesis::DeleteStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DeleteStreamRequest &, const Model::DeleteStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeleteStreamResponseReceivedHandler
Definition: KinesisClient.h:163
Aws::Kinesis::KinesisClient::DescribeStreamSummary
virtual Model::DescribeStreamSummaryOutcome DescribeStreamSummary(const Model::DescribeStreamSummaryRequest &request) const
Aws::Kinesis::Model::MergeShardsOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > MergeShardsOutcome
Definition: KinesisClient.h:117
Aws::Kinesis::KinesisClient::UpdateShardCountAsync
virtual void UpdateShardCountAsync(const Model::UpdateShardCountRequest &request, const UpdateShardCountResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::CreateStreamOutcomeCallable
std::future< CreateStreamOutcome > CreateStreamOutcomeCallable
Definition: KinesisClient.h:129
Aws::Kinesis::Model::DescribeLimitsOutcomeCallable
std::future< DescribeLimitsOutcome > DescribeLimitsOutcomeCallable
Definition: KinesisClient.h:133
Kinesis_EXPORTS.h
Aws::Kinesis::CreateStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::CreateStreamRequest &, const Model::CreateStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > CreateStreamResponseReceivedHandler
Definition: KinesisClient.h:161
Aws::Kinesis::Model::PutRecordOutcome
Aws::Utils::Outcome< PutRecordResult, KinesisError > PutRecordOutcome
Definition: KinesisClient.h:118
Aws::Kinesis::Model::SubscribeToShardOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > SubscribeToShardOutcome
Definition: KinesisClient.h:125
Aws::Kinesis::Model::SubscribeToShardOutcomeCallable
std::future< SubscribeToShardOutcome > SubscribeToShardOutcomeCallable
Definition: KinesisClient.h:154
ListTagsForStreamResult.h
Aws::Kinesis::Model::StartStreamEncryptionRequest
Definition: StartStreamEncryptionRequest.h:23
Aws::Kinesis::Model::EnableEnhancedMonitoringOutcomeCallable
std::future< EnableEnhancedMonitoringOutcome > EnableEnhancedMonitoringOutcomeCallable
Definition: KinesisClient.h:138
Aws::Kinesis::KinesisClient::SplitShard
virtual Model::SplitShardOutcome SplitShard(const Model::SplitShardRequest &request) const
Aws::Kinesis::KinesisClient::RegisterStreamConsumer
virtual Model::RegisterStreamConsumerOutcome RegisterStreamConsumer(const Model::RegisterStreamConsumerRequest &request) const
Aws::Kinesis::DescribeStreamSummaryResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DescribeStreamSummaryRequest &, const Model::DescribeStreamSummaryOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamSummaryResponseReceivedHandler
Definition: KinesisClient.h:168
Aws::Kinesis::Model::IncreaseStreamRetentionPeriodOutcomeCallable
std::future< IncreaseStreamRetentionPeriodOutcome > IncreaseStreamRetentionPeriodOutcomeCallable
Definition: KinesisClient.h:141
DescribeLimitsResult.h
Aws::Kinesis::KinesisClient::PutRecordCallable
virtual Model::PutRecordOutcomeCallable PutRecordCallable(const Model::PutRecordRequest &request) const
GetRecordsResult.h
ClientConfiguration.h
Aws::Kinesis::Model::CreateStreamRequest
Definition: CreateStreamRequest.h:26
Aws::Kinesis::Model::CreateStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > CreateStreamOutcome
Definition: KinesisClient.h:100
Aws::Kinesis::Model::RegisterStreamConsumerOutcomeCallable
std::future< RegisterStreamConsumerOutcome > RegisterStreamConsumerOutcomeCallable
Definition: KinesisClient.h:149
Aws::Kinesis::Model::RemoveTagsFromStreamRequest
Definition: RemoveTagsFromStreamRequest.h:27
Aws::Kinesis::Model::StopStreamEncryptionOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > StopStreamEncryptionOutcome
Definition: KinesisClient.h:124
Aws
Definition: AccessManagementClient.h:15
Aws::Kinesis::Model::GetRecordsOutcome
Aws::Utils::Outcome< GetRecordsResult, KinesisError > GetRecordsOutcome
Definition: KinesisClient.h:110
Aws::Kinesis::Model::EnableEnhancedMonitoringOutcome
Aws::Utils::Outcome< EnableEnhancedMonitoringResult, KinesisError > EnableEnhancedMonitoringOutcome
Definition: KinesisClient.h:109
Aws::Kinesis::KinesisClient::IncreaseStreamRetentionPeriodAsync
virtual void IncreaseStreamRetentionPeriodAsync(const Model::IncreaseStreamRetentionPeriodRequest &request, const IncreaseStreamRetentionPeriodResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
HttpTypes.h
Aws::Kinesis::KinesisClient::DescribeStreamConsumerCallable
virtual Model::DescribeStreamConsumerOutcomeCallable DescribeStreamConsumerCallable(const Model::DescribeStreamConsumerRequest &request) const
Aws::Kinesis::DeregisterStreamConsumerResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DeregisterStreamConsumerRequest &, const Model::DeregisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeregisterStreamConsumerResponseReceivedHandler
Definition: KinesisClient.h:164
Aws::Kinesis::KinesisClient::PutRecordAsync
virtual void PutRecordAsync(const Model::PutRecordRequest &request, const PutRecordResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::MergeShardsRequest
Definition: MergeShardsRequest.h:26
Aws::Kinesis::KinesisClient::RegisterStreamConsumerAsync
virtual void RegisterStreamConsumerAsync(const Model::RegisterStreamConsumerRequest &request, const RegisterStreamConsumerResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::RemoveTagsFromStreamAsync
virtual void RemoveTagsFromStreamAsync(const Model::RemoveTagsFromStreamRequest &request, const RemoveTagsFromStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Utils::Outcome
Definition: Outcome.h:26
Aws::Kinesis::KinesisClient::EnableEnhancedMonitoringAsync
virtual void EnableEnhancedMonitoringAsync(const Model::EnableEnhancedMonitoringRequest &request, const EnableEnhancedMonitoringResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::DescribeStreamOutcomeCallable
std::future< DescribeStreamOutcome > DescribeStreamOutcomeCallable
Definition: KinesisClient.h:134
Aws::Kinesis::KinesisClient::DisableEnhancedMonitoringCallable
virtual Model::DisableEnhancedMonitoringOutcomeCallable DisableEnhancedMonitoringCallable(const Model::DisableEnhancedMonitoringRequest &request) const
Aws::String
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
AWSClient.h
Aws::Kinesis::DescribeStreamConsumerResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DescribeStreamConsumerRequest &, const Model::DescribeStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamConsumerResponseReceivedHandler
Definition: KinesisClient.h:167
Aws::Kinesis::Model::DecreaseStreamRetentionPeriodOutcomeCallable
std::future< DecreaseStreamRetentionPeriodOutcome > DecreaseStreamRetentionPeriodOutcomeCallable
Definition: KinesisClient.h:130
Aws::Kinesis::Model::DisableEnhancedMonitoringOutcomeCallable
std::future< DisableEnhancedMonitoringOutcome > DisableEnhancedMonitoringOutcomeCallable
Definition: KinesisClient.h:137
Aws::Kinesis::KinesisClient::DeleteStreamAsync
virtual void DeleteStreamAsync(const Model::DeleteStreamRequest &request, const DeleteStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::AddTagsToStreamRequest
Definition: AddTagsToStreamRequest.h:27
Aws::Kinesis::Model::DecreaseStreamRetentionPeriodRequest
Definition: DecreaseStreamRetentionPeriodRequest.h:26
Aws::Kinesis::GetRecordsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::GetRecordsRequest &, const Model::GetRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetRecordsResponseReceivedHandler
Definition: KinesisClient.h:171
Aws::Kinesis::Model::DeregisterStreamConsumerRequest
Definition: DeregisterStreamConsumerRequest.h:22
Aws::Kinesis::AddTagsToStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::AddTagsToStreamRequest &, const Model::AddTagsToStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > AddTagsToStreamResponseReceivedHandler
Definition: KinesisClient.h:158
Aws::Kinesis::Model::DescribeLimitsRequest
Definition: DescribeLimitsRequest.h:20
Aws::Kinesis::Model::DeregisterStreamConsumerOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DeregisterStreamConsumerOutcome
Definition: KinesisClient.h:103
Aws::Kinesis::KinesisClient::StartStreamEncryptionAsync
virtual void StartStreamEncryptionAsync(const Model::StartStreamEncryptionRequest &request, const StartStreamEncryptionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::Model::DescribeStreamRequest
Definition: DescribeStreamRequest.h:26
Aws::Kinesis::KinesisClient::DescribeLimits
virtual Model::DescribeLimitsOutcome DescribeLimits(const Model::DescribeLimitsRequest &request) const
Aws::Kinesis::Model::PutRecordsOutcomeCallable
std::future< PutRecordsOutcome > PutRecordsOutcomeCallable
Definition: KinesisClient.h:148
DisableEnhancedMonitoringResult.h
Aws::Kinesis::KinesisClient::AddTagsToStreamAsync
virtual void AddTagsToStreamAsync(const Model::AddTagsToStreamRequest &request, const AddTagsToStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Kinesis::KinesisClient::ListStreams
virtual Model::ListStreamsOutcome ListStreams(const Model::ListStreamsRequest &request) const
Aws::Kinesis::KinesisClient::StartStreamEncryption
virtual Model::StartStreamEncryptionOutcome StartStreamEncryption(const Model::StartStreamEncryptionRequest &request) const
Aws::Kinesis::KinesisClient::DescribeStream
virtual Model::DescribeStreamOutcome DescribeStream(const Model::DescribeStreamRequest &request) const
JsonSerializer.h
Aws::Kinesis::KinesisClient::StopStreamEncryption
virtual Model::StopStreamEncryptionOutcome StopStreamEncryption(const Model::StopStreamEncryptionRequest &request) const
Aws::Kinesis::Model::RegisterStreamConsumerOutcome
Aws::Utils::Outcome< RegisterStreamConsumerResult, KinesisError > RegisterStreamConsumerOutcome
Definition: KinesisClient.h:120
ListStreamsResult.h
RegisterStreamConsumerResult.h
Aws::Kinesis::Model::DescribeStreamSummaryRequest
Definition: DescribeStreamSummaryRequest.h:22
Aws::Kinesis::SplitShardResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::SplitShardRequest &, const Model::SplitShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SplitShardResponseReceivedHandler
Definition: KinesisClient.h:183
Aws::Kinesis::Model::DescribeStreamConsumerOutcome
Aws::Utils::Outcome< DescribeStreamConsumerResult, KinesisError > DescribeStreamConsumerOutcome
Definition: KinesisClient.h:106