7#include <aws/core/utils/memory/stl/AWSMap.h>
8#include <aws/core/utils/memory/stl/AWSString.h>
9#include <aws/core/utils/memory/stl/AWSVector.h>
10#include <aws/kafkaconnect/KafkaConnectRequest.h>
11#include <aws/kafkaconnect/KafkaConnect_EXPORTS.h>
12#include <aws/kafkaconnect/model/Capacity.h>
13#include <aws/kafkaconnect/model/KafkaCluster.h>
14#include <aws/kafkaconnect/model/KafkaClusterClientAuthentication.h>
15#include <aws/kafkaconnect/model/KafkaClusterEncryptionInTransit.h>
16#include <aws/kafkaconnect/model/LogDelivery.h>
17#include <aws/kafkaconnect/model/NetworkType.h>
18#include <aws/kafkaconnect/model/Plugin.h>
19#include <aws/kafkaconnect/model/WorkerConfiguration.h>
24namespace KafkaConnect {
48 template <
typename CapacityT = Capacity>
50 m_capacityHasBeenSet =
true;
51 m_capacity = std::forward<CapacityT>(value);
53 template <
typename CapacityT = Capacity>
67 template <
typename ConnectorConfigurationT = Aws::Map<Aws::String, Aws::String>>
69 m_connectorConfigurationHasBeenSet =
true;
70 m_connectorConfiguration = std::forward<ConnectorConfigurationT>(value);
72 template <
typename ConnectorConfigurationT = Aws::Map<Aws::String, Aws::String>>
77 template <
typename ConnectorConfigurationKeyT = Aws::String,
typename ConnectorConfigurationValueT = Aws::String>
79 m_connectorConfigurationHasBeenSet =
true;
80 m_connectorConfiguration.emplace(std::forward<ConnectorConfigurationKeyT>(key), std::forward<ConnectorConfigurationValueT>(value));
91 template <
typename ConnectorDescriptionT = Aws::String>
93 m_connectorDescriptionHasBeenSet =
true;
94 m_connectorDescription = std::forward<ConnectorDescriptionT>(value);
96 template <
typename ConnectorDescriptionT = Aws::String>
109 template <
typename ConnectorNameT = Aws::String>
111 m_connectorNameHasBeenSet =
true;
112 m_connectorName = std::forward<ConnectorNameT>(value);
114 template <
typename ConnectorNameT = Aws::String>
127 template <
typename KafkaClusterT = KafkaCluster>
129 m_kafkaClusterHasBeenSet =
true;
130 m_kafkaCluster = std::forward<KafkaClusterT>(value);
132 template <
typename KafkaClusterT = KafkaCluster>
145 template <
typename KafkaClusterClientAuthenticationT = KafkaClusterClientAuthentication>
147 m_kafkaClusterClientAuthenticationHasBeenSet =
true;
148 m_kafkaClusterClientAuthentication = std::forward<KafkaClusterClientAuthenticationT>(value);
150 template <
typename KafkaClusterClientAuthenticationT = KafkaClusterClientAuthentication>
163 template <
typename KafkaClusterEncryptionInTransitT = KafkaClusterEncryptionInTransit>
165 m_kafkaClusterEncryptionInTransitHasBeenSet =
true;
166 m_kafkaClusterEncryptionInTransit = std::forward<KafkaClusterEncryptionInTransitT>(value);
168 template <
typename KafkaClusterEncryptionInTransitT = KafkaClusterEncryptionInTransit>
182 template <
typename KafkaConnectVersionT = Aws::String>
184 m_kafkaConnectVersionHasBeenSet =
true;
185 m_kafkaConnectVersion = std::forward<KafkaConnectVersionT>(value);
187 template <
typename KafkaConnectVersionT = Aws::String>
200 template <
typename LogDeliveryT = LogDelivery>
202 m_logDeliveryHasBeenSet =
true;
203 m_logDelivery = std::forward<LogDeliveryT>(value);
205 template <
typename LogDeliveryT = LogDelivery>
220 m_networkTypeHasBeenSet =
true;
221 m_networkType = value;
240 template <
typename PluginsT = Aws::Vector<Plugin>>
242 m_pluginsHasBeenSet =
true;
243 m_plugins = std::forward<PluginsT>(value);
245 template <
typename PluginsT = Aws::Vector<Plugin>>
250 template <
typename PluginsT = Plugin>
252 m_pluginsHasBeenSet =
true;
253 m_plugins.emplace_back(std::forward<PluginsT>(value));
268 template <
typename ServiceExecutionRoleArnT = Aws::String>
270 m_serviceExecutionRoleArnHasBeenSet =
true;
271 m_serviceExecutionRoleArn = std::forward<ServiceExecutionRoleArnT>(value);
273 template <
typename ServiceExecutionRoleArnT = Aws::String>
286 template <
typename WorkerConfigurationT = WorkerConfiguration>
288 m_workerConfigurationHasBeenSet =
true;
289 m_workerConfiguration = std::forward<WorkerConfigurationT>(value);
291 template <
typename WorkerConfigurationT = WorkerConfiguration>
304 template <
typename TagsT = Aws::Map<Aws::String, Aws::String>>
306 m_tagsHasBeenSet =
true;
307 m_tags = std::forward<TagsT>(value);
309 template <
typename TagsT = Aws::Map<Aws::String, Aws::String>>
311 SetTags(std::forward<TagsT>(value));
314 template <
typename TagsKeyT = Aws::String,
typename TagsValueT = Aws::String>
316 m_tagsHasBeenSet =
true;
317 m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value));
346 WorkerConfiguration m_workerConfiguration;
349 bool m_capacityHasBeenSet =
false;
350 bool m_connectorConfigurationHasBeenSet =
false;
351 bool m_connectorDescriptionHasBeenSet =
false;
352 bool m_connectorNameHasBeenSet =
false;
353 bool m_kafkaClusterHasBeenSet =
false;
354 bool m_kafkaClusterClientAuthenticationHasBeenSet =
false;
355 bool m_kafkaClusterEncryptionInTransitHasBeenSet =
false;
356 bool m_kafkaConnectVersionHasBeenSet =
false;
357 bool m_logDeliveryHasBeenSet =
false;
358 bool m_networkTypeHasBeenSet =
false;
359 bool m_pluginsHasBeenSet =
false;
360 bool m_serviceExecutionRoleArnHasBeenSet =
false;
361 bool m_workerConfigurationHasBeenSet =
false;
362 bool m_tagsHasBeenSet =
false;
CreateConnectorRequest & WithConnectorDescription(ConnectorDescriptionT &&value)
const Aws::String & GetKafkaConnectVersion() const
CreateConnectorRequest & WithKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransitT &&value)
CreateConnectorRequest & AddConnectorConfiguration(ConnectorConfigurationKeyT &&key, ConnectorConfigurationValueT &&value)
CreateConnectorRequest & WithCapacity(CapacityT &&value)
bool PluginsHasBeenSet() const
const Capacity & GetCapacity() const
bool KafkaConnectVersionHasBeenSet() const
CreateConnectorRequest & WithLogDelivery(LogDeliveryT &&value)
const Aws::String & GetServiceExecutionRoleArn() const
void SetLogDelivery(LogDeliveryT &&value)
AWS_KAFKACONNECT_API Aws::String SerializePayload() const override
bool NetworkTypeHasBeenSet() const
CreateConnectorRequest & WithTags(TagsT &&value)
CreateConnectorRequest & WithConnectorName(ConnectorNameT &&value)
CreateConnectorRequest & AddPlugins(PluginsT &&value)
CreateConnectorRequest & WithKafkaClusterClientAuthentication(KafkaClusterClientAuthenticationT &&value)
void SetConnectorDescription(ConnectorDescriptionT &&value)
CreateConnectorRequest & WithKafkaCluster(KafkaClusterT &&value)
const Aws::String & GetConnectorName() const
bool KafkaClusterEncryptionInTransitHasBeenSet() const
CreateConnectorRequest & AddTags(TagsKeyT &&key, TagsValueT &&value)
CreateConnectorRequest & WithConnectorConfiguration(ConnectorConfigurationT &&value)
AWS_KAFKACONNECT_API CreateConnectorRequest()=default
CreateConnectorRequest & WithWorkerConfiguration(WorkerConfigurationT &&value)
const KafkaCluster & GetKafkaCluster() const
bool KafkaClusterHasBeenSet() const
bool CapacityHasBeenSet() const
bool ServiceExecutionRoleArnHasBeenSet() const
void SetConnectorName(ConnectorNameT &&value)
void SetNetworkType(NetworkType value)
const KafkaClusterClientAuthentication & GetKafkaClusterClientAuthentication() const
void SetKafkaConnectVersion(KafkaConnectVersionT &&value)
virtual const char * GetServiceRequestName() const override
const Aws::Map< Aws::String, Aws::String > & GetTags() const
const Aws::String & GetConnectorDescription() const
bool KafkaClusterClientAuthenticationHasBeenSet() const
const KafkaClusterEncryptionInTransit & GetKafkaClusterEncryptionInTransit() const
bool ConnectorConfigurationHasBeenSet() const
const WorkerConfiguration & GetWorkerConfiguration() const
void SetPlugins(PluginsT &&value)
void SetConnectorConfiguration(ConnectorConfigurationT &&value)
bool LogDeliveryHasBeenSet() const
bool ConnectorDescriptionHasBeenSet() const
NetworkType GetNetworkType() const
CreateConnectorRequest & WithNetworkType(NetworkType value)
bool ConnectorNameHasBeenSet() const
void SetKafkaClusterClientAuthentication(KafkaClusterClientAuthenticationT &&value)
void SetWorkerConfiguration(WorkerConfigurationT &&value)
const Aws::Vector< Plugin > & GetPlugins() const
CreateConnectorRequest & WithServiceExecutionRoleArn(ServiceExecutionRoleArnT &&value)
void SetKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransitT &&value)
void SetCapacity(CapacityT &&value)
bool TagsHasBeenSet() const
bool WorkerConfigurationHasBeenSet() const
void SetServiceExecutionRoleArn(ServiceExecutionRoleArnT &&value)
const Aws::Map< Aws::String, Aws::String > & GetConnectorConfiguration() const
CreateConnectorRequest & WithPlugins(PluginsT &&value)
const LogDelivery & GetLogDelivery() const
void SetKafkaCluster(KafkaClusterT &&value)
void SetTags(TagsT &&value)
CreateConnectorRequest & WithKafkaConnectVersion(KafkaConnectVersionT &&value)
std::map< K, V, std::less< K >, Aws::Allocator< std::pair< const K, V > > > Map
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
std::vector< T, Aws::Allocator< T > > Vector