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>
52 inline void SetCapacity(
Capacity&& value) { m_capacityHasBeenSet =
true; m_capacity = std::move(value); }
85 inline void SetConnectorDescription(
const char* value) { m_connectorDescriptionHasBeenSet =
true; m_connectorDescription.assign(value); }
99 inline void SetConnectorName(
const char* value) { m_connectorNameHasBeenSet =
true; m_connectorName.assign(value); }
150 inline void SetKafkaConnectVersion(
const char* value) { m_kafkaConnectVersionHasBeenSet =
true; m_kafkaConnectVersion.assign(value); }
199 inline void SetServiceExecutionRoleArn(
const char* value) { m_serviceExecutionRoleArnHasBeenSet =
true; m_serviceExecutionRoleArn.assign(value); }
238 bool m_capacityHasBeenSet =
false;
241 bool m_connectorConfigurationHasBeenSet =
false;
244 bool m_connectorDescriptionHasBeenSet =
false;
247 bool m_connectorNameHasBeenSet =
false;
250 bool m_kafkaClusterHasBeenSet =
false;
253 bool m_kafkaClusterClientAuthenticationHasBeenSet =
false;
256 bool m_kafkaClusterEncryptionInTransitHasBeenSet =
false;
259 bool m_kafkaConnectVersionHasBeenSet =
false;
262 bool m_logDeliveryHasBeenSet =
false;
265 bool m_pluginsHasBeenSet =
false;
268 bool m_serviceExecutionRoleArnHasBeenSet =
false;
271 bool m_tagsHasBeenSet =
false;
274 bool m_workerConfigurationHasBeenSet =
false;
void SetWorkerConfiguration(const WorkerConfiguration &value)
const Aws::String & GetKafkaConnectVersion() const
void SetCapacity(Capacity &&value)
bool PluginsHasBeenSet() const
void SetKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransit &&value)
const Capacity & GetCapacity() const
bool KafkaConnectVersionHasBeenSet() const
CreateConnectorRequest & WithWorkerConfiguration(const WorkerConfiguration &value)
const Aws::String & GetServiceExecutionRoleArn() const
CreateConnectorRequest & WithKafkaClusterClientAuthentication(KafkaClusterClientAuthentication &&value)
void SetServiceExecutionRoleArn(const Aws::String &value)
AWS_KAFKACONNECT_API Aws::String SerializePayload() const override
CreateConnectorRequest & AddTags(Aws::String &&key, const char *value)
void SetPlugins(Aws::Vector< Plugin > &&value)
void SetKafkaConnectVersion(Aws::String &&value)
void SetServiceExecutionRoleArn(const char *value)
CreateConnectorRequest & AddTags(Aws::String &&key, Aws::String &&value)
CreateConnectorRequest & WithConnectorDescription(Aws::String &&value)
CreateConnectorRequest & WithPlugins(const Aws::Vector< Plugin > &value)
CreateConnectorRequest & WithKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransit &&value)
void SetConnectorName(Aws::String &&value)
CreateConnectorRequest & AddPlugins(const Plugin &value)
void SetCapacity(const Capacity &value)
void SetPlugins(const Aws::Vector< Plugin > &value)
CreateConnectorRequest & WithCapacity(const Capacity &value)
const Aws::String & GetConnectorName() const
bool KafkaClusterEncryptionInTransitHasBeenSet() const
CreateConnectorRequest & WithConnectorName(const char *value)
CreateConnectorRequest & WithConnectorConfiguration(const Aws::Map< Aws::String, Aws::String > &value)
CreateConnectorRequest & AddConnectorConfiguration(const Aws::String &key, Aws::String &&value)
void SetKafkaConnectVersion(const Aws::String &value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, Aws::String &&value)
CreateConnectorRequest & AddPlugins(Plugin &&value)
const KafkaCluster & GetKafkaCluster() const
void SetConnectorName(const char *value)
AWS_KAFKACONNECT_API CreateConnectorRequest()
CreateConnectorRequest & AddConnectorConfiguration(const char *key, const char *value)
void SetKafkaCluster(const KafkaCluster &value)
bool KafkaClusterHasBeenSet() const
void SetConnectorDescription(const Aws::String &value)
CreateConnectorRequest & AddTags(const Aws::String &key, Aws::String &&value)
CreateConnectorRequest & WithLogDelivery(LogDelivery &&value)
CreateConnectorRequest & WithKafkaClusterClientAuthentication(const KafkaClusterClientAuthentication &value)
CreateConnectorRequest & WithKafkaConnectVersion(const Aws::String &value)
bool CapacityHasBeenSet() const
bool ServiceExecutionRoleArnHasBeenSet() const
void SetKafkaClusterClientAuthentication(const KafkaClusterClientAuthentication &value)
CreateConnectorRequest & WithServiceExecutionRoleArn(const Aws::String &value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, const char *value)
void SetKafkaCluster(KafkaCluster &&value)
const KafkaClusterClientAuthentication & GetKafkaClusterClientAuthentication() const
CreateConnectorRequest & AddConnectorConfiguration(const Aws::String &key, const Aws::String &value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, const Aws::String &value)
void SetLogDelivery(const LogDelivery &value)
virtual const char * GetServiceRequestName() const override
CreateConnectorRequest & AddTags(const char *key, Aws::String &&value)
CreateConnectorRequest & WithConnectorName(const Aws::String &value)
void SetConnectorName(const Aws::String &value)
CreateConnectorRequest & WithServiceExecutionRoleArn(const char *value)
CreateConnectorRequest & WithKafkaCluster(KafkaCluster &&value)
const Aws::Map< Aws::String, Aws::String > & GetTags() const
const Aws::String & GetConnectorDescription() const
void SetWorkerConfiguration(WorkerConfiguration &&value)
bool KafkaClusterClientAuthenticationHasBeenSet() const
CreateConnectorRequest & WithTags(Aws::Map< Aws::String, Aws::String > &&value)
void SetTags(Aws::Map< Aws::String, Aws::String > &&value)
const KafkaClusterEncryptionInTransit & GetKafkaClusterEncryptionInTransit() const
CreateConnectorRequest & WithConnectorConfiguration(Aws::Map< Aws::String, Aws::String > &&value)
void SetKafkaConnectVersion(const char *value)
bool ConnectorConfigurationHasBeenSet() const
CreateConnectorRequest & WithConnectorName(Aws::String &&value)
const WorkerConfiguration & GetWorkerConfiguration() const
CreateConnectorRequest & WithWorkerConfiguration(WorkerConfiguration &&value)
CreateConnectorRequest & WithKafkaConnectVersion(const char *value)
bool LogDeliveryHasBeenSet() const
CreateConnectorRequest & AddTags(const Aws::String &key, const Aws::String &value)
bool ConnectorDescriptionHasBeenSet() const
CreateConnectorRequest & AddTags(const char *key, const char *value)
void SetConnectorDescription(Aws::String &&value)
void SetServiceExecutionRoleArn(Aws::String &&value)
CreateConnectorRequest & WithServiceExecutionRoleArn(Aws::String &&value)
void SetKafkaClusterClientAuthentication(KafkaClusterClientAuthentication &&value)
bool ConnectorNameHasBeenSet() const
CreateConnectorRequest & AddTags(Aws::String &&key, const Aws::String &value)
void SetKafkaClusterEncryptionInTransit(const KafkaClusterEncryptionInTransit &value)
CreateConnectorRequest & WithKafkaClusterEncryptionInTransit(const KafkaClusterEncryptionInTransit &value)
CreateConnectorRequest & WithCapacity(Capacity &&value)
CreateConnectorRequest & AddConnectorConfiguration(const char *key, Aws::String &&value)
CreateConnectorRequest & WithLogDelivery(const LogDelivery &value)
const Aws::Vector< Plugin > & GetPlugins() const
CreateConnectorRequest & WithTags(const Aws::Map< Aws::String, Aws::String > &value)
CreateConnectorRequest & WithKafkaCluster(const KafkaCluster &value)
CreateConnectorRequest & WithKafkaConnectVersion(Aws::String &&value)
void SetConnectorConfiguration(Aws::Map< Aws::String, Aws::String > &&value)
void SetConnectorDescription(const char *value)
bool TagsHasBeenSet() const
bool WorkerConfigurationHasBeenSet() const
CreateConnectorRequest & WithConnectorDescription(const Aws::String &value)
void SetLogDelivery(LogDelivery &&value)
const Aws::Map< Aws::String, Aws::String > & GetConnectorConfiguration() const
const LogDelivery & GetLogDelivery() const
CreateConnectorRequest & WithPlugins(Aws::Vector< Plugin > &&value)
void SetTags(const Aws::Map< Aws::String, Aws::String > &value)
void SetConnectorConfiguration(const Aws::Map< Aws::String, Aws::String > &value)
CreateConnectorRequest & WithConnectorDescription(const char *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