7#include <aws/pipes/Pipes_EXPORTS.h>
8#include <aws/pipes/model/FilterCriteria.h>
9#include <aws/pipes/model/UpdatePipeSourceActiveMQBrokerParameters.h>
10#include <aws/pipes/model/UpdatePipeSourceDynamoDBStreamParameters.h>
11#include <aws/pipes/model/UpdatePipeSourceKinesisStreamParameters.h>
12#include <aws/pipes/model/UpdatePipeSourceManagedStreamingKafkaParameters.h>
13#include <aws/pipes/model/UpdatePipeSourceRabbitMQBrokerParameters.h>
14#include <aws/pipes/model/UpdatePipeSourceSelfManagedKafkaParameters.h>
15#include <aws/pipes/model/UpdatePipeSourceSqsQueueParameters.h>
52 template <
typename FilterCriteriaT = FilterCriteria>
54 m_filterCriteriaHasBeenSet =
true;
55 m_filterCriteria = std::forward<FilterCriteriaT>(value);
57 template <
typename FilterCriteriaT = FilterCriteria>
70 template <
typename KinesisStreamParametersT = UpdatePipeSourceKinesisStreamParameters>
72 m_kinesisStreamParametersHasBeenSet =
true;
73 m_kinesisStreamParameters = std::forward<KinesisStreamParametersT>(value);
75 template <
typename KinesisStreamParametersT = UpdatePipeSourceKinesisStreamParameters>
88 template <
typename DynamoDBStreamParametersT = UpdatePipeSourceDynamoDBStreamParameters>
90 m_dynamoDBStreamParametersHasBeenSet =
true;
91 m_dynamoDBStreamParameters = std::forward<DynamoDBStreamParametersT>(value);
93 template <
typename DynamoDBStreamParametersT = UpdatePipeSourceDynamoDBStreamParameters>
106 template <
typename SqsQueueParametersT = UpdatePipeSourceSqsQueueParameters>
108 m_sqsQueueParametersHasBeenSet =
true;
109 m_sqsQueueParameters = std::forward<SqsQueueParametersT>(value);
111 template <
typename SqsQueueParametersT = UpdatePipeSourceSqsQueueParameters>
124 template <
typename ActiveMQBrokerParametersT = UpdatePipeSourceActiveMQBrokerParameters>
126 m_activeMQBrokerParametersHasBeenSet =
true;
127 m_activeMQBrokerParameters = std::forward<ActiveMQBrokerParametersT>(value);
129 template <
typename ActiveMQBrokerParametersT = UpdatePipeSourceActiveMQBrokerParameters>
142 template <
typename RabbitMQBrokerParametersT = UpdatePipeSourceRabbitMQBrokerParameters>
144 m_rabbitMQBrokerParametersHasBeenSet =
true;
145 m_rabbitMQBrokerParameters = std::forward<RabbitMQBrokerParametersT>(value);
147 template <
typename RabbitMQBrokerParametersT = UpdatePipeSourceRabbitMQBrokerParameters>
159 return m_managedStreamingKafkaParameters;
162 template <
typename ManagedStreamingKafkaParametersT = UpdatePipeSourceManagedStreamingKafkaParameters>
164 m_managedStreamingKafkaParametersHasBeenSet =
true;
165 m_managedStreamingKafkaParameters = std::forward<ManagedStreamingKafkaParametersT>(value);
167 template <
typename ManagedStreamingKafkaParametersT = UpdatePipeSourceManagedStreamingKafkaParameters>
188 template <
typename SelfManagedKafkaParametersT = UpdatePipeSourceSelfManagedKafkaParameters>
190 m_selfManagedKafkaParametersHasBeenSet =
true;
191 m_selfManagedKafkaParameters = std::forward<SelfManagedKafkaParametersT>(value);
193 template <
typename SelfManagedKafkaParametersT = UpdatePipeSourceSelfManagedKafkaParameters>
215 bool m_filterCriteriaHasBeenSet =
false;
216 bool m_kinesisStreamParametersHasBeenSet =
false;
217 bool m_dynamoDBStreamParametersHasBeenSet =
false;
218 bool m_sqsQueueParametersHasBeenSet =
false;
219 bool m_activeMQBrokerParametersHasBeenSet =
false;
220 bool m_rabbitMQBrokerParametersHasBeenSet =
false;
221 bool m_managedStreamingKafkaParametersHasBeenSet =
false;
222 bool m_selfManagedKafkaParametersHasBeenSet =
false;
const UpdatePipeSourceDynamoDBStreamParameters & GetDynamoDBStreamParameters() const
UpdatePipeSourceParameters & WithSqsQueueParameters(SqsQueueParametersT &&value)
UpdatePipeSourceParameters & WithFilterCriteria(FilterCriteriaT &&value)
UpdatePipeSourceParameters & WithActiveMQBrokerParameters(ActiveMQBrokerParametersT &&value)
void SetRabbitMQBrokerParameters(RabbitMQBrokerParametersT &&value)
AWS_PIPES_API UpdatePipeSourceParameters()=default
const UpdatePipeSourceSelfManagedKafkaParameters & GetSelfManagedKafkaParameters() const
UpdatePipeSourceParameters & WithManagedStreamingKafkaParameters(ManagedStreamingKafkaParametersT &&value)
const UpdatePipeSourceSqsQueueParameters & GetSqsQueueParameters() const
const FilterCriteria & GetFilterCriteria() const
bool ManagedStreamingKafkaParametersHasBeenSet() const
bool FilterCriteriaHasBeenSet() const
void SetManagedStreamingKafkaParameters(ManagedStreamingKafkaParametersT &&value)
void SetActiveMQBrokerParameters(ActiveMQBrokerParametersT &&value)
UpdatePipeSourceParameters & WithDynamoDBStreamParameters(DynamoDBStreamParametersT &&value)
AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const
bool SqsQueueParametersHasBeenSet() const
AWS_PIPES_API UpdatePipeSourceParameters & operator=(Aws::Utils::Json::JsonView jsonValue)
void SetDynamoDBStreamParameters(DynamoDBStreamParametersT &&value)
bool ActiveMQBrokerParametersHasBeenSet() const
bool DynamoDBStreamParametersHasBeenSet() const
void SetKinesisStreamParameters(KinesisStreamParametersT &&value)
const UpdatePipeSourceKinesisStreamParameters & GetKinesisStreamParameters() const
const UpdatePipeSourceManagedStreamingKafkaParameters & GetManagedStreamingKafkaParameters() const
UpdatePipeSourceParameters & WithSelfManagedKafkaParameters(SelfManagedKafkaParametersT &&value)
bool RabbitMQBrokerParametersHasBeenSet() const
void SetSqsQueueParameters(SqsQueueParametersT &&value)
bool SelfManagedKafkaParametersHasBeenSet() const
UpdatePipeSourceParameters & WithRabbitMQBrokerParameters(RabbitMQBrokerParametersT &&value)
AWS_PIPES_API UpdatePipeSourceParameters(Aws::Utils::Json::JsonView jsonValue)
void SetSelfManagedKafkaParameters(SelfManagedKafkaParametersT &&value)
UpdatePipeSourceParameters & WithKinesisStreamParameters(KinesisStreamParametersT &&value)
bool KinesisStreamParametersHasBeenSet() const
const UpdatePipeSourceRabbitMQBrokerParameters & GetRabbitMQBrokerParameters() const
void SetFilterCriteria(FilterCriteriaT &&value)
const UpdatePipeSourceActiveMQBrokerParameters & GetActiveMQBrokerParameters() const
Aws::Utils::Json::JsonValue JsonValue