7#include <aws/pipes/Pipes_EXPORTS.h>
8#include <aws/pipes/model/FilterCriteria.h>
9#include <aws/pipes/model/UpdatePipeSourceKinesisStreamParameters.h>
10#include <aws/pipes/model/UpdatePipeSourceDynamoDBStreamParameters.h>
11#include <aws/pipes/model/UpdatePipeSourceSqsQueueParameters.h>
12#include <aws/pipes/model/UpdatePipeSourceActiveMQBrokerParameters.h>
13#include <aws/pipes/model/UpdatePipeSourceRabbitMQBrokerParameters.h>
14#include <aws/pipes/model/UpdatePipeSourceManagedStreamingKafkaParameters.h>
15#include <aws/pipes/model/UpdatePipeSourceSelfManagedKafkaParameters.h>
58 template<
typename FilterCriteriaT = FilterCriteria>
59 void SetFilterCriteria(FilterCriteriaT&& value) { m_filterCriteriaHasBeenSet =
true; m_filterCriteria = std::forward<FilterCriteriaT>(value); }
60 template<
typename FilterCriteriaT = FilterCriteria>
70 template<
typename KinesisStreamParametersT = UpdatePipeSourceKinesisStreamParameters>
71 void SetKinesisStreamParameters(KinesisStreamParametersT&& value) { m_kinesisStreamParametersHasBeenSet =
true; m_kinesisStreamParameters = std::forward<KinesisStreamParametersT>(value); }
72 template<
typename KinesisStreamParametersT = UpdatePipeSourceKinesisStreamParameters>
82 template<
typename DynamoDBStreamParametersT = UpdatePipeSourceDynamoDBStreamParameters>
83 void SetDynamoDBStreamParameters(DynamoDBStreamParametersT&& value) { m_dynamoDBStreamParametersHasBeenSet =
true; m_dynamoDBStreamParameters = std::forward<DynamoDBStreamParametersT>(value); }
84 template<
typename DynamoDBStreamParametersT = UpdatePipeSourceDynamoDBStreamParameters>
94 template<
typename SqsQueueParametersT = UpdatePipeSourceSqsQueueParameters>
95 void SetSqsQueueParameters(SqsQueueParametersT&& value) { m_sqsQueueParametersHasBeenSet =
true; m_sqsQueueParameters = std::forward<SqsQueueParametersT>(value); }
96 template<
typename SqsQueueParametersT = UpdatePipeSourceSqsQueueParameters>
106 template<
typename ActiveMQBrokerParametersT = UpdatePipeSourceActiveMQBrokerParameters>
107 void SetActiveMQBrokerParameters(ActiveMQBrokerParametersT&& value) { m_activeMQBrokerParametersHasBeenSet =
true; m_activeMQBrokerParameters = std::forward<ActiveMQBrokerParametersT>(value); }
108 template<
typename ActiveMQBrokerParametersT = UpdatePipeSourceActiveMQBrokerParameters>
118 template<
typename RabbitMQBrokerParametersT = UpdatePipeSourceRabbitMQBrokerParameters>
119 void SetRabbitMQBrokerParameters(RabbitMQBrokerParametersT&& value) { m_rabbitMQBrokerParametersHasBeenSet =
true; m_rabbitMQBrokerParameters = std::forward<RabbitMQBrokerParametersT>(value); }
120 template<
typename RabbitMQBrokerParametersT = UpdatePipeSourceRabbitMQBrokerParameters>
130 template<
typename ManagedStreamingKafkaParametersT = UpdatePipeSourceManagedStreamingKafkaParameters>
131 void SetManagedStreamingKafkaParameters(ManagedStreamingKafkaParametersT&& value) { m_managedStreamingKafkaParametersHasBeenSet =
true; m_managedStreamingKafkaParameters = std::forward<ManagedStreamingKafkaParametersT>(value); }
132 template<
typename ManagedStreamingKafkaParametersT = UpdatePipeSourceManagedStreamingKafkaParameters>
150 template<
typename SelfManagedKafkaParametersT = UpdatePipeSourceSelfManagedKafkaParameters>
151 void SetSelfManagedKafkaParameters(SelfManagedKafkaParametersT&& value) { m_selfManagedKafkaParametersHasBeenSet =
true; m_selfManagedKafkaParameters = std::forward<SelfManagedKafkaParametersT>(value); }
152 template<
typename SelfManagedKafkaParametersT = UpdatePipeSourceSelfManagedKafkaParameters>
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;
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