AWS SDK for C++  1.9.103
AWS SDK for C++
DynamoDBStreamsClient.h
Go to the documentation of this file.
1 
6 #pragma once
20 #include <future>
21 #include <functional>
22 
23 namespace Aws
24 {
25 
26 namespace Http
27 {
28  class HttpClient;
29  class HttpClientFactory;
30 } // namespace Http
31 
32 namespace Utils
33 {
34  template< typename R, typename E> class Outcome;
35 namespace Threading
36 {
37  class Executor;
38 } // namespace Threading
39 } // namespace Utils
40 
41 namespace Auth
42 {
43  class AWSCredentials;
44  class AWSCredentialsProvider;
45 } // namespace Auth
46 
47 namespace Client
48 {
49  class RetryStrategy;
50 } // namespace Client
51 
52 namespace DynamoDBStreams
53 {
54 
55 namespace Model
56 {
58  class GetRecordsRequest;
60  class ListStreamsRequest;
61 
66 
67  typedef std::future<DescribeStreamOutcome> DescribeStreamOutcomeCallable;
68  typedef std::future<GetRecordsOutcome> GetRecordsOutcomeCallable;
69  typedef std::future<GetShardIteratorOutcome> GetShardIteratorOutcomeCallable;
70  typedef std::future<ListStreamsOutcome> ListStreamsOutcomeCallable;
71 } // namespace Model
72 
74 
75  typedef std::function<void(const DynamoDBStreamsClient*, const Model::DescribeStreamRequest&, const Model::DescribeStreamOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeStreamResponseReceivedHandler;
76  typedef std::function<void(const DynamoDBStreamsClient*, const Model::GetRecordsRequest&, const Model::GetRecordsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > GetRecordsResponseReceivedHandler;
77  typedef std::function<void(const DynamoDBStreamsClient*, const Model::GetShardIteratorRequest&, const Model::GetShardIteratorOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > GetShardIteratorResponseReceivedHandler;
78  typedef std::function<void(const DynamoDBStreamsClient*, const Model::ListStreamsRequest&, const Model::ListStreamsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListStreamsResponseReceivedHandler;
79 
89  {
90  public:
92 
98 
104 
109  DynamoDBStreamsClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
111 
113 
114 
131 
150 
168  virtual void DescribeStreamAsync(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
169 
184 
201 
217  virtual void GetRecordsAsync(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
218 
229 
242 
254  virtual void GetShardIteratorAsync(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
255 
266 
279 
291  virtual void ListStreamsAsync(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
292 
293 
294  void OverrideEndpoint(const Aws::String& endpoint);
295  private:
296  void init(const Aws::Client::ClientConfiguration& clientConfiguration);
297  void DescribeStreamAsyncHelper(const Model::DescribeStreamRequest& request, const DescribeStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
298  void GetRecordsAsyncHelper(const Model::GetRecordsRequest& request, const GetRecordsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
299  void GetShardIteratorAsyncHelper(const Model::GetShardIteratorRequest& request, const GetShardIteratorResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
300  void ListStreamsAsyncHelper(const Model::ListStreamsRequest& request, const ListStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
301 
302  Aws::String m_uri;
303  Aws::String m_configScheme;
304  std::shared_ptr<Aws::Utils::Threading::Executor> m_executor;
305  };
306 
307 } // namespace DynamoDBStreams
308 } // namespace Aws
Aws::DynamoDBStreams::GetRecordsResponseReceivedHandler
std::function< void(const DynamoDBStreamsClient *, const Model::GetRecordsRequest &, const Model::GetRecordsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetRecordsResponseReceivedHandler
Definition: DynamoDBStreamsClient.h:76
Aws::DynamoDBStreams::Model::ListStreamsOutcome
Aws::Utils::Outcome< ListStreamsResult, DynamoDBStreamsError > ListStreamsOutcome
Definition: DynamoDBStreamsClient.h:65
Aws::DynamoDBStreams::Model::GetRecordsOutcomeCallable
std::future< GetRecordsOutcome > GetRecordsOutcomeCallable
Definition: DynamoDBStreamsClient.h:68
Aws::DirectoryService::Model::LDAPSType::NOT_SET
@ NOT_SET
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetRecordsAsync
virtual void GetRecordsAsync(const Model::GetRecordsRequest &request, const GetRecordsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::DynamoDBStreams::Model::DescribeStreamOutcome
Aws::Utils::Outcome< DescribeStreamResult, DynamoDBStreamsError > DescribeStreamOutcome
Definition: DynamoDBStreamsClient.h:60
AWSError.h
Aws::DynamoDBStreams::Model::GetShardIteratorRequest
Definition: GetShardIteratorRequest.h:27
Aws::DynamoDBStreams::DynamoDBStreamsClient::DynamoDBStreamsClient
DynamoDBStreamsClient(const Aws::Auth::AWSCredentials &credentials, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetRecordsCallable
virtual Model::GetRecordsOutcomeCallable GetRecordsCallable(const Model::GetRecordsRequest &request) const
Aws::DynamoDBStreams::DynamoDBStreamsClient::DynamoDBStreamsClient
DynamoDBStreamsClient(const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetShardIteratorCallable
virtual Model::GetShardIteratorOutcomeCallable GetShardIteratorCallable(const Model::GetShardIteratorRequest &request) const
Aws::DynamoDBStreams::DynamoDBStreamsClient::DynamoDBStreamsClient
DynamoDBStreamsClient(const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
DynamoDBStreams_EXPORTS.h
Aws::DynamoDBStreams::Model::GetShardIteratorOutcomeCallable
std::future< GetShardIteratorOutcome > GetShardIteratorOutcomeCallable
Definition: DynamoDBStreamsClient.h:69
Aws::DynamoDBStreams::DynamoDBStreamsClient::ListStreams
virtual Model::ListStreamsOutcome ListStreams(const Model::ListStreamsRequest &request) const
DescribeStreamResult.h
AsyncCallerContext.h
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetShardIterator
virtual Model::GetShardIteratorOutcome GetShardIterator(const Model::GetShardIteratorRequest &request) const
AWS_DYNAMODBSTREAMS_API
#define AWS_DYNAMODBSTREAMS_API
Definition: DynamoDBStreams_EXPORTS.h:28
Aws::DynamoDBStreams::DescribeStreamResponseReceivedHandler
std::function< void(const DynamoDBStreamsClient *, const Model::DescribeStreamRequest &, const Model::DescribeStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeStreamResponseReceivedHandler
Definition: DynamoDBStreamsClient.h:73
ListStreamsResult.h
Aws::DynamoDBStreams::Model::DescribeStreamOutcomeCallable
std::future< DescribeStreamOutcome > DescribeStreamOutcomeCallable
Definition: DynamoDBStreamsClient.h:67
Aws::DynamoDBStreams::DynamoDBStreamsClient::~DynamoDBStreamsClient
virtual ~DynamoDBStreamsClient()
Aws::Client::ClientConfiguration
Definition: ClientConfiguration.h:53
Aws::DynamoDBStreams::DynamoDBStreamsClient::DescribeStream
virtual Model::DescribeStreamOutcome DescribeStream(const Model::DescribeStreamRequest &request) const
Aws::DynamoDBStreams::Model::GetRecordsOutcome
Aws::Utils::Outcome< GetRecordsResult, DynamoDBStreamsError > GetRecordsOutcome
Definition: DynamoDBStreamsClient.h:63
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetShardIteratorAsync
virtual void GetShardIteratorAsync(const Model::GetShardIteratorRequest &request, const GetShardIteratorResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::DynamoDBStreams::DynamoDBStreamsClient::BASECLASS
Aws::Client::AWSJsonClient BASECLASS
Definition: DynamoDBStreamsClient.h:91
Aws::DynamoDBStreams::DynamoDBStreamsClient::ListStreamsAsync
virtual void ListStreamsAsync(const Model::ListStreamsRequest &request, const ListStreamsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::Auth::AWSCredentials
Definition: AWSCredentials.h:19
DynamoDBStreamsErrors.h
AWSString.h
Aws::DynamoDBStreams::GetShardIteratorResponseReceivedHandler
std::function< void(const DynamoDBStreamsClient *, const Model::GetShardIteratorRequest &, const Model::GetShardIteratorOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetShardIteratorResponseReceivedHandler
Definition: DynamoDBStreamsClient.h:77
Aws::DynamoDBStreams::DynamoDBStreamsClient::DescribeStreamCallable
virtual Model::DescribeStreamOutcomeCallable DescribeStreamCallable(const Model::DescribeStreamRequest &request) const
Aws::Client::AWSJsonClient
Definition: AWSClient.h:338
Aws::DynamoDBStreams::Model::DescribeStreamRequest
Definition: DescribeStreamRequest.h:26
Aws::DynamoDBStreams::ListStreamsResponseReceivedHandler
std::function< void(const DynamoDBStreamsClient *, const Model::ListStreamsRequest &, const Model::ListStreamsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListStreamsResponseReceivedHandler
Definition: DynamoDBStreamsClient.h:78
Aws::DynamoDBStreams::Model::GetShardIteratorOutcome
Aws::Utils::Outcome< GetShardIteratorResult, DynamoDBStreamsError > GetShardIteratorOutcome
Definition: DynamoDBStreamsClient.h:64
Aws::DynamoDBStreams::DynamoDBStreamsClient::ListStreamsCallable
virtual Model::ListStreamsOutcomeCallable ListStreamsCallable(const Model::ListStreamsRequest &request) const
Aws::DynamoDBStreams::DynamoDBStreamsClient::DescribeStreamAsync
virtual void DescribeStreamAsync(const Model::DescribeStreamRequest &request, const DescribeStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::DynamoDBStreams::DynamoDBStreamsClient::OverrideEndpoint
void OverrideEndpoint(const Aws::String &endpoint)
GetShardIteratorResult.h
GetRecordsResult.h
ClientConfiguration.h
Aws
Definition: AccessManagementClient.h:15
HttpTypes.h
Aws::DynamoDBStreams::DynamoDBStreamsClient::GetRecords
virtual Model::GetRecordsOutcome GetRecords(const Model::GetRecordsRequest &request) const
Aws::Utils::Outcome
Definition: Outcome.h:26
Aws::DynamoDBStreams::Model::ListStreamsOutcomeCallable
std::future< ListStreamsOutcome > ListStreamsOutcomeCallable
Definition: DynamoDBStreamsClient.h:70
Aws::String
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
AWSClient.h
JsonSerializer.h
Aws::DynamoDBStreams::DynamoDBStreamsClient
Definition: DynamoDBStreamsClient.h:89
Aws::DynamoDBStreams::Model::GetRecordsRequest
Definition: GetRecordsRequest.h:26
Aws::DynamoDBStreams::Model::ListStreamsRequest
Definition: ListStreamsRequest.h:26