AWS SDK for C++

AWS SDK for C++ Version 1.11.440

Loading...
Searching...
No Matches
FirehoseClient.h
1
6#pragma once
7#include <aws/firehose/Firehose_EXPORTS.h>
8#include <aws/core/client/ClientConfiguration.h>
9#include <aws/core/client/AWSClient.h>
10#include <aws/core/client/AWSClientAsyncCRTP.h>
11#include <aws/core/utils/json/JsonSerializer.h>
12#include <aws/firehose/FirehoseServiceClientModel.h>
13
14namespace Aws
15{
16namespace Firehose
17{
26 class AWS_FIREHOSE_API FirehoseClient : public Aws::Client::AWSJsonClient, public Aws::Client::ClientWithAsyncTemplateMethods<FirehoseClient>
27 {
28 public:
30 static const char* GetServiceName();
31 static const char* GetAllocationTag();
32
35
41 std::shared_ptr<FirehoseEndpointProviderBase> endpointProvider = nullptr);
42
48 std::shared_ptr<FirehoseEndpointProviderBase> endpointProvider = nullptr,
50
55 FirehoseClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
56 std::shared_ptr<FirehoseEndpointProviderBase> endpointProvider = nullptr,
58
59
60 /* Legacy constructors due deprecation */
66
72 const Aws::Client::ClientConfiguration& clientConfiguration);
73
78 FirehoseClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
79 const Aws::Client::ClientConfiguration& clientConfiguration);
80
81 /* End of legacy constructors due deprecation */
82 virtual ~FirehoseClient();
83
151
155 template<typename CreateDeliveryStreamRequestT = Model::CreateDeliveryStreamRequest>
156 Model::CreateDeliveryStreamOutcomeCallable CreateDeliveryStreamCallable(const CreateDeliveryStreamRequestT& request) const
157 {
158 return SubmitCallable(&FirehoseClient::CreateDeliveryStream, request);
159 }
160
164 template<typename CreateDeliveryStreamRequestT = Model::CreateDeliveryStreamRequest>
165 void CreateDeliveryStreamAsync(const CreateDeliveryStreamRequestT& request, const CreateDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
166 {
167 return SubmitAsync(&FirehoseClient::CreateDeliveryStream, request, handler, context);
168 }
169
192
196 template<typename DeleteDeliveryStreamRequestT = Model::DeleteDeliveryStreamRequest>
197 Model::DeleteDeliveryStreamOutcomeCallable DeleteDeliveryStreamCallable(const DeleteDeliveryStreamRequestT& request) const
198 {
199 return SubmitCallable(&FirehoseClient::DeleteDeliveryStream, request);
200 }
201
205 template<typename DeleteDeliveryStreamRequestT = Model::DeleteDeliveryStreamRequest>
206 void DeleteDeliveryStreamAsync(const DeleteDeliveryStreamRequestT& request, const DeleteDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
207 {
208 return SubmitAsync(&FirehoseClient::DeleteDeliveryStream, request, handler, context);
209 }
210
227
231 template<typename DescribeDeliveryStreamRequestT = Model::DescribeDeliveryStreamRequest>
232 Model::DescribeDeliveryStreamOutcomeCallable DescribeDeliveryStreamCallable(const DescribeDeliveryStreamRequestT& request) const
233 {
234 return SubmitCallable(&FirehoseClient::DescribeDeliveryStream, request);
235 }
236
240 template<typename DescribeDeliveryStreamRequestT = Model::DescribeDeliveryStreamRequest>
241 void DescribeDeliveryStreamAsync(const DescribeDeliveryStreamRequestT& request, const DescribeDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
242 {
243 return SubmitAsync(&FirehoseClient::DescribeDeliveryStream, request, handler, context);
244 }
245
261
265 template<typename ListDeliveryStreamsRequestT = Model::ListDeliveryStreamsRequest>
266 Model::ListDeliveryStreamsOutcomeCallable ListDeliveryStreamsCallable(const ListDeliveryStreamsRequestT& request = {}) const
267 {
268 return SubmitCallable(&FirehoseClient::ListDeliveryStreams, request);
269 }
270
274 template<typename ListDeliveryStreamsRequestT = Model::ListDeliveryStreamsRequest>
275 void ListDeliveryStreamsAsync(const ListDeliveryStreamsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr, const ListDeliveryStreamsRequestT& request = {}) const
276 {
277 return SubmitAsync(&FirehoseClient::ListDeliveryStreams, request, handler, context);
278 }
279
287
291 template<typename ListTagsForDeliveryStreamRequestT = Model::ListTagsForDeliveryStreamRequest>
292 Model::ListTagsForDeliveryStreamOutcomeCallable ListTagsForDeliveryStreamCallable(const ListTagsForDeliveryStreamRequestT& request) const
293 {
294 return SubmitCallable(&FirehoseClient::ListTagsForDeliveryStream, request);
295 }
296
300 template<typename ListTagsForDeliveryStreamRequestT = Model::ListTagsForDeliveryStreamRequest>
301 void ListTagsForDeliveryStreamAsync(const ListTagsForDeliveryStreamRequestT& request, const ListTagsForDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
302 {
303 return SubmitAsync(&FirehoseClient::ListTagsForDeliveryStream, request, handler, context);
304 }
305
349
353 template<typename PutRecordRequestT = Model::PutRecordRequest>
354 Model::PutRecordOutcomeCallable PutRecordCallable(const PutRecordRequestT& request) const
355 {
356 return SubmitCallable(&FirehoseClient::PutRecord, request);
357 }
358
362 template<typename PutRecordRequestT = Model::PutRecordRequest>
363 void PutRecordAsync(const PutRecordRequestT& request, const PutRecordResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
364 {
365 return SubmitAsync(&FirehoseClient::PutRecord, request, handler, context);
366 }
367
433
437 template<typename PutRecordBatchRequestT = Model::PutRecordBatchRequest>
438 Model::PutRecordBatchOutcomeCallable PutRecordBatchCallable(const PutRecordBatchRequestT& request) const
439 {
440 return SubmitCallable(&FirehoseClient::PutRecordBatch, request);
441 }
442
446 template<typename PutRecordBatchRequestT = Model::PutRecordBatchRequest>
447 void PutRecordBatchAsync(const PutRecordBatchRequestT& request, const PutRecordBatchResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
448 {
449 return SubmitAsync(&FirehoseClient::PutRecordBatch, request, handler, context);
450 }
451
497
501 template<typename StartDeliveryStreamEncryptionRequestT = Model::StartDeliveryStreamEncryptionRequest>
502 Model::StartDeliveryStreamEncryptionOutcomeCallable StartDeliveryStreamEncryptionCallable(const StartDeliveryStreamEncryptionRequestT& request) const
503 {
504 return SubmitCallable(&FirehoseClient::StartDeliveryStreamEncryption, request);
505 }
506
510 template<typename StartDeliveryStreamEncryptionRequestT = Model::StartDeliveryStreamEncryptionRequest>
511 void StartDeliveryStreamEncryptionAsync(const StartDeliveryStreamEncryptionRequestT& request, const StartDeliveryStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
512 {
513 return SubmitAsync(&FirehoseClient::StartDeliveryStreamEncryption, request, handler, context);
514 }
515
542
546 template<typename StopDeliveryStreamEncryptionRequestT = Model::StopDeliveryStreamEncryptionRequest>
547 Model::StopDeliveryStreamEncryptionOutcomeCallable StopDeliveryStreamEncryptionCallable(const StopDeliveryStreamEncryptionRequestT& request) const
548 {
549 return SubmitCallable(&FirehoseClient::StopDeliveryStreamEncryption, request);
550 }
551
555 template<typename StopDeliveryStreamEncryptionRequestT = Model::StopDeliveryStreamEncryptionRequest>
556 void StopDeliveryStreamEncryptionAsync(const StopDeliveryStreamEncryptionRequestT& request, const StopDeliveryStreamEncryptionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
557 {
558 return SubmitAsync(&FirehoseClient::StopDeliveryStreamEncryption, request, handler, context);
559 }
560
577
581 template<typename TagDeliveryStreamRequestT = Model::TagDeliveryStreamRequest>
582 Model::TagDeliveryStreamOutcomeCallable TagDeliveryStreamCallable(const TagDeliveryStreamRequestT& request) const
583 {
584 return SubmitCallable(&FirehoseClient::TagDeliveryStream, request);
585 }
586
590 template<typename TagDeliveryStreamRequestT = Model::TagDeliveryStreamRequest>
591 void TagDeliveryStreamAsync(const TagDeliveryStreamRequestT& request, const TagDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
592 {
593 return SubmitAsync(&FirehoseClient::TagDeliveryStream, request, handler, context);
594 }
595
606
610 template<typename UntagDeliveryStreamRequestT = Model::UntagDeliveryStreamRequest>
611 Model::UntagDeliveryStreamOutcomeCallable UntagDeliveryStreamCallable(const UntagDeliveryStreamRequestT& request) const
612 {
613 return SubmitCallable(&FirehoseClient::UntagDeliveryStream, request);
614 }
615
619 template<typename UntagDeliveryStreamRequestT = Model::UntagDeliveryStreamRequest>
620 void UntagDeliveryStreamAsync(const UntagDeliveryStreamRequestT& request, const UntagDeliveryStreamResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
621 {
622 return SubmitAsync(&FirehoseClient::UntagDeliveryStream, request, handler, context);
623 }
624
656
660 template<typename UpdateDestinationRequestT = Model::UpdateDestinationRequest>
661 Model::UpdateDestinationOutcomeCallable UpdateDestinationCallable(const UpdateDestinationRequestT& request) const
662 {
663 return SubmitCallable(&FirehoseClient::UpdateDestination, request);
664 }
665
669 template<typename UpdateDestinationRequestT = Model::UpdateDestinationRequest>
670 void UpdateDestinationAsync(const UpdateDestinationRequestT& request, const UpdateDestinationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const
671 {
672 return SubmitAsync(&FirehoseClient::UpdateDestination, request, handler, context);
673 }
674
675
676 void OverrideEndpoint(const Aws::String& endpoint);
677 std::shared_ptr<FirehoseEndpointProviderBase>& accessEndpointProvider();
678 private:
680 void init(const FirehoseClientConfiguration& clientConfiguration);
681
682 FirehoseClientConfiguration m_clientConfiguration;
683 std::shared_ptr<FirehoseEndpointProviderBase> m_endpointProvider;
684 };
685
686} // namespace Firehose
687} // namespace Aws
FirehoseClient(const Aws::Auth::AWSCredentials &credentials, std::shared_ptr< FirehoseEndpointProviderBase > endpointProvider=nullptr, const Aws::Firehose::FirehoseClientConfiguration &clientConfiguration=Aws::Firehose::FirehoseClientConfiguration())
void CreateDeliveryStreamAsync(const CreateDeliveryStreamRequestT &request, const CreateDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
void PutRecordBatchAsync(const PutRecordBatchRequestT &request, const PutRecordBatchResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
virtual Model::PutRecordOutcome PutRecord(const Model::PutRecordRequest &request) const
Model::DescribeDeliveryStreamOutcomeCallable DescribeDeliveryStreamCallable(const DescribeDeliveryStreamRequestT &request) const
virtual Model::ListDeliveryStreamsOutcome ListDeliveryStreams(const Model::ListDeliveryStreamsRequest &request={}) const
Model::StartDeliveryStreamEncryptionOutcomeCallable StartDeliveryStreamEncryptionCallable(const StartDeliveryStreamEncryptionRequestT &request) const
virtual Model::DeleteDeliveryStreamOutcome DeleteDeliveryStream(const Model::DeleteDeliveryStreamRequest &request) const
FirehoseClient(const Aws::Auth::AWSCredentials &credentials, const Aws::Client::ClientConfiguration &clientConfiguration)
void StartDeliveryStreamEncryptionAsync(const StartDeliveryStreamEncryptionRequestT &request, const StartDeliveryStreamEncryptionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
FirehoseClientConfiguration ClientConfigurationType
virtual Model::ListTagsForDeliveryStreamOutcome ListTagsForDeliveryStream(const Model::ListTagsForDeliveryStreamRequest &request) const
virtual Model::StartDeliveryStreamEncryptionOutcome StartDeliveryStreamEncryption(const Model::StartDeliveryStreamEncryptionRequest &request) const
Model::PutRecordOutcomeCallable PutRecordCallable(const PutRecordRequestT &request) const
void ListTagsForDeliveryStreamAsync(const ListTagsForDeliveryStreamRequestT &request, const ListTagsForDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
void UntagDeliveryStreamAsync(const UntagDeliveryStreamRequestT &request, const UntagDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Model::TagDeliveryStreamOutcomeCallable TagDeliveryStreamCallable(const TagDeliveryStreamRequestT &request) const
void PutRecordAsync(const PutRecordRequestT &request, const PutRecordResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
static const char * GetServiceName()
virtual Model::PutRecordBatchOutcome PutRecordBatch(const Model::PutRecordBatchRequest &request) const
void StopDeliveryStreamEncryptionAsync(const StopDeliveryStreamEncryptionRequestT &request, const StopDeliveryStreamEncryptionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Model::ListTagsForDeliveryStreamOutcomeCallable ListTagsForDeliveryStreamCallable(const ListTagsForDeliveryStreamRequestT &request) const
void UpdateDestinationAsync(const UpdateDestinationRequestT &request, const UpdateDestinationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
std::shared_ptr< FirehoseEndpointProviderBase > & accessEndpointProvider()
Model::PutRecordBatchOutcomeCallable PutRecordBatchCallable(const PutRecordBatchRequestT &request) const
FirehoseClient(const Aws::Firehose::FirehoseClientConfiguration &clientConfiguration=Aws::Firehose::FirehoseClientConfiguration(), std::shared_ptr< FirehoseEndpointProviderBase > endpointProvider=nullptr)
void TagDeliveryStreamAsync(const TagDeliveryStreamRequestT &request, const TagDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
virtual Model::CreateDeliveryStreamOutcome CreateDeliveryStream(const Model::CreateDeliveryStreamRequest &request) const
FirehoseClient(const Aws::Client::ClientConfiguration &clientConfiguration)
FirehoseClient(const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, const Aws::Client::ClientConfiguration &clientConfiguration)
Model::CreateDeliveryStreamOutcomeCallable CreateDeliveryStreamCallable(const CreateDeliveryStreamRequestT &request) const
virtual Model::UpdateDestinationOutcome UpdateDestination(const Model::UpdateDestinationRequest &request) const
virtual Model::StopDeliveryStreamEncryptionOutcome StopDeliveryStreamEncryption(const Model::StopDeliveryStreamEncryptionRequest &request) const
Model::DeleteDeliveryStreamOutcomeCallable DeleteDeliveryStreamCallable(const DeleteDeliveryStreamRequestT &request) const
static const char * GetAllocationTag()
virtual Model::DescribeDeliveryStreamOutcome DescribeDeliveryStream(const Model::DescribeDeliveryStreamRequest &request) const
FirehoseEndpointProvider EndpointProviderType
void DeleteDeliveryStreamAsync(const DeleteDeliveryStreamRequestT &request, const DeleteDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
virtual Model::TagDeliveryStreamOutcome TagDeliveryStream(const Model::TagDeliveryStreamRequest &request) const
virtual Model::UntagDeliveryStreamOutcome UntagDeliveryStream(const Model::UntagDeliveryStreamRequest &request) const
Model::ListDeliveryStreamsOutcomeCallable ListDeliveryStreamsCallable(const ListDeliveryStreamsRequestT &request={}) const
Aws::Client::AWSJsonClient BASECLASS
void ListDeliveryStreamsAsync(const ListDeliveryStreamsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListDeliveryStreamsRequestT &request={}) const
FirehoseClient(const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, std::shared_ptr< FirehoseEndpointProviderBase > endpointProvider=nullptr, const Aws::Firehose::FirehoseClientConfiguration &clientConfiguration=Aws::Firehose::FirehoseClientConfiguration())
void DescribeDeliveryStreamAsync(const DescribeDeliveryStreamRequestT &request, const DescribeDeliveryStreamResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
Model::UpdateDestinationOutcomeCallable UpdateDestinationCallable(const UpdateDestinationRequestT &request) const
void OverrideEndpoint(const Aws::String &endpoint)
Model::UntagDeliveryStreamOutcomeCallable UntagDeliveryStreamCallable(const UntagDeliveryStreamRequestT &request) const
Model::StopDeliveryStreamEncryptionOutcomeCallable StopDeliveryStreamEncryptionCallable(const StopDeliveryStreamEncryptionRequestT &request) const
std::future< UpdateDestinationOutcome > UpdateDestinationOutcomeCallable
std::future< DeleteDeliveryStreamOutcome > DeleteDeliveryStreamOutcomeCallable
std::future< DescribeDeliveryStreamOutcome > DescribeDeliveryStreamOutcomeCallable
std::future< CreateDeliveryStreamOutcome > CreateDeliveryStreamOutcomeCallable
std::future< UntagDeliveryStreamOutcome > UntagDeliveryStreamOutcomeCallable
std::future< PutRecordBatchOutcome > PutRecordBatchOutcomeCallable
std::future< ListDeliveryStreamsOutcome > ListDeliveryStreamsOutcomeCallable
std::future< TagDeliveryStreamOutcome > TagDeliveryStreamOutcomeCallable
std::future< StartDeliveryStreamEncryptionOutcome > StartDeliveryStreamEncryptionOutcomeCallable
std::future< StopDeliveryStreamEncryptionOutcome > StopDeliveryStreamEncryptionOutcomeCallable
std::future< PutRecordOutcome > PutRecordOutcomeCallable
std::future< ListTagsForDeliveryStreamOutcome > ListTagsForDeliveryStreamOutcomeCallable
std::function< void(const FirehoseClient *, const Model::TagDeliveryStreamRequest &, const Model::TagDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > TagDeliveryStreamResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::UpdateDestinationRequest &, const Model::UpdateDestinationOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > UpdateDestinationResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::StopDeliveryStreamEncryptionRequest &, const Model::StopDeliveryStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StopDeliveryStreamEncryptionResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::CreateDeliveryStreamRequest &, const Model::CreateDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > CreateDeliveryStreamResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::PutRecordBatchRequest &, const Model::PutRecordBatchOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordBatchResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::PutRecordRequest &, const Model::PutRecordOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutRecordResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::DeleteDeliveryStreamRequest &, const Model::DeleteDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeleteDeliveryStreamResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::StartDeliveryStreamEncryptionRequest &, const Model::StartDeliveryStreamEncryptionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > StartDeliveryStreamEncryptionResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::UntagDeliveryStreamRequest &, const Model::UntagDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > UntagDeliveryStreamResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::ListTagsForDeliveryStreamRequest &, const Model::ListTagsForDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListTagsForDeliveryStreamResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::ListDeliveryStreamsRequest &, const Model::ListDeliveryStreamsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListDeliveryStreamsResponseReceivedHandler
std::function< void(const FirehoseClient *, const Model::DescribeDeliveryStreamRequest &, const Model::DescribeDeliveryStreamOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeDeliveryStreamResponseReceivedHandler
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String