AWS IoT Device SDK C++ v2  1.34.0
AWS IoT Device SDK C++ v2
IotJobsClient.h
Go to the documentation of this file.
1 #pragma once
2 
3 /* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
4  * SPDX-License-Identifier: Apache-2.0.
5  *
6  * This file is generated
7  */
8 
9 #include <aws/iotjobs/Exports.h>
10 
11 #include <aws/crt/StlAllocator.h>
12 #include <aws/crt/Types.h>
13 
16 
17 namespace Aws
18 {
19  namespace Iotjobs
20  {
21 
22  class DescribeJobExecutionRequest;
23  class DescribeJobExecutionResponse;
24  class DescribeJobExecutionSubscriptionRequest;
25  class GetPendingJobExecutionsRequest;
26  class GetPendingJobExecutionsResponse;
27  class GetPendingJobExecutionsSubscriptionRequest;
28  class JobExecutionsChangedEvent;
29  class JobExecutionsChangedSubscriptionRequest;
30  class NextJobExecutionChangedEvent;
31  class NextJobExecutionChangedSubscriptionRequest;
32  class RejectedError;
33  class StartNextJobExecutionResponse;
34  class StartNextPendingJobExecutionRequest;
35  class StartNextPendingJobExecutionSubscriptionRequest;
36  class UpdateJobExecutionRequest;
37  class UpdateJobExecutionResponse;
38  class UpdateJobExecutionSubscriptionRequest;
39 
40  using OnSubscribeComplete = std::function<void(int ioErr)>;
41  using OnPublishComplete = std::function<void(int ioErr)>;
42 
44  std::function<void(Aws::Iotjobs::DescribeJobExecutionResponse *, int ioErr)>;
45 
47  std::function<void(Aws::Iotjobs::RejectedError *, int ioErr)>;
48 
50  std::function<void(Aws::Iotjobs::GetPendingJobExecutionsResponse *, int ioErr)>;
51 
53  std::function<void(Aws::Iotjobs::RejectedError *, int ioErr)>;
54 
56  std::function<void(Aws::Iotjobs::JobExecutionsChangedEvent *, int ioErr)>;
57 
59  std::function<void(Aws::Iotjobs::NextJobExecutionChangedEvent *, int ioErr)>;
60 
62  std::function<void(Aws::Iotjobs::StartNextJobExecutionResponse *, int ioErr)>;
63 
65  std::function<void(Aws::Iotjobs::RejectedError *, int ioErr)>;
66 
68  std::function<void(Aws::Iotjobs::UpdateJobExecutionResponse *, int ioErr)>;
69 
71  std::function<void(Aws::Iotjobs::RejectedError *, int ioErr)>;
72 
81  {
82  public:
83  IotJobsClient(const std::shared_ptr<Aws::Crt::Mqtt::MqttConnection> &connection);
84  IotJobsClient(const std::shared_ptr<Aws::Crt::Mqtt5::Mqtt5Client> &mqtt5Client);
85 
86  operator bool() const noexcept;
87  int GetLastError() const noexcept;
88 
108  bool SubscribeToDescribeJobExecutionAccepted(
112  const OnSubscribeComplete &onSubAck);
113 
133  bool SubscribeToDescribeJobExecutionRejected(
137  const OnSubscribeComplete &onSubAck);
138 
158  bool SubscribeToGetPendingJobExecutionsAccepted(
162  const OnSubscribeComplete &onSubAck);
163 
183  bool SubscribeToGetPendingJobExecutionsRejected(
187  const OnSubscribeComplete &onSubAck);
188 
208  bool SubscribeToJobExecutionsChangedEvents(
212  const OnSubscribeComplete &onSubAck);
213 
233  bool SubscribeToNextJobExecutionChangedEvents(
237  const OnSubscribeComplete &onSubAck);
238 
258  bool SubscribeToStartNextPendingJobExecutionAccepted(
262  const OnSubscribeComplete &onSubAck);
263 
283  bool SubscribeToStartNextPendingJobExecutionRejected(
287  const OnSubscribeComplete &onSubAck);
288 
308  bool SubscribeToUpdateJobExecutionAccepted(
312  const OnSubscribeComplete &onSubAck);
313 
333  bool SubscribeToUpdateJobExecutionRejected(
337  const OnSubscribeComplete &onSubAck);
338 
357  bool PublishDescribeJobExecution(
360  const OnPublishComplete &onPubAck);
361 
380  bool PublishGetPendingJobExecutions(
383  const OnPublishComplete &onPubAck);
384 
403  bool PublishStartNextPendingJobExecution(
406  const OnPublishComplete &onPubAck);
407 
428  bool PublishUpdateJobExecution(
431  const OnPublishComplete &onPubAck);
432 
433  private:
434  std::shared_ptr<Aws::Crt::Mqtt::MqttConnection> m_connection;
435  };
436 
437  } // namespace Iotjobs
438 
439 } // namespace Aws
Aws::Iotjobs::OnSubscribeToDescribeJobExecutionRejectedResponse
std::function< void(Aws::Iotjobs::RejectedError *, int ioErr)> OnSubscribeToDescribeJobExecutionRejectedResponse
Definition: IotJobsClient.h:47
Aws::Iotjobs::NextJobExecutionChangedEvent
Definition: NextJobExecutionChangedEvent.h:30
AWS_IOTJOBS_API
#define AWS_IOTJOBS_API
Definition: Exports.h:20
Aws::Iotjobs::StartNextJobExecutionResponse
Definition: StartNextJobExecutionResponse.h:27
Aws::Iotjobs::RejectedError
Definition: RejectedError.h:28
Aws::Iotjobs::OnSubscribeToNextJobExecutionChangedEventsResponse
std::function< void(Aws::Iotjobs::NextJobExecutionChangedEvent *, int ioErr)> OnSubscribeToNextJobExecutionChangedEventsResponse
Definition: IotJobsClient.h:59
Aws::Iotjobs::OnSubscribeToStartNextPendingJobExecutionRejectedResponse
std::function< void(Aws::Iotjobs::RejectedError *, int ioErr)> OnSubscribeToStartNextPendingJobExecutionRejectedResponse
Definition: IotJobsClient.h:65
Aws::Iotjobs::StartNextPendingJobExecutionSubscriptionRequest
Definition: StartNextPendingJobExecutionSubscriptionRequest.h:24
Aws::Iotjobs::OnSubscribeToDescribeJobExecutionAcceptedResponse
std::function< void(Aws::Iotjobs::DescribeJobExecutionResponse *, int ioErr)> OnSubscribeToDescribeJobExecutionAcceptedResponse
Definition: IotJobsClient.h:44
Aws::Iotjobs::OnSubscribeToGetPendingJobExecutionsAcceptedResponse
std::function< void(Aws::Iotjobs::GetPendingJobExecutionsResponse *, int ioErr)> OnSubscribeToGetPendingJobExecutionsAcceptedResponse
Definition: IotJobsClient.h:50
Aws::Iotjobs::StartNextPendingJobExecutionRequest
Definition: StartNextPendingJobExecutionRequest.h:24
StlAllocator.h
Exports.h
Aws::Iotjobs::OnSubscribeToUpdateJobExecutionRejectedResponse
std::function< void(Aws::Iotjobs::RejectedError *, int ioErr)> OnSubscribeToUpdateJobExecutionRejectedResponse
Definition: IotJobsClient.h:71
Aws::Iotjobs::JobExecutionsChangedEvent
Definition: JobExecutionsChangedEvent.h:28
Aws::Crt::Mqtt::QOS
aws_mqtt_qos QOS
Definition: Types.h:40
Aws::Iotjobs::DescribeJobExecutionRequest
Definition: DescribeJobExecutionRequest.h:24
Mqtt5Client.h
Aws::Iotjobs::DescribeJobExecutionResponse
Definition: DescribeJobExecutionResponse.h:27
Aws::Iotjobs::DescribeJobExecutionSubscriptionRequest
Definition: DescribeJobExecutionSubscriptionRequest.h:24
Aws::Iotjobs::GetPendingJobExecutionsSubscriptionRequest
Definition: GetPendingJobExecutionsSubscriptionRequest.h:24
Aws::Iotjobs::UpdateJobExecutionSubscriptionRequest
Definition: UpdateJobExecutionSubscriptionRequest.h:24
Aws::Iotjobs::OnSubscribeToJobExecutionsChangedEventsResponse
std::function< void(Aws::Iotjobs::JobExecutionsChangedEvent *, int ioErr)> OnSubscribeToJobExecutionsChangedEventsResponse
Definition: IotJobsClient.h:56
Types.h
Aws::Iotjobs::GetPendingJobExecutionsRequest
Definition: GetPendingJobExecutionsRequest.h:24
Aws::Iotjobs::OnSubscribeToStartNextPendingJobExecutionAcceptedResponse
std::function< void(Aws::Iotjobs::StartNextJobExecutionResponse *, int ioErr)> OnSubscribeToStartNextPendingJobExecutionAcceptedResponse
Definition: IotJobsClient.h:62
Aws::Iotjobs::OnSubscribeToUpdateJobExecutionAcceptedResponse
std::function< void(Aws::Iotjobs::UpdateJobExecutionResponse *, int ioErr)> OnSubscribeToUpdateJobExecutionAcceptedResponse
Definition: IotJobsClient.h:68
Aws::Iotjobs::NextJobExecutionChangedSubscriptionRequest
Definition: NextJobExecutionChangedSubscriptionRequest.h:24
Aws::Iotjobs::IotJobsClient
Definition: IotJobsClient.h:81
Aws
Definition: Allocator.h:11
Aws::Iotjobs::GetPendingJobExecutionsResponse
Definition: GetPendingJobExecutionsResponse.h:27
Aws::Iotjobs::OnSubscribeToGetPendingJobExecutionsRejectedResponse
std::function< void(Aws::Iotjobs::RejectedError *, int ioErr)> OnSubscribeToGetPendingJobExecutionsRejectedResponse
Definition: IotJobsClient.h:53
MqttClient.h
Aws::Iotjobs::JobExecutionsChangedSubscriptionRequest
Definition: JobExecutionsChangedSubscriptionRequest.h:24
Aws::Iotjobs::OnSubscribeComplete
std::function< void(int ioErr)> OnSubscribeComplete
Definition: IotJobsClient.h:40
Aws::Iotjobs::OnPublishComplete
std::function< void(int ioErr)> OnPublishComplete
Definition: IotJobsClient.h:41
Aws::Iotjobs::UpdateJobExecutionRequest
Definition: UpdateJobExecutionRequest.h:26
Aws::Iotjobs::UpdateJobExecutionResponse
Definition: UpdateJobExecutionResponse.h:28