PipeSourceParameters.h

 
#pragma once
#include <aws/pipes/Pipes_EXPORTS.h>
#include <aws/pipes/model/FilterCriteria.h>
#include <aws/pipes/model/PipeSourceActiveMQBrokerParameters.h>
#include <aws/pipes/model/PipeSourceDynamoDBStreamParameters.h>
#include <aws/pipes/model/PipeSourceKinesisStreamParameters.h>
#include <aws/pipes/model/PipeSourceManagedStreamingKafkaParameters.h>
#include <aws/pipes/model/PipeSourceRabbitMQBrokerParameters.h>
#include <aws/pipes/model/PipeSourceSelfManagedKafkaParameters.h>
#include <aws/pipes/model/PipeSourceSqsQueueParameters.h>
 
#include <utility>
 
namespace Aws {
namespace Utils {
namespace Json {
class JsonValue;
class JsonView;
}  // namespace Json
}  // namespace Utils
namespace Pipes {
namespace Model {
 
class PipeSourceParameters {
 public:
  AWS_PIPES_API PipeSourceParameters() = default;
  AWS_PIPES_API PipeSourceParameters(Aws::Utils::Json::JsonView jsonValue);
  AWS_PIPES_API PipeSourceParameters& operator=(Aws::Utils::Json::JsonView jsonValue);
  AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const;
 
 
  inline const FilterCriteria& GetFilterCriteria() const { return m_filterCriteria; }
  inline bool FilterCriteriaHasBeenSet() const { return m_filterCriteriaHasBeenSet; }
  template <typename FilterCriteriaT = FilterCriteria>
  void SetFilterCriteria(FilterCriteriaT&& value) {
    m_filterCriteriaHasBeenSet = true;
    m_filterCriteria = std::forward<FilterCriteriaT>(value);
  }
  template <typename FilterCriteriaT = FilterCriteria>
  PipeSourceParameters& WithFilterCriteria(FilterCriteriaT&& value) {
    SetFilterCriteria(std::forward<FilterCriteriaT>(value));
    return *this;
  }
 
 
  inline const PipeSourceKinesisStreamParameters& GetKinesisStreamParameters() const { return m_kinesisStreamParameters; }
  inline bool KinesisStreamParametersHasBeenSet() const { return m_kinesisStreamParametersHasBeenSet; }
  template <typename KinesisStreamParametersT = PipeSourceKinesisStreamParameters>
  void SetKinesisStreamParameters(KinesisStreamParametersT&& value) {
    m_kinesisStreamParametersHasBeenSet = true;
    m_kinesisStreamParameters = std::forward<KinesisStreamParametersT>(value);
  }
  template <typename KinesisStreamParametersT = PipeSourceKinesisStreamParameters>
  PipeSourceParameters& WithKinesisStreamParameters(KinesisStreamParametersT&& value) {
    SetKinesisStreamParameters(std::forward<KinesisStreamParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceDynamoDBStreamParameters& GetDynamoDBStreamParameters() const { return m_dynamoDBStreamParameters; }
  inline bool DynamoDBStreamParametersHasBeenSet() const { return m_dynamoDBStreamParametersHasBeenSet; }
  template <typename DynamoDBStreamParametersT = PipeSourceDynamoDBStreamParameters>
  void SetDynamoDBStreamParameters(DynamoDBStreamParametersT&& value) {
    m_dynamoDBStreamParametersHasBeenSet = true;
    m_dynamoDBStreamParameters = std::forward<DynamoDBStreamParametersT>(value);
  }
  template <typename DynamoDBStreamParametersT = PipeSourceDynamoDBStreamParameters>
  PipeSourceParameters& WithDynamoDBStreamParameters(DynamoDBStreamParametersT&& value) {
    SetDynamoDBStreamParameters(std::forward<DynamoDBStreamParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceSqsQueueParameters& GetSqsQueueParameters() const { return m_sqsQueueParameters; }
  inline bool SqsQueueParametersHasBeenSet() const { return m_sqsQueueParametersHasBeenSet; }
  template <typename SqsQueueParametersT = PipeSourceSqsQueueParameters>
  void SetSqsQueueParameters(SqsQueueParametersT&& value) {
    m_sqsQueueParametersHasBeenSet = true;
    m_sqsQueueParameters = std::forward<SqsQueueParametersT>(value);
  }
  template <typename SqsQueueParametersT = PipeSourceSqsQueueParameters>
  PipeSourceParameters& WithSqsQueueParameters(SqsQueueParametersT&& value) {
    SetSqsQueueParameters(std::forward<SqsQueueParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceActiveMQBrokerParameters& GetActiveMQBrokerParameters() const { return m_activeMQBrokerParameters; }
  inline bool ActiveMQBrokerParametersHasBeenSet() const { return m_activeMQBrokerParametersHasBeenSet; }
  template <typename ActiveMQBrokerParametersT = PipeSourceActiveMQBrokerParameters>
  void SetActiveMQBrokerParameters(ActiveMQBrokerParametersT&& value) {
    m_activeMQBrokerParametersHasBeenSet = true;
    m_activeMQBrokerParameters = std::forward<ActiveMQBrokerParametersT>(value);
  }
  template <typename ActiveMQBrokerParametersT = PipeSourceActiveMQBrokerParameters>
  PipeSourceParameters& WithActiveMQBrokerParameters(ActiveMQBrokerParametersT&& value) {
    SetActiveMQBrokerParameters(std::forward<ActiveMQBrokerParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceRabbitMQBrokerParameters& GetRabbitMQBrokerParameters() const { return m_rabbitMQBrokerParameters; }
  inline bool RabbitMQBrokerParametersHasBeenSet() const { return m_rabbitMQBrokerParametersHasBeenSet; }
  template <typename RabbitMQBrokerParametersT = PipeSourceRabbitMQBrokerParameters>
  void SetRabbitMQBrokerParameters(RabbitMQBrokerParametersT&& value) {
    m_rabbitMQBrokerParametersHasBeenSet = true;
    m_rabbitMQBrokerParameters = std::forward<RabbitMQBrokerParametersT>(value);
  }
  template <typename RabbitMQBrokerParametersT = PipeSourceRabbitMQBrokerParameters>
  PipeSourceParameters& WithRabbitMQBrokerParameters(RabbitMQBrokerParametersT&& value) {
    SetRabbitMQBrokerParameters(std::forward<RabbitMQBrokerParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceManagedStreamingKafkaParameters& GetManagedStreamingKafkaParameters() const {
    return m_managedStreamingKafkaParameters;
  }
  inline bool ManagedStreamingKafkaParametersHasBeenSet() const { return m_managedStreamingKafkaParametersHasBeenSet; }
  template <typename ManagedStreamingKafkaParametersT = PipeSourceManagedStreamingKafkaParameters>
  void SetManagedStreamingKafkaParameters(ManagedStreamingKafkaParametersT&& value) {
    m_managedStreamingKafkaParametersHasBeenSet = true;
    m_managedStreamingKafkaParameters = std::forward<ManagedStreamingKafkaParametersT>(value);
  }
  template <typename ManagedStreamingKafkaParametersT = PipeSourceManagedStreamingKafkaParameters>
  PipeSourceParameters& WithManagedStreamingKafkaParameters(ManagedStreamingKafkaParametersT&& value) {
    SetManagedStreamingKafkaParameters(std::forward<ManagedStreamingKafkaParametersT>(value));
    return *this;
  }
 
 
  inline const PipeSourceSelfManagedKafkaParameters& GetSelfManagedKafkaParameters() const { return m_selfManagedKafkaParameters; }
  inline bool SelfManagedKafkaParametersHasBeenSet() const { return m_selfManagedKafkaParametersHasBeenSet; }
  template <typename SelfManagedKafkaParametersT = PipeSourceSelfManagedKafkaParameters>
  void SetSelfManagedKafkaParameters(SelfManagedKafkaParametersT&& value) {
    m_selfManagedKafkaParametersHasBeenSet = true;
    m_selfManagedKafkaParameters = std::forward<SelfManagedKafkaParametersT>(value);
  }
  template <typename SelfManagedKafkaParametersT = PipeSourceSelfManagedKafkaParameters>
  PipeSourceParameters& WithSelfManagedKafkaParameters(SelfManagedKafkaParametersT&& value) {
    SetSelfManagedKafkaParameters(std::forward<SelfManagedKafkaParametersT>(value));
    return *this;
  }
 private:
  FilterCriteria m_filterCriteria;
 
  PipeSourceKinesisStreamParameters m_kinesisStreamParameters;
 
  PipeSourceDynamoDBStreamParameters m_dynamoDBStreamParameters;
 
  PipeSourceSqsQueueParameters m_sqsQueueParameters;
 
  PipeSourceActiveMQBrokerParameters m_activeMQBrokerParameters;
 
  PipeSourceRabbitMQBrokerParameters m_rabbitMQBrokerParameters;
 
  PipeSourceManagedStreamingKafkaParameters m_managedStreamingKafkaParameters;
 
  PipeSourceSelfManagedKafkaParameters m_selfManagedKafkaParameters;
  bool m_filterCriteriaHasBeenSet = false;
  bool m_kinesisStreamParametersHasBeenSet = false;
  bool m_dynamoDBStreamParametersHasBeenSet = false;
  bool m_sqsQueueParametersHasBeenSet = false;
  bool m_activeMQBrokerParametersHasBeenSet = false;
  bool m_rabbitMQBrokerParametersHasBeenSet = false;
  bool m_managedStreamingKafkaParametersHasBeenSet = false;
  bool m_selfManagedKafkaParametersHasBeenSet = false;
};
 
}  // namespace Model
}  // namespace Pipes
}  // namespace Aws