AWS SDK for C++  1.9.40
AWS SDK for C++
TimestreamQueryClient.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 TimestreamQuery
53 {
54 
55 namespace Model
56 {
57  class CancelQueryRequest;
58  class DescribeEndpointsRequest;
59  class QueryRequest;
60 
64 
65  typedef std::future<CancelQueryOutcome> CancelQueryOutcomeCallable;
66  typedef std::future<DescribeEndpointsOutcome> DescribeEndpointsOutcomeCallable;
67  typedef std::future<QueryOutcome> QueryOutcomeCallable;
68 } // namespace Model
69 
71 
72  typedef std::function<void(const TimestreamQueryClient*, const Model::CancelQueryRequest&, const Model::CancelQueryOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > CancelQueryResponseReceivedHandler;
73  typedef std::function<void(const TimestreamQueryClient*, const Model::DescribeEndpointsRequest&, const Model::DescribeEndpointsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeEndpointsResponseReceivedHandler;
74  typedef std::function<void(const TimestreamQueryClient*, const Model::QueryRequest&, const Model::QueryOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > QueryResponseReceivedHandler;
75 
80  {
81  public:
83 
89 
95 
100  TimestreamQueryClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
102 
104 
105 
116 
129 
141  virtual void CancelQueryAsync(const Model::CancelQueryRequest& request, const CancelQueryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
142 
159 
178 
196  virtual void DescribeEndpointsAsync(const Model::DescribeEndpointsRequest& request, const DescribeEndpointsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
197 
207  virtual Model::QueryOutcome Query(const Model::QueryRequest& request) const;
208 
221 
233  virtual void QueryAsync(const Model::QueryRequest& request, const QueryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
234 
235 
236  void OverrideEndpoint(const Aws::String& endpoint);
237  private:
238  void init(const Aws::Client::ClientConfiguration& clientConfiguration);
239  void LoadTimestreamQuerySpecificConfig(const Aws::Client::ClientConfiguration& clientConfiguration);
240  void CancelQueryAsyncHelper(const Model::CancelQueryRequest& request, const CancelQueryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
241  void DescribeEndpointsAsyncHelper(const Model::DescribeEndpointsRequest& request, const DescribeEndpointsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
242  void QueryAsyncHelper(const Model::QueryRequest& request, const QueryResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
243 
244  Aws::String m_uri;
246  bool m_enableEndpointDiscovery;
247  Aws::String m_configScheme;
248  std::shared_ptr<Aws::Utils::Threading::Executor> m_executor;
249  };
250 
251 } // namespace TimestreamQuery
252 } // namespace Aws
DescribeEndpointsResult.h
Aws::TimestreamQuery::Model::QueryOutcomeCallable
std::future< QueryOutcome > QueryOutcomeCallable
Definition: TimestreamQueryClient.h:67
Aws::DirectoryService::Model::LDAPSType::NOT_SET
@ NOT_SET
Aws::TimestreamQuery::Model::DescribeEndpointsOutcome
Aws::Utils::Outcome< DescribeEndpointsResult, TimestreamQueryError > DescribeEndpointsOutcome
Definition: TimestreamQueryClient.h:62
AWS_TIMESTREAMQUERY_API
#define AWS_TIMESTREAMQUERY_API
Definition: TimestreamQuery_EXPORTS.h:28
Aws::TimestreamQuery::TimestreamQueryClient::~TimestreamQueryClient
virtual ~TimestreamQueryClient()
AWSError.h
Aws::TimestreamQuery::Model::DescribeEndpointsRequest
Definition: DescribeEndpointsRequest.h:20
Aws::TimestreamQuery::TimestreamQueryClient::Query
virtual Model::QueryOutcome Query(const Model::QueryRequest &request) const
Aws::TimestreamQuery::Model::QueryRequest
Definition: QueryRequest.h:23
Aws::TimestreamQuery::Model::QueryOutcome
Aws::Utils::Outcome< QueryResult, TimestreamQueryError > QueryOutcome
Definition: TimestreamQueryClient.h:63
Aws::TimestreamQuery::Model::CancelQueryOutcomeCallable
std::future< CancelQueryOutcome > CancelQueryOutcomeCallable
Definition: TimestreamQueryClient.h:65
Aws::TimestreamQuery::Model::DescribeEndpointsOutcomeCallable
std::future< DescribeEndpointsOutcome > DescribeEndpointsOutcomeCallable
Definition: TimestreamQueryClient.h:66
AsyncCallerContext.h
TimestreamQuery_EXPORTS.h
Aws::TimestreamQuery::Model::CancelQueryRequest
Definition: CancelQueryRequest.h:22
Aws::TimestreamQuery::TimestreamQueryClient::CancelQueryAsync
virtual void CancelQueryAsync(const Model::CancelQueryRequest &request, const CancelQueryResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::TimestreamQuery::TimestreamQueryClient::BASECLASS
Aws::Client::AWSJsonClient BASECLASS
Definition: TimestreamQueryClient.h:82
Aws::TimestreamQuery::Model::CancelQueryOutcome
Aws::Utils::Outcome< CancelQueryResult, TimestreamQueryError > CancelQueryOutcome
Definition: TimestreamQueryClient.h:59
Aws::TimestreamQuery::TimestreamQueryClient::DescribeEndpoints
virtual Model::DescribeEndpointsOutcome DescribeEndpoints(const Model::DescribeEndpointsRequest &request) const
ConcurrentCache.h
Aws::Client::ClientConfiguration
Definition: ClientConfiguration.h:53
Aws::TimestreamQuery::QueryResponseReceivedHandler
std::function< void(const TimestreamQueryClient *, const Model::QueryRequest &, const Model::QueryOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > QueryResponseReceivedHandler
Definition: TimestreamQueryClient.h:74
Aws::TimestreamQuery::TimestreamQueryClient::TimestreamQueryClient
TimestreamQueryClient(const Aws::Auth::AWSCredentials &credentials, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
CancelQueryResult.h
Aws::TimestreamQuery::TimestreamQueryClient::CancelQueryCallable
virtual Model::CancelQueryOutcomeCallable CancelQueryCallable(const Model::CancelQueryRequest &request) const
Aws::Auth::AWSCredentials
Definition: AWSCredentials.h:19
AWSString.h
Aws::Utils::ConcurrentCache< Aws::String, Aws::String >
Aws::Client::AWSJsonClient
Definition: AWSClient.h:323
Aws::TimestreamQuery::TimestreamQueryClient::DescribeEndpointsAsync
virtual void DescribeEndpointsAsync(const Model::DescribeEndpointsRequest &request, const DescribeEndpointsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::TimestreamQuery::TimestreamQueryClient::OverrideEndpoint
void OverrideEndpoint(const Aws::String &endpoint)
Aws::TimestreamQuery::TimestreamQueryClient::DescribeEndpointsCallable
virtual Model::DescribeEndpointsOutcomeCallable DescribeEndpointsCallable(const Model::DescribeEndpointsRequest &request) const
Aws::TimestreamQuery::TimestreamQueryClient::QueryAsync
virtual void QueryAsync(const Model::QueryRequest &request, const QueryResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Aws::TimestreamQuery::TimestreamQueryClient::TimestreamQueryClient
TimestreamQueryClient(const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
QueryResult.h
ClientConfiguration.h
Aws::TimestreamQuery::TimestreamQueryClient::TimestreamQueryClient
TimestreamQueryClient(const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, const Aws::Client::ClientConfiguration &clientConfiguration=Aws::Client::ClientConfiguration())
Aws::TimestreamQuery::CancelQueryResponseReceivedHandler
std::function< void(const TimestreamQueryClient *, const Model::CancelQueryRequest &, const Model::CancelQueryOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > CancelQueryResponseReceivedHandler
Definition: TimestreamQueryClient.h:70
Aws
Definition: AccessManagementClient.h:15
HttpTypes.h
Aws::Utils::Outcome
Definition: Outcome.h:26
Aws::String
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
AWSClient.h
Aws::TimestreamQuery::TimestreamQueryClient::QueryCallable
virtual Model::QueryOutcomeCallable QueryCallable(const Model::QueryRequest &request) const
Aws::TimestreamQuery::TimestreamQueryClient::CancelQuery
virtual Model::CancelQueryOutcome CancelQuery(const Model::CancelQueryRequest &request) const
TimestreamQueryErrors.h
Aws::TimestreamQuery::TimestreamQueryClient
Definition: TimestreamQueryClient.h:80
Aws::TimestreamQuery::DescribeEndpointsResponseReceivedHandler
std::function< void(const TimestreamQueryClient *, const Model::DescribeEndpointsRequest &, const Model::DescribeEndpointsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeEndpointsResponseReceivedHandler
Definition: TimestreamQueryClient.h:73
JsonSerializer.h