AWS SDK for C++  1.8.22
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 
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  inline virtual const char* GetServiceClientName() const override { return "Kinesis"; }
221 
222 
235  virtual Model::AddTagsToStreamOutcome AddTagsToStream(const Model::AddTagsToStreamRequest& request) const;
236 
251  virtual Model::AddTagsToStreamOutcomeCallable AddTagsToStreamCallable(const Model::AddTagsToStreamRequest& request) const;
252 
267  virtual void AddTagsToStreamAsync(const Model::AddTagsToStreamRequest& request, const AddTagsToStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
268 
305  virtual Model::CreateStreamOutcome CreateStream(const Model::CreateStreamRequest& request) const;
306 
345  virtual Model::CreateStreamOutcomeCallable CreateStreamCallable(const Model::CreateStreamRequest& request) const;
346 
385  virtual void CreateStreamAsync(const Model::CreateStreamRequest& request, const CreateStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
386 
397  virtual Model::DecreaseStreamRetentionPeriodOutcome DecreaseStreamRetentionPeriod(const Model::DecreaseStreamRetentionPeriodRequest& request) const;
398 
411  virtual Model::DecreaseStreamRetentionPeriodOutcomeCallable DecreaseStreamRetentionPeriodCallable(const Model::DecreaseStreamRetentionPeriodRequest& request) const;
412 
425  virtual void DecreaseStreamRetentionPeriodAsync(const Model::DecreaseStreamRetentionPeriodRequest& request, const DecreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
426 
446  virtual Model::DeleteStreamOutcome DeleteStream(const Model::DeleteStreamRequest& request) const;
447 
469  virtual Model::DeleteStreamOutcomeCallable DeleteStreamCallable(const Model::DeleteStreamRequest& request) const;
470 
492  virtual void DeleteStreamAsync(const Model::DeleteStreamRequest& request, const DeleteStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
493 
507  virtual Model::DeregisterStreamConsumerOutcome DeregisterStreamConsumer(const Model::DeregisterStreamConsumerRequest& request) const;
508 
524  virtual Model::DeregisterStreamConsumerOutcomeCallable DeregisterStreamConsumerCallable(const Model::DeregisterStreamConsumerRequest& request) const;
525 
541  virtual void DeregisterStreamConsumerAsync(const Model::DeregisterStreamConsumerRequest& request, const DeregisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
542 
551  virtual Model::DescribeLimitsOutcome DescribeLimits(const Model::DescribeLimitsRequest& request) const;
552 
563  virtual Model::DescribeLimitsOutcomeCallable DescribeLimitsCallable(const Model::DescribeLimitsRequest& request) const;
564 
575  virtual void DescribeLimitsAsync(const Model::DescribeLimitsRequest& request, const DescribeLimitsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
576 
595  virtual Model::DescribeStreamOutcome DescribeStream(const Model::DescribeStreamRequest& request) const;
596 
617  virtual Model::DescribeStreamOutcomeCallable DescribeStreamCallable(const Model::DescribeStreamRequest& request) const;
618 
639  virtual void DescribeStreamAsync(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
640 
654  virtual Model::DescribeStreamConsumerOutcome DescribeStreamConsumer(const Model::DescribeStreamConsumerRequest& request) const;
655 
671  virtual Model::DescribeStreamConsumerOutcomeCallable DescribeStreamConsumerCallable(const Model::DescribeStreamConsumerRequest& request) const;
672 
688  virtual void DescribeStreamConsumerAsync(const Model::DescribeStreamConsumerRequest& request, const DescribeStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
689 
699  virtual Model::DescribeStreamSummaryOutcome DescribeStreamSummary(const Model::DescribeStreamSummaryRequest& request) const;
700 
712  virtual Model::DescribeStreamSummaryOutcomeCallable DescribeStreamSummaryCallable(const Model::DescribeStreamSummaryRequest& request) const;
713 
725  virtual void DescribeStreamSummaryAsync(const Model::DescribeStreamSummaryRequest& request, const DescribeStreamSummaryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
726 
732  virtual Model::DisableEnhancedMonitoringOutcome DisableEnhancedMonitoring(const Model::DisableEnhancedMonitoringRequest& request) const;
733 
741  virtual Model::DisableEnhancedMonitoringOutcomeCallable DisableEnhancedMonitoringCallable(const Model::DisableEnhancedMonitoringRequest& request) const;
742 
750  virtual void DisableEnhancedMonitoringAsync(const Model::DisableEnhancedMonitoringRequest& request, const DisableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
751 
758  virtual Model::EnableEnhancedMonitoringOutcome EnableEnhancedMonitoring(const Model::EnableEnhancedMonitoringRequest& request) const;
759 
768  virtual Model::EnableEnhancedMonitoringOutcomeCallable EnableEnhancedMonitoringCallable(const Model::EnableEnhancedMonitoringRequest& request) const;
769 
778  virtual void EnableEnhancedMonitoringAsync(const Model::EnableEnhancedMonitoringRequest& request, const EnableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
779 
836  virtual Model::GetRecordsOutcome GetRecords(const Model::GetRecordsRequest& request) const;
837 
896  virtual Model::GetRecordsOutcomeCallable GetRecordsCallable(const Model::GetRecordsRequest& request) const;
897 
956  virtual void GetRecordsAsync(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
957 
997  virtual Model::GetShardIteratorOutcome GetShardIterator(const Model::GetShardIteratorRequest& request) const;
998 
1040  virtual Model::GetShardIteratorOutcomeCallable GetShardIteratorCallable(const Model::GetShardIteratorRequest& request) const;
1041 
1083  virtual void GetShardIteratorAsync(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1084 
1099  virtual Model::IncreaseStreamRetentionPeriodOutcome IncreaseStreamRetentionPeriod(const Model::IncreaseStreamRetentionPeriodRequest& request) const;
1100 
1117  virtual Model::IncreaseStreamRetentionPeriodOutcomeCallable IncreaseStreamRetentionPeriodCallable(const Model::IncreaseStreamRetentionPeriodRequest& request) const;
1118 
1135  virtual void IncreaseStreamRetentionPeriodAsync(const Model::IncreaseStreamRetentionPeriodRequest& request, const IncreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1136 
1150  virtual Model::ListShardsOutcome ListShards(const Model::ListShardsRequest& request) const;
1151 
1167  virtual Model::ListShardsOutcomeCallable ListShardsCallable(const Model::ListShardsRequest& request) const;
1168 
1184  virtual void ListShardsAsync(const Model::ListShardsRequest& request, const ListShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1185 
1193  virtual Model::ListStreamConsumersOutcome ListStreamConsumers(const Model::ListStreamConsumersRequest& request) const;
1194 
1204  virtual Model::ListStreamConsumersOutcomeCallable ListStreamConsumersCallable(const Model::ListStreamConsumersRequest& request) const;
1205 
1215  virtual void ListStreamConsumersAsync(const Model::ListStreamConsumersRequest& request, const ListStreamConsumersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1216 
1235  virtual Model::ListStreamsOutcome ListStreams(const Model::ListStreamsRequest& request) const;
1236 
1257  virtual Model::ListStreamsOutcomeCallable ListStreamsCallable(const Model::ListStreamsRequest& request) const;
1258 
1279  virtual void ListStreamsAsync(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1280 
1287  virtual Model::ListTagsForStreamOutcome ListTagsForStream(const Model::ListTagsForStreamRequest& request) const;
1288 
1297  virtual Model::ListTagsForStreamOutcomeCallable ListTagsForStreamCallable(const Model::ListTagsForStreamRequest& request) const;
1298 
1307  virtual void ListTagsForStreamAsync(const Model::ListTagsForStreamRequest& request, const ListTagsForStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1308 
1347  virtual Model::MergeShardsOutcome MergeShards(const Model::MergeShardsRequest& request) const;
1348 
1389  virtual Model::MergeShardsOutcomeCallable MergeShardsCallable(const Model::MergeShardsRequest& request) const;
1390 
1431  virtual void MergeShardsAsync(const Model::MergeShardsRequest& request, const MergeShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1432 
1473  virtual Model::PutRecordOutcome PutRecord(const Model::PutRecordRequest& request) const;
1474 
1517  virtual Model::PutRecordOutcomeCallable PutRecordCallable(const Model::PutRecordRequest& request) const;
1518 
1561  virtual void PutRecordAsync(const Model::PutRecordRequest& request, const PutRecordResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1562 
1621  virtual Model::PutRecordsOutcome PutRecords(const Model::PutRecordsRequest& request) const;
1622 
1683  virtual Model::PutRecordsOutcomeCallable PutRecordsCallable(const Model::PutRecordsRequest& request) const;
1684 
1745  virtual void PutRecordsAsync(const Model::PutRecordsRequest& request, const PutRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1746 
1758  virtual Model::RegisterStreamConsumerOutcome RegisterStreamConsumer(const Model::RegisterStreamConsumerRequest& request) const;
1759 
1773  virtual Model::RegisterStreamConsumerOutcomeCallable RegisterStreamConsumerCallable(const Model::RegisterStreamConsumerRequest& request) const;
1774 
1788  virtual void RegisterStreamConsumerAsync(const Model::RegisterStreamConsumerRequest& request, const RegisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1789 
1799  virtual Model::RemoveTagsFromStreamOutcome RemoveTagsFromStream(const Model::RemoveTagsFromStreamRequest& request) const;
1800 
1812  virtual Model::RemoveTagsFromStreamOutcomeCallable RemoveTagsFromStreamCallable(const Model::RemoveTagsFromStreamRequest& request) const;
1813 
1825  virtual void RemoveTagsFromStreamAsync(const Model::RemoveTagsFromStreamRequest& request, const RemoveTagsFromStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1826 
1875  virtual Model::SplitShardOutcome SplitShard(const Model::SplitShardRequest& request) const;
1876 
1927  virtual Model::SplitShardOutcomeCallable SplitShardCallable(const Model::SplitShardRequest& request) const;
1928 
1979  virtual void SplitShardAsync(const Model::SplitShardRequest& request, const SplitShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
1980 
2000  virtual Model::StartStreamEncryptionOutcome StartStreamEncryption(const Model::StartStreamEncryptionRequest& request) const;
2001 
2023  virtual Model::StartStreamEncryptionOutcomeCallable StartStreamEncryptionCallable(const Model::StartStreamEncryptionRequest& request) const;
2024 
2046  virtual void StartStreamEncryptionAsync(const Model::StartStreamEncryptionRequest& request, const StartStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2047 
2067  virtual Model::StopStreamEncryptionOutcome StopStreamEncryption(const Model::StopStreamEncryptionRequest& request) const;
2068 
2090  virtual Model::StopStreamEncryptionOutcomeCallable StopStreamEncryptionCallable(const Model::StopStreamEncryptionRequest& request) const;
2091 
2113  virtual void StopStreamEncryptionAsync(const Model::StopStreamEncryptionRequest& request, const StopStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2114 
2131  virtual Model::SubscribeToShardOutcome SubscribeToShard(Model::SubscribeToShardRequest& request) const;
2132 
2151  virtual Model::SubscribeToShardOutcomeCallable SubscribeToShardCallable(Model::SubscribeToShardRequest& request) const;
2152 
2171  virtual void SubscribeToShardAsync(Model::SubscribeToShardRequest& request, const SubscribeToShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2172 
2203  virtual Model::UpdateShardCountOutcome UpdateShardCount(const Model::UpdateShardCountRequest& request) const;
2204 
2237  virtual Model::UpdateShardCountOutcomeCallable UpdateShardCountCallable(const Model::UpdateShardCountRequest& request) const;
2238 
2271  virtual void UpdateShardCountAsync(const Model::UpdateShardCountRequest& request, const UpdateShardCountResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
2272 
2273 
2274  void OverrideEndpoint(const Aws::String& endpoint);
2275  private:
2276  void init(const Aws::Client::ClientConfiguration& clientConfiguration);
2277  void AddTagsToStreamAsyncHelper(const Model::AddTagsToStreamRequest& request, const AddTagsToStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2278  void CreateStreamAsyncHelper(const Model::CreateStreamRequest& request, const CreateStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2279  void DecreaseStreamRetentionPeriodAsyncHelper(const Model::DecreaseStreamRetentionPeriodRequest& request, const DecreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2280  void DeleteStreamAsyncHelper(const Model::DeleteStreamRequest& request, const DeleteStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2281  void DeregisterStreamConsumerAsyncHelper(const Model::DeregisterStreamConsumerRequest& request, const DeregisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2282  void DescribeLimitsAsyncHelper(const Model::DescribeLimitsRequest& request, const DescribeLimitsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2283  void DescribeStreamAsyncHelper(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2284  void DescribeStreamConsumerAsyncHelper(const Model::DescribeStreamConsumerRequest& request, const DescribeStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2285  void DescribeStreamSummaryAsyncHelper(const Model::DescribeStreamSummaryRequest& request, const DescribeStreamSummaryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2286  void DisableEnhancedMonitoringAsyncHelper(const Model::DisableEnhancedMonitoringRequest& request, const DisableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2287  void EnableEnhancedMonitoringAsyncHelper(const Model::EnableEnhancedMonitoringRequest& request, const EnableEnhancedMonitoringResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2288  void GetRecordsAsyncHelper(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2289  void GetShardIteratorAsyncHelper(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2290  void IncreaseStreamRetentionPeriodAsyncHelper(const Model::IncreaseStreamRetentionPeriodRequest& request, const IncreaseStreamRetentionPeriodResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2291  void ListShardsAsyncHelper(const Model::ListShardsRequest& request, const ListShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2292  void ListStreamConsumersAsyncHelper(const Model::ListStreamConsumersRequest& request, const ListStreamConsumersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2293  void ListStreamsAsyncHelper(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2294  void ListTagsForStreamAsyncHelper(const Model::ListTagsForStreamRequest& request, const ListTagsForStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2295  void MergeShardsAsyncHelper(const Model::MergeShardsRequest& request, const MergeShardsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2296  void PutRecordAsyncHelper(const Model::PutRecordRequest& request, const PutRecordResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2297  void PutRecordsAsyncHelper(const Model::PutRecordsRequest& request, const PutRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2298  void RegisterStreamConsumerAsyncHelper(const Model::RegisterStreamConsumerRequest& request, const RegisterStreamConsumerResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2299  void RemoveTagsFromStreamAsyncHelper(const Model::RemoveTagsFromStreamRequest& request, const RemoveTagsFromStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2300  void SplitShardAsyncHelper(const Model::SplitShardRequest& request, const SplitShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2301  void StartStreamEncryptionAsyncHelper(const Model::StartStreamEncryptionRequest& request, const StartStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2302  void StopStreamEncryptionAsyncHelper(const Model::StopStreamEncryptionRequest& request, const StopStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2303  void SubscribeToShardAsyncHelper(Model::SubscribeToShardRequest& request, const SubscribeToShardResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2304  void UpdateShardCountAsyncHelper(const Model::UpdateShardCountRequest& request, const UpdateShardCountResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
2305 
2306  Aws::String m_uri;
2307  Aws::String m_configScheme;
2308  std::shared_ptr<Aws::Utils::Threading::Executor> m_executor;
2309  };
2310 
2311 } // namespace Kinesis
2312 } // namespace Aws
std::function< void(const KinesisClient *, const Model::EnableEnhancedMonitoringRequest &, const Model::EnableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > EnableEnhancedMonitoringResponseReceivedHandler
std::future< PutRecordsOutcome > PutRecordsOutcomeCallable
std::function< void(const KinesisClient *, const Model::PutRecordsRequest &, const Model::PutRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::IncreaseStreamRetentionPeriodRequest &, const Model::IncreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > IncreaseStreamRetentionPeriodResponseReceivedHandler
std::future< SubscribeToShardOutcome > SubscribeToShardOutcomeCallable
std::function< void(const KinesisClient *, const Model::DescribeStreamConsumerRequest &, const Model::DescribeStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamConsumerResponseReceivedHandler
Aws::Utils::Outcome< PutRecordResult, KinesisError > PutRecordOutcome
std::function< void(const KinesisClient *, const Model::DescribeLimitsRequest &, const Model::DescribeLimitsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeLimitsResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListStreamConsumersRequest &, const Model::ListStreamConsumersOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListStreamConsumersResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DecreaseStreamRetentionPeriodOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > IncreaseStreamRetentionPeriodOutcome
std::function< void(const KinesisClient *, const Model::StopStreamEncryptionRequest &, const Model::StopStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StopStreamEncryptionResponseReceivedHandler
Aws::Utils::Outcome< DescribeStreamConsumerResult, KinesisError > DescribeStreamConsumerOutcome
std::function< void(const KinesisClient *, const Model::MergeShardsRequest &, const Model::MergeShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > MergeShardsResponseReceivedHandler
std::future< DescribeStreamConsumerOutcome > DescribeStreamConsumerOutcomeCallable
std::function< void(const KinesisClient *, const Model::AddTagsToStreamRequest &, const Model::AddTagsToStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > AddTagsToStreamResponseReceivedHandler
std::future< AddTagsToStreamOutcome > AddTagsToStreamOutcomeCallable
Aws::Utils::Outcome< ListStreamConsumersResult, KinesisError > ListStreamConsumersOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DeleteStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > CreateStreamOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > SplitShardOutcome
Aws::Utils::Outcome< ListShardsResult, KinesisError > ListShardsOutcome
std::function< void(const KinesisClient *, const Model::ListStreamsRequest &, const Model::ListStreamsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListStreamsResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > RemoveTagsFromStreamOutcome
std::future< DisableEnhancedMonitoringOutcome > DisableEnhancedMonitoringOutcomeCallable
std::function< void(const KinesisClient *, const Model::StartStreamEncryptionRequest &, const Model::StartStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StartStreamEncryptionResponseReceivedHandler
std::future< RemoveTagsFromStreamOutcome > RemoveTagsFromStreamOutcomeCallable
Aws::Utils::Outcome< DescribeStreamSummaryResult, KinesisError > DescribeStreamSummaryOutcome
std::function< void(const KinesisClient *, const Model::SubscribeToShardRequest &, const Model::SubscribeToShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SubscribeToShardResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DecreaseStreamRetentionPeriodRequest &, const Model::DecreaseStreamRetentionPeriodOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DecreaseStreamRetentionPeriodResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::ListTagsForStreamRequest &, const Model::ListTagsForStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListTagsForStreamResponseReceivedHandler
std::future< IncreaseStreamRetentionPeriodOutcome > IncreaseStreamRetentionPeriodOutcomeCallable
Aws::Utils::Outcome< DescribeLimitsResult, KinesisError > DescribeLimitsOutcome
std::function< void(const KinesisClient *, const Model::PutRecordRequest &, const Model::PutRecordOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > StartStreamEncryptionOutcome
std::future< ListTagsForStreamOutcome > ListTagsForStreamOutcomeCallable
std::function< void(const KinesisClient *, const Model::RemoveTagsFromStreamRequest &, const Model::RemoveTagsFromStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > RemoveTagsFromStreamResponseReceivedHandler
std::future< DescribeStreamSummaryOutcome > DescribeStreamSummaryOutcomeCallable
std::function< void(const KinesisClient *, const Model::RegisterStreamConsumerRequest &, const Model::RegisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > RegisterStreamConsumerResponseReceivedHandler
std::future< PutRecordOutcome > PutRecordOutcomeCallable
Aws::Utils::Outcome< RegisterStreamConsumerResult, KinesisError > RegisterStreamConsumerOutcome
Aws::Utils::Outcome< DisableEnhancedMonitoringResult, KinesisError > DisableEnhancedMonitoringOutcome
std::future< DescribeStreamOutcome > DescribeStreamOutcomeCallable
std::future< GetShardIteratorOutcome > GetShardIteratorOutcomeCallable
Aws::Utils::Outcome< EnableEnhancedMonitoringResult, KinesisError > EnableEnhancedMonitoringOutcome
std::function< void(const KinesisClient *, const Model::DescribeStreamRequest &, const Model::DescribeStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamResponseReceivedHandler
std::future< DescribeLimitsOutcome > DescribeLimitsOutcomeCallable
std::function< void(const KinesisClient *, const Model::ListShardsRequest &, const Model::ListShardsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListShardsResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > StopStreamEncryptionOutcome
std::future< UpdateShardCountOutcome > UpdateShardCountOutcomeCallable
Aws::Utils::Outcome< DescribeStreamResult, KinesisError > DescribeStreamOutcome
Aws::Utils::Outcome< ListStreamsResult, KinesisError > ListStreamsOutcome
Aws::Utils::Outcome< GetRecordsResult, KinesisError > GetRecordsOutcome
std::future< DecreaseStreamRetentionPeriodOutcome > DecreaseStreamRetentionPeriodOutcomeCallable
std::function< void(const KinesisClient *, const Model::UpdateShardCountRequest &, const Model::UpdateShardCountOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > UpdateShardCountResponseReceivedHandler
std::future< ListStreamConsumersOutcome > ListStreamConsumersOutcomeCallable
std::future< EnableEnhancedMonitoringOutcome > EnableEnhancedMonitoringOutcomeCallable
std::future< SplitShardOutcome > SplitShardOutcomeCallable
Aws::Utils::Outcome< Aws::NoResult, KinesisError > SubscribeToShardOutcome
std::function< void(const KinesisClient *, const Model::GetShardIteratorRequest &, const Model::GetShardIteratorOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetShardIteratorResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > DeregisterStreamConsumerOutcome
std::future< MergeShardsOutcome > MergeShardsOutcomeCallable
std::future< ListStreamsOutcome > ListStreamsOutcomeCallable
std::future< RegisterStreamConsumerOutcome > RegisterStreamConsumerOutcomeCallable
std::function< void(const KinesisClient *, const Model::DisableEnhancedMonitoringRequest &, const Model::DisableEnhancedMonitoringOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DisableEnhancedMonitoringResponseReceivedHandler
Aws::Utils::Outcome< Aws::NoResult, KinesisError > MergeShardsOutcome
std::function< void(const KinesisClient *, const Model::SplitShardRequest &, const Model::SplitShardOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SplitShardResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DescribeStreamSummaryRequest &, const Model::DescribeStreamSummaryOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamSummaryResponseReceivedHandler
#define AWS_KINESIS_API
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
Aws::Utils::Outcome< UpdateShardCountResult, KinesisError > UpdateShardCountOutcome
std::future< ListShardsOutcome > ListShardsOutcomeCallable
virtual const char * GetServiceClientName() const override
std::function< void(const KinesisClient *, const Model::DeleteStreamRequest &, const Model::DeleteStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeleteStreamResponseReceivedHandler
Aws::Utils::Outcome< ListTagsForStreamResult, KinesisError > ListTagsForStreamOutcome
std::future< StartStreamEncryptionOutcome > StartStreamEncryptionOutcomeCallable
Aws::Utils::Outcome< GetShardIteratorResult, KinesisError > GetShardIteratorOutcome
Aws::Utils::Outcome< Aws::NoResult, KinesisError > AddTagsToStreamOutcome
Definition: KinesisClient.h:97
std::function< void(const KinesisClient *, const Model::GetRecordsRequest &, const Model::GetRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetRecordsResponseReceivedHandler
std::future< GetRecordsOutcome > GetRecordsOutcomeCallable
std::future< CreateStreamOutcome > CreateStreamOutcomeCallable
Aws::Client::AWSJsonClient BASECLASS
std::function< void(const KinesisClient *, const Model::CreateStreamRequest &, const Model::CreateStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > CreateStreamResponseReceivedHandler
std::function< void(const KinesisClient *, const Model::DeregisterStreamConsumerRequest &, const Model::DeregisterStreamConsumerOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeregisterStreamConsumerResponseReceivedHandler
Aws::Utils::Outcome< PutRecordsResult, KinesisError > PutRecordsOutcome
std::future< StopStreamEncryptionOutcome > StopStreamEncryptionOutcomeCallable
std::future< DeleteStreamOutcome > DeleteStreamOutcomeCallable
std::future< DeregisterStreamConsumerOutcome > DeregisterStreamConsumerOutcomeCallable