7#include <aws/core/utils/memory/stl/AWSString.h>
8#include <aws/core/utils/memory/stl/AWSVector.h>
9#include <aws/lambda/LambdaRequest.h>
10#include <aws/lambda/Lambda_EXPORTS.h>
11#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
12#include <aws/lambda/model/DestinationConfig.h>
13#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
14#include <aws/lambda/model/EventSourceMappingLoggingConfig.h>
15#include <aws/lambda/model/EventSourceMappingMetricsConfig.h>
16#include <aws/lambda/model/FilterCriteria.h>
17#include <aws/lambda/model/FunctionResponseType.h>
18#include <aws/lambda/model/ProvisionedPollerConfig.h>
19#include <aws/lambda/model/ScalingConfig.h>
20#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
21#include <aws/lambda/model/SourceAccessConfiguration.h>
49 template <
typename UUIDT = Aws::String>
51 m_uUIDHasBeenSet =
true;
52 m_uUID = std::forward<UUIDT>(value);
54 template <
typename UUIDT = Aws::String>
56 SetUUID(std::forward<UUIDT>(value));
76 template <
typename FunctionNameT = Aws::String>
78 m_functionNameHasBeenSet =
true;
79 m_functionName = std::forward<FunctionNameT>(value);
81 template <
typename FunctionNameT = Aws::String>
96 m_enabledHasBeenSet =
true;
123 m_batchSizeHasBeenSet =
true;
141 template <
typename FilterCriteriaT = FilterCriteria>
143 m_filterCriteriaHasBeenSet =
true;
144 m_filterCriteria = std::forward<FilterCriteriaT>(value);
146 template <
typename FilterCriteriaT = FilterCriteria>
163 template <
typename KMSKeyArnT = Aws::String>
165 m_kMSKeyArnHasBeenSet =
true;
166 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
168 template <
typename KMSKeyArnT = Aws::String>
183 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
185 m_metricsConfigHasBeenSet =
true;
186 m_metricsConfig = std::forward<MetricsConfigT>(value);
188 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
199 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
201 m_loggingConfigHasBeenSet =
true;
202 m_loggingConfig = std::forward<LoggingConfigT>(value);
204 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
220 template <
typename ScalingConfigT = ScalingConfig>
222 m_scalingConfigHasBeenSet =
true;
223 m_scalingConfig = std::forward<ScalingConfigT>(value);
225 template <
typename ScalingConfigT = ScalingConfig>
251 m_maximumBatchingWindowInSecondsHasBeenSet =
true;
252 m_maximumBatchingWindowInSeconds = value;
268 m_parallelizationFactorHasBeenSet =
true;
269 m_parallelizationFactor = value;
285 template <
typename DestinationConfigT = DestinationConfig>
287 m_destinationConfigHasBeenSet =
true;
288 m_destinationConfig = std::forward<DestinationConfigT>(value);
290 template <
typename DestinationConfigT = DestinationConfig>
306 m_maximumRecordAgeInSecondsHasBeenSet =
true;
307 m_maximumRecordAgeInSeconds = value;
323 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
324 m_bisectBatchOnFunctionError = value;
342 m_maximumRetryAttemptsHasBeenSet =
true;
343 m_maximumRetryAttempts = value;
360 m_tumblingWindowInSecondsHasBeenSet =
true;
361 m_tumblingWindowInSeconds = value;
376 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
378 m_sourceAccessConfigurationsHasBeenSet =
true;
379 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
381 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
386 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
388 m_sourceAccessConfigurationsHasBeenSet =
true;
389 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
402 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
404 m_functionResponseTypesHasBeenSet =
true;
405 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
407 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
413 m_functionResponseTypesHasBeenSet =
true;
414 m_functionResponseTypes.push_back(value);
422 return m_amazonManagedKafkaEventSourceConfig;
425 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
427 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
428 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
430 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
440 return m_selfManagedKafkaEventSourceConfig;
443 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
445 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
446 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
448 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
461 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
463 m_documentDBEventSourceConfigHasBeenSet =
true;
464 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
466 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
482 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
484 m_provisionedPollerConfigHasBeenSet =
true;
485 m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value);
487 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
498 bool m_enabled{
false};
502 FilterCriteria m_filterCriteria;
506 EventSourceMappingMetricsConfig m_metricsConfig;
508 EventSourceMappingLoggingConfig m_loggingConfig;
510 ScalingConfig m_scalingConfig;
512 int m_maximumBatchingWindowInSeconds{0};
514 int m_parallelizationFactor{0};
516 DestinationConfig m_destinationConfig;
518 int m_maximumRecordAgeInSeconds{0};
520 bool m_bisectBatchOnFunctionError{
false};
522 int m_maximumRetryAttempts{0};
524 int m_tumblingWindowInSeconds{0};
530 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
532 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
534 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
536 ProvisionedPollerConfig m_provisionedPollerConfig;
537 bool m_uUIDHasBeenSet =
false;
538 bool m_functionNameHasBeenSet =
false;
539 bool m_enabledHasBeenSet =
false;
540 bool m_batchSizeHasBeenSet =
false;
541 bool m_filterCriteriaHasBeenSet =
false;
542 bool m_kMSKeyArnHasBeenSet =
false;
543 bool m_metricsConfigHasBeenSet =
false;
544 bool m_loggingConfigHasBeenSet =
false;
545 bool m_scalingConfigHasBeenSet =
false;
546 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
547 bool m_parallelizationFactorHasBeenSet =
false;
548 bool m_destinationConfigHasBeenSet =
false;
549 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
550 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
551 bool m_maximumRetryAttemptsHasBeenSet =
false;
552 bool m_tumblingWindowInSecondsHasBeenSet =
false;
553 bool m_sourceAccessConfigurationsHasBeenSet =
false;
554 bool m_functionResponseTypesHasBeenSet =
false;
555 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
556 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
557 bool m_documentDBEventSourceConfigHasBeenSet =
false;
558 bool m_provisionedPollerConfigHasBeenSet =
false;
void SetProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
void SetMaximumRecordAgeInSeconds(int value)
bool BatchSizeHasBeenSet() const
bool SourceAccessConfigurationsHasBeenSet() const
int GetTumblingWindowInSeconds() const
int GetMaximumRecordAgeInSeconds() const
bool LoggingConfigHasBeenSet() const
const EventSourceMappingLoggingConfig & GetLoggingConfig() const
void SetMaximumBatchingWindowInSeconds(int value)
UpdateEventSourceMappingRequest & WithSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
void SetUUID(UUIDT &&value)
bool ParallelizationFactorHasBeenSet() const
bool EnabledHasBeenSet() const
UpdateEventSourceMappingRequest & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
int GetMaximumBatchingWindowInSeconds() const
bool MetricsConfigHasBeenSet() const
bool SelfManagedKafkaEventSourceConfigHasBeenSet() const
UpdateEventSourceMappingRequest & WithProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
void SetEnabled(bool value)
UpdateEventSourceMappingRequest & WithBisectBatchOnFunctionError(bool value)
void SetTumblingWindowInSeconds(int value)
void SetFilterCriteria(FilterCriteriaT &&value)
bool BisectBatchOnFunctionErrorHasBeenSet() const
UpdateEventSourceMappingRequest & WithFunctionName(FunctionNameT &&value)
void SetKMSKeyArn(KMSKeyArnT &&value)
bool FunctionNameHasBeenSet() const
bool FunctionResponseTypesHasBeenSet() const
bool MaximumRecordAgeInSecondsHasBeenSet() const
UpdateEventSourceMappingRequest & WithFunctionResponseTypes(FunctionResponseTypesT &&value)
bool GetBisectBatchOnFunctionError() const
const Aws::String & GetKMSKeyArn() const
UpdateEventSourceMappingRequest & WithMaximumBatchingWindowInSeconds(int value)
AWS_LAMBDA_API UpdateEventSourceMappingRequest()=default
void SetFunctionResponseTypes(FunctionResponseTypesT &&value)
UpdateEventSourceMappingRequest & WithTumblingWindowInSeconds(int value)
bool KMSKeyArnHasBeenSet() const
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
const Aws::String & GetFunctionName() const
bool DestinationConfigHasBeenSet() const
UpdateEventSourceMappingRequest & WithDestinationConfig(DestinationConfigT &&value)
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
const Aws::String & GetUUID() const
bool DocumentDBEventSourceConfigHasBeenSet() const
bool UUIDHasBeenSet() const
bool ProvisionedPollerConfigHasBeenSet() const
void SetLoggingConfig(LoggingConfigT &&value)
const FilterCriteria & GetFilterCriteria() const
bool ScalingConfigHasBeenSet() const
void SetBatchSize(int value)
void SetSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
UpdateEventSourceMappingRequest & WithFilterCriteria(FilterCriteriaT &&value)
void SetBisectBatchOnFunctionError(bool value)
const ScalingConfig & GetScalingConfig() const
UpdateEventSourceMappingRequest & WithMaximumRecordAgeInSeconds(int value)
bool MaximumRetryAttemptsHasBeenSet() const
int GetMaximumRetryAttempts() const
AWS_LAMBDA_API Aws::String SerializePayload() const override
virtual const char * GetServiceRequestName() const override
void SetFunctionName(FunctionNameT &&value)
UpdateEventSourceMappingRequest & WithEnabled(bool value)
UpdateEventSourceMappingRequest & WithMaximumRetryAttempts(int value)
UpdateEventSourceMappingRequest & AddSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
UpdateEventSourceMappingRequest & WithLoggingConfig(LoggingConfigT &&value)
const ProvisionedPollerConfig & GetProvisionedPollerConfig() const
bool FilterCriteriaHasBeenSet() const
void SetDestinationConfig(DestinationConfigT &&value)
bool MaximumBatchingWindowInSecondsHasBeenSet() const
UpdateEventSourceMappingRequest & WithUUID(UUIDT &&value)
void SetParallelizationFactor(int value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
UpdateEventSourceMappingRequest & WithParallelizationFactor(int value)
void SetMetricsConfig(MetricsConfigT &&value)
UpdateEventSourceMappingRequest & WithScalingConfig(ScalingConfigT &&value)
void SetScalingConfig(ScalingConfigT &&value)
int GetParallelizationFactor() const
bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const
UpdateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
UpdateEventSourceMappingRequest & WithMetricsConfig(MetricsConfigT &&value)
UpdateEventSourceMappingRequest & WithKMSKeyArn(KMSKeyArnT &&value)
bool TumblingWindowInSecondsHasBeenSet() const
UpdateEventSourceMappingRequest & AddFunctionResponseTypes(FunctionResponseType value)
const DestinationConfig & GetDestinationConfig() const
UpdateEventSourceMappingRequest & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
UpdateEventSourceMappingRequest & WithBatchSize(int value)
const EventSourceMappingMetricsConfig & GetMetricsConfig() const
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
void SetMaximumRetryAttempts(int value)
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
std::vector< T, Aws::Allocator< T > > Vector