7#include <aws/lambda/Lambda_EXPORTS.h>
8#include <aws/core/utils/memory/stl/AWSString.h>
9#include <aws/lambda/model/EventSourcePosition.h>
10#include <aws/core/utils/DateTime.h>
11#include <aws/lambda/model/FilterCriteria.h>
12#include <aws/lambda/model/DestinationConfig.h>
13#include <aws/core/utils/memory/stl/AWSVector.h>
14#include <aws/lambda/model/SelfManagedEventSource.h>
15#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
16#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
17#include <aws/lambda/model/ScalingConfig.h>
18#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
19#include <aws/lambda/model/FilterCriteriaError.h>
20#include <aws/lambda/model/SourceAccessConfiguration.h>
21#include <aws/lambda/model/FunctionResponseType.h>
62 inline void SetUUID(
const char* value) { m_uUIDHasBeenSet =
true; m_uUID.assign(value); }
109 inline void SetBatchSize(
int value) { m_batchSizeHasBeenSet =
true; m_batchSize = value; }
154 inline void SetEventSourceArn(
const char* value) { m_eventSourceArnHasBeenSet =
true; m_eventSourceArn.assign(value); }
187 inline void SetFunctionArn(
const char* value) { m_functionArnHasBeenSet =
true; m_functionArn.assign(value); }
214 inline void SetLastProcessingResult(
const char* value) { m_lastProcessingResultHasBeenSet =
true; m_lastProcessingResult.assign(value); }
231 inline void SetState(
const char* value) { m_stateHasBeenSet =
true; m_state.assign(value); }
246 inline void SetStateTransitionReason(
const char* value) { m_stateTransitionReasonHasBeenSet =
true; m_stateTransitionReason.assign(value); }
454 inline void SetKMSKeyArn(
const char* value) { m_kMSKeyArnHasBeenSet =
true; m_kMSKeyArn.assign(value); }
481 inline void SetEventSourceMappingArn(
const char* value) { m_eventSourceMappingArnHasBeenSet =
true; m_eventSourceMappingArn.assign(value); }
493 inline void SetRequestId(
const char* value) { m_requestIdHasBeenSet =
true; m_requestId.assign(value); }
501 bool m_uUIDHasBeenSet =
false;
504 bool m_startingPositionHasBeenSet =
false;
507 bool m_startingPositionTimestampHasBeenSet =
false;
510 bool m_batchSizeHasBeenSet =
false;
512 int m_maximumBatchingWindowInSeconds;
513 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
515 int m_parallelizationFactor;
516 bool m_parallelizationFactorHasBeenSet =
false;
519 bool m_eventSourceArnHasBeenSet =
false;
522 bool m_filterCriteriaHasBeenSet =
false;
525 bool m_functionArnHasBeenSet =
false;
528 bool m_lastModifiedHasBeenSet =
false;
531 bool m_lastProcessingResultHasBeenSet =
false;
534 bool m_stateHasBeenSet =
false;
537 bool m_stateTransitionReasonHasBeenSet =
false;
540 bool m_destinationConfigHasBeenSet =
false;
543 bool m_topicsHasBeenSet =
false;
546 bool m_queuesHasBeenSet =
false;
549 bool m_sourceAccessConfigurationsHasBeenSet =
false;
552 bool m_selfManagedEventSourceHasBeenSet =
false;
554 int m_maximumRecordAgeInSeconds;
555 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
557 bool m_bisectBatchOnFunctionError;
558 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
560 int m_maximumRetryAttempts;
561 bool m_maximumRetryAttemptsHasBeenSet =
false;
563 int m_tumblingWindowInSeconds;
564 bool m_tumblingWindowInSecondsHasBeenSet =
false;
567 bool m_functionResponseTypesHasBeenSet =
false;
570 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
573 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
576 bool m_scalingConfigHasBeenSet =
false;
579 bool m_documentDBEventSourceConfigHasBeenSet =
false;
582 bool m_kMSKeyArnHasBeenSet =
false;
585 bool m_filterCriteriaErrorHasBeenSet =
false;
588 bool m_eventSourceMappingArnHasBeenSet =
false;
591 bool m_requestIdHasBeenSet =
false;
EventSourceMappingConfiguration & WithQueues(Aws::Vector< Aws::String > &&value)
void SetLastModified(Aws::Utils::DateTime &&value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
EventSourceMappingConfiguration & WithUUID(Aws::String &&value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig &&value)
const FilterCriteriaError & GetFilterCriteriaError() const
EventSourceMappingConfiguration & WithFilterCriteria(const FilterCriteria &value)
AWS_LAMBDA_API Aws::Utils::Json::JsonValue Jsonize() const
EventSourceMappingConfiguration & AddFunctionResponseTypes(FunctionResponseType &&value)
EventSourceMappingConfiguration & WithFunctionArn(const Aws::String &value)
bool StateHasBeenSet() const
EventSourceMappingConfiguration & WithFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
bool FilterCriteriaHasBeenSet() const
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfig &&value)
void SetUUID(const char *value)
EventSourceMappingConfiguration & WithTopics(Aws::Vector< Aws::String > &&value)
void SetScalingConfig(ScalingConfig &&value)
void SetRequestId(Aws::String &&value)
void SetStartingPosition(const EventSourcePosition &value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
EventSourceMappingConfiguration & WithAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig &value)
EventSourceMappingConfiguration & WithEventSourceMappingArn(const char *value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
bool TopicsHasBeenSet() const
const Aws::String & GetKMSKeyArn() const
EventSourceMappingConfiguration & AddSourceAccessConfigurations(const SourceAccessConfiguration &value)
void SetSourceAccessConfigurations(Aws::Vector< SourceAccessConfiguration > &&value)
EventSourceMappingConfiguration & WithDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
void SetSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
const Aws::Utils::DateTime & GetStartingPositionTimestamp() const
EventSourceMappingConfiguration & WithStateTransitionReason(Aws::String &&value)
void SetLastProcessingResult(const Aws::String &value)
EventSourceMappingConfiguration & WithFilterCriteriaError(FilterCriteriaError &&value)
bool QueuesHasBeenSet() const
EventSourceMappingConfiguration & AddQueues(const char *value)
const ScalingConfig & GetScalingConfig() const
const Aws::Vector< Aws::String > & GetTopics() const
void SetDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig &value)
void SetQueues(Aws::Vector< Aws::String > &&value)
EventSourceMappingConfiguration & WithEventSourceMappingArn(const Aws::String &value)
bool DestinationConfigHasBeenSet() const
void SetEventSourceMappingArn(const char *value)
int GetMaximumRecordAgeInSeconds() const
void SetScalingConfig(const ScalingConfig &value)
EventSourceMappingConfiguration & WithFilterCriteriaError(const FilterCriteriaError &value)
EventSourceMappingConfiguration & WithScalingConfig(ScalingConfig &&value)
EventSourceMappingConfiguration & WithEventSourceArn(const char *value)
const Aws::String & GetLastProcessingResult() const
bool ScalingConfigHasBeenSet() const
void SetFilterCriteriaError(FilterCriteriaError &&value)
void SetSelfManagedEventSource(SelfManagedEventSource &&value)
void SetFunctionArn(const Aws::String &value)
void SetKMSKeyArn(const char *value)
const Aws::String & GetRequestId() const
EventSourceMappingConfiguration & WithEventSourceArn(Aws::String &&value)
bool KMSKeyArnHasBeenSet() const
const DestinationConfig & GetDestinationConfig() const
bool FilterCriteriaErrorHasBeenSet() const
bool RequestIdHasBeenSet() const
EventSourceMappingConfiguration & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfig &&value)
EventSourceMappingConfiguration & AddQueues(const Aws::String &value)
void SetKMSKeyArn(const Aws::String &value)
const Aws::String & GetFunctionArn() const
void SetStartingPositionTimestamp(Aws::Utils::DateTime &&value)
void SetAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig &value)
void SetStateTransitionReason(const Aws::String &value)
void SetTumblingWindowInSeconds(int value)
EventSourceMappingConfiguration & AddQueues(Aws::String &&value)
void SetFilterCriteria(const FilterCriteria &value)
void SetBatchSize(int value)
void SetEventSourceMappingArn(const Aws::String &value)
EventSourceMappingConfiguration & WithFunctionArn(Aws::String &&value)
EventSourceMappingConfiguration & WithLastModified(Aws::Utils::DateTime &&value)
bool DocumentDBEventSourceConfigHasBeenSet() const
void SetUUID(const Aws::String &value)
bool SelfManagedKafkaEventSourceConfigHasBeenSet() const
EventSourceMappingConfiguration & WithStartingPosition(EventSourcePosition &&value)
void SetMaximumRetryAttempts(int value)
EventSourceMappingConfiguration & WithMaximumBatchingWindowInSeconds(int value)
EventSourceMappingConfiguration & WithSourceAccessConfigurations(const Aws::Vector< SourceAccessConfiguration > &value)
const SelfManagedEventSource & GetSelfManagedEventSource() const
void SetStartingPositionTimestamp(const Aws::Utils::DateTime &value)
EventSourceMappingConfiguration & WithDestinationConfig(DestinationConfig &&value)
void SetSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig &value)
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig &&value)
EventSourceMappingConfiguration & WithStartingPositionTimestamp(const Aws::Utils::DateTime &value)
const Aws::Utils::DateTime & GetLastModified() const
EventSourceMappingConfiguration & WithLastProcessingResult(Aws::String &&value)
void SetTopics(const Aws::Vector< Aws::String > &value)
void SetFilterCriteria(FilterCriteria &&value)
EventSourceMappingConfiguration & WithBatchSize(int value)
EventSourceMappingConfiguration & WithParallelizationFactor(int value)
const Aws::String & GetStateTransitionReason() const
void SetRequestId(const char *value)
void SetUUID(Aws::String &&value)
bool LastModifiedHasBeenSet() const
const Aws::Vector< Aws::String > & GetQueues() const
void SetQueues(const Aws::Vector< Aws::String > &value)
void SetState(const Aws::String &value)
EventSourceMappingConfiguration & WithLastProcessingResult(const char *value)
EventSourceMappingConfiguration & WithFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
void SetStartingPosition(EventSourcePosition &&value)
void SetStateTransitionReason(Aws::String &&value)
EventSourceMappingConfiguration & WithSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig &value)
EventSourceMappingConfiguration & AddFunctionResponseTypes(const FunctionResponseType &value)
EventSourceMappingConfiguration & WithKMSKeyArn(Aws::String &&value)
bool BisectBatchOnFunctionErrorHasBeenSet() const
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
EventSourceMappingConfiguration & AddTopics(Aws::String &&value)
EventSourceMappingConfiguration & WithRequestId(Aws::String &&value)
bool SourceAccessConfigurationsHasBeenSet() const
EventSourceMappingConfiguration & WithStateTransitionReason(const char *value)
EventSourceMappingConfiguration & WithKMSKeyArn(const Aws::String &value)
EventSourceMappingConfiguration & WithRequestId(const char *value)
void SetDestinationConfig(DestinationConfig &&value)
EventSourceMappingConfiguration & WithMaximumRecordAgeInSeconds(int value)
EventSourceMappingConfiguration & WithState(const Aws::String &value)
void SetTopics(Aws::Vector< Aws::String > &&value)
bool StartingPositionTimestampHasBeenSet() const
EventSourceMappingConfiguration & WithStateTransitionReason(const Aws::String &value)
bool MaximumBatchingWindowInSecondsHasBeenSet() const
EventSourceMappingConfiguration & WithSelfManagedEventSource(SelfManagedEventSource &&value)
EventSourceMappingConfiguration & WithStartingPosition(const EventSourcePosition &value)
bool FunctionResponseTypesHasBeenSet() const
void SetState(const char *value)
AWS_LAMBDA_API EventSourceMappingConfiguration()
EventSourceMappingConfiguration & WithQueues(const Aws::Vector< Aws::String > &value)
const Aws::String & GetEventSourceMappingArn() const
EventSourceMappingConfiguration & WithEventSourceArn(const Aws::String &value)
void SetLastModified(const Aws::Utils::DateTime &value)
void SetStateTransitionReason(const char *value)
void SetEventSourceArn(const char *value)
bool GetBisectBatchOnFunctionError() const
void SetRequestId(const Aws::String &value)
AWS_LAMBDA_API EventSourceMappingConfiguration & operator=(Aws::Utils::Json::JsonView jsonValue)
int GetParallelizationFactor() const
EventSourceMappingConfiguration & WithEventSourceMappingArn(Aws::String &&value)
EventSourceMappingConfiguration & WithSelfManagedEventSource(const SelfManagedEventSource &value)
void SetLastProcessingResult(const char *value)
EventSourceMappingConfiguration & WithScalingConfig(const ScalingConfig &value)
const EventSourcePosition & GetStartingPosition() const
AWS_LAMBDA_API EventSourceMappingConfiguration(Aws::Utils::Json::JsonView jsonValue)
bool FunctionArnHasBeenSet() const
void SetEventSourceArn(const Aws::String &value)
bool StartingPositionHasBeenSet() const
void SetLastProcessingResult(Aws::String &&value)
bool BatchSizeHasBeenSet() const
void SetState(Aws::String &&value)
bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const
EventSourceMappingConfiguration & WithTopics(const Aws::Vector< Aws::String > &value)
const Aws::String & GetState() const
EventSourceMappingConfiguration & WithLastProcessingResult(const Aws::String &value)
const Aws::String & GetUUID() const
EventSourceMappingConfiguration & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig &&value)
bool MaximumRecordAgeInSecondsHasBeenSet() const
EventSourceMappingConfiguration & AddTopics(const char *value)
void SetFunctionResponseTypes(Aws::Vector< FunctionResponseType > &&value)
int GetMaximumBatchingWindowInSeconds() const
bool MaximumRetryAttemptsHasBeenSet() const
void SetKMSKeyArn(Aws::String &&value)
bool LastProcessingResultHasBeenSet() const
int GetTumblingWindowInSeconds() const
EventSourceMappingConfiguration & AddSourceAccessConfigurations(SourceAccessConfiguration &&value)
void SetFunctionResponseTypes(const Aws::Vector< FunctionResponseType > &value)
EventSourceMappingConfiguration & WithLastModified(const Aws::Utils::DateTime &value)
EventSourceMappingConfiguration & WithState(const char *value)
void SetSelfManagedEventSource(const SelfManagedEventSource &value)
EventSourceMappingConfiguration & AddTopics(const Aws::String &value)
bool ParallelizationFactorHasBeenSet() const
void SetParallelizationFactor(int value)
void SetFilterCriteriaError(const FilterCriteriaError &value)
EventSourceMappingConfiguration & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig &&value)
EventSourceMappingConfiguration & WithSourceAccessConfigurations(Aws::Vector< SourceAccessConfiguration > &&value)
void SetMaximumRecordAgeInSeconds(int value)
EventSourceMappingConfiguration & WithStartingPositionTimestamp(Aws::Utils::DateTime &&value)
void SetMaximumBatchingWindowInSeconds(int value)
EventSourceMappingConfiguration & WithFunctionArn(const char *value)
EventSourceMappingConfiguration & WithDestinationConfig(const DestinationConfig &value)
const FilterCriteria & GetFilterCriteria() const
EventSourceMappingConfiguration & WithUUID(const char *value)
EventSourceMappingConfiguration & WithTumblingWindowInSeconds(int value)
EventSourceMappingConfiguration & WithMaximumRetryAttempts(int value)
void SetFunctionArn(Aws::String &&value)
EventSourceMappingConfiguration & WithFilterCriteria(FilterCriteria &&value)
int GetMaximumRetryAttempts() const
void SetBisectBatchOnFunctionError(bool value)
EventSourceMappingConfiguration & WithState(Aws::String &&value)
bool UUIDHasBeenSet() const
const Aws::String & GetEventSourceArn() const
EventSourceMappingConfiguration & WithRequestId(const Aws::String &value)
EventSourceMappingConfiguration & WithUUID(const Aws::String &value)
void SetEventSourceMappingArn(Aws::String &&value)
void SetEventSourceArn(Aws::String &&value)
void SetDestinationConfig(const DestinationConfig &value)
bool TumblingWindowInSecondsHasBeenSet() const
bool EventSourceArnHasBeenSet() const
EventSourceMappingConfiguration & WithKMSKeyArn(const char *value)
bool StateTransitionReasonHasBeenSet() const
EventSourceMappingConfiguration & WithBisectBatchOnFunctionError(bool value)
bool SelfManagedEventSourceHasBeenSet() const
void SetFunctionArn(const char *value)
bool EventSourceMappingArnHasBeenSet() const
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
std::vector< T, Aws::Allocator< T > > Vector
Aws::Utils::Json::JsonValue JsonValue