AWS SDK for C++

AWS SDK for C++ Version 1.11.743

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
182 inline int GetMaximumBatchingWindowInSeconds() const { return m_maximumBatchingWindowInSeconds; }
183 inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
184 inline void SetMaximumBatchingWindowInSeconds(int value) {
185 m_maximumBatchingWindowInSecondsHasBeenSet = true;
186 m_maximumBatchingWindowInSeconds = value;
187 }
190 return *this;
191 }
193
195
199 inline int GetParallelizationFactor() const { return m_parallelizationFactor; }
200 inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
201 inline void SetParallelizationFactor(int value) {
202 m_parallelizationFactorHasBeenSet = true;
203 m_parallelizationFactor = value;
204 }
207 return *this;
208 }
210
212
218 inline EventSourcePosition GetStartingPosition() const { return m_startingPosition; }
219 inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
221 m_startingPositionHasBeenSet = true;
222 m_startingPosition = value;
223 }
225 SetStartingPosition(value);
226 return *this;
227 }
229
231
236 inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const { return m_startingPositionTimestamp; }
237 inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
238 template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
239 void SetStartingPositionTimestamp(StartingPositionTimestampT&& value) {
240 m_startingPositionTimestampHasBeenSet = true;
241 m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
242 }
243 template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
245 SetStartingPositionTimestamp(std::forward<StartingPositionTimestampT>(value));
246 return *this;
247 }
249
251
256 inline const DestinationConfig& GetDestinationConfig() const { return m_destinationConfig; }
257 inline bool DestinationConfigHasBeenSet() const { return m_destinationConfigHasBeenSet; }
258 template <typename DestinationConfigT = DestinationConfig>
259 void SetDestinationConfig(DestinationConfigT&& value) {
260 m_destinationConfigHasBeenSet = true;
261 m_destinationConfig = std::forward<DestinationConfigT>(value);
262 }
263 template <typename DestinationConfigT = DestinationConfig>
265 SetDestinationConfig(std::forward<DestinationConfigT>(value));
266 return *this;
267 }
269
271
276 inline int GetMaximumRecordAgeInSeconds() const { return m_maximumRecordAgeInSeconds; }
277 inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
278 inline void SetMaximumRecordAgeInSeconds(int value) {
279 m_maximumRecordAgeInSecondsHasBeenSet = true;
280 m_maximumRecordAgeInSeconds = value;
281 }
284 return *this;
285 }
287
289
293 inline bool GetBisectBatchOnFunctionError() const { return m_bisectBatchOnFunctionError; }
294 inline bool BisectBatchOnFunctionErrorHasBeenSet() const { return m_bisectBatchOnFunctionErrorHasBeenSet; }
295 inline void SetBisectBatchOnFunctionError(bool value) {
296 m_bisectBatchOnFunctionErrorHasBeenSet = true;
297 m_bisectBatchOnFunctionError = value;
298 }
301 return *this;
302 }
304
306
312 inline int GetMaximumRetryAttempts() const { return m_maximumRetryAttempts; }
313 inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
314 inline void SetMaximumRetryAttempts(int value) {
315 m_maximumRetryAttemptsHasBeenSet = true;
316 m_maximumRetryAttempts = value;
317 }
320 return *this;
321 }
323
325
328 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const { return m_tags; }
329 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
330 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
331 void SetTags(TagsT&& value) {
332 m_tagsHasBeenSet = true;
333 m_tags = std::forward<TagsT>(value);
334 }
335 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
337 SetTags(std::forward<TagsT>(value));
338 return *this;
339 }
340 template <typename TagsKeyT = Aws::String, typename TagsValueT = Aws::String>
341 CreateEventSourceMappingRequest& AddTags(TagsKeyT&& key, TagsValueT&& value) {
342 m_tagsHasBeenSet = true;
343 m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value));
344 return *this;
345 }
347
349
354 inline int GetTumblingWindowInSeconds() const { return m_tumblingWindowInSeconds; }
355 inline bool TumblingWindowInSecondsHasBeenSet() const { return m_tumblingWindowInSecondsHasBeenSet; }
356 inline void SetTumblingWindowInSeconds(int value) {
357 m_tumblingWindowInSecondsHasBeenSet = true;
358 m_tumblingWindowInSeconds = value;
359 }
362 return *this;
363 }
365
367
370 inline const Aws::Vector<Aws::String>& GetTopics() const { return m_topics; }
371 inline bool TopicsHasBeenSet() const { return m_topicsHasBeenSet; }
372 template <typename TopicsT = Aws::Vector<Aws::String>>
373 void SetTopics(TopicsT&& value) {
374 m_topicsHasBeenSet = true;
375 m_topics = std::forward<TopicsT>(value);
376 }
377 template <typename TopicsT = Aws::Vector<Aws::String>>
379 SetTopics(std::forward<TopicsT>(value));
380 return *this;
381 }
382 template <typename TopicsT = Aws::String>
384 m_topicsHasBeenSet = true;
385 m_topics.emplace_back(std::forward<TopicsT>(value));
386 return *this;
387 }
389
391
394 inline const Aws::Vector<Aws::String>& GetQueues() const { return m_queues; }
395 inline bool QueuesHasBeenSet() const { return m_queuesHasBeenSet; }
396 template <typename QueuesT = Aws::Vector<Aws::String>>
397 void SetQueues(QueuesT&& value) {
398 m_queuesHasBeenSet = true;
399 m_queues = std::forward<QueuesT>(value);
400 }
401 template <typename QueuesT = Aws::Vector<Aws::String>>
403 SetQueues(std::forward<QueuesT>(value));
404 return *this;
405 }
406 template <typename QueuesT = Aws::String>
408 m_queuesHasBeenSet = true;
409 m_queues.emplace_back(std::forward<QueuesT>(value));
410 return *this;
411 }
413
415
419 inline const Aws::Vector<SourceAccessConfiguration>& GetSourceAccessConfigurations() const { return m_sourceAccessConfigurations; }
420 inline bool SourceAccessConfigurationsHasBeenSet() const { return m_sourceAccessConfigurationsHasBeenSet; }
421 template <typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
422 void SetSourceAccessConfigurations(SourceAccessConfigurationsT&& value) {
423 m_sourceAccessConfigurationsHasBeenSet = true;
424 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
425 }
426 template <typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
428 SetSourceAccessConfigurations(std::forward<SourceAccessConfigurationsT>(value));
429 return *this;
430 }
431 template <typename SourceAccessConfigurationsT = SourceAccessConfiguration>
433 m_sourceAccessConfigurationsHasBeenSet = true;
434 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
435 return *this;
436 }
438
440
443 inline const SelfManagedEventSource& GetSelfManagedEventSource() const { return m_selfManagedEventSource; }
444 inline bool SelfManagedEventSourceHasBeenSet() const { return m_selfManagedEventSourceHasBeenSet; }
445 template <typename SelfManagedEventSourceT = SelfManagedEventSource>
446 void SetSelfManagedEventSource(SelfManagedEventSourceT&& value) {
447 m_selfManagedEventSourceHasBeenSet = true;
448 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
449 }
450 template <typename SelfManagedEventSourceT = SelfManagedEventSource>
452 SetSelfManagedEventSource(std::forward<SelfManagedEventSourceT>(value));
453 return *this;
454 }
456
458
463 inline const Aws::Vector<FunctionResponseType>& GetFunctionResponseTypes() const { return m_functionResponseTypes; }
464 inline bool FunctionResponseTypesHasBeenSet() const { return m_functionResponseTypesHasBeenSet; }
465 template <typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
466 void SetFunctionResponseTypes(FunctionResponseTypesT&& value) {
467 m_functionResponseTypesHasBeenSet = true;
468 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
469 }
470 template <typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
472 SetFunctionResponseTypes(std::forward<FunctionResponseTypesT>(value));
473 return *this;
474 }
476 m_functionResponseTypesHasBeenSet = true;
477 m_functionResponseTypes.push_back(value);
478 return *this;
479 }
481
483
488 return m_amazonManagedKafkaEventSourceConfig;
489 }
490 inline bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const { return m_amazonManagedKafkaEventSourceConfigHasBeenSet; }
491 template <typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
492 void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) {
493 m_amazonManagedKafkaEventSourceConfigHasBeenSet = true;
494 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
495 }
496 template <typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
497 CreateEventSourceMappingRequest& WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) {
498 SetAmazonManagedKafkaEventSourceConfig(std::forward<AmazonManagedKafkaEventSourceConfigT>(value));
499 return *this;
500 }
502
504
509 return m_selfManagedKafkaEventSourceConfig;
510 }
511 inline bool SelfManagedKafkaEventSourceConfigHasBeenSet() const { return m_selfManagedKafkaEventSourceConfigHasBeenSet; }
512 template <typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
513 void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) {
514 m_selfManagedKafkaEventSourceConfigHasBeenSet = true;
515 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
516 }
517 template <typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
518 CreateEventSourceMappingRequest& WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) {
519 SetSelfManagedKafkaEventSourceConfig(std::forward<SelfManagedKafkaEventSourceConfigT>(value));
520 return *this;
521 }
523
525
531 inline const ScalingConfig& GetScalingConfig() const { return m_scalingConfig; }
532 inline bool ScalingConfigHasBeenSet() const { return m_scalingConfigHasBeenSet; }
533 template <typename ScalingConfigT = ScalingConfig>
534 void SetScalingConfig(ScalingConfigT&& value) {
535 m_scalingConfigHasBeenSet = true;
536 m_scalingConfig = std::forward<ScalingConfigT>(value);
537 }
538 template <typename ScalingConfigT = ScalingConfig>
540 SetScalingConfig(std::forward<ScalingConfigT>(value));
541 return *this;
542 }
544
546
549 inline const DocumentDBEventSourceConfig& GetDocumentDBEventSourceConfig() const { return m_documentDBEventSourceConfig; }
550 inline bool DocumentDBEventSourceConfigHasBeenSet() const { return m_documentDBEventSourceConfigHasBeenSet; }
551 template <typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
552 void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT&& value) {
553 m_documentDBEventSourceConfigHasBeenSet = true;
554 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
555 }
556 template <typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
558 SetDocumentDBEventSourceConfig(std::forward<DocumentDBEventSourceConfigT>(value));
559 return *this;
560 }
562
564
571 inline const Aws::String& GetKMSKeyArn() const { return m_kMSKeyArn; }
572 inline bool KMSKeyArnHasBeenSet() const { return m_kMSKeyArnHasBeenSet; }
573 template <typename KMSKeyArnT = Aws::String>
574 void SetKMSKeyArn(KMSKeyArnT&& value) {
575 m_kMSKeyArnHasBeenSet = true;
576 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
577 }
578 template <typename KMSKeyArnT = Aws::String>
580 SetKMSKeyArn(std::forward<KMSKeyArnT>(value));
581 return *this;
582 }
584
586
591 inline const EventSourceMappingMetricsConfig& GetMetricsConfig() const { return m_metricsConfig; }
592 inline bool MetricsConfigHasBeenSet() const { return m_metricsConfigHasBeenSet; }
593 template <typename MetricsConfigT = EventSourceMappingMetricsConfig>
594 void SetMetricsConfig(MetricsConfigT&& value) {
595 m_metricsConfigHasBeenSet = true;
596 m_metricsConfig = std::forward<MetricsConfigT>(value);
597 }
598 template <typename MetricsConfigT = EventSourceMappingMetricsConfig>
600 SetMetricsConfig(std::forward<MetricsConfigT>(value));
601 return *this;
602 }
604
606
612 inline const EventSourceMappingLoggingConfig& GetLoggingConfig() const { return m_loggingConfig; }
613 inline bool LoggingConfigHasBeenSet() const { return m_loggingConfigHasBeenSet; }
614 template <typename LoggingConfigT = EventSourceMappingLoggingConfig>
615 void SetLoggingConfig(LoggingConfigT&& value) {
616 m_loggingConfigHasBeenSet = true;
617 m_loggingConfig = std::forward<LoggingConfigT>(value);
618 }
619 template <typename LoggingConfigT = EventSourceMappingLoggingConfig>
621 SetLoggingConfig(std::forward<LoggingConfigT>(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 int m_maximumBatchingWindowInSeconds{0};
658
659 int m_parallelizationFactor{0};
660
662
663 Aws::Utils::DateTime m_startingPositionTimestamp{};
664
665 DestinationConfig m_destinationConfig;
666
667 int m_maximumRecordAgeInSeconds{0};
668
669 bool m_bisectBatchOnFunctionError{false};
670
671 int m_maximumRetryAttempts{0};
672
674
675 int m_tumblingWindowInSeconds{0};
676
678
680
681 Aws::Vector<SourceAccessConfiguration> m_sourceAccessConfigurations;
682
683 SelfManagedEventSource m_selfManagedEventSource;
684
685 Aws::Vector<FunctionResponseType> m_functionResponseTypes;
686
687 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
688
689 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
690
691 ScalingConfig m_scalingConfig;
692
693 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
694
695 Aws::String m_kMSKeyArn;
696
697 EventSourceMappingMetricsConfig m_metricsConfig;
698
699 EventSourceMappingLoggingConfig m_loggingConfig;
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_maximumBatchingWindowInSecondsHasBeenSet = false;
708 bool m_parallelizationFactorHasBeenSet = false;
709 bool m_startingPositionHasBeenSet = false;
710 bool m_startingPositionTimestampHasBeenSet = false;
711 bool m_destinationConfigHasBeenSet = false;
712 bool m_maximumRecordAgeInSecondsHasBeenSet = false;
713 bool m_bisectBatchOnFunctionErrorHasBeenSet = false;
714 bool m_maximumRetryAttemptsHasBeenSet = false;
715 bool m_tagsHasBeenSet = false;
716 bool m_tumblingWindowInSecondsHasBeenSet = false;
717 bool m_topicsHasBeenSet = false;
718 bool m_queuesHasBeenSet = false;
719 bool m_sourceAccessConfigurationsHasBeenSet = false;
720 bool m_selfManagedEventSourceHasBeenSet = false;
721 bool m_functionResponseTypesHasBeenSet = false;
722 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet = false;
723 bool m_selfManagedKafkaEventSourceConfigHasBeenSet = false;
724 bool m_scalingConfigHasBeenSet = false;
725 bool m_documentDBEventSourceConfigHasBeenSet = false;
726 bool m_kMSKeyArnHasBeenSet = false;
727 bool m_metricsConfigHasBeenSet = false;
728 bool m_loggingConfigHasBeenSet = 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