7#include <aws/kafkaconnect/KafkaConnect_EXPORTS.h>
8#include <aws/kafkaconnect/KafkaConnectRequest.h>
9#include <aws/kafkaconnect/model/Capacity.h>
10#include <aws/core/utils/memory/stl/AWSMap.h>
11#include <aws/core/utils/memory/stl/AWSString.h>
12#include <aws/kafkaconnect/model/KafkaCluster.h>
13#include <aws/kafkaconnect/model/KafkaClusterClientAuthentication.h>
14#include <aws/kafkaconnect/model/KafkaClusterEncryptionInTransit.h>
15#include <aws/kafkaconnect/model/LogDelivery.h>
16#include <aws/core/utils/memory/stl/AWSVector.h>
17#include <aws/kafkaconnect/model/WorkerConfiguration.h>
18#include <aws/kafkaconnect/model/Plugin.h>
51 template<
typename CapacityT = Capacity>
52 void SetCapacity(CapacityT&& value) { m_capacityHasBeenSet =
true; m_capacity = std::forward<CapacityT>(value); }
53 template<
typename CapacityT = Capacity>
64 template<
typename ConnectorConfigurationT = Aws::Map<Aws::String, Aws::String>>
65 void SetConnectorConfiguration(ConnectorConfigurationT&& value) { m_connectorConfigurationHasBeenSet =
true; m_connectorConfiguration = std::forward<ConnectorConfigurationT>(value); }
66 template<
typename ConnectorConfigurationT = Aws::Map<Aws::String, Aws::String>>
68 template<
typename ConnectorConfigurationKeyT = Aws::String,
typename ConnectorConfigurationValueT = Aws::String>
70 m_connectorConfigurationHasBeenSet =
true; m_connectorConfiguration.emplace(std::forward<ConnectorConfigurationKeyT>(key), std::forward<ConnectorConfigurationValueT>(value));
return *
this;
80 template<
typename ConnectorDescriptionT = Aws::String>
81 void SetConnectorDescription(ConnectorDescriptionT&& value) { m_connectorDescriptionHasBeenSet =
true; m_connectorDescription = std::forward<ConnectorDescriptionT>(value); }
82 template<
typename ConnectorDescriptionT = Aws::String>
92 template<
typename ConnectorNameT = Aws::String>
93 void SetConnectorName(ConnectorNameT&& value) { m_connectorNameHasBeenSet =
true; m_connectorName = std::forward<ConnectorNameT>(value); }
94 template<
typename ConnectorNameT = Aws::String>
104 template<
typename KafkaClusterT = KafkaCluster>
105 void SetKafkaCluster(KafkaClusterT&& value) { m_kafkaClusterHasBeenSet =
true; m_kafkaCluster = std::forward<KafkaClusterT>(value); }
106 template<
typename KafkaClusterT = KafkaCluster>
116 template<
typename KafkaClusterClientAuthenticationT = KafkaClusterClientAuthentication>
117 void SetKafkaClusterClientAuthentication(KafkaClusterClientAuthenticationT&& value) { m_kafkaClusterClientAuthenticationHasBeenSet =
true; m_kafkaClusterClientAuthentication = std::forward<KafkaClusterClientAuthenticationT>(value); }
118 template<
typename KafkaClusterClientAuthenticationT = KafkaClusterClientAuthentication>
128 template<
typename KafkaClusterEncryptionInTransitT = KafkaClusterEncryptionInTransit>
129 void SetKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransitT&& value) { m_kafkaClusterEncryptionInTransitHasBeenSet =
true; m_kafkaClusterEncryptionInTransit = std::forward<KafkaClusterEncryptionInTransitT>(value); }
130 template<
typename KafkaClusterEncryptionInTransitT = KafkaClusterEncryptionInTransit>
141 template<
typename KafkaConnectVersionT = Aws::String>
142 void SetKafkaConnectVersion(KafkaConnectVersionT&& value) { m_kafkaConnectVersionHasBeenSet =
true; m_kafkaConnectVersion = std::forward<KafkaConnectVersionT>(value); }
143 template<
typename KafkaConnectVersionT = Aws::String>
153 template<
typename LogDeliveryT = LogDelivery>
154 void SetLogDelivery(LogDeliveryT&& value) { m_logDeliveryHasBeenSet =
true; m_logDelivery = std::forward<LogDeliveryT>(value); }
155 template<
typename LogDeliveryT = LogDelivery>
170 template<
typename PluginsT = Aws::Vector<Plugin>>
171 void SetPlugins(PluginsT&& value) { m_pluginsHasBeenSet =
true; m_plugins = std::forward<PluginsT>(value); }
172 template<
typename PluginsT = Aws::Vector<Plugin>>
174 template<
typename PluginsT = Plugin>
188 template<
typename ServiceExecutionRoleArnT = Aws::String>
189 void SetServiceExecutionRoleArn(ServiceExecutionRoleArnT&& value) { m_serviceExecutionRoleArnHasBeenSet =
true; m_serviceExecutionRoleArn = std::forward<ServiceExecutionRoleArnT>(value); }
190 template<
typename ServiceExecutionRoleArnT = Aws::String>
200 template<
typename WorkerConfigurationT = WorkerConfiguration>
201 void SetWorkerConfiguration(WorkerConfigurationT&& value) { m_workerConfigurationHasBeenSet =
true; m_workerConfiguration = std::forward<WorkerConfigurationT>(value); }
202 template<
typename WorkerConfigurationT = WorkerConfiguration>
212 template<
typename TagsT = Aws::Map<Aws::String, Aws::String>>
213 void SetTags(TagsT&& value) { m_tagsHasBeenSet =
true; m_tags = std::forward<TagsT>(value); }
214 template<
typename TagsT = Aws::Map<Aws::String, Aws::String>>
216 template<
typename TagsKeyT = Aws::String,
typename TagsValueT = Aws::String>
218 m_tagsHasBeenSet =
true; m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value));
return *
this;
224 bool m_capacityHasBeenSet =
false;
227 bool m_connectorConfigurationHasBeenSet =
false;
230 bool m_connectorDescriptionHasBeenSet =
false;
233 bool m_connectorNameHasBeenSet =
false;
236 bool m_kafkaClusterHasBeenSet =
false;
239 bool m_kafkaClusterClientAuthenticationHasBeenSet =
false;
242 bool m_kafkaClusterEncryptionInTransitHasBeenSet =
false;
245 bool m_kafkaConnectVersionHasBeenSet =
false;
248 bool m_logDeliveryHasBeenSet =
false;
251 bool m_pluginsHasBeenSet =
false;
254 bool m_serviceExecutionRoleArnHasBeenSet =
false;
257 bool m_workerConfigurationHasBeenSet =
false;
260 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
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)
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
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