AWS SDK for C++

AWS SDK for C++ Version 1.11.834

Loading...
Searching...
No Matches
CreateEventSourceMappingRequest.h
1
6#pragma once
7#include <aws/core/utils/DateTime.h>
8#include <aws/core/utils/memory/stl/AWSMap.h>
9#include <aws/core/utils/memory/stl/AWSString.h>
10#include <aws/core/utils/memory/stl/AWSVector.h>
11#include <aws/lambda/LambdaRequest.h>
12#include <aws/lambda/Lambda_EXPORTS.h>
13#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
14#include <aws/lambda/model/DestinationConfig.h>
15#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
16#include <aws/lambda/model/EventSourceMappingLoggingConfig.h>
17#include <aws/lambda/model/EventSourceMappingMetricsConfig.h>
18#include <aws/lambda/model/EventSourcePosition.h>
19#include <aws/lambda/model/FilterCriteria.h>
20#include <aws/lambda/model/FunctionResponseType.h>
21#include <aws/lambda/model/ProvisionedPollerConfig.h>
22#include <aws/lambda/model/ScalingConfig.h>
23#include <aws/lambda/model/SelfManagedEventSource.h>
24#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
25#include <aws/lambda/model/SourceAccessConfiguration.h>
26
27#include <utility>
28
29namespace Aws {
30namespace Lambda {
31namespace Model {
32
36 public:
37 AWS_LAMBDA_API CreateEventSourceMappingRequest() = default;
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
48
60 inline const Aws::String& GetEventSourceArn() const { return m_eventSourceArn; }
61 inline bool EventSourceArnHasBeenSet() const { return m_eventSourceArnHasBeenSet; }
62 template <typename EventSourceArnT = Aws::String>
63 void SetEventSourceArn(EventSourceArnT&& value) {
64 m_eventSourceArnHasBeenSet = true;
65 m_eventSourceArn = std::forward<EventSourceArnT>(value);
66 }
67 template <typename EventSourceArnT = Aws::String>
69 SetEventSourceArn(std::forward<EventSourceArnT>(value));
70 return *this;
71 }
73
75
87 inline const Aws::String& GetFunctionName() const { return m_functionName; }
88 inline bool FunctionNameHasBeenSet() const { return m_functionNameHasBeenSet; }
89 template <typename FunctionNameT = Aws::String>
90 void SetFunctionName(FunctionNameT&& value) {
91 m_functionNameHasBeenSet = true;
92 m_functionName = std::forward<FunctionNameT>(value);
93 }
94 template <typename FunctionNameT = Aws::String>
96 SetFunctionName(std::forward<FunctionNameT>(value));
97 return *this;
98 }
100
102
106 inline bool GetEnabled() const { return m_enabled; }
107 inline bool EnabledHasBeenSet() const { return m_enabledHasBeenSet; }
108 inline void SetEnabled(bool value) {
109 m_enabledHasBeenSet = true;
110 m_enabled = value;
111 }
113 SetEnabled(value);
114 return *this;
115 }
117
119
133 inline int GetBatchSize() const { return m_batchSize; }
134 inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; }
135 inline void SetBatchSize(int value) {
136 m_batchSizeHasBeenSet = true;
137 m_batchSize = value;
138 }
140 SetBatchSize(value);
141 return *this;
142 }
144
146
152 inline const FilterCriteria& GetFilterCriteria() const { return m_filterCriteria; }
153 inline bool FilterCriteriaHasBeenSet() const { return m_filterCriteriaHasBeenSet; }
154 template <typename FilterCriteriaT = FilterCriteria>
155 void SetFilterCriteria(FilterCriteriaT&& value) {
156 m_filterCriteriaHasBeenSet = true;
157 m_filterCriteria = std::forward<FilterCriteriaT>(value);
158 }
159 template <typename FilterCriteriaT = FilterCriteria>
161 SetFilterCriteria(std::forward<FilterCriteriaT>(value));
162 return *this;
163 }
165
167
174 inline const Aws::String& GetKMSKeyArn() const { return m_kMSKeyArn; }
175 inline bool KMSKeyArnHasBeenSet() const { return m_kMSKeyArnHasBeenSet; }
176 template <typename KMSKeyArnT = Aws::String>
177 void SetKMSKeyArn(KMSKeyArnT&& value) {
178 m_kMSKeyArnHasBeenSet = true;
179 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
180 }
181 template <typename KMSKeyArnT = Aws::String>
183 SetKMSKeyArn(std::forward<KMSKeyArnT>(value));
184 return *this;
185 }
187
189
194 inline const EventSourceMappingMetricsConfig& GetMetricsConfig() const { return m_metricsConfig; }
195 inline bool MetricsConfigHasBeenSet() const { return m_metricsConfigHasBeenSet; }
196 template <typename MetricsConfigT = EventSourceMappingMetricsConfig>
197 void SetMetricsConfig(MetricsConfigT&& value) {
198 m_metricsConfigHasBeenSet = true;
199 m_metricsConfig = std::forward<MetricsConfigT>(value);
200 }
201 template <typename MetricsConfigT = EventSourceMappingMetricsConfig>
203 SetMetricsConfig(std::forward<MetricsConfigT>(value));
204 return *this;
205 }
207
209
215 inline const EventSourceMappingLoggingConfig& GetLoggingConfig() const { return m_loggingConfig; }
216 inline bool LoggingConfigHasBeenSet() const { return m_loggingConfigHasBeenSet; }
217 template <typename LoggingConfigT = EventSourceMappingLoggingConfig>
218 void SetLoggingConfig(LoggingConfigT&& value) {
219 m_loggingConfigHasBeenSet = true;
220 m_loggingConfig = std::forward<LoggingConfigT>(value);
221 }
222 template <typename LoggingConfigT = EventSourceMappingLoggingConfig>
224 SetLoggingConfig(std::forward<LoggingConfigT>(value));
225 return *this;
226 }
228
230
236 inline const ScalingConfig& GetScalingConfig() const { return m_scalingConfig; }
237 inline bool ScalingConfigHasBeenSet() const { return m_scalingConfigHasBeenSet; }
238 template <typename ScalingConfigT = ScalingConfig>
239 void SetScalingConfig(ScalingConfigT&& value) {
240 m_scalingConfigHasBeenSet = true;
241 m_scalingConfig = std::forward<ScalingConfigT>(value);
242 }
243 template <typename ScalingConfigT = ScalingConfig>
245 SetScalingConfig(std::forward<ScalingConfigT>(value));
246 return *this;
247 }
249
251
266 inline int GetMaximumBatchingWindowInSeconds() const { return m_maximumBatchingWindowInSeconds; }
267 inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
268 inline void SetMaximumBatchingWindowInSeconds(int value) {
269 m_maximumBatchingWindowInSecondsHasBeenSet = true;
270 m_maximumBatchingWindowInSeconds = value;
271 }
274 return *this;
275 }
277
279
283 inline int GetParallelizationFactor() const { return m_parallelizationFactor; }
284 inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
285 inline void SetParallelizationFactor(int value) {
286 m_parallelizationFactorHasBeenSet = true;
287 m_parallelizationFactor = value;
288 }
291 return *this;
292 }
294
296
302 inline EventSourcePosition GetStartingPosition() const { return m_startingPosition; }
303 inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
305 m_startingPositionHasBeenSet = true;
306 m_startingPosition = value;
307 }
309 SetStartingPosition(value);
310 return *this;
311 }
313
315
320 inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const { return m_startingPositionTimestamp; }
321 inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
322 template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
323 void SetStartingPositionTimestamp(StartingPositionTimestampT&& value) {
324 m_startingPositionTimestampHasBeenSet = true;
325 m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
326 }
327 template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
329 SetStartingPositionTimestamp(std::forward<StartingPositionTimestampT>(value));
330 return *this;
331 }
333
335
340 inline const DestinationConfig& GetDestinationConfig() const { return m_destinationConfig; }
341 inline bool DestinationConfigHasBeenSet() const { return m_destinationConfigHasBeenSet; }
342 template <typename DestinationConfigT = DestinationConfig>
343 void SetDestinationConfig(DestinationConfigT&& value) {
344 m_destinationConfigHasBeenSet = true;
345 m_destinationConfig = std::forward<DestinationConfigT>(value);
346 }
347 template <typename DestinationConfigT = DestinationConfig>
349 SetDestinationConfig(std::forward<DestinationConfigT>(value));
350 return *this;
351 }
353
355
360 inline int GetMaximumRecordAgeInSeconds() const { return m_maximumRecordAgeInSeconds; }
361 inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
362 inline void SetMaximumRecordAgeInSeconds(int value) {
363 m_maximumRecordAgeInSecondsHasBeenSet = true;
364 m_maximumRecordAgeInSeconds = value;
365 }
368 return *this;
369 }
371
373
377 inline bool GetBisectBatchOnFunctionError() const { return m_bisectBatchOnFunctionError; }
378 inline bool BisectBatchOnFunctionErrorHasBeenSet() const { return m_bisectBatchOnFunctionErrorHasBeenSet; }
379 inline void SetBisectBatchOnFunctionError(bool value) {
380 m_bisectBatchOnFunctionErrorHasBeenSet = true;
381 m_bisectBatchOnFunctionError = value;
382 }
385 return *this;
386 }
388
390
396 inline int GetMaximumRetryAttempts() const { return m_maximumRetryAttempts; }
397 inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
398 inline void SetMaximumRetryAttempts(int value) {
399 m_maximumRetryAttemptsHasBeenSet = true;
400 m_maximumRetryAttempts = value;
401 }
404 return *this;
405 }
407
409
412 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const { return m_tags; }
413 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
414 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
415 void SetTags(TagsT&& value) {
416 m_tagsHasBeenSet = true;
417 m_tags = std::forward<TagsT>(value);
418 }
419 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
421 SetTags(std::forward<TagsT>(value));
422 return *this;
423 }
424 template <typename TagsKeyT = Aws::String, typename TagsValueT = Aws::String>
425 CreateEventSourceMappingRequest& AddTags(TagsKeyT&& key, TagsValueT&& value) {
426 m_tagsHasBeenSet = true;
427 m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value));
428 return *this;
429 }
431
433
438 inline int GetTumblingWindowInSeconds() const { return m_tumblingWindowInSeconds; }
439 inline bool TumblingWindowInSecondsHasBeenSet() const { return m_tumblingWindowInSecondsHasBeenSet; }
440 inline void SetTumblingWindowInSeconds(int value) {
441 m_tumblingWindowInSecondsHasBeenSet = true;
442 m_tumblingWindowInSeconds = value;
443 }
446 return *this;
447 }
449
451
454 inline const Aws::Vector<Aws::String>& GetTopics() const { return m_topics; }
455 inline bool TopicsHasBeenSet() const { return m_topicsHasBeenSet; }
456 template <typename TopicsT = Aws::Vector<Aws::String>>
457 void SetTopics(TopicsT&& value) {
458 m_topicsHasBeenSet = true;
459 m_topics = std::forward<TopicsT>(value);
460 }
461 template <typename TopicsT = Aws::Vector<Aws::String>>
463 SetTopics(std::forward<TopicsT>(value));
464 return *this;
465 }
466 template <typename TopicsT = Aws::String>
468 m_topicsHasBeenSet = true;
469 m_topics.emplace_back(std::forward<TopicsT>(value));
470 return *this;
471 }
473
475
478 inline const Aws::Vector<Aws::String>& GetQueues() const { return m_queues; }
479 inline bool QueuesHasBeenSet() const { return m_queuesHasBeenSet; }
480 template <typename QueuesT = Aws::Vector<Aws::String>>
481 void SetQueues(QueuesT&& value) {
482 m_queuesHasBeenSet = true;
483 m_queues = std::forward<QueuesT>(value);
484 }
485 template <typename QueuesT = Aws::Vector<Aws::String>>
487 SetQueues(std::forward<QueuesT>(value));
488 return *this;
489 }
490 template <typename QueuesT = Aws::String>
492 m_queuesHasBeenSet = true;
493 m_queues.emplace_back(std::forward<QueuesT>(value));
494 return *this;
495 }
497
499
503 inline const Aws::Vector<SourceAccessConfiguration>& GetSourceAccessConfigurations() const { return m_sourceAccessConfigurations; }
504 inline bool SourceAccessConfigurationsHasBeenSet() const { return m_sourceAccessConfigurationsHasBeenSet; }
505 template <typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
506 void SetSourceAccessConfigurations(SourceAccessConfigurationsT&& value) {
507 m_sourceAccessConfigurationsHasBeenSet = true;
508 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
509 }
510 template <typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
512 SetSourceAccessConfigurations(std::forward<SourceAccessConfigurationsT>(value));
513 return *this;
514 }
515 template <typename SourceAccessConfigurationsT = SourceAccessConfiguration>
517 m_sourceAccessConfigurationsHasBeenSet = true;
518 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
519 return *this;
520 }
522
524
527 inline const SelfManagedEventSource& GetSelfManagedEventSource() const { return m_selfManagedEventSource; }
528 inline bool SelfManagedEventSourceHasBeenSet() const { return m_selfManagedEventSourceHasBeenSet; }
529 template <typename SelfManagedEventSourceT = SelfManagedEventSource>
530 void SetSelfManagedEventSource(SelfManagedEventSourceT&& value) {
531 m_selfManagedEventSourceHasBeenSet = true;
532 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
533 }
534 template <typename SelfManagedEventSourceT = SelfManagedEventSource>
536 SetSelfManagedEventSource(std::forward<SelfManagedEventSourceT>(value));
537 return *this;
538 }
540
542
547 inline const Aws::Vector<FunctionResponseType>& GetFunctionResponseTypes() const { return m_functionResponseTypes; }
548 inline bool FunctionResponseTypesHasBeenSet() const { return m_functionResponseTypesHasBeenSet; }
549 template <typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
550 void SetFunctionResponseTypes(FunctionResponseTypesT&& value) {
551 m_functionResponseTypesHasBeenSet = true;
552 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
553 }
554 template <typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
556 SetFunctionResponseTypes(std::forward<FunctionResponseTypesT>(value));
557 return *this;
558 }
560 m_functionResponseTypesHasBeenSet = true;
561 m_functionResponseTypes.push_back(value);
562 return *this;
563 }
565
567
572 return m_amazonManagedKafkaEventSourceConfig;
573 }
574 inline bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const { return m_amazonManagedKafkaEventSourceConfigHasBeenSet; }
575 template <typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
576 void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) {
577 m_amazonManagedKafkaEventSourceConfigHasBeenSet = true;
578 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
579 }
580 template <typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
581 CreateEventSourceMappingRequest& WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) {
582 SetAmazonManagedKafkaEventSourceConfig(std::forward<AmazonManagedKafkaEventSourceConfigT>(value));
583 return *this;
584 }
586
588
593 return m_selfManagedKafkaEventSourceConfig;
594 }
595 inline bool SelfManagedKafkaEventSourceConfigHasBeenSet() const { return m_selfManagedKafkaEventSourceConfigHasBeenSet; }
596 template <typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
597 void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) {
598 m_selfManagedKafkaEventSourceConfigHasBeenSet = true;
599 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
600 }
601 template <typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
602 CreateEventSourceMappingRequest& WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) {
603 SetSelfManagedKafkaEventSourceConfig(std::forward<SelfManagedKafkaEventSourceConfigT>(value));
604 return *this;
605 }
607
609
612 inline const DocumentDBEventSourceConfig& GetDocumentDBEventSourceConfig() const { return m_documentDBEventSourceConfig; }
613 inline bool DocumentDBEventSourceConfigHasBeenSet() const { return m_documentDBEventSourceConfigHasBeenSet; }
614 template <typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
615 void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT&& value) {
616 m_documentDBEventSourceConfigHasBeenSet = true;
617 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
618 }
619 template <typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
621 SetDocumentDBEventSourceConfig(std::forward<DocumentDBEventSourceConfigT>(value));
622 return *this;
623 }
625
627
633 inline const ProvisionedPollerConfig& GetProvisionedPollerConfig() const { return m_provisionedPollerConfig; }
634 inline bool ProvisionedPollerConfigHasBeenSet() const { return m_provisionedPollerConfigHasBeenSet; }
635 template <typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
636 void SetProvisionedPollerConfig(ProvisionedPollerConfigT&& value) {
637 m_provisionedPollerConfigHasBeenSet = true;
638 m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value);
639 }
640 template <typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
642 SetProvisionedPollerConfig(std::forward<ProvisionedPollerConfigT>(value));
643 return *this;
644 }
646 private:
647 Aws::String m_eventSourceArn;
648
649 Aws::String m_functionName;
650
651 bool m_enabled{false};
652
653 int m_batchSize{0};
654
655 FilterCriteria m_filterCriteria;
656
657 Aws::String m_kMSKeyArn;
658
659 EventSourceMappingMetricsConfig m_metricsConfig;
660
661 EventSourceMappingLoggingConfig m_loggingConfig;
662
663 ScalingConfig m_scalingConfig;
664
665 int m_maximumBatchingWindowInSeconds{0};
666
667 int m_parallelizationFactor{0};
668
670
671 Aws::Utils::DateTime m_startingPositionTimestamp{};
672
673 DestinationConfig m_destinationConfig;
674
675 int m_maximumRecordAgeInSeconds{0};
676
677 bool m_bisectBatchOnFunctionError{false};
678
679 int m_maximumRetryAttempts{0};
680
682
683 int m_tumblingWindowInSeconds{0};
684
686
688
689 Aws::Vector<SourceAccessConfiguration> m_sourceAccessConfigurations;
690
691 SelfManagedEventSource m_selfManagedEventSource;
692
693 Aws::Vector<FunctionResponseType> m_functionResponseTypes;
694
695 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
696
697 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
698
699 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
700
701 ProvisionedPollerConfig m_provisionedPollerConfig;
702 bool m_eventSourceArnHasBeenSet = false;
703 bool m_functionNameHasBeenSet = false;
704 bool m_enabledHasBeenSet = false;
705 bool m_batchSizeHasBeenSet = false;
706 bool m_filterCriteriaHasBeenSet = false;
707 bool m_kMSKeyArnHasBeenSet = false;
708 bool m_metricsConfigHasBeenSet = false;
709 bool m_loggingConfigHasBeenSet = false;
710 bool m_scalingConfigHasBeenSet = false;
711 bool m_maximumBatchingWindowInSecondsHasBeenSet = false;
712 bool m_parallelizationFactorHasBeenSet = false;
713 bool m_startingPositionHasBeenSet = false;
714 bool m_startingPositionTimestampHasBeenSet = false;
715 bool m_destinationConfigHasBeenSet = false;
716 bool m_maximumRecordAgeInSecondsHasBeenSet = false;
717 bool m_bisectBatchOnFunctionErrorHasBeenSet = false;
718 bool m_maximumRetryAttemptsHasBeenSet = false;
719 bool m_tagsHasBeenSet = false;
720 bool m_tumblingWindowInSecondsHasBeenSet = false;
721 bool m_topicsHasBeenSet = false;
722 bool m_queuesHasBeenSet = false;
723 bool m_sourceAccessConfigurationsHasBeenSet = false;
724 bool m_selfManagedEventSourceHasBeenSet = false;
725 bool m_functionResponseTypesHasBeenSet = false;
726 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet = false;
727 bool m_selfManagedKafkaEventSourceConfigHasBeenSet = false;
728 bool m_documentDBEventSourceConfigHasBeenSet = false;
729 bool m_provisionedPollerConfigHasBeenSet = false;
730};
731
732} // namespace Model
733} // namespace Lambda
734} // namespace Aws
CreateEventSourceMappingRequest & WithMetricsConfig(MetricsConfigT &&value)
CreateEventSourceMappingRequest & WithTumblingWindowInSeconds(int value)
CreateEventSourceMappingRequest & WithKMSKeyArn(KMSKeyArnT &&value)
CreateEventSourceMappingRequest & WithBatchSize(int value)
CreateEventSourceMappingRequest & WithEventSourceArn(EventSourceArnT &&value)
CreateEventSourceMappingRequest & AddFunctionResponseTypes(FunctionResponseType value)
CreateEventSourceMappingRequest & WithDestinationConfig(DestinationConfigT &&value)
CreateEventSourceMappingRequest & AddTags(TagsKeyT &&key, TagsValueT &&value)
CreateEventSourceMappingRequest & WithBisectBatchOnFunctionError(bool value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
CreateEventSourceMappingRequest & WithTags(TagsT &&value)
CreateEventSourceMappingRequest & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
CreateEventSourceMappingRequest & WithFilterCriteria(FilterCriteriaT &&value)
CreateEventSourceMappingRequest & WithQueues(QueuesT &&value)
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
CreateEventSourceMappingRequest & WithMaximumRecordAgeInSeconds(int value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
const Aws::Map< Aws::String, Aws::String > & GetTags() const
const EventSourceMappingLoggingConfig & GetLoggingConfig() const
AWS_LAMBDA_API CreateEventSourceMappingRequest()=default
CreateEventSourceMappingRequest & WithFunctionName(FunctionNameT &&value)
CreateEventSourceMappingRequest & AddQueues(QueuesT &&value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
void SetSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
CreateEventSourceMappingRequest & WithMaximumBatchingWindowInSeconds(int value)
CreateEventSourceMappingRequest & WithParallelizationFactor(int value)
CreateEventSourceMappingRequest & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
CreateEventSourceMappingRequest & WithStartingPosition(EventSourcePosition value)
CreateEventSourceMappingRequest & WithSelfManagedEventSource(SelfManagedEventSourceT &&value)
CreateEventSourceMappingRequest & WithScalingConfig(ScalingConfigT &&value)
CreateEventSourceMappingRequest & AddTopics(TopicsT &&value)
CreateEventSourceMappingRequest & AddSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
AWS_LAMBDA_API Aws::String SerializePayload() const override
CreateEventSourceMappingRequest & WithTopics(TopicsT &&value)
CreateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
const EventSourceMappingMetricsConfig & GetMetricsConfig() const
CreateEventSourceMappingRequest & WithMaximumRetryAttempts(int value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
CreateEventSourceMappingRequest & WithLoggingConfig(LoggingConfigT &&value)
CreateEventSourceMappingRequest & WithStartingPositionTimestamp(StartingPositionTimestampT &&value)
CreateEventSourceMappingRequest & WithFunctionResponseTypes(FunctionResponseTypesT &&value)
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
CreateEventSourceMappingRequest & WithProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
void SetStartingPositionTimestamp(StartingPositionTimestampT &&value)
CreateEventSourceMappingRequest & WithEnabled(bool value)
CreateEventSourceMappingRequest & WithSourceAccessConfigurations(SourceAccessConfigurationsT &&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