AWS SDK for C++

AWS SDK for C++ Version 1.11.440

Loading...
Searching...
No Matches
CreateConnectorRequest.h
1
6#pragma once
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>
19#include <utility>
20
21namespace Aws
22{
23namespace KafkaConnect
24{
25namespace Model
26{
27
31 {
32 public:
33 AWS_KAFKACONNECT_API CreateConnectorRequest();
34
35 // Service request name is the Operation name which will send this request out,
36 // each operation should has unique request name, so that we can get operation's name from this request.
37 // Note: this is not true for response, multiple operations may have the same response name,
38 // so we can not get operation's name from response.
39 inline virtual const char* GetServiceRequestName() const override { return "CreateConnector"; }
40
41 AWS_KAFKACONNECT_API Aws::String SerializePayload() const override;
42
43
45
49 inline const Capacity& GetCapacity() const{ return m_capacity; }
50 inline bool CapacityHasBeenSet() const { return m_capacityHasBeenSet; }
51 inline void SetCapacity(const Capacity& value) { m_capacityHasBeenSet = true; m_capacity = value; }
52 inline void SetCapacity(Capacity&& value) { m_capacityHasBeenSet = true; m_capacity = std::move(value); }
53 inline CreateConnectorRequest& WithCapacity(const Capacity& value) { SetCapacity(value); return *this;}
54 inline CreateConnectorRequest& WithCapacity(Capacity&& value) { SetCapacity(std::move(value)); return *this;}
56
58
62 inline const Aws::Map<Aws::String, Aws::String>& GetConnectorConfiguration() const{ return m_connectorConfiguration; }
63 inline bool ConnectorConfigurationHasBeenSet() const { return m_connectorConfigurationHasBeenSet; }
64 inline void SetConnectorConfiguration(const Aws::Map<Aws::String, Aws::String>& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration = value; }
65 inline void SetConnectorConfiguration(Aws::Map<Aws::String, Aws::String>&& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration = std::move(value); }
68 inline CreateConnectorRequest& AddConnectorConfiguration(const Aws::String& key, const Aws::String& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(key, value); return *this; }
69 inline CreateConnectorRequest& AddConnectorConfiguration(Aws::String&& key, const Aws::String& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(std::move(key), value); return *this; }
70 inline CreateConnectorRequest& AddConnectorConfiguration(const Aws::String& key, Aws::String&& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(key, std::move(value)); return *this; }
71 inline CreateConnectorRequest& AddConnectorConfiguration(Aws::String&& key, Aws::String&& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(std::move(key), std::move(value)); return *this; }
72 inline CreateConnectorRequest& AddConnectorConfiguration(const char* key, Aws::String&& value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(key, std::move(value)); return *this; }
73 inline CreateConnectorRequest& AddConnectorConfiguration(Aws::String&& key, const char* value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(std::move(key), value); return *this; }
74 inline CreateConnectorRequest& AddConnectorConfiguration(const char* key, const char* value) { m_connectorConfigurationHasBeenSet = true; m_connectorConfiguration.emplace(key, value); return *this; }
76
78
81 inline const Aws::String& GetConnectorDescription() const{ return m_connectorDescription; }
82 inline bool ConnectorDescriptionHasBeenSet() const { return m_connectorDescriptionHasBeenSet; }
83 inline void SetConnectorDescription(const Aws::String& value) { m_connectorDescriptionHasBeenSet = true; m_connectorDescription = value; }
84 inline void SetConnectorDescription(Aws::String&& value) { m_connectorDescriptionHasBeenSet = true; m_connectorDescription = std::move(value); }
85 inline void SetConnectorDescription(const char* value) { m_connectorDescriptionHasBeenSet = true; m_connectorDescription.assign(value); }
87 inline CreateConnectorRequest& WithConnectorDescription(Aws::String&& value) { SetConnectorDescription(std::move(value)); return *this;}
88 inline CreateConnectorRequest& WithConnectorDescription(const char* value) { SetConnectorDescription(value); return *this;}
90
92
95 inline const Aws::String& GetConnectorName() const{ return m_connectorName; }
96 inline bool ConnectorNameHasBeenSet() const { return m_connectorNameHasBeenSet; }
97 inline void SetConnectorName(const Aws::String& value) { m_connectorNameHasBeenSet = true; m_connectorName = value; }
98 inline void SetConnectorName(Aws::String&& value) { m_connectorNameHasBeenSet = true; m_connectorName = std::move(value); }
99 inline void SetConnectorName(const char* value) { m_connectorNameHasBeenSet = true; m_connectorName.assign(value); }
100 inline CreateConnectorRequest& WithConnectorName(const Aws::String& value) { SetConnectorName(value); return *this;}
101 inline CreateConnectorRequest& WithConnectorName(Aws::String&& value) { SetConnectorName(std::move(value)); return *this;}
102 inline CreateConnectorRequest& WithConnectorName(const char* value) { SetConnectorName(value); return *this;}
104
106
109 inline const KafkaCluster& GetKafkaCluster() const{ return m_kafkaCluster; }
110 inline bool KafkaClusterHasBeenSet() const { return m_kafkaClusterHasBeenSet; }
111 inline void SetKafkaCluster(const KafkaCluster& value) { m_kafkaClusterHasBeenSet = true; m_kafkaCluster = value; }
112 inline void SetKafkaCluster(KafkaCluster&& value) { m_kafkaClusterHasBeenSet = true; m_kafkaCluster = std::move(value); }
113 inline CreateConnectorRequest& WithKafkaCluster(const KafkaCluster& value) { SetKafkaCluster(value); return *this;}
114 inline CreateConnectorRequest& WithKafkaCluster(KafkaCluster&& value) { SetKafkaCluster(std::move(value)); return *this;}
116
118
121 inline const KafkaClusterClientAuthentication& GetKafkaClusterClientAuthentication() const{ return m_kafkaClusterClientAuthentication; }
122 inline bool KafkaClusterClientAuthenticationHasBeenSet() const { return m_kafkaClusterClientAuthenticationHasBeenSet; }
123 inline void SetKafkaClusterClientAuthentication(const KafkaClusterClientAuthentication& value) { m_kafkaClusterClientAuthenticationHasBeenSet = true; m_kafkaClusterClientAuthentication = value; }
124 inline void SetKafkaClusterClientAuthentication(KafkaClusterClientAuthentication&& value) { m_kafkaClusterClientAuthenticationHasBeenSet = true; m_kafkaClusterClientAuthentication = std::move(value); }
128
130
133 inline const KafkaClusterEncryptionInTransit& GetKafkaClusterEncryptionInTransit() const{ return m_kafkaClusterEncryptionInTransit; }
134 inline bool KafkaClusterEncryptionInTransitHasBeenSet() const { return m_kafkaClusterEncryptionInTransitHasBeenSet; }
135 inline void SetKafkaClusterEncryptionInTransit(const KafkaClusterEncryptionInTransit& value) { m_kafkaClusterEncryptionInTransitHasBeenSet = true; m_kafkaClusterEncryptionInTransit = value; }
136 inline void SetKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransit&& value) { m_kafkaClusterEncryptionInTransitHasBeenSet = true; m_kafkaClusterEncryptionInTransit = std::move(value); }
140
142
146 inline const Aws::String& GetKafkaConnectVersion() const{ return m_kafkaConnectVersion; }
147 inline bool KafkaConnectVersionHasBeenSet() const { return m_kafkaConnectVersionHasBeenSet; }
148 inline void SetKafkaConnectVersion(const Aws::String& value) { m_kafkaConnectVersionHasBeenSet = true; m_kafkaConnectVersion = value; }
149 inline void SetKafkaConnectVersion(Aws::String&& value) { m_kafkaConnectVersionHasBeenSet = true; m_kafkaConnectVersion = std::move(value); }
150 inline void SetKafkaConnectVersion(const char* value) { m_kafkaConnectVersionHasBeenSet = true; m_kafkaConnectVersion.assign(value); }
152 inline CreateConnectorRequest& WithKafkaConnectVersion(Aws::String&& value) { SetKafkaConnectVersion(std::move(value)); return *this;}
153 inline CreateConnectorRequest& WithKafkaConnectVersion(const char* value) { SetKafkaConnectVersion(value); return *this;}
155
157
160 inline const LogDelivery& GetLogDelivery() const{ return m_logDelivery; }
161 inline bool LogDeliveryHasBeenSet() const { return m_logDeliveryHasBeenSet; }
162 inline void SetLogDelivery(const LogDelivery& value) { m_logDeliveryHasBeenSet = true; m_logDelivery = value; }
163 inline void SetLogDelivery(LogDelivery&& value) { m_logDeliveryHasBeenSet = true; m_logDelivery = std::move(value); }
164 inline CreateConnectorRequest& WithLogDelivery(const LogDelivery& value) { SetLogDelivery(value); return *this;}
165 inline CreateConnectorRequest& WithLogDelivery(LogDelivery&& value) { SetLogDelivery(std::move(value)); return *this;}
167
169
177 inline const Aws::Vector<Plugin>& GetPlugins() const{ return m_plugins; }
178 inline bool PluginsHasBeenSet() const { return m_pluginsHasBeenSet; }
179 inline void SetPlugins(const Aws::Vector<Plugin>& value) { m_pluginsHasBeenSet = true; m_plugins = value; }
180 inline void SetPlugins(Aws::Vector<Plugin>&& value) { m_pluginsHasBeenSet = true; m_plugins = std::move(value); }
181 inline CreateConnectorRequest& WithPlugins(const Aws::Vector<Plugin>& value) { SetPlugins(value); return *this;}
182 inline CreateConnectorRequest& WithPlugins(Aws::Vector<Plugin>&& value) { SetPlugins(std::move(value)); return *this;}
183 inline CreateConnectorRequest& AddPlugins(const Plugin& value) { m_pluginsHasBeenSet = true; m_plugins.push_back(value); return *this; }
184 inline CreateConnectorRequest& AddPlugins(Plugin&& value) { m_pluginsHasBeenSet = true; m_plugins.push_back(std::move(value)); return *this; }
186
188
195 inline const Aws::String& GetServiceExecutionRoleArn() const{ return m_serviceExecutionRoleArn; }
196 inline bool ServiceExecutionRoleArnHasBeenSet() const { return m_serviceExecutionRoleArnHasBeenSet; }
197 inline void SetServiceExecutionRoleArn(const Aws::String& value) { m_serviceExecutionRoleArnHasBeenSet = true; m_serviceExecutionRoleArn = value; }
198 inline void SetServiceExecutionRoleArn(Aws::String&& value) { m_serviceExecutionRoleArnHasBeenSet = true; m_serviceExecutionRoleArn = std::move(value); }
199 inline void SetServiceExecutionRoleArn(const char* value) { m_serviceExecutionRoleArnHasBeenSet = true; m_serviceExecutionRoleArn.assign(value); }
202 inline CreateConnectorRequest& WithServiceExecutionRoleArn(const char* value) { SetServiceExecutionRoleArn(value); return *this;}
204
206
209 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const{ return m_tags; }
210 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
211 inline void SetTags(const Aws::Map<Aws::String, Aws::String>& value) { m_tagsHasBeenSet = true; m_tags = value; }
212 inline void SetTags(Aws::Map<Aws::String, Aws::String>&& value) { m_tagsHasBeenSet = true; m_tags = std::move(value); }
213 inline CreateConnectorRequest& WithTags(const Aws::Map<Aws::String, Aws::String>& value) { SetTags(value); return *this;}
214 inline CreateConnectorRequest& WithTags(Aws::Map<Aws::String, Aws::String>&& value) { SetTags(std::move(value)); return *this;}
215 inline CreateConnectorRequest& AddTags(const Aws::String& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
216 inline CreateConnectorRequest& AddTags(Aws::String&& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
217 inline CreateConnectorRequest& AddTags(const Aws::String& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
218 inline CreateConnectorRequest& AddTags(Aws::String&& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), std::move(value)); return *this; }
219 inline CreateConnectorRequest& AddTags(const char* key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
220 inline CreateConnectorRequest& AddTags(Aws::String&& key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
221 inline CreateConnectorRequest& AddTags(const char* key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
223
225
228 inline const WorkerConfiguration& GetWorkerConfiguration() const{ return m_workerConfiguration; }
229 inline bool WorkerConfigurationHasBeenSet() const { return m_workerConfigurationHasBeenSet; }
230 inline void SetWorkerConfiguration(const WorkerConfiguration& value) { m_workerConfigurationHasBeenSet = true; m_workerConfiguration = value; }
231 inline void SetWorkerConfiguration(WorkerConfiguration&& value) { m_workerConfigurationHasBeenSet = true; m_workerConfiguration = std::move(value); }
235 private:
236
237 Capacity m_capacity;
238 bool m_capacityHasBeenSet = false;
239
240 Aws::Map<Aws::String, Aws::String> m_connectorConfiguration;
241 bool m_connectorConfigurationHasBeenSet = false;
242
243 Aws::String m_connectorDescription;
244 bool m_connectorDescriptionHasBeenSet = false;
245
246 Aws::String m_connectorName;
247 bool m_connectorNameHasBeenSet = false;
248
249 KafkaCluster m_kafkaCluster;
250 bool m_kafkaClusterHasBeenSet = false;
251
252 KafkaClusterClientAuthentication m_kafkaClusterClientAuthentication;
253 bool m_kafkaClusterClientAuthenticationHasBeenSet = false;
254
255 KafkaClusterEncryptionInTransit m_kafkaClusterEncryptionInTransit;
256 bool m_kafkaClusterEncryptionInTransitHasBeenSet = false;
257
258 Aws::String m_kafkaConnectVersion;
259 bool m_kafkaConnectVersionHasBeenSet = false;
260
261 LogDelivery m_logDelivery;
262 bool m_logDeliveryHasBeenSet = false;
263
264 Aws::Vector<Plugin> m_plugins;
265 bool m_pluginsHasBeenSet = false;
266
267 Aws::String m_serviceExecutionRoleArn;
268 bool m_serviceExecutionRoleArnHasBeenSet = false;
269
271 bool m_tagsHasBeenSet = false;
272
273 WorkerConfiguration m_workerConfiguration;
274 bool m_workerConfigurationHasBeenSet = false;
275 };
276
277} // namespace Model
278} // namespace KafkaConnect
279} // namespace Aws
void SetWorkerConfiguration(const WorkerConfiguration &value)
void SetKafkaClusterEncryptionInTransit(KafkaClusterEncryptionInTransit &&value)
CreateConnectorRequest & WithWorkerConfiguration(const WorkerConfiguration &value)
CreateConnectorRequest & WithKafkaClusterClientAuthentication(KafkaClusterClientAuthentication &&value)
AWS_KAFKACONNECT_API Aws::String SerializePayload() const override
CreateConnectorRequest & AddTags(Aws::String &&key, 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)
CreateConnectorRequest & AddPlugins(const Plugin &value)
void SetPlugins(const Aws::Vector< Plugin > &value)
CreateConnectorRequest & WithCapacity(const Capacity &value)
CreateConnectorRequest & WithConnectorName(const char *value)
CreateConnectorRequest & WithConnectorConfiguration(const Aws::Map< Aws::String, Aws::String > &value)
CreateConnectorRequest & AddConnectorConfiguration(const Aws::String &key, Aws::String &&value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, Aws::String &&value)
CreateConnectorRequest & AddPlugins(Plugin &&value)
CreateConnectorRequest & AddConnectorConfiguration(const char *key, const char *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)
void SetKafkaClusterClientAuthentication(const KafkaClusterClientAuthentication &value)
CreateConnectorRequest & WithServiceExecutionRoleArn(const Aws::String &value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, const char *value)
const KafkaClusterClientAuthentication & GetKafkaClusterClientAuthentication() const
CreateConnectorRequest & AddConnectorConfiguration(const Aws::String &key, const Aws::String &value)
CreateConnectorRequest & AddConnectorConfiguration(Aws::String &&key, const Aws::String &value)
virtual const char * GetServiceRequestName() const override
CreateConnectorRequest & AddTags(const char *key, Aws::String &&value)
CreateConnectorRequest & WithConnectorName(const Aws::String &value)
CreateConnectorRequest & WithServiceExecutionRoleArn(const char *value)
CreateConnectorRequest & WithKafkaCluster(KafkaCluster &&value)
const Aws::Map< Aws::String, Aws::String > & GetTags() const
void SetWorkerConfiguration(WorkerConfiguration &&value)
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)
CreateConnectorRequest & WithConnectorName(Aws::String &&value)
const WorkerConfiguration & GetWorkerConfiguration() const
CreateConnectorRequest & WithWorkerConfiguration(WorkerConfiguration &&value)
CreateConnectorRequest & WithKafkaConnectVersion(const char *value)
CreateConnectorRequest & AddTags(const Aws::String &key, const Aws::String &value)
CreateConnectorRequest & AddTags(const char *key, const char *value)
CreateConnectorRequest & WithServiceExecutionRoleArn(Aws::String &&value)
void SetKafkaClusterClientAuthentication(KafkaClusterClientAuthentication &&value)
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)
CreateConnectorRequest & WithConnectorDescription(const Aws::String &value)
const Aws::Map< Aws::String, Aws::String > & GetConnectorConfiguration() 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