AWS SDK for C++

AWS SDK for C++ Version 1.11.440

Loading...
Searching...
No Matches
CreateEventSourceMappingRequest.h
1
6#pragma once
7#include <aws/lambda/Lambda_EXPORTS.h>
8#include <aws/lambda/LambdaRequest.h>
9#include <aws/core/utils/memory/stl/AWSString.h>
10#include <aws/lambda/model/FilterCriteria.h>
11#include <aws/lambda/model/EventSourcePosition.h>
12#include <aws/core/utils/DateTime.h>
13#include <aws/lambda/model/DestinationConfig.h>
14#include <aws/core/utils/memory/stl/AWSMap.h>
15#include <aws/core/utils/memory/stl/AWSVector.h>
16#include <aws/lambda/model/SelfManagedEventSource.h>
17#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
18#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
19#include <aws/lambda/model/ScalingConfig.h>
20#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
21#include <aws/lambda/model/SourceAccessConfiguration.h>
22#include <aws/lambda/model/FunctionResponseType.h>
23#include <utility>
24
25namespace Aws
26{
27namespace Lambda
28{
29namespace Model
30{
31
35 {
36 public:
38
39 // Service request name is the Operation name which will send this request out,
40 // each operation should has unique request name, so that we can get operation's name from this request.
41 // Note: this is not true for response, multiple operations may have the same response name,
42 // so we can not get operation's name from response.
43 inline virtual const char* GetServiceRequestName() const override { return "CreateEventSourceMapping"; }
44
45 AWS_LAMBDA_API Aws::String SerializePayload() const override;
46
47
49
61 inline const Aws::String& GetEventSourceArn() const{ return m_eventSourceArn; }
62 inline bool EventSourceArnHasBeenSet() const { return m_eventSourceArnHasBeenSet; }
63 inline void SetEventSourceArn(const Aws::String& value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn = value; }
64 inline void SetEventSourceArn(Aws::String&& value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn = std::move(value); }
65 inline void SetEventSourceArn(const char* value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn.assign(value); }
67 inline CreateEventSourceMappingRequest& WithEventSourceArn(Aws::String&& value) { SetEventSourceArn(std::move(value)); return *this;}
68 inline CreateEventSourceMappingRequest& WithEventSourceArn(const char* value) { SetEventSourceArn(value); return *this;}
70
72
84 inline const Aws::String& GetFunctionName() const{ return m_functionName; }
85 inline bool FunctionNameHasBeenSet() const { return m_functionNameHasBeenSet; }
86 inline void SetFunctionName(const Aws::String& value) { m_functionNameHasBeenSet = true; m_functionName = value; }
87 inline void SetFunctionName(Aws::String&& value) { m_functionNameHasBeenSet = true; m_functionName = std::move(value); }
88 inline void SetFunctionName(const char* value) { m_functionNameHasBeenSet = true; m_functionName.assign(value); }
89 inline CreateEventSourceMappingRequest& WithFunctionName(const Aws::String& value) { SetFunctionName(value); return *this;}
90 inline CreateEventSourceMappingRequest& WithFunctionName(Aws::String&& value) { SetFunctionName(std::move(value)); return *this;}
91 inline CreateEventSourceMappingRequest& WithFunctionName(const char* value) { SetFunctionName(value); return *this;}
93
95
99 inline bool GetEnabled() const{ return m_enabled; }
100 inline bool EnabledHasBeenSet() const { return m_enabledHasBeenSet; }
101 inline void SetEnabled(bool value) { m_enabledHasBeenSet = true; m_enabled = value; }
102 inline CreateEventSourceMappingRequest& WithEnabled(bool value) { SetEnabled(value); return *this;}
104
106
120 inline int GetBatchSize() const{ return m_batchSize; }
121 inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; }
122 inline void SetBatchSize(int value) { m_batchSizeHasBeenSet = true; m_batchSize = value; }
123 inline CreateEventSourceMappingRequest& WithBatchSize(int value) { SetBatchSize(value); return *this;}
125
127
133 inline const FilterCriteria& GetFilterCriteria() const{ return m_filterCriteria; }
134 inline bool FilterCriteriaHasBeenSet() const { return m_filterCriteriaHasBeenSet; }
135 inline void SetFilterCriteria(const FilterCriteria& value) { m_filterCriteriaHasBeenSet = true; m_filterCriteria = value; }
136 inline void SetFilterCriteria(FilterCriteria&& value) { m_filterCriteriaHasBeenSet = true; m_filterCriteria = std::move(value); }
138 inline CreateEventSourceMappingRequest& WithFilterCriteria(FilterCriteria&& value) { SetFilterCriteria(std::move(value)); return *this;}
140
142
157 inline int GetMaximumBatchingWindowInSeconds() const{ return m_maximumBatchingWindowInSeconds; }
158 inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
159 inline void SetMaximumBatchingWindowInSeconds(int value) { m_maximumBatchingWindowInSecondsHasBeenSet = true; m_maximumBatchingWindowInSeconds = value; }
162
164
168 inline int GetParallelizationFactor() const{ return m_parallelizationFactor; }
169 inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
170 inline void SetParallelizationFactor(int value) { m_parallelizationFactorHasBeenSet = true; m_parallelizationFactor = value; }
173
175
181 inline const EventSourcePosition& GetStartingPosition() const{ return m_startingPosition; }
182 inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
183 inline void SetStartingPosition(const EventSourcePosition& value) { m_startingPositionHasBeenSet = true; m_startingPosition = value; }
184 inline void SetStartingPosition(EventSourcePosition&& value) { m_startingPositionHasBeenSet = true; m_startingPosition = std::move(value); }
188
190
195 inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const{ return m_startingPositionTimestamp; }
196 inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
197 inline void SetStartingPositionTimestamp(const Aws::Utils::DateTime& value) { m_startingPositionTimestampHasBeenSet = true; m_startingPositionTimestamp = value; }
198 inline void SetStartingPositionTimestamp(Aws::Utils::DateTime&& value) { m_startingPositionTimestampHasBeenSet = true; m_startingPositionTimestamp = std::move(value); }
202
204
209 inline const DestinationConfig& GetDestinationConfig() const{ return m_destinationConfig; }
210 inline bool DestinationConfigHasBeenSet() const { return m_destinationConfigHasBeenSet; }
211 inline void SetDestinationConfig(const DestinationConfig& value) { m_destinationConfigHasBeenSet = true; m_destinationConfig = value; }
212 inline void SetDestinationConfig(DestinationConfig&& value) { m_destinationConfigHasBeenSet = true; m_destinationConfig = std::move(value); }
216
218
222 inline int GetMaximumRecordAgeInSeconds() const{ return m_maximumRecordAgeInSeconds; }
223 inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
224 inline void SetMaximumRecordAgeInSeconds(int value) { m_maximumRecordAgeInSecondsHasBeenSet = true; m_maximumRecordAgeInSeconds = value; }
227
229
233 inline bool GetBisectBatchOnFunctionError() const{ return m_bisectBatchOnFunctionError; }
234 inline bool BisectBatchOnFunctionErrorHasBeenSet() const { return m_bisectBatchOnFunctionErrorHasBeenSet; }
235 inline void SetBisectBatchOnFunctionError(bool value) { m_bisectBatchOnFunctionErrorHasBeenSet = true; m_bisectBatchOnFunctionError = value; }
238
240
245 inline int GetMaximumRetryAttempts() const{ return m_maximumRetryAttempts; }
246 inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
247 inline void SetMaximumRetryAttempts(int value) { m_maximumRetryAttemptsHasBeenSet = true; m_maximumRetryAttempts = value; }
250
252
255 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const{ return m_tags; }
256 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
257 inline void SetTags(const Aws::Map<Aws::String, Aws::String>& value) { m_tagsHasBeenSet = true; m_tags = value; }
258 inline void SetTags(Aws::Map<Aws::String, Aws::String>&& value) { m_tagsHasBeenSet = true; m_tags = std::move(value); }
260 inline CreateEventSourceMappingRequest& WithTags(Aws::Map<Aws::String, Aws::String>&& value) { SetTags(std::move(value)); return *this;}
261 inline CreateEventSourceMappingRequest& AddTags(const Aws::String& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
262 inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
263 inline CreateEventSourceMappingRequest& AddTags(const Aws::String& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
264 inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), std::move(value)); return *this; }
265 inline CreateEventSourceMappingRequest& AddTags(const char* key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
266 inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
267 inline CreateEventSourceMappingRequest& AddTags(const char* key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
269
271
276 inline int GetTumblingWindowInSeconds() const{ return m_tumblingWindowInSeconds; }
277 inline bool TumblingWindowInSecondsHasBeenSet() const { return m_tumblingWindowInSecondsHasBeenSet; }
278 inline void SetTumblingWindowInSeconds(int value) { m_tumblingWindowInSecondsHasBeenSet = true; m_tumblingWindowInSeconds = value; }
281
283
286 inline const Aws::Vector<Aws::String>& GetTopics() const{ return m_topics; }
287 inline bool TopicsHasBeenSet() const { return m_topicsHasBeenSet; }
288 inline void SetTopics(const Aws::Vector<Aws::String>& value) { m_topicsHasBeenSet = true; m_topics = value; }
289 inline void SetTopics(Aws::Vector<Aws::String>&& value) { m_topicsHasBeenSet = true; m_topics = std::move(value); }
291 inline CreateEventSourceMappingRequest& WithTopics(Aws::Vector<Aws::String>&& value) { SetTopics(std::move(value)); return *this;}
292 inline CreateEventSourceMappingRequest& AddTopics(const Aws::String& value) { m_topicsHasBeenSet = true; m_topics.push_back(value); return *this; }
293 inline CreateEventSourceMappingRequest& AddTopics(Aws::String&& value) { m_topicsHasBeenSet = true; m_topics.push_back(std::move(value)); return *this; }
294 inline CreateEventSourceMappingRequest& AddTopics(const char* value) { m_topicsHasBeenSet = true; m_topics.push_back(value); return *this; }
296
298
301 inline const Aws::Vector<Aws::String>& GetQueues() const{ return m_queues; }
302 inline bool QueuesHasBeenSet() const { return m_queuesHasBeenSet; }
303 inline void SetQueues(const Aws::Vector<Aws::String>& value) { m_queuesHasBeenSet = true; m_queues = value; }
304 inline void SetQueues(Aws::Vector<Aws::String>&& value) { m_queuesHasBeenSet = true; m_queues = std::move(value); }
306 inline CreateEventSourceMappingRequest& WithQueues(Aws::Vector<Aws::String>&& value) { SetQueues(std::move(value)); return *this;}
307 inline CreateEventSourceMappingRequest& AddQueues(const Aws::String& value) { m_queuesHasBeenSet = true; m_queues.push_back(value); return *this; }
308 inline CreateEventSourceMappingRequest& AddQueues(Aws::String&& value) { m_queuesHasBeenSet = true; m_queues.push_back(std::move(value)); return *this; }
309 inline CreateEventSourceMappingRequest& AddQueues(const char* value) { m_queuesHasBeenSet = true; m_queues.push_back(value); return *this; }
311
313
317 inline const Aws::Vector<SourceAccessConfiguration>& GetSourceAccessConfigurations() const{ return m_sourceAccessConfigurations; }
318 inline bool SourceAccessConfigurationsHasBeenSet() const { return m_sourceAccessConfigurationsHasBeenSet; }
319 inline void SetSourceAccessConfigurations(const Aws::Vector<SourceAccessConfiguration>& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations = value; }
320 inline void SetSourceAccessConfigurations(Aws::Vector<SourceAccessConfiguration>&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations = std::move(value); }
323 inline CreateEventSourceMappingRequest& AddSourceAccessConfigurations(const SourceAccessConfiguration& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations.push_back(value); return *this; }
324 inline CreateEventSourceMappingRequest& AddSourceAccessConfigurations(SourceAccessConfiguration&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations.push_back(std::move(value)); return *this; }
326
328
331 inline const SelfManagedEventSource& GetSelfManagedEventSource() const{ return m_selfManagedEventSource; }
332 inline bool SelfManagedEventSourceHasBeenSet() const { return m_selfManagedEventSourceHasBeenSet; }
333 inline void SetSelfManagedEventSource(const SelfManagedEventSource& value) { m_selfManagedEventSourceHasBeenSet = true; m_selfManagedEventSource = value; }
334 inline void SetSelfManagedEventSource(SelfManagedEventSource&& value) { m_selfManagedEventSourceHasBeenSet = true; m_selfManagedEventSource = std::move(value); }
338
340
344 inline const Aws::Vector<FunctionResponseType>& GetFunctionResponseTypes() const{ return m_functionResponseTypes; }
345 inline bool FunctionResponseTypesHasBeenSet() const { return m_functionResponseTypesHasBeenSet; }
346 inline void SetFunctionResponseTypes(const Aws::Vector<FunctionResponseType>& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes = value; }
347 inline void SetFunctionResponseTypes(Aws::Vector<FunctionResponseType>&& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes = std::move(value); }
350 inline CreateEventSourceMappingRequest& AddFunctionResponseTypes(const FunctionResponseType& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes.push_back(value); return *this; }
351 inline CreateEventSourceMappingRequest& AddFunctionResponseTypes(FunctionResponseType&& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes.push_back(std::move(value)); return *this; }
353
355
359 inline const AmazonManagedKafkaEventSourceConfig& GetAmazonManagedKafkaEventSourceConfig() const{ return m_amazonManagedKafkaEventSourceConfig; }
360 inline bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const { return m_amazonManagedKafkaEventSourceConfigHasBeenSet; }
361 inline void SetAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig& value) { m_amazonManagedKafkaEventSourceConfigHasBeenSet = true; m_amazonManagedKafkaEventSourceConfig = value; }
362 inline void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig&& value) { m_amazonManagedKafkaEventSourceConfigHasBeenSet = true; m_amazonManagedKafkaEventSourceConfig = std::move(value); }
366
368
372 inline const SelfManagedKafkaEventSourceConfig& GetSelfManagedKafkaEventSourceConfig() const{ return m_selfManagedKafkaEventSourceConfig; }
373 inline bool SelfManagedKafkaEventSourceConfigHasBeenSet() const { return m_selfManagedKafkaEventSourceConfigHasBeenSet; }
374 inline void SetSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig& value) { m_selfManagedKafkaEventSourceConfigHasBeenSet = true; m_selfManagedKafkaEventSourceConfig = value; }
375 inline void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig&& value) { m_selfManagedKafkaEventSourceConfigHasBeenSet = true; m_selfManagedKafkaEventSourceConfig = std::move(value); }
379
381
387 inline const ScalingConfig& GetScalingConfig() const{ return m_scalingConfig; }
388 inline bool ScalingConfigHasBeenSet() const { return m_scalingConfigHasBeenSet; }
389 inline void SetScalingConfig(const ScalingConfig& value) { m_scalingConfigHasBeenSet = true; m_scalingConfig = value; }
390 inline void SetScalingConfig(ScalingConfig&& value) { m_scalingConfigHasBeenSet = true; m_scalingConfig = std::move(value); }
392 inline CreateEventSourceMappingRequest& WithScalingConfig(ScalingConfig&& value) { SetScalingConfig(std::move(value)); return *this;}
394
396
399 inline const DocumentDBEventSourceConfig& GetDocumentDBEventSourceConfig() const{ return m_documentDBEventSourceConfig; }
400 inline bool DocumentDBEventSourceConfigHasBeenSet() const { return m_documentDBEventSourceConfigHasBeenSet; }
401 inline void SetDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig& value) { m_documentDBEventSourceConfigHasBeenSet = true; m_documentDBEventSourceConfig = value; }
402 inline void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfig&& value) { m_documentDBEventSourceConfigHasBeenSet = true; m_documentDBEventSourceConfig = std::move(value); }
406
408
415 inline const Aws::String& GetKMSKeyArn() const{ return m_kMSKeyArn; }
416 inline bool KMSKeyArnHasBeenSet() const { return m_kMSKeyArnHasBeenSet; }
417 inline void SetKMSKeyArn(const Aws::String& value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn = value; }
418 inline void SetKMSKeyArn(Aws::String&& value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn = std::move(value); }
419 inline void SetKMSKeyArn(const char* value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn.assign(value); }
420 inline CreateEventSourceMappingRequest& WithKMSKeyArn(const Aws::String& value) { SetKMSKeyArn(value); return *this;}
421 inline CreateEventSourceMappingRequest& WithKMSKeyArn(Aws::String&& value) { SetKMSKeyArn(std::move(value)); return *this;}
422 inline CreateEventSourceMappingRequest& WithKMSKeyArn(const char* value) { SetKMSKeyArn(value); return *this;}
424 private:
425
426 Aws::String m_eventSourceArn;
427 bool m_eventSourceArnHasBeenSet = false;
428
429 Aws::String m_functionName;
430 bool m_functionNameHasBeenSet = false;
431
432 bool m_enabled;
433 bool m_enabledHasBeenSet = false;
434
435 int m_batchSize;
436 bool m_batchSizeHasBeenSet = false;
437
438 FilterCriteria m_filterCriteria;
439 bool m_filterCriteriaHasBeenSet = false;
440
441 int m_maximumBatchingWindowInSeconds;
442 bool m_maximumBatchingWindowInSecondsHasBeenSet = false;
443
444 int m_parallelizationFactor;
445 bool m_parallelizationFactorHasBeenSet = false;
446
447 EventSourcePosition m_startingPosition;
448 bool m_startingPositionHasBeenSet = false;
449
450 Aws::Utils::DateTime m_startingPositionTimestamp;
451 bool m_startingPositionTimestampHasBeenSet = false;
452
453 DestinationConfig m_destinationConfig;
454 bool m_destinationConfigHasBeenSet = false;
455
456 int m_maximumRecordAgeInSeconds;
457 bool m_maximumRecordAgeInSecondsHasBeenSet = false;
458
459 bool m_bisectBatchOnFunctionError;
460 bool m_bisectBatchOnFunctionErrorHasBeenSet = false;
461
462 int m_maximumRetryAttempts;
463 bool m_maximumRetryAttemptsHasBeenSet = false;
464
466 bool m_tagsHasBeenSet = false;
467
468 int m_tumblingWindowInSeconds;
469 bool m_tumblingWindowInSecondsHasBeenSet = false;
470
472 bool m_topicsHasBeenSet = false;
473
475 bool m_queuesHasBeenSet = false;
476
477 Aws::Vector<SourceAccessConfiguration> m_sourceAccessConfigurations;
478 bool m_sourceAccessConfigurationsHasBeenSet = false;
479
480 SelfManagedEventSource m_selfManagedEventSource;
481 bool m_selfManagedEventSourceHasBeenSet = false;
482
483 Aws::Vector<FunctionResponseType> m_functionResponseTypes;
484 bool m_functionResponseTypesHasBeenSet = false;
485
486 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
487 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet = false;
488
489 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
490 bool m_selfManagedKafkaEventSourceConfigHasBeenSet = false;
491
492 ScalingConfig m_scalingConfig;
493 bool m_scalingConfigHasBeenSet = false;
494
495 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
496 bool m_documentDBEventSourceConfigHasBeenSet = false;
497
498 Aws::String m_kMSKeyArn;
499 bool m_kMSKeyArnHasBeenSet = false;
500 };
501
502} // namespace Model
503} // namespace Lambda
504} // namespace Aws
CreateEventSourceMappingRequest & WithTumblingWindowInSeconds(int value)
CreateEventSourceMappingRequest & AddQueues(const char *value)
CreateEventSourceMappingRequest & WithKMSKeyArn(const Aws::String &value)
void SetAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig &value)
CreateEventSourceMappingRequest & WithKMSKeyArn(Aws::String &&value)
CreateEventSourceMappingRequest & AddTags(const char *key, Aws::String &&value)
CreateEventSourceMappingRequest & WithEventSourceArn(const char *value)
CreateEventSourceMappingRequest & WithBatchSize(int value)
CreateEventSourceMappingRequest & AddSourceAccessConfigurations(SourceAccessConfiguration &&value)
CreateEventSourceMappingRequest & WithQueues(Aws::Vector< Aws::String > &&value)
CreateEventSourceMappingRequest & WithStartingPositionTimestamp(const Aws::Utils::DateTime &value)
void SetFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
CreateEventSourceMappingRequest & WithStartingPosition(const EventSourcePosition &value)
CreateEventSourceMappingRequest & WithFunctionName(const Aws::String &value)
CreateEventSourceMappingRequest & WithSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
CreateEventSourceMappingRequest & AddTopics(const char *value)
CreateEventSourceMappingRequest & WithEventSourceArn(Aws::String &&value)
CreateEventSourceMappingRequest & AddQueues(Aws::String &&value)
void SetSelfManagedEventSource(const SelfManagedEventSource &value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithDestinationConfig(const DestinationConfig &value)
CreateEventSourceMappingRequest & WithAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig &value)
CreateEventSourceMappingRequest & WithTags(Aws::Map< Aws::String, Aws::String > &&value)
CreateEventSourceMappingRequest & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithFilterCriteria(FilterCriteria &&value)
CreateEventSourceMappingRequest & WithBisectBatchOnFunctionError(bool value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
CreateEventSourceMappingRequest & WithScalingConfig(ScalingConfig &&value)
CreateEventSourceMappingRequest & WithFunctionName(const char *value)
CreateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithTopics(Aws::Vector< Aws::String > &&value)
CreateEventSourceMappingRequest & WithMaximumRecordAgeInSeconds(int value)
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
void SetSourceAccessConfigurations(Aws::Vector< SourceAccessConfiguration > &&value)
CreateEventSourceMappingRequest & AddTopics(const Aws::String &value)
const Aws::Map< Aws::String, Aws::String > & GetTags() const
CreateEventSourceMappingRequest & WithStartingPosition(EventSourcePosition &&value)
CreateEventSourceMappingRequest & WithFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
void SetDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
CreateEventSourceMappingRequest & WithSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig &value)
CreateEventSourceMappingRequest & AddTopics(Aws::String &&value)
CreateEventSourceMappingRequest & AddTags(Aws::String &&key, const Aws::String &value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
CreateEventSourceMappingRequest & AddTags(const char *key, const char *value)
CreateEventSourceMappingRequest & WithMaximumBatchingWindowInSeconds(int value)
void SetSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
CreateEventSourceMappingRequest & WithParallelizationFactor(int value)
CreateEventSourceMappingRequest & AddTags(Aws::String &&key, const char *value)
CreateEventSourceMappingRequest & WithSelfManagedEventSource(const SelfManagedEventSource &value)
CreateEventSourceMappingRequest & WithFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
CreateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
CreateEventSourceMappingRequest & WithStartingPositionTimestamp(Aws::Utils::DateTime &&value)
CreateEventSourceMappingRequest & WithTags(const Aws::Map< Aws::String, Aws::String > &value)
CreateEventSourceMappingRequest & AddTags(Aws::String &&key, Aws::String &&value)
CreateEventSourceMappingRequest & WithSelfManagedEventSource(SelfManagedEventSource &&value)
CreateEventSourceMappingRequest & AddFunctionResponseTypes(const FunctionResponseType &value)
void SetStartingPositionTimestamp(const Aws::Utils::DateTime &value)
void SetTopics(const Aws::Vector< Aws::String > &value)
AWS_LAMBDA_API Aws::String SerializePayload() const override
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithSourceAccessConfigurations(Aws::Vector< SourceAccessConfiguration > &&value)
CreateEventSourceMappingRequest & WithKMSKeyArn(const char *value)
CreateEventSourceMappingRequest & AddTags(const Aws::String &key, const Aws::String &value)
CreateEventSourceMappingRequest & WithScalingConfig(const ScalingConfig &value)
CreateEventSourceMappingRequest & AddFunctionResponseTypes(FunctionResponseType &&value)
CreateEventSourceMappingRequest & AddTags(const Aws::String &key, Aws::String &&value)
CreateEventSourceMappingRequest & WithMaximumRetryAttempts(int value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
CreateEventSourceMappingRequest & WithEventSourceArn(const Aws::String &value)
void SetQueues(const Aws::Vector< Aws::String > &value)
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithQueues(const Aws::Vector< Aws::String > &value)
CreateEventSourceMappingRequest & WithTopics(const Aws::Vector< Aws::String > &value)
void SetFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
CreateEventSourceMappingRequest & AddQueues(const Aws::String &value)
CreateEventSourceMappingRequest & WithEnabled(bool value)
CreateEventSourceMappingRequest & AddSourceAccessConfigurations(const SourceAccessConfiguration &value)
void SetTags(Aws::Map< Aws::String, Aws::String > &&value)
CreateEventSourceMappingRequest & WithFunctionName(Aws::String &&value)
CreateEventSourceMappingRequest & WithDestinationConfig(DestinationConfig &&value)
void SetTags(const Aws::Map< Aws::String, Aws::String > &value)
CreateEventSourceMappingRequest & WithFilterCriteria(const FilterCriteria &value)
void SetSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig &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