7#include <aws/core/utils/DateTime.h>
8#include <aws/core/utils/memory/stl/AWSString.h>
9#include <aws/core/utils/memory/stl/AWSVector.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/EventSourceMappingMetricsConfig.h>
15#include <aws/lambda/model/EventSourcePosition.h>
16#include <aws/lambda/model/FilterCriteria.h>
17#include <aws/lambda/model/FilterCriteriaError.h>
18#include <aws/lambda/model/FunctionResponseType.h>
19#include <aws/lambda/model/ProvisionedPollerConfig.h>
20#include <aws/lambda/model/ScalingConfig.h>
21#include <aws/lambda/model/SelfManagedEventSource.h>
22#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
23#include <aws/lambda/model/SourceAccessConfiguration.h>
28template <
typename RESULT_TYPE>
29class AmazonWebServiceResult;
55 template <
typename UUIDT = Aws::String>
57 m_uUIDHasBeenSet =
true;
58 m_uUID = std::forward<UUIDT>(value);
60 template <
typename UUIDT = Aws::String>
62 SetUUID(std::forward<UUIDT>(value));
76 m_startingPositionHasBeenSet =
true;
77 m_startingPosition = value;
92 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
94 m_startingPositionTimestampHasBeenSet =
true;
95 m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
97 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
116 m_batchSizeHasBeenSet =
true;
143 m_maximumBatchingWindowInSecondsHasBeenSet =
true;
144 m_maximumBatchingWindowInSeconds = value;
159 m_parallelizationFactorHasBeenSet =
true;
160 m_parallelizationFactor = value;
173 template <
typename EventSourceArnT = Aws::String>
175 m_eventSourceArnHasBeenSet =
true;
176 m_eventSourceArn = std::forward<EventSourceArnT>(value);
178 template <
typename EventSourceArnT = Aws::String>
197 template <
typename FilterCriteriaT = FilterCriteria>
199 m_filterCriteriaHasBeenSet =
true;
200 m_filterCriteria = std::forward<FilterCriteriaT>(value);
202 template <
typename FilterCriteriaT = FilterCriteria>
214 template <
typename FunctionArnT = Aws::String>
216 m_functionArnHasBeenSet =
true;
217 m_functionArn = std::forward<FunctionArnT>(value);
219 template <
typename FunctionArnT = Aws::String>
232 template <
typename LastModifiedT = Aws::Utils::DateTime>
234 m_lastModifiedHasBeenSet =
true;
235 m_lastModified = std::forward<LastModifiedT>(value);
237 template <
typename LastModifiedT = Aws::Utils::DateTime>
249 template <
typename LastProcessingResultT = Aws::String>
251 m_lastProcessingResultHasBeenSet =
true;
252 m_lastProcessingResult = std::forward<LastProcessingResultT>(value);
254 template <
typename LastProcessingResultT = Aws::String>
269 template <
typename StateT = Aws::String>
271 m_stateHasBeenSet =
true;
272 m_state = std::forward<StateT>(value);
274 template <
typename StateT = Aws::String>
276 SetState(std::forward<StateT>(value));
287 template <
typename StateTransitionReasonT = Aws::String>
289 m_stateTransitionReasonHasBeenSet =
true;
290 m_stateTransitionReason = std::forward<StateTransitionReasonT>(value);
292 template <
typename StateTransitionReasonT = Aws::String>
306 template <
typename DestinationConfigT = DestinationConfig>
308 m_destinationConfigHasBeenSet =
true;
309 m_destinationConfig = std::forward<DestinationConfigT>(value);
311 template <
typename DestinationConfigT = DestinationConfig>
323 template <
typename TopicsT = Aws::Vector<Aws::String>>
325 m_topicsHasBeenSet =
true;
326 m_topics = std::forward<TopicsT>(value);
328 template <
typename TopicsT = Aws::Vector<Aws::String>>
333 template <
typename TopicsT = Aws::String>
335 m_topicsHasBeenSet =
true;
336 m_topics.emplace_back(std::forward<TopicsT>(value));
347 template <
typename QueuesT = Aws::Vector<Aws::String>>
349 m_queuesHasBeenSet =
true;
350 m_queues = std::forward<QueuesT>(value);
352 template <
typename QueuesT = Aws::Vector<Aws::String>>
357 template <
typename QueuesT = Aws::String>
359 m_queuesHasBeenSet =
true;
360 m_queues.emplace_back(std::forward<QueuesT>(value));
371 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
373 m_sourceAccessConfigurationsHasBeenSet =
true;
374 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
376 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
381 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
383 m_sourceAccessConfigurationsHasBeenSet =
true;
384 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
394 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
396 m_selfManagedEventSourceHasBeenSet =
true;
397 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
399 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
417 m_maximumRecordAgeInSecondsHasBeenSet =
true;
418 m_maximumRecordAgeInSeconds = value;
434 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
435 m_bisectBatchOnFunctionError = value;
453 m_maximumRetryAttemptsHasBeenSet =
true;
454 m_maximumRetryAttempts = value;
470 m_tumblingWindowInSecondsHasBeenSet =
true;
471 m_tumblingWindowInSeconds = value;
486 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
488 m_functionResponseTypesHasBeenSet =
true;
489 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
491 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
497 m_functionResponseTypesHasBeenSet =
true;
498 m_functionResponseTypes.push_back(value);
509 return m_amazonManagedKafkaEventSourceConfig;
511 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
513 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
514 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
516 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
529 return m_selfManagedKafkaEventSourceConfig;
531 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
533 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
534 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
536 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
551 template <
typename ScalingConfigT = ScalingConfig>
553 m_scalingConfigHasBeenSet =
true;
554 m_scalingConfig = std::forward<ScalingConfigT>(value);
556 template <
typename ScalingConfigT = ScalingConfig>
568 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
570 m_documentDBEventSourceConfigHasBeenSet =
true;
571 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
573 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
588 template <
typename KMSKeyArnT = Aws::String>
590 m_kMSKeyArnHasBeenSet =
true;
591 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
593 template <
typename KMSKeyArnT = Aws::String>
606 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
608 m_filterCriteriaErrorHasBeenSet =
true;
609 m_filterCriteriaError = std::forward<FilterCriteriaErrorT>(value);
611 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
623 template <
typename EventSourceMappingArnT = Aws::String>
625 m_eventSourceMappingArnHasBeenSet =
true;
626 m_eventSourceMappingArn = std::forward<EventSourceMappingArnT>(value);
628 template <
typename EventSourceMappingArnT = Aws::String>
642 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
644 m_metricsConfigHasBeenSet =
true;
645 m_metricsConfig = std::forward<MetricsConfigT>(value);
647 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
662 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
664 m_provisionedPollerConfigHasBeenSet =
true;
665 m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value);
667 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
677 template <
typename RequestIdT = Aws::String>
679 m_requestIdHasBeenSet =
true;
680 m_requestId = std::forward<RequestIdT>(value);
682 template <
typename RequestIdT = Aws::String>
697 int m_maximumBatchingWindowInSeconds{0};
699 int m_parallelizationFactor{0};
703 FilterCriteria m_filterCriteria;
715 DestinationConfig m_destinationConfig;
723 SelfManagedEventSource m_selfManagedEventSource;
725 int m_maximumRecordAgeInSeconds{0};
727 bool m_bisectBatchOnFunctionError{
false};
729 int m_maximumRetryAttempts{0};
731 int m_tumblingWindowInSeconds{0};
735 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
737 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
739 ScalingConfig m_scalingConfig;
741 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
745 FilterCriteriaError m_filterCriteriaError;
749 EventSourceMappingMetricsConfig m_metricsConfig;
751 ProvisionedPollerConfig m_provisionedPollerConfig;
754 bool m_uUIDHasBeenSet =
false;
755 bool m_startingPositionHasBeenSet =
false;
756 bool m_startingPositionTimestampHasBeenSet =
false;
757 bool m_batchSizeHasBeenSet =
false;
758 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
759 bool m_parallelizationFactorHasBeenSet =
false;
760 bool m_eventSourceArnHasBeenSet =
false;
761 bool m_filterCriteriaHasBeenSet =
false;
762 bool m_functionArnHasBeenSet =
false;
763 bool m_lastModifiedHasBeenSet =
false;
764 bool m_lastProcessingResultHasBeenSet =
false;
765 bool m_stateHasBeenSet =
false;
766 bool m_stateTransitionReasonHasBeenSet =
false;
767 bool m_destinationConfigHasBeenSet =
false;
768 bool m_topicsHasBeenSet =
false;
769 bool m_queuesHasBeenSet =
false;
770 bool m_sourceAccessConfigurationsHasBeenSet =
false;
771 bool m_selfManagedEventSourceHasBeenSet =
false;
772 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
773 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
774 bool m_maximumRetryAttemptsHasBeenSet =
false;
775 bool m_tumblingWindowInSecondsHasBeenSet =
false;
776 bool m_functionResponseTypesHasBeenSet =
false;
777 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
778 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
779 bool m_scalingConfigHasBeenSet =
false;
780 bool m_documentDBEventSourceConfigHasBeenSet =
false;
781 bool m_kMSKeyArnHasBeenSet =
false;
782 bool m_filterCriteriaErrorHasBeenSet =
false;
783 bool m_eventSourceMappingArnHasBeenSet =
false;
784 bool m_metricsConfigHasBeenSet =
false;
785 bool m_provisionedPollerConfigHasBeenSet =
false;
786 bool m_requestIdHasBeenSet =
false;
CreateEventSourceMappingResult & WithFunctionResponseTypes(FunctionResponseTypesT &&value)
CreateEventSourceMappingResult & WithTopics(TopicsT &&value)
CreateEventSourceMappingResult & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
bool GetBisectBatchOnFunctionError() const
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
CreateEventSourceMappingResult & WithFilterCriteria(FilterCriteriaT &&value)
void SetSelfManagedEventSource(SelfManagedEventSourceT &&value)
CreateEventSourceMappingResult & AddSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
CreateEventSourceMappingResult & WithDestinationConfig(DestinationConfigT &&value)
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
void SetProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
void SetBisectBatchOnFunctionError(bool value)
CreateEventSourceMappingResult & WithStartingPositionTimestamp(StartingPositionTimestampT &&value)
CreateEventSourceMappingResult & WithState(StateT &&value)
EventSourcePosition GetStartingPosition() const
void SetFilterCriteriaError(FilterCriteriaErrorT &&value)
CreateEventSourceMappingResult & WithFilterCriteriaError(FilterCriteriaErrorT &&value)
CreateEventSourceMappingResult & WithEventSourceArn(EventSourceArnT &&value)
CreateEventSourceMappingResult & WithMaximumRetryAttempts(int value)
CreateEventSourceMappingResult & WithEventSourceMappingArn(EventSourceMappingArnT &&value)
const Aws::String & GetKMSKeyArn() const
int GetTumblingWindowInSeconds() const
AWS_LAMBDA_API CreateEventSourceMappingResult()=default
CreateEventSourceMappingResult & WithBisectBatchOnFunctionError(bool value)
const ScalingConfig & GetScalingConfig() const
void SetStartingPositionTimestamp(StartingPositionTimestampT &&value)
const Aws::String & GetUUID() const
void SetBatchSize(int value)
CreateEventSourceMappingResult & WithProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
CreateEventSourceMappingResult & AddQueues(QueuesT &&value)
const FilterCriteria & GetFilterCriteria() const
const Aws::Utils::DateTime & GetLastModified() const
AWS_LAMBDA_API CreateEventSourceMappingResult(const Aws::AmazonWebServiceResult< Aws::Utils::Json::JsonValue > &result)
CreateEventSourceMappingResult & WithStateTransitionReason(StateTransitionReasonT &&value)
int GetParallelizationFactor() const
AWS_LAMBDA_API CreateEventSourceMappingResult & operator=(const Aws::AmazonWebServiceResult< Aws::Utils::Json::JsonValue > &result)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
void SetFunctionResponseTypes(FunctionResponseTypesT &&value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
void SetRequestId(RequestIdT &&value)
CreateEventSourceMappingResult & WithMaximumRecordAgeInSeconds(int value)
void SetMaximumRetryAttempts(int value)
CreateEventSourceMappingResult & WithSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
int GetMaximumRecordAgeInSeconds() const
void SetMaximumBatchingWindowInSeconds(int value)
void SetSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
const Aws::Utils::DateTime & GetStartingPositionTimestamp() const
void SetEventSourceMappingArn(EventSourceMappingArnT &&value)
void SetMetricsConfig(MetricsConfigT &&value)
CreateEventSourceMappingResult & WithSelfManagedEventSource(SelfManagedEventSourceT &&value)
void SetScalingConfig(ScalingConfigT &&value)
void SetDestinationConfig(DestinationConfigT &&value)
void SetStateTransitionReason(StateTransitionReasonT &&value)
CreateEventSourceMappingResult & WithFunctionArn(FunctionArnT &&value)
CreateEventSourceMappingResult & WithStartingPosition(EventSourcePosition value)
CreateEventSourceMappingResult & WithQueues(QueuesT &&value)
CreateEventSourceMappingResult & WithKMSKeyArn(KMSKeyArnT &&value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
const ProvisionedPollerConfig & GetProvisionedPollerConfig() const
CreateEventSourceMappingResult & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
const EventSourceMappingMetricsConfig & GetMetricsConfig() const
CreateEventSourceMappingResult & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
const Aws::Vector< Aws::String > & GetQueues() const
CreateEventSourceMappingResult & AddFunctionResponseTypes(FunctionResponseType value)
CreateEventSourceMappingResult & WithLastModified(LastModifiedT &&value)
void SetLastModified(LastModifiedT &&value)
CreateEventSourceMappingResult & WithRequestId(RequestIdT &&value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
void SetUUID(UUIDT &&value)
const SelfManagedEventSource & GetSelfManagedEventSource() const
CreateEventSourceMappingResult & AddTopics(TopicsT &&value)
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
void SetTumblingWindowInSeconds(int value)
void SetLastProcessingResult(LastProcessingResultT &&value)
void SetMaximumRecordAgeInSeconds(int value)
const FilterCriteriaError & GetFilterCriteriaError() const
const Aws::String & GetEventSourceArn() const
CreateEventSourceMappingResult & WithScalingConfig(ScalingConfigT &&value)
CreateEventSourceMappingResult & WithMaximumBatchingWindowInSeconds(int value)
void SetFilterCriteria(FilterCriteriaT &&value)
const Aws::String & GetFunctionArn() const
void SetQueues(QueuesT &&value)
void SetState(StateT &&value)
const Aws::String & GetRequestId() const
const DestinationConfig & GetDestinationConfig() const
CreateEventSourceMappingResult & WithMetricsConfig(MetricsConfigT &&value)
const Aws::Vector< Aws::String > & GetTopics() const
const Aws::String & GetEventSourceMappingArn() const
const Aws::String & GetState() const
CreateEventSourceMappingResult & WithBatchSize(int value)
CreateEventSourceMappingResult & WithLastProcessingResult(LastProcessingResultT &&value)
const Aws::String & GetLastProcessingResult() const
void SetEventSourceArn(EventSourceArnT &&value)
CreateEventSourceMappingResult & WithTumblingWindowInSeconds(int value)
const Aws::String & GetStateTransitionReason() const
void SetStartingPosition(EventSourcePosition value)
void SetTopics(TopicsT &&value)
void SetKMSKeyArn(KMSKeyArnT &&value)
int GetMaximumRetryAttempts() const
CreateEventSourceMappingResult & WithUUID(UUIDT &&value)
void SetParallelizationFactor(int value)
void SetFunctionArn(FunctionArnT &&value)
CreateEventSourceMappingResult & WithParallelizationFactor(int value)
int GetMaximumBatchingWindowInSeconds() 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