AWS SDK for C++  1.8.95
AWS SDK for C++
DataPipelineClient.h
Go to the documentation of this file.
1 
6 #pragma once
31 #include <aws/core/NoResult.h>
34 #include <future>
35 #include <functional>
36 
37 namespace Aws
38 {
39 
40 namespace Http
41 {
42  class HttpClient;
43  class HttpClientFactory;
44 } // namespace Http
45 
46 namespace Utils
47 {
48  template< typename R, typename E> class Outcome;
49 namespace Threading
50 {
51  class Executor;
52 } // namespace Threading
53 } // namespace Utils
54 
55 namespace Auth
56 {
57  class AWSCredentials;
58  class AWSCredentialsProvider;
59 } // namespace Auth
60 
61 namespace Client
62 {
63  class RetryStrategy;
64 } // namespace Client
65 
66 namespace DataPipeline
67 {
68 
69 namespace Model
70 {
72  class AddTagsRequest;
81  class PollForTaskRequest;
83  class QueryObjectsRequest;
84  class RemoveTagsRequest;
87  class SetStatusRequest;
90 
110 
111  typedef std::future<ActivatePipelineOutcome> ActivatePipelineOutcomeCallable;
112  typedef std::future<AddTagsOutcome> AddTagsOutcomeCallable;
113  typedef std::future<CreatePipelineOutcome> CreatePipelineOutcomeCallable;
114  typedef std::future<DeactivatePipelineOutcome> DeactivatePipelineOutcomeCallable;
115  typedef std::future<DeletePipelineOutcome> DeletePipelineOutcomeCallable;
116  typedef std::future<DescribeObjectsOutcome> DescribeObjectsOutcomeCallable;
117  typedef std::future<DescribePipelinesOutcome> DescribePipelinesOutcomeCallable;
118  typedef std::future<EvaluateExpressionOutcome> EvaluateExpressionOutcomeCallable;
119  typedef std::future<GetPipelineDefinitionOutcome> GetPipelineDefinitionOutcomeCallable;
120  typedef std::future<ListPipelinesOutcome> ListPipelinesOutcomeCallable;
121  typedef std::future<PollForTaskOutcome> PollForTaskOutcomeCallable;
122  typedef std::future<PutPipelineDefinitionOutcome> PutPipelineDefinitionOutcomeCallable;
123  typedef std::future<QueryObjectsOutcome> QueryObjectsOutcomeCallable;
124  typedef std::future<RemoveTagsOutcome> RemoveTagsOutcomeCallable;
125  typedef std::future<ReportTaskProgressOutcome> ReportTaskProgressOutcomeCallable;
126  typedef std::future<ReportTaskRunnerHeartbeatOutcome> ReportTaskRunnerHeartbeatOutcomeCallable;
127  typedef std::future<SetStatusOutcome> SetStatusOutcomeCallable;
128  typedef std::future<SetTaskStatusOutcome> SetTaskStatusOutcomeCallable;
129  typedef std::future<ValidatePipelineDefinitionOutcome> ValidatePipelineDefinitionOutcomeCallable;
130 } // namespace Model
131 
133 
134  typedef std::function<void(const DataPipelineClient*, const Model::ActivatePipelineRequest&, const Model::ActivatePipelineOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ActivatePipelineResponseReceivedHandler;
135  typedef std::function<void(const DataPipelineClient*, const Model::AddTagsRequest&, const Model::AddTagsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > AddTagsResponseReceivedHandler;
136  typedef std::function<void(const DataPipelineClient*, const Model::CreatePipelineRequest&, const Model::CreatePipelineOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > CreatePipelineResponseReceivedHandler;
137  typedef std::function<void(const DataPipelineClient*, const Model::DeactivatePipelineRequest&, const Model::DeactivatePipelineOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DeactivatePipelineResponseReceivedHandler;
138  typedef std::function<void(const DataPipelineClient*, const Model::DeletePipelineRequest&, const Model::DeletePipelineOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DeletePipelineResponseReceivedHandler;
139  typedef std::function<void(const DataPipelineClient*, const Model::DescribeObjectsRequest&, const Model::DescribeObjectsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribeObjectsResponseReceivedHandler;
140  typedef std::function<void(const DataPipelineClient*, const Model::DescribePipelinesRequest&, const Model::DescribePipelinesOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > DescribePipelinesResponseReceivedHandler;
141  typedef std::function<void(const DataPipelineClient*, const Model::EvaluateExpressionRequest&, const Model::EvaluateExpressionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > EvaluateExpressionResponseReceivedHandler;
142  typedef std::function<void(const DataPipelineClient*, const Model::GetPipelineDefinitionRequest&, const Model::GetPipelineDefinitionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > GetPipelineDefinitionResponseReceivedHandler;
143  typedef std::function<void(const DataPipelineClient*, const Model::ListPipelinesRequest&, const Model::ListPipelinesOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ListPipelinesResponseReceivedHandler;
144  typedef std::function<void(const DataPipelineClient*, const Model::PollForTaskRequest&, const Model::PollForTaskOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > PollForTaskResponseReceivedHandler;
145  typedef std::function<void(const DataPipelineClient*, const Model::PutPipelineDefinitionRequest&, const Model::PutPipelineDefinitionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > PutPipelineDefinitionResponseReceivedHandler;
146  typedef std::function<void(const DataPipelineClient*, const Model::QueryObjectsRequest&, const Model::QueryObjectsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > QueryObjectsResponseReceivedHandler;
147  typedef std::function<void(const DataPipelineClient*, const Model::RemoveTagsRequest&, const Model::RemoveTagsOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > RemoveTagsResponseReceivedHandler;
148  typedef std::function<void(const DataPipelineClient*, const Model::ReportTaskProgressRequest&, const Model::ReportTaskProgressOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ReportTaskProgressResponseReceivedHandler;
149  typedef std::function<void(const DataPipelineClient*, const Model::ReportTaskRunnerHeartbeatRequest&, const Model::ReportTaskRunnerHeartbeatOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ReportTaskRunnerHeartbeatResponseReceivedHandler;
150  typedef std::function<void(const DataPipelineClient*, const Model::SetStatusRequest&, const Model::SetStatusOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > SetStatusResponseReceivedHandler;
151  typedef std::function<void(const DataPipelineClient*, const Model::SetTaskStatusRequest&, const Model::SetTaskStatusOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > SetTaskStatusResponseReceivedHandler;
152  typedef std::function<void(const DataPipelineClient*, const Model::ValidatePipelineDefinitionRequest&, const Model::ValidatePipelineDefinitionOutcome&, const std::shared_ptr<const Aws::Client::AsyncCallerContext>&) > ValidatePipelineDefinitionResponseReceivedHandler;
153 
175  {
176  public:
178 
184 
190 
195  DataPipelineClient(const std::shared_ptr<Aws::Auth::AWSCredentialsProvider>& credentialsProvider,
197 
198  virtual ~DataPipelineClient();
199 
200 
211  virtual Model::ActivatePipelineOutcome ActivatePipeline(const Model::ActivatePipelineRequest& request) const;
212 
225  virtual Model::ActivatePipelineOutcomeCallable ActivatePipelineCallable(const Model::ActivatePipelineRequest& request) const;
226 
239  virtual void ActivatePipelineAsync(const Model::ActivatePipelineRequest& request, const ActivatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
240 
247  virtual Model::AddTagsOutcome AddTags(const Model::AddTagsRequest& request) const;
248 
257  virtual Model::AddTagsOutcomeCallable AddTagsCallable(const Model::AddTagsRequest& request) const;
258 
267  virtual void AddTagsAsync(const Model::AddTagsRequest& request, const AddTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
268 
275  virtual Model::CreatePipelineOutcome CreatePipeline(const Model::CreatePipelineRequest& request) const;
276 
285  virtual Model::CreatePipelineOutcomeCallable CreatePipelineCallable(const Model::CreatePipelineRequest& request) const;
286 
295  virtual void CreatePipelineAsync(const Model::CreatePipelineRequest& request, const CreatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
296 
306  virtual Model::DeactivatePipelineOutcome DeactivatePipeline(const Model::DeactivatePipelineRequest& request) const;
307 
319  virtual Model::DeactivatePipelineOutcomeCallable DeactivatePipelineCallable(const Model::DeactivatePipelineRequest& request) const;
320 
332  virtual void DeactivatePipelineAsync(const Model::DeactivatePipelineRequest& request, const DeactivatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
333 
345  virtual Model::DeletePipelineOutcome DeletePipeline(const Model::DeletePipelineRequest& request) const;
346 
360  virtual Model::DeletePipelineOutcomeCallable DeletePipelineCallable(const Model::DeletePipelineRequest& request) const;
361 
375  virtual void DeletePipelineAsync(const Model::DeletePipelineRequest& request, const DeletePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
376 
384  virtual Model::DescribeObjectsOutcome DescribeObjects(const Model::DescribeObjectsRequest& request) const;
385 
395  virtual Model::DescribeObjectsOutcomeCallable DescribeObjectsCallable(const Model::DescribeObjectsRequest& request) const;
396 
406  virtual void DescribeObjectsAsync(const Model::DescribeObjectsRequest& request, const DescribeObjectsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
407 
420  virtual Model::DescribePipelinesOutcome DescribePipelines(const Model::DescribePipelinesRequest& request) const;
421 
436  virtual Model::DescribePipelinesOutcomeCallable DescribePipelinesCallable(const Model::DescribePipelinesRequest& request) const;
437 
452  virtual void DescribePipelinesAsync(const Model::DescribePipelinesRequest& request, const DescribePipelinesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
453 
461  virtual Model::EvaluateExpressionOutcome EvaluateExpression(const Model::EvaluateExpressionRequest& request) const;
462 
472  virtual Model::EvaluateExpressionOutcomeCallable EvaluateExpressionCallable(const Model::EvaluateExpressionRequest& request) const;
473 
483  virtual void EvaluateExpressionAsync(const Model::EvaluateExpressionRequest& request, const EvaluateExpressionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
484 
492  virtual Model::GetPipelineDefinitionOutcome GetPipelineDefinition(const Model::GetPipelineDefinitionRequest& request) const;
493 
503  virtual Model::GetPipelineDefinitionOutcomeCallable GetPipelineDefinitionCallable(const Model::GetPipelineDefinitionRequest& request) const;
504 
514  virtual void GetPipelineDefinitionAsync(const Model::GetPipelineDefinitionRequest& request, const GetPipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
515 
522  virtual Model::ListPipelinesOutcome ListPipelines(const Model::ListPipelinesRequest& request) const;
523 
532  virtual Model::ListPipelinesOutcomeCallable ListPipelinesCallable(const Model::ListPipelinesRequest& request) const;
533 
542  virtual void ListPipelinesAsync(const Model::ListPipelinesRequest& request, const ListPipelinesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
543 
562  virtual Model::PollForTaskOutcome PollForTask(const Model::PollForTaskRequest& request) const;
563 
584  virtual Model::PollForTaskOutcomeCallable PollForTaskCallable(const Model::PollForTaskRequest& request) const;
585 
606  virtual void PollForTaskAsync(const Model::PollForTaskRequest& request, const PollForTaskResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
607 
623  virtual Model::PutPipelineDefinitionOutcome PutPipelineDefinition(const Model::PutPipelineDefinitionRequest& request) const;
624 
642  virtual Model::PutPipelineDefinitionOutcomeCallable PutPipelineDefinitionCallable(const Model::PutPipelineDefinitionRequest& request) const;
643 
661  virtual void PutPipelineDefinitionAsync(const Model::PutPipelineDefinitionRequest& request, const PutPipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
662 
669  virtual Model::QueryObjectsOutcome QueryObjects(const Model::QueryObjectsRequest& request) const;
670 
679  virtual Model::QueryObjectsOutcomeCallable QueryObjectsCallable(const Model::QueryObjectsRequest& request) const;
680 
689  virtual void QueryObjectsAsync(const Model::QueryObjectsRequest& request, const QueryObjectsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
690 
697  virtual Model::RemoveTagsOutcome RemoveTags(const Model::RemoveTagsRequest& request) const;
698 
707  virtual Model::RemoveTagsOutcomeCallable RemoveTagsCallable(const Model::RemoveTagsRequest& request) const;
708 
717  virtual void RemoveTagsAsync(const Model::RemoveTagsRequest& request, const RemoveTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
718 
734  virtual Model::ReportTaskProgressOutcome ReportTaskProgress(const Model::ReportTaskProgressRequest& request) const;
735 
753  virtual Model::ReportTaskProgressOutcomeCallable ReportTaskProgressCallable(const Model::ReportTaskProgressRequest& request) const;
754 
772  virtual void ReportTaskProgressAsync(const Model::ReportTaskProgressRequest& request, const ReportTaskProgressResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
773 
783  virtual Model::ReportTaskRunnerHeartbeatOutcome ReportTaskRunnerHeartbeat(const Model::ReportTaskRunnerHeartbeatRequest& request) const;
784 
796  virtual Model::ReportTaskRunnerHeartbeatOutcomeCallable ReportTaskRunnerHeartbeatCallable(const Model::ReportTaskRunnerHeartbeatRequest& request) const;
797 
809  virtual void ReportTaskRunnerHeartbeatAsync(const Model::ReportTaskRunnerHeartbeatRequest& request, const ReportTaskRunnerHeartbeatResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
810 
821  virtual Model::SetStatusOutcome SetStatus(const Model::SetStatusRequest& request) const;
822 
835  virtual Model::SetStatusOutcomeCallable SetStatusCallable(const Model::SetStatusRequest& request) const;
836 
849  virtual void SetStatusAsync(const Model::SetStatusRequest& request, const SetStatusResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
850 
861  virtual Model::SetTaskStatusOutcome SetTaskStatus(const Model::SetTaskStatusRequest& request) const;
862 
875  virtual Model::SetTaskStatusOutcomeCallable SetTaskStatusCallable(const Model::SetTaskStatusRequest& request) const;
876 
889  virtual void SetTaskStatusAsync(const Model::SetTaskStatusRequest& request, const SetTaskStatusResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
890 
897  virtual Model::ValidatePipelineDefinitionOutcome ValidatePipelineDefinition(const Model::ValidatePipelineDefinitionRequest& request) const;
898 
907  virtual Model::ValidatePipelineDefinitionOutcomeCallable ValidatePipelineDefinitionCallable(const Model::ValidatePipelineDefinitionRequest& request) const;
908 
917  virtual void ValidatePipelineDefinitionAsync(const Model::ValidatePipelineDefinitionRequest& request, const ValidatePipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context = nullptr) const;
918 
919 
920  void OverrideEndpoint(const Aws::String& endpoint);
921  private:
922  void init(const Aws::Client::ClientConfiguration& clientConfiguration);
923  void ActivatePipelineAsyncHelper(const Model::ActivatePipelineRequest& request, const ActivatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
924  void AddTagsAsyncHelper(const Model::AddTagsRequest& request, const AddTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
925  void CreatePipelineAsyncHelper(const Model::CreatePipelineRequest& request, const CreatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
926  void DeactivatePipelineAsyncHelper(const Model::DeactivatePipelineRequest& request, const DeactivatePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
927  void DeletePipelineAsyncHelper(const Model::DeletePipelineRequest& request, const DeletePipelineResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
928  void DescribeObjectsAsyncHelper(const Model::DescribeObjectsRequest& request, const DescribeObjectsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
929  void DescribePipelinesAsyncHelper(const Model::DescribePipelinesRequest& request, const DescribePipelinesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
930  void EvaluateExpressionAsyncHelper(const Model::EvaluateExpressionRequest& request, const EvaluateExpressionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
931  void GetPipelineDefinitionAsyncHelper(const Model::GetPipelineDefinitionRequest& request, const GetPipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
932  void ListPipelinesAsyncHelper(const Model::ListPipelinesRequest& request, const ListPipelinesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
933  void PollForTaskAsyncHelper(const Model::PollForTaskRequest& request, const PollForTaskResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
934  void PutPipelineDefinitionAsyncHelper(const Model::PutPipelineDefinitionRequest& request, const PutPipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
935  void QueryObjectsAsyncHelper(const Model::QueryObjectsRequest& request, const QueryObjectsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
936  void RemoveTagsAsyncHelper(const Model::RemoveTagsRequest& request, const RemoveTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
937  void ReportTaskProgressAsyncHelper(const Model::ReportTaskProgressRequest& request, const ReportTaskProgressResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
938  void ReportTaskRunnerHeartbeatAsyncHelper(const Model::ReportTaskRunnerHeartbeatRequest& request, const ReportTaskRunnerHeartbeatResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
939  void SetStatusAsyncHelper(const Model::SetStatusRequest& request, const SetStatusResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
940  void SetTaskStatusAsyncHelper(const Model::SetTaskStatusRequest& request, const SetTaskStatusResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
941  void ValidatePipelineDefinitionAsyncHelper(const Model::ValidatePipelineDefinitionRequest& request, const ValidatePipelineDefinitionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const;
942 
943  Aws::String m_uri;
944  Aws::String m_configScheme;
945  std::shared_ptr<Aws::Utils::Threading::Executor> m_executor;
946  };
947 
948 } // namespace DataPipeline
949 } // namespace Aws
std::function< void(const DataPipelineClient *, const Model::ReportTaskRunnerHeartbeatRequest &, const Model::ReportTaskRunnerHeartbeatOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ReportTaskRunnerHeartbeatResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::GetPipelineDefinitionRequest &, const Model::GetPipelineDefinitionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > GetPipelineDefinitionResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::EvaluateExpressionRequest &, const Model::EvaluateExpressionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > EvaluateExpressionResponseReceivedHandler
Aws::Utils::Outcome< SetTaskStatusResult, DataPipelineError > SetTaskStatusOutcome
Aws::Utils::Outcome< EvaluateExpressionResult, DataPipelineError > EvaluateExpressionOutcome
std::function< void(const DataPipelineClient *, const Model::QueryObjectsRequest &, const Model::QueryObjectsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > QueryObjectsResponseReceivedHandler
std::future< AddTagsOutcome > AddTagsOutcomeCallable
Aws::Utils::Outcome< DeactivatePipelineResult, DataPipelineError > DeactivatePipelineOutcome
std::future< DescribeObjectsOutcome > DescribeObjectsOutcomeCallable
Aws::Utils::Outcome< ReportTaskRunnerHeartbeatResult, DataPipelineError > ReportTaskRunnerHeartbeatOutcome
Aws::Utils::Outcome< PutPipelineDefinitionResult, DataPipelineError > PutPipelineDefinitionOutcome
std::function< void(const DataPipelineClient *, const Model::DeletePipelineRequest &, const Model::DeletePipelineOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeletePipelineResponseReceivedHandler
std::future< SetTaskStatusOutcome > SetTaskStatusOutcomeCallable
Aws::Utils::Outcome< ReportTaskProgressResult, DataPipelineError > ReportTaskProgressOutcome
std::future< EvaluateExpressionOutcome > EvaluateExpressionOutcomeCallable
std::future< ValidatePipelineDefinitionOutcome > ValidatePipelineDefinitionOutcomeCallable
std::function< void(const DataPipelineClient *, const Model::PollForTaskRequest &, const Model::PollForTaskOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PollForTaskResponseReceivedHandler
std::future< CreatePipelineOutcome > CreatePipelineOutcomeCallable
Aws::Utils::Outcome< CreatePipelineResult, DataPipelineError > CreatePipelineOutcome
Aws::Client::AWSJsonClient BASECLASS
Aws::Utils::Outcome< PollForTaskResult, DataPipelineError > PollForTaskOutcome
Aws::Utils::Outcome< ValidatePipelineDefinitionResult, DataPipelineError > ValidatePipelineDefinitionOutcome
std::future< PutPipelineDefinitionOutcome > PutPipelineDefinitionOutcomeCallable
#define AWS_DATAPIPELINE_API
std::function< void(const DataPipelineClient *, const Model::RemoveTagsRequest &, const Model::RemoveTagsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > RemoveTagsResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::DescribeObjectsRequest &, const Model::DescribeObjectsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribeObjectsResponseReceivedHandler
std::future< SetStatusOutcome > SetStatusOutcomeCallable
std::future< RemoveTagsOutcome > RemoveTagsOutcomeCallable
Aws::Utils::Outcome< Aws::NoResult, DataPipelineError > SetStatusOutcome
std::future< DeactivatePipelineOutcome > DeactivatePipelineOutcomeCallable
Aws::Utils::Outcome< Aws::NoResult, DataPipelineError > DeletePipelineOutcome
Aws::Utils::Outcome< ListPipelinesResult, DataPipelineError > ListPipelinesOutcome
Aws::Utils::Outcome< DescribeObjectsResult, DataPipelineError > DescribeObjectsOutcome
Aws::Utils::Outcome< ActivatePipelineResult, DataPipelineError > ActivatePipelineOutcome
std::function< void(const DataPipelineClient *, const Model::SetStatusRequest &, const Model::SetStatusOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SetStatusResponseReceivedHandler
std::future< DescribePipelinesOutcome > DescribePipelinesOutcomeCallable
Aws::Utils::Outcome< RemoveTagsResult, DataPipelineError > RemoveTagsOutcome
std::future< PollForTaskOutcome > PollForTaskOutcomeCallable
std::future< QueryObjectsOutcome > QueryObjectsOutcomeCallable
std::function< void(const DataPipelineClient *, const Model::CreatePipelineRequest &, const Model::CreatePipelineOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > CreatePipelineResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::PutPipelineDefinitionRequest &, const Model::PutPipelineDefinitionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > PutPipelineDefinitionResponseReceivedHandler
std::future< GetPipelineDefinitionOutcome > GetPipelineDefinitionOutcomeCallable
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
std::function< void(const DataPipelineClient *, const Model::ListPipelinesRequest &, const Model::ListPipelinesOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ListPipelinesResponseReceivedHandler
std::future< ListPipelinesOutcome > ListPipelinesOutcomeCallable
std::function< void(const DataPipelineClient *, const Model::DescribePipelinesRequest &, const Model::DescribePipelinesOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DescribePipelinesResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::SetTaskStatusRequest &, const Model::SetTaskStatusOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > SetTaskStatusResponseReceivedHandler
std::future< ReportTaskProgressOutcome > ReportTaskProgressOutcomeCallable
Aws::Utils::Outcome< QueryObjectsResult, DataPipelineError > QueryObjectsOutcome
Aws::Utils::Outcome< GetPipelineDefinitionResult, DataPipelineError > GetPipelineDefinitionOutcome
std::future< ActivatePipelineOutcome > ActivatePipelineOutcomeCallable
std::function< void(const DataPipelineClient *, const Model::ReportTaskProgressRequest &, const Model::ReportTaskProgressOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ReportTaskProgressResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::AddTagsRequest &, const Model::AddTagsOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > AddTagsResponseReceivedHandler
std::function< void(const DataPipelineClient *, const Model::DeactivatePipelineRequest &, const Model::DeactivatePipelineOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > DeactivatePipelineResponseReceivedHandler
Aws::Utils::Outcome< DescribePipelinesResult, DataPipelineError > DescribePipelinesOutcome
std::function< void(const DataPipelineClient *, const Model::ValidatePipelineDefinitionRequest &, const Model::ValidatePipelineDefinitionOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ValidatePipelineDefinitionResponseReceivedHandler
std::future< ReportTaskRunnerHeartbeatOutcome > ReportTaskRunnerHeartbeatOutcomeCallable
Aws::Utils::Outcome< AddTagsResult, DataPipelineError > AddTagsOutcome
std::future< DeletePipelineOutcome > DeletePipelineOutcomeCallable
std::function< void(const DataPipelineClient *, const Model::ActivatePipelineRequest &, const Model::ActivatePipelineOutcome &, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &) > ActivatePipelineResponseReceivedHandler