7#include <aws/pipes/Pipes_EXPORTS.h>
8#include <aws/pipes/model/FilterCriteria.h>
9#include <aws/pipes/model/PipeSourceKinesisStreamParameters.h>
10#include <aws/pipes/model/PipeSourceDynamoDBStreamParameters.h>
11#include <aws/pipes/model/PipeSourceSqsQueueParameters.h>
12#include <aws/pipes/model/PipeSourceActiveMQBrokerParameters.h>
13#include <aws/pipes/model/PipeSourceRabbitMQBrokerParameters.h>
14#include <aws/pipes/model/PipeSourceManagedStreamingKafkaParameters.h>
15#include <aws/pipes/model/PipeSourceSelfManagedKafkaParameters.h>
158 bool m_filterCriteriaHasBeenSet =
false;
161 bool m_kinesisStreamParametersHasBeenSet =
false;
164 bool m_dynamoDBStreamParametersHasBeenSet =
false;
167 bool m_sqsQueueParametersHasBeenSet =
false;
170 bool m_activeMQBrokerParametersHasBeenSet =
false;
173 bool m_rabbitMQBrokerParametersHasBeenSet =
false;
176 bool m_managedStreamingKafkaParametersHasBeenSet =
false;
179 bool m_selfManagedKafkaParametersHasBeenSet =
false;
void SetFilterCriteria(const FilterCriteria &value)
void SetSelfManagedKafkaParameters(PipeSourceSelfManagedKafkaParameters &&value)
bool RabbitMQBrokerParametersHasBeenSet() const
bool FilterCriteriaHasBeenSet() const
void SetSqsQueueParameters(PipeSourceSqsQueueParameters &&value)
void SetManagedStreamingKafkaParameters(const PipeSourceManagedStreamingKafkaParameters &value)
const FilterCriteria & GetFilterCriteria() const
PipeSourceParameters & WithKinesisStreamParameters(PipeSourceKinesisStreamParameters &&value)
const PipeSourceManagedStreamingKafkaParameters & GetManagedStreamingKafkaParameters() const
void SetFilterCriteria(FilterCriteria &&value)
PipeSourceParameters & WithFilterCriteria(FilterCriteria &&value)
PipeSourceParameters & WithSelfManagedKafkaParameters(PipeSourceSelfManagedKafkaParameters &&value)
PipeSourceParameters & WithActiveMQBrokerParameters(PipeSourceActiveMQBrokerParameters &&value)
PipeSourceParameters & WithDynamoDBStreamParameters(const PipeSourceDynamoDBStreamParameters &value)
void SetActiveMQBrokerParameters(const PipeSourceActiveMQBrokerParameters &value)
void SetSqsQueueParameters(const PipeSourceSqsQueueParameters &value)
const PipeSourceDynamoDBStreamParameters & GetDynamoDBStreamParameters() const
void SetDynamoDBStreamParameters(const PipeSourceDynamoDBStreamParameters &value)
const PipeSourceActiveMQBrokerParameters & GetActiveMQBrokerParameters() const
void SetDynamoDBStreamParameters(PipeSourceDynamoDBStreamParameters &&value)
void SetActiveMQBrokerParameters(PipeSourceActiveMQBrokerParameters &&value)
PipeSourceParameters & WithSqsQueueParameters(PipeSourceSqsQueueParameters &&value)
void SetKinesisStreamParameters(PipeSourceKinesisStreamParameters &&value)
AWS_PIPES_API PipeSourceParameters()
bool ActiveMQBrokerParametersHasBeenSet() const
bool KinesisStreamParametersHasBeenSet() const
const PipeSourceSqsQueueParameters & GetSqsQueueParameters() const
PipeSourceParameters & WithRabbitMQBrokerParameters(const PipeSourceRabbitMQBrokerParameters &value)
AWS_PIPES_API PipeSourceParameters & operator=(Aws::Utils::Json::JsonView jsonValue)
bool SqsQueueParametersHasBeenSet() const
PipeSourceParameters & WithSqsQueueParameters(const PipeSourceSqsQueueParameters &value)
void SetManagedStreamingKafkaParameters(PipeSourceManagedStreamingKafkaParameters &&value)
bool SelfManagedKafkaParametersHasBeenSet() const
PipeSourceParameters & WithActiveMQBrokerParameters(const PipeSourceActiveMQBrokerParameters &value)
bool ManagedStreamingKafkaParametersHasBeenSet() const
PipeSourceParameters & WithSelfManagedKafkaParameters(const PipeSourceSelfManagedKafkaParameters &value)
void SetSelfManagedKafkaParameters(const PipeSourceSelfManagedKafkaParameters &value)
PipeSourceParameters & WithKinesisStreamParameters(const PipeSourceKinesisStreamParameters &value)
PipeSourceParameters & WithFilterCriteria(const FilterCriteria &value)
bool DynamoDBStreamParametersHasBeenSet() const
PipeSourceParameters & WithManagedStreamingKafkaParameters(PipeSourceManagedStreamingKafkaParameters &&value)
const PipeSourceKinesisStreamParameters & GetKinesisStreamParameters() const
void SetKinesisStreamParameters(const PipeSourceKinesisStreamParameters &value)
const PipeSourceSelfManagedKafkaParameters & GetSelfManagedKafkaParameters() const
PipeSourceParameters & WithManagedStreamingKafkaParameters(const PipeSourceManagedStreamingKafkaParameters &value)
PipeSourceParameters & WithDynamoDBStreamParameters(PipeSourceDynamoDBStreamParameters &&value)
AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const
AWS_PIPES_API PipeSourceParameters(Aws::Utils::Json::JsonView jsonValue)
void SetRabbitMQBrokerParameters(PipeSourceRabbitMQBrokerParameters &&value)
PipeSourceParameters & WithRabbitMQBrokerParameters(PipeSourceRabbitMQBrokerParameters &&value)
const PipeSourceRabbitMQBrokerParameters & GetRabbitMQBrokerParameters() const
void SetRabbitMQBrokerParameters(const PipeSourceRabbitMQBrokerParameters &value)
Aws::Utils::Json::JsonValue JsonValue