AWS SDK for C++

AWS SDK for C++ Version 1.11.606

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/EventSourceMappingMetricsConfig.h>
22#include <aws/lambda/model/ProvisionedPollerConfig.h>
23#include <aws/lambda/model/SourceAccessConfiguration.h>
24#include <aws/lambda/model/FunctionResponseType.h>
25#include <utility>
26
27namespace Aws
28{
29namespace Lambda
30{
31namespace Model
32{
33
37 {
38 public:
39 AWS_LAMBDA_API CreateEventSourceMappingRequest() = default;
40
41 // Service request name is the Operation name which will send this request out,
42 // each operation should has unique request name, so that we can get operation's name from this request.
43 // Note: this is not true for response, multiple operations may have the same response name,
44 // so we can not get operation's name from response.
45 inline virtual const char* GetServiceRequestName() const override { return "CreateEventSourceMapping"; }
46
47 AWS_LAMBDA_API Aws::String SerializePayload() const override;
48
49
51
63 inline const Aws::String& GetEventSourceArn() const { return m_eventSourceArn; }
64 inline bool EventSourceArnHasBeenSet() const { return m_eventSourceArnHasBeenSet; }
65 template<typename EventSourceArnT = Aws::String>
66 void SetEventSourceArn(EventSourceArnT&& value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn = std::forward<EventSourceArnT>(value); }
67 template<typename EventSourceArnT = Aws::String>
68 CreateEventSourceMappingRequest& WithEventSourceArn(EventSourceArnT&& value) { SetEventSourceArn(std::forward<EventSourceArnT>(value)); return *this;}
70
72
84 inline const Aws::String& GetFunctionName() const { return m_functionName; }
85 inline bool FunctionNameHasBeenSet() const { return m_functionNameHasBeenSet; }
86 template<typename FunctionNameT = Aws::String>
87 void SetFunctionName(FunctionNameT&& value) { m_functionNameHasBeenSet = true; m_functionName = std::forward<FunctionNameT>(value); }
88 template<typename FunctionNameT = Aws::String>
89 CreateEventSourceMappingRequest& WithFunctionName(FunctionNameT&& value) { SetFunctionName(std::forward<FunctionNameT>(value)); return *this;}
91
93
97 inline bool GetEnabled() const { return m_enabled; }
98 inline bool EnabledHasBeenSet() const { return m_enabledHasBeenSet; }
99 inline void SetEnabled(bool value) { m_enabledHasBeenSet = true; m_enabled = value; }
100 inline CreateEventSourceMappingRequest& WithEnabled(bool value) { SetEnabled(value); return *this;}
102
104
118 inline int GetBatchSize() const { return m_batchSize; }
119 inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; }
120 inline void SetBatchSize(int value) { m_batchSizeHasBeenSet = true; m_batchSize = value; }
121 inline CreateEventSourceMappingRequest& WithBatchSize(int value) { SetBatchSize(value); return *this;}
123
125
131 inline const FilterCriteria& GetFilterCriteria() const { return m_filterCriteria; }
132 inline bool FilterCriteriaHasBeenSet() const { return m_filterCriteriaHasBeenSet; }
133 template<typename FilterCriteriaT = FilterCriteria>
134 void SetFilterCriteria(FilterCriteriaT&& value) { m_filterCriteriaHasBeenSet = true; m_filterCriteria = std::forward<FilterCriteriaT>(value); }
135 template<typename FilterCriteriaT = FilterCriteria>
136 CreateEventSourceMappingRequest& WithFilterCriteria(FilterCriteriaT&& value) { SetFilterCriteria(std::forward<FilterCriteriaT>(value)); return *this;}
138
140
155 inline int GetMaximumBatchingWindowInSeconds() const { return m_maximumBatchingWindowInSeconds; }
156 inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
157 inline void SetMaximumBatchingWindowInSeconds(int value) { m_maximumBatchingWindowInSecondsHasBeenSet = true; m_maximumBatchingWindowInSeconds = value; }
160
162
166 inline int GetParallelizationFactor() const { return m_parallelizationFactor; }
167 inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
168 inline void SetParallelizationFactor(int value) { m_parallelizationFactorHasBeenSet = true; m_parallelizationFactor = value; }
171
173
179 inline EventSourcePosition GetStartingPosition() const { return m_startingPosition; }
180 inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
181 inline void SetStartingPosition(EventSourcePosition value) { m_startingPositionHasBeenSet = true; m_startingPosition = value; }
184
186
191 inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const { return m_startingPositionTimestamp; }
192 inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
193 template<typename StartingPositionTimestampT = Aws::Utils::DateTime>
194 void SetStartingPositionTimestamp(StartingPositionTimestampT&& value) { m_startingPositionTimestampHasBeenSet = true; m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value); }
195 template<typename StartingPositionTimestampT = Aws::Utils::DateTime>
196 CreateEventSourceMappingRequest& WithStartingPositionTimestamp(StartingPositionTimestampT&& value) { SetStartingPositionTimestamp(std::forward<StartingPositionTimestampT>(value)); return *this;}
198
200
205 inline const DestinationConfig& GetDestinationConfig() const { return m_destinationConfig; }
206 inline bool DestinationConfigHasBeenSet() const { return m_destinationConfigHasBeenSet; }
207 template<typename DestinationConfigT = DestinationConfig>
208 void SetDestinationConfig(DestinationConfigT&& value) { m_destinationConfigHasBeenSet = true; m_destinationConfig = std::forward<DestinationConfigT>(value); }
209 template<typename DestinationConfigT = DestinationConfig>
210 CreateEventSourceMappingRequest& WithDestinationConfig(DestinationConfigT&& value) { SetDestinationConfig(std::forward<DestinationConfigT>(value)); return *this;}
212
214
218 inline int GetMaximumRecordAgeInSeconds() const { return m_maximumRecordAgeInSeconds; }
219 inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
220 inline void SetMaximumRecordAgeInSeconds(int value) { m_maximumRecordAgeInSecondsHasBeenSet = true; m_maximumRecordAgeInSeconds = value; }
223
225
229 inline bool GetBisectBatchOnFunctionError() const { return m_bisectBatchOnFunctionError; }
230 inline bool BisectBatchOnFunctionErrorHasBeenSet() const { return m_bisectBatchOnFunctionErrorHasBeenSet; }
231 inline void SetBisectBatchOnFunctionError(bool value) { m_bisectBatchOnFunctionErrorHasBeenSet = true; m_bisectBatchOnFunctionError = value; }
234
236
241 inline int GetMaximumRetryAttempts() const { return m_maximumRetryAttempts; }
242 inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
243 inline void SetMaximumRetryAttempts(int value) { m_maximumRetryAttemptsHasBeenSet = true; m_maximumRetryAttempts = value; }
246
248
251 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const { return m_tags; }
252 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
253 template<typename TagsT = Aws::Map<Aws::String, Aws::String>>
254 void SetTags(TagsT&& value) { m_tagsHasBeenSet = true; m_tags = std::forward<TagsT>(value); }
255 template<typename TagsT = Aws::Map<Aws::String, Aws::String>>
256 CreateEventSourceMappingRequest& WithTags(TagsT&& value) { SetTags(std::forward<TagsT>(value)); return *this;}
257 template<typename TagsKeyT = Aws::String, typename TagsValueT = Aws::String>
258 CreateEventSourceMappingRequest& AddTags(TagsKeyT&& key, TagsValueT&& value) {
259 m_tagsHasBeenSet = true; m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value)); return *this;
260 }
262
264
269 inline int GetTumblingWindowInSeconds() const { return m_tumblingWindowInSeconds; }
270 inline bool TumblingWindowInSecondsHasBeenSet() const { return m_tumblingWindowInSecondsHasBeenSet; }
271 inline void SetTumblingWindowInSeconds(int value) { m_tumblingWindowInSecondsHasBeenSet = true; m_tumblingWindowInSeconds = value; }
274
276
279 inline const Aws::Vector<Aws::String>& GetTopics() const { return m_topics; }
280 inline bool TopicsHasBeenSet() const { return m_topicsHasBeenSet; }
281 template<typename TopicsT = Aws::Vector<Aws::String>>
282 void SetTopics(TopicsT&& value) { m_topicsHasBeenSet = true; m_topics = std::forward<TopicsT>(value); }
283 template<typename TopicsT = Aws::Vector<Aws::String>>
284 CreateEventSourceMappingRequest& WithTopics(TopicsT&& value) { SetTopics(std::forward<TopicsT>(value)); return *this;}
285 template<typename TopicsT = Aws::String>
286 CreateEventSourceMappingRequest& AddTopics(TopicsT&& value) { m_topicsHasBeenSet = true; m_topics.emplace_back(std::forward<TopicsT>(value)); return *this; }
288
290
293 inline const Aws::Vector<Aws::String>& GetQueues() const { return m_queues; }
294 inline bool QueuesHasBeenSet() const { return m_queuesHasBeenSet; }
295 template<typename QueuesT = Aws::Vector<Aws::String>>
296 void SetQueues(QueuesT&& value) { m_queuesHasBeenSet = true; m_queues = std::forward<QueuesT>(value); }
297 template<typename QueuesT = Aws::Vector<Aws::String>>
298 CreateEventSourceMappingRequest& WithQueues(QueuesT&& value) { SetQueues(std::forward<QueuesT>(value)); return *this;}
299 template<typename QueuesT = Aws::String>
300 CreateEventSourceMappingRequest& AddQueues(QueuesT&& value) { m_queuesHasBeenSet = true; m_queues.emplace_back(std::forward<QueuesT>(value)); return *this; }
302
304
308 inline const Aws::Vector<SourceAccessConfiguration>& GetSourceAccessConfigurations() const { return m_sourceAccessConfigurations; }
309 inline bool SourceAccessConfigurationsHasBeenSet() const { return m_sourceAccessConfigurationsHasBeenSet; }
310 template<typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
311 void SetSourceAccessConfigurations(SourceAccessConfigurationsT&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value); }
312 template<typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
313 CreateEventSourceMappingRequest& WithSourceAccessConfigurations(SourceAccessConfigurationsT&& value) { SetSourceAccessConfigurations(std::forward<SourceAccessConfigurationsT>(value)); return *this;}
314 template<typename SourceAccessConfigurationsT = SourceAccessConfiguration>
315 CreateEventSourceMappingRequest& AddSourceAccessConfigurations(SourceAccessConfigurationsT&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value)); return *this; }
317
319
322 inline const SelfManagedEventSource& GetSelfManagedEventSource() const { return m_selfManagedEventSource; }
323 inline bool SelfManagedEventSourceHasBeenSet() const { return m_selfManagedEventSourceHasBeenSet; }
324 template<typename SelfManagedEventSourceT = SelfManagedEventSource>
325 void SetSelfManagedEventSource(SelfManagedEventSourceT&& value) { m_selfManagedEventSourceHasBeenSet = true; m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value); }
326 template<typename SelfManagedEventSourceT = SelfManagedEventSource>
327 CreateEventSourceMappingRequest& WithSelfManagedEventSource(SelfManagedEventSourceT&& value) { SetSelfManagedEventSource(std::forward<SelfManagedEventSourceT>(value)); return *this;}
329
331
335 inline const Aws::Vector<FunctionResponseType>& GetFunctionResponseTypes() const { return m_functionResponseTypes; }
336 inline bool FunctionResponseTypesHasBeenSet() const { return m_functionResponseTypesHasBeenSet; }
337 template<typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
338 void SetFunctionResponseTypes(FunctionResponseTypesT&& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value); }
339 template<typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
340 CreateEventSourceMappingRequest& WithFunctionResponseTypes(FunctionResponseTypesT&& value) { SetFunctionResponseTypes(std::forward<FunctionResponseTypesT>(value)); return *this;}
341 inline CreateEventSourceMappingRequest& AddFunctionResponseTypes(FunctionResponseType value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes.push_back(value); return *this; }
343
345
349 inline const AmazonManagedKafkaEventSourceConfig& GetAmazonManagedKafkaEventSourceConfig() const { return m_amazonManagedKafkaEventSourceConfig; }
350 inline bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const { return m_amazonManagedKafkaEventSourceConfigHasBeenSet; }
351 template<typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
352 void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) { m_amazonManagedKafkaEventSourceConfigHasBeenSet = true; m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value); }
353 template<typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
354 CreateEventSourceMappingRequest& WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT&& value) { SetAmazonManagedKafkaEventSourceConfig(std::forward<AmazonManagedKafkaEventSourceConfigT>(value)); return *this;}
356
358
362 inline const SelfManagedKafkaEventSourceConfig& GetSelfManagedKafkaEventSourceConfig() const { return m_selfManagedKafkaEventSourceConfig; }
363 inline bool SelfManagedKafkaEventSourceConfigHasBeenSet() const { return m_selfManagedKafkaEventSourceConfigHasBeenSet; }
364 template<typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
365 void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) { m_selfManagedKafkaEventSourceConfigHasBeenSet = true; m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value); }
366 template<typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
367 CreateEventSourceMappingRequest& WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT&& value) { SetSelfManagedKafkaEventSourceConfig(std::forward<SelfManagedKafkaEventSourceConfigT>(value)); return *this;}
369
371
377 inline const ScalingConfig& GetScalingConfig() const { return m_scalingConfig; }
378 inline bool ScalingConfigHasBeenSet() const { return m_scalingConfigHasBeenSet; }
379 template<typename ScalingConfigT = ScalingConfig>
380 void SetScalingConfig(ScalingConfigT&& value) { m_scalingConfigHasBeenSet = true; m_scalingConfig = std::forward<ScalingConfigT>(value); }
381 template<typename ScalingConfigT = ScalingConfig>
382 CreateEventSourceMappingRequest& WithScalingConfig(ScalingConfigT&& value) { SetScalingConfig(std::forward<ScalingConfigT>(value)); return *this;}
384
386
389 inline const DocumentDBEventSourceConfig& GetDocumentDBEventSourceConfig() const { return m_documentDBEventSourceConfig; }
390 inline bool DocumentDBEventSourceConfigHasBeenSet() const { return m_documentDBEventSourceConfigHasBeenSet; }
391 template<typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
392 void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT&& value) { m_documentDBEventSourceConfigHasBeenSet = true; m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value); }
393 template<typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
394 CreateEventSourceMappingRequest& WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT&& value) { SetDocumentDBEventSourceConfig(std::forward<DocumentDBEventSourceConfigT>(value)); return *this;}
396
398
405 inline const Aws::String& GetKMSKeyArn() const { return m_kMSKeyArn; }
406 inline bool KMSKeyArnHasBeenSet() const { return m_kMSKeyArnHasBeenSet; }
407 template<typename KMSKeyArnT = Aws::String>
408 void SetKMSKeyArn(KMSKeyArnT&& value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn = std::forward<KMSKeyArnT>(value); }
409 template<typename KMSKeyArnT = Aws::String>
410 CreateEventSourceMappingRequest& WithKMSKeyArn(KMSKeyArnT&& value) { SetKMSKeyArn(std::forward<KMSKeyArnT>(value)); return *this;}
412
414
419 inline const EventSourceMappingMetricsConfig& GetMetricsConfig() const { return m_metricsConfig; }
420 inline bool MetricsConfigHasBeenSet() const { return m_metricsConfigHasBeenSet; }
421 template<typename MetricsConfigT = EventSourceMappingMetricsConfig>
422 void SetMetricsConfig(MetricsConfigT&& value) { m_metricsConfigHasBeenSet = true; m_metricsConfig = std::forward<MetricsConfigT>(value); }
423 template<typename MetricsConfigT = EventSourceMappingMetricsConfig>
424 CreateEventSourceMappingRequest& WithMetricsConfig(MetricsConfigT&& value) { SetMetricsConfig(std::forward<MetricsConfigT>(value)); return *this;}
426
428
434 inline const ProvisionedPollerConfig& GetProvisionedPollerConfig() const { return m_provisionedPollerConfig; }
435 inline bool ProvisionedPollerConfigHasBeenSet() const { return m_provisionedPollerConfigHasBeenSet; }
436 template<typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
437 void SetProvisionedPollerConfig(ProvisionedPollerConfigT&& value) { m_provisionedPollerConfigHasBeenSet = true; m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value); }
438 template<typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
439 CreateEventSourceMappingRequest& WithProvisionedPollerConfig(ProvisionedPollerConfigT&& value) { SetProvisionedPollerConfig(std::forward<ProvisionedPollerConfigT>(value)); return *this;}
441 private:
442
443 Aws::String m_eventSourceArn;
444 bool m_eventSourceArnHasBeenSet = false;
445
446 Aws::String m_functionName;
447 bool m_functionNameHasBeenSet = false;
448
449 bool m_enabled{false};
450 bool m_enabledHasBeenSet = false;
451
452 int m_batchSize{0};
453 bool m_batchSizeHasBeenSet = false;
454
455 FilterCriteria m_filterCriteria;
456 bool m_filterCriteriaHasBeenSet = false;
457
458 int m_maximumBatchingWindowInSeconds{0};
459 bool m_maximumBatchingWindowInSecondsHasBeenSet = false;
460
461 int m_parallelizationFactor{0};
462 bool m_parallelizationFactorHasBeenSet = false;
463
465 bool m_startingPositionHasBeenSet = false;
466
467 Aws::Utils::DateTime m_startingPositionTimestamp{};
468 bool m_startingPositionTimestampHasBeenSet = false;
469
470 DestinationConfig m_destinationConfig;
471 bool m_destinationConfigHasBeenSet = false;
472
473 int m_maximumRecordAgeInSeconds{0};
474 bool m_maximumRecordAgeInSecondsHasBeenSet = false;
475
476 bool m_bisectBatchOnFunctionError{false};
477 bool m_bisectBatchOnFunctionErrorHasBeenSet = false;
478
479 int m_maximumRetryAttempts{0};
480 bool m_maximumRetryAttemptsHasBeenSet = false;
481
483 bool m_tagsHasBeenSet = false;
484
485 int m_tumblingWindowInSeconds{0};
486 bool m_tumblingWindowInSecondsHasBeenSet = false;
487
489 bool m_topicsHasBeenSet = false;
490
492 bool m_queuesHasBeenSet = false;
493
494 Aws::Vector<SourceAccessConfiguration> m_sourceAccessConfigurations;
495 bool m_sourceAccessConfigurationsHasBeenSet = false;
496
497 SelfManagedEventSource m_selfManagedEventSource;
498 bool m_selfManagedEventSourceHasBeenSet = false;
499
500 Aws::Vector<FunctionResponseType> m_functionResponseTypes;
501 bool m_functionResponseTypesHasBeenSet = false;
502
503 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
504 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet = false;
505
506 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
507 bool m_selfManagedKafkaEventSourceConfigHasBeenSet = false;
508
509 ScalingConfig m_scalingConfig;
510 bool m_scalingConfigHasBeenSet = false;
511
512 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
513 bool m_documentDBEventSourceConfigHasBeenSet = false;
514
515 Aws::String m_kMSKeyArn;
516 bool m_kMSKeyArnHasBeenSet = false;
517
518 EventSourceMappingMetricsConfig m_metricsConfig;
519 bool m_metricsConfigHasBeenSet = false;
520
521 ProvisionedPollerConfig m_provisionedPollerConfig;
522 bool m_provisionedPollerConfigHasBeenSet = false;
523 };
524
525} // namespace Model
526} // namespace Lambda
527} // 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
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 & 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