IotJobsClientV2.h

Go to the documentation of this file.

#pragma once
 
/* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: Apache-2.0.
 *
 * This file is generated
 */
 
#include <aws/iotjobs/Exports.h>
 
#include <aws/crt/StlAllocator.h>
#include <aws/crt/Types.h>
#include <aws/iot/MqttRequestResponseClient.h>
 
#include <functional>
 
namespace Aws
{
    namespace Crt
    {
        namespace Mqtt
        {
            class MqttConnection;
        }
        namespace Mqtt5
        {
            class Mqtt5Client;
        }
    } // namespace Crt
} // namespace Aws
 
namespace Aws
{
    namespace Iotjobs
    {
 
        template <typename E> class ServiceErrorV2
        {
          public:
            ServiceErrorV2() = delete;
            ServiceErrorV2(const ServiceErrorV2<E> &rhs) = default;
            ServiceErrorV2(ServiceErrorV2<E> &&rhs) = default;
 
            explicit ServiceErrorV2(int errorCode) : m_errorCode(errorCode), m_modeledError() {}
 
            ServiceErrorV2(int errorCode, E &&modeledError)
                : m_errorCode(errorCode), m_modeledError(std::move(modeledError))
            {
            }
 
            ~ServiceErrorV2() = default;
 
            ServiceErrorV2<E> &operator=(const ServiceErrorV2<E> &rhs) = default;
            ServiceErrorV2<E> &operator=(ServiceErrorV2<E> &&rhs) = default;
 
            int GetErrorCode() const { return m_errorCode; }
 
            bool HasModeledError() const { return m_modeledError.has_value(); }
            const E &GetModeledError() const { return m_modeledError.value(); }
 
          private:
            int m_errorCode;
 
            Aws::Crt::Optional<E> m_modeledError;
        };
 
        class DescribeJobExecutionRequest;
        class DescribeJobExecutionResponse;
        class GetPendingJobExecutionsRequest;
        class GetPendingJobExecutionsResponse;
        class JobExecutionsChangedEvent;
        class JobExecutionsChangedSubscriptionRequest;
        class NextJobExecutionChangedEvent;
        class NextJobExecutionChangedSubscriptionRequest;
        class StartNextJobExecutionResponse;
        class StartNextPendingJobExecutionRequest;
        class UpdateJobExecutionRequest;
        class UpdateJobExecutionResponse;
        class V2ErrorResponse;
 
        using DescribeJobExecutionResult =
            Aws::Iot::RequestResponse::Result<DescribeJobExecutionResponse, ServiceErrorV2<V2ErrorResponse>>;
        using DescribeJobExecutionResultHandler = std::function<void(DescribeJobExecutionResult &&)>;
 
        using GetPendingJobExecutionsResult =
            Aws::Iot::RequestResponse::Result<GetPendingJobExecutionsResponse, ServiceErrorV2<V2ErrorResponse>>;
        using GetPendingJobExecutionsResultHandler = std::function<void(GetPendingJobExecutionsResult &&)>;
 
        using StartNextPendingJobExecutionResult =
            Aws::Iot::RequestResponse::Result<StartNextJobExecutionResponse, ServiceErrorV2<V2ErrorResponse>>;
        using StartNextPendingJobExecutionResultHandler = std::function<void(StartNextPendingJobExecutionResult &&)>;
 
        using UpdateJobExecutionResult =
            Aws::Iot::RequestResponse::Result<UpdateJobExecutionResponse, ServiceErrorV2<V2ErrorResponse>>;
        using UpdateJobExecutionResultHandler = std::function<void(UpdateJobExecutionResult &&)>;

        class AWS_IOTJOBS_API IClientV2
        {
          public:
            virtual ~IClientV2() = default;

            virtual bool DescribeJobExecution(
                const DescribeJobExecutionRequest &request,
                const DescribeJobExecutionResultHandler &handler) = 0;

            virtual bool GetPendingJobExecutions(
                const GetPendingJobExecutionsRequest &request,
                const GetPendingJobExecutionsResultHandler &handler) = 0;

            virtual bool StartNextPendingJobExecution(
                const StartNextPendingJobExecutionRequest &request,
                const StartNextPendingJobExecutionResultHandler &handler) = 0;

            virtual bool UpdateJobExecution(
                const UpdateJobExecutionRequest &request,
                const UpdateJobExecutionResultHandler &handler) = 0;

            virtual std::shared_ptr<Aws::Iot::RequestResponse::IStreamingOperation> CreateJobExecutionsChangedStream(
                const JobExecutionsChangedSubscriptionRequest &request,
                const Aws::Iot::RequestResponse::StreamingOperationOptions<JobExecutionsChangedEvent> &options) = 0;

            virtual std::shared_ptr<Aws::Iot::RequestResponse::IStreamingOperation> CreateNextJobExecutionChangedStream(
                const NextJobExecutionChangedSubscriptionRequest &request,
                const Aws::Iot::RequestResponse::StreamingOperationOptions<NextJobExecutionChangedEvent> &options) = 0;
        };

        AWS_IOTJOBS_API std::shared_ptr<IClientV2> NewClientFrom5(
            const Aws::Crt::Mqtt5::Mqtt5Client &protocolClient,
            const Aws::Iot::RequestResponse::RequestResponseClientOptions &options,
            Aws::Crt::Allocator *allocator = Aws::Crt::ApiAllocator());

        AWS_IOTJOBS_API std::shared_ptr<IClientV2> NewClientFrom311(
            const Aws::Crt::Mqtt::MqttConnection &protocolClient,
            const Aws::Iot::RequestResponse::RequestResponseClientOptions &options,
            Aws::Crt::Allocator *allocator = Aws::Crt::ApiAllocator());
 
    } // namespace Iotjobs
} // namespace Aws