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>
65 inline void SetEventSourceArn(
const char* value) { m_eventSourceArnHasBeenSet =
true; m_eventSourceArn.assign(value); }
88 inline void SetFunctionName(
const char* value) { m_functionNameHasBeenSet =
true; m_functionName.assign(value); }
101 inline void SetEnabled(
bool value) { m_enabledHasBeenSet =
true; m_enabled = value; }
122 inline void SetBatchSize(
int value) { m_batchSizeHasBeenSet =
true; m_batchSize = value; }
419 inline void SetKMSKeyArn(
const char* value) { m_kMSKeyArnHasBeenSet =
true; m_kMSKeyArn.assign(value); }
427 bool m_eventSourceArnHasBeenSet =
false;
430 bool m_functionNameHasBeenSet =
false;
433 bool m_enabledHasBeenSet =
false;
436 bool m_batchSizeHasBeenSet =
false;
439 bool m_filterCriteriaHasBeenSet =
false;
441 int m_maximumBatchingWindowInSeconds;
442 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
444 int m_parallelizationFactor;
445 bool m_parallelizationFactorHasBeenSet =
false;
448 bool m_startingPositionHasBeenSet =
false;
451 bool m_startingPositionTimestampHasBeenSet =
false;
454 bool m_destinationConfigHasBeenSet =
false;
456 int m_maximumRecordAgeInSeconds;
457 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
459 bool m_bisectBatchOnFunctionError;
460 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
462 int m_maximumRetryAttempts;
463 bool m_maximumRetryAttemptsHasBeenSet =
false;
466 bool m_tagsHasBeenSet =
false;
468 int m_tumblingWindowInSeconds;
469 bool m_tumblingWindowInSecondsHasBeenSet =
false;
472 bool m_topicsHasBeenSet =
false;
475 bool m_queuesHasBeenSet =
false;
478 bool m_sourceAccessConfigurationsHasBeenSet =
false;
481 bool m_selfManagedEventSourceHasBeenSet =
false;
484 bool m_functionResponseTypesHasBeenSet =
false;
487 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
490 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
493 bool m_scalingConfigHasBeenSet =
false;
496 bool m_documentDBEventSourceConfigHasBeenSet =
false;
499 bool m_kMSKeyArnHasBeenSet =
false;
const SelfManagedEventSource & GetSelfManagedEventSource() const
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)
void SetMaximumBatchingWindowInSeconds(int value)
CreateEventSourceMappingRequest & AddTags(const char *key, Aws::String &&value)
const Aws::Utils::DateTime & GetStartingPositionTimestamp() const
CreateEventSourceMappingRequest & WithEventSourceArn(const char *value)
virtual const char * GetServiceRequestName() const override
CreateEventSourceMappingRequest & WithBatchSize(int value)
int GetMaximumRecordAgeInSeconds() const
CreateEventSourceMappingRequest & AddSourceAccessConfigurations(SourceAccessConfiguration &&value)
bool ParallelizationFactorHasBeenSet() const
void SetFilterCriteria(const FilterCriteria &value)
CreateEventSourceMappingRequest & WithQueues(Aws::Vector< Aws::String > &&value)
CreateEventSourceMappingRequest & WithStartingPositionTimestamp(const Aws::Utils::DateTime &value)
void SetFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
void SetStartingPositionTimestamp(Aws::Utils::DateTime &&value)
int GetParallelizationFactor() const
bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const
CreateEventSourceMappingRequest & WithStartingPosition(const EventSourcePosition &value)
void SetDestinationConfig(const DestinationConfig &value)
CreateEventSourceMappingRequest & WithFunctionName(const Aws::String &value)
CreateEventSourceMappingRequest & WithSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
CreateEventSourceMappingRequest & AddTopics(const char *value)
bool FilterCriteriaHasBeenSet() const
AWS_LAMBDA_API CreateEventSourceMappingRequest()
CreateEventSourceMappingRequest & WithEventSourceArn(Aws::String &&value)
void SetFunctionName(Aws::String &&value)
void SetKMSKeyArn(const char *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
void SetEventSourceArn(const Aws::String &value)
CreateEventSourceMappingRequest & WithScalingConfig(ScalingConfig &&value)
void SetEnabled(bool value)
bool MaximumRetryAttemptsHasBeenSet() const
bool MaximumBatchingWindowInSecondsHasBeenSet() const
CreateEventSourceMappingRequest & WithFunctionName(const char *value)
CreateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfig &&value)
void SetFunctionName(const Aws::String &value)
CreateEventSourceMappingRequest & WithTopics(Aws::Vector< Aws::String > &&value)
CreateEventSourceMappingRequest & WithMaximumRecordAgeInSeconds(int value)
bool FunctionNameHasBeenSet() const
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
bool SelfManagedKafkaEventSourceConfigHasBeenSet() const
void SetSourceAccessConfigurations(Aws::Vector< SourceAccessConfiguration > &&value)
bool MaximumRecordAgeInSecondsHasBeenSet() const
const FilterCriteria & GetFilterCriteria() const
bool StartingPositionHasBeenSet() const
CreateEventSourceMappingRequest & AddTopics(const Aws::String &value)
bool TopicsHasBeenSet() const
const Aws::Map< Aws::String, Aws::String > & GetTags() const
CreateEventSourceMappingRequest & WithStartingPosition(EventSourcePosition &&value)
CreateEventSourceMappingRequest & WithFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
void SetSelfManagedEventSource(SelfManagedEventSource &&value)
void SetDestinationConfig(DestinationConfig &&value)
bool StartingPositionTimestampHasBeenSet() const
void SetDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
CreateEventSourceMappingRequest & WithSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig &value)
const Aws::String & GetEventSourceArn() const
CreateEventSourceMappingRequest & AddTopics(Aws::String &&value)
bool EventSourceArnHasBeenSet() const
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 SetEventSourceArn(Aws::String &&value)
void SetSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
bool KMSKeyArnHasBeenSet() const
const DestinationConfig & GetDestinationConfig() const
CreateEventSourceMappingRequest & WithParallelizationFactor(int value)
void SetEventSourceArn(const char *value)
bool ScalingConfigHasBeenSet() const
CreateEventSourceMappingRequest & AddTags(Aws::String &&key, const char *value)
CreateEventSourceMappingRequest & WithSelfManagedEventSource(const SelfManagedEventSource &value)
CreateEventSourceMappingRequest & WithFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
void SetFilterCriteria(FilterCriteria &&value)
CreateEventSourceMappingRequest & WithDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
void SetFunctionName(const char *value)
CreateEventSourceMappingRequest & WithStartingPositionTimestamp(Aws::Utils::DateTime &&value)
bool TagsHasBeenSet() const
const EventSourcePosition & GetStartingPosition() const
CreateEventSourceMappingRequest & WithTags(const Aws::Map< Aws::String, Aws::String > &value)
CreateEventSourceMappingRequest & AddTags(Aws::String &&key, Aws::String &&value)
CreateEventSourceMappingRequest & WithSelfManagedEventSource(SelfManagedEventSource &&value)
void SetParallelizationFactor(int value)
bool SourceAccessConfigurationsHasBeenSet() const
CreateEventSourceMappingRequest & AddFunctionResponseTypes(const FunctionResponseType &value)
bool DocumentDBEventSourceConfigHasBeenSet() const
void SetTumblingWindowInSeconds(int value)
void SetMaximumRecordAgeInSeconds(int value)
bool GetBisectBatchOnFunctionError() const
void SetStartingPositionTimestamp(const Aws::Utils::DateTime &value)
int GetTumblingWindowInSeconds() const
const Aws::String & GetKMSKeyArn() const
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)
const Aws::Vector< Aws::String > & GetTopics() const
void SetKMSKeyArn(const Aws::String &value)
CreateEventSourceMappingRequest & WithKMSKeyArn(const char *value)
CreateEventSourceMappingRequest & AddTags(const Aws::String &key, const Aws::String &value)
void SetStartingPosition(EventSourcePosition &&value)
CreateEventSourceMappingRequest & WithScalingConfig(const ScalingConfig &value)
const Aws::Vector< Aws::String > & GetQueues() const
CreateEventSourceMappingRequest & AddFunctionResponseTypes(FunctionResponseType &&value)
bool QueuesHasBeenSet() const
void SetKMSKeyArn(Aws::String &&value)
CreateEventSourceMappingRequest & AddTags(const Aws::String &key, Aws::String &&value)
void SetStartingPosition(const EventSourcePosition &value)
CreateEventSourceMappingRequest & WithMaximumRetryAttempts(int value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
bool SelfManagedEventSourceHasBeenSet() const
bool DestinationConfigHasBeenSet() 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)
const Aws::String & GetFunctionName() const
bool BisectBatchOnFunctionErrorHasBeenSet() const
void SetTopics(Aws::Vector< Aws::String > &&value)
void SetBisectBatchOnFunctionError(bool value)
void SetBatchSize(int value)
void SetScalingConfig(const ScalingConfig &value)
void SetScalingConfig(ScalingConfig &&value)
CreateEventSourceMappingRequest & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig &&value)
CreateEventSourceMappingRequest & WithQueues(const Aws::Vector< Aws::String > &value)
CreateEventSourceMappingRequest & WithTopics(const Aws::Vector< Aws::String > &value)
void SetQueues(Aws::Vector< Aws::String > &&value)
bool TumblingWindowInSecondsHasBeenSet() const
int GetMaximumBatchingWindowInSeconds() const
void SetMaximumRetryAttempts(int value)
const ScalingConfig & GetScalingConfig() const
bool EnabledHasBeenSet() const
void SetFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
CreateEventSourceMappingRequest & AddQueues(const Aws::String &value)
int GetMaximumRetryAttempts() const
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)
bool FunctionResponseTypesHasBeenSet() const
bool BatchSizeHasBeenSet() const
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