7#include <aws/core/http/HttpResponse.h>
8#include <aws/core/utils/DateTime.h>
9#include <aws/core/utils/memory/stl/AWSString.h>
10#include <aws/core/utils/memory/stl/AWSVector.h>
11#include <aws/lambda/Lambda_EXPORTS.h>
12#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
13#include <aws/lambda/model/DestinationConfig.h>
14#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
15#include <aws/lambda/model/EventSourceMappingLoggingConfig.h>
16#include <aws/lambda/model/EventSourceMappingMetricsConfig.h>
17#include <aws/lambda/model/EventSourcePosition.h>
18#include <aws/lambda/model/FilterCriteria.h>
19#include <aws/lambda/model/FilterCriteriaError.h>
20#include <aws/lambda/model/FunctionResponseType.h>
21#include <aws/lambda/model/ProvisionedPollerConfig.h>
22#include <aws/lambda/model/ScalingConfig.h>
23#include <aws/lambda/model/SelfManagedEventSource.h>
24#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
25#include <aws/lambda/model/SourceAccessConfiguration.h>
30template <
typename RESULT_TYPE>
31class AmazonWebServiceResult;
57 template <
typename UUIDT = Aws::String>
59 m_uUIDHasBeenSet =
true;
60 m_uUID = std::forward<UUIDT>(value);
62 template <
typename UUIDT = Aws::String>
64 SetUUID(std::forward<UUIDT>(value));
78 m_startingPositionHasBeenSet =
true;
79 m_startingPosition = value;
94 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
96 m_startingPositionTimestampHasBeenSet =
true;
97 m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
99 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
118 m_batchSizeHasBeenSet =
true;
145 m_maximumBatchingWindowInSecondsHasBeenSet =
true;
146 m_maximumBatchingWindowInSeconds = value;
161 m_parallelizationFactorHasBeenSet =
true;
162 m_parallelizationFactor = value;
175 template <
typename EventSourceArnT = Aws::String>
177 m_eventSourceArnHasBeenSet =
true;
178 m_eventSourceArn = std::forward<EventSourceArnT>(value);
180 template <
typename EventSourceArnT = Aws::String>
199 template <
typename FilterCriteriaT = FilterCriteria>
201 m_filterCriteriaHasBeenSet =
true;
202 m_filterCriteria = std::forward<FilterCriteriaT>(value);
204 template <
typename FilterCriteriaT = FilterCriteria>
216 template <
typename FunctionArnT = Aws::String>
218 m_functionArnHasBeenSet =
true;
219 m_functionArn = std::forward<FunctionArnT>(value);
221 template <
typename FunctionArnT = Aws::String>
234 template <
typename LastModifiedT = Aws::Utils::DateTime>
236 m_lastModifiedHasBeenSet =
true;
237 m_lastModified = std::forward<LastModifiedT>(value);
239 template <
typename LastModifiedT = Aws::Utils::DateTime>
251 template <
typename LastProcessingResultT = Aws::String>
253 m_lastProcessingResultHasBeenSet =
true;
254 m_lastProcessingResult = std::forward<LastProcessingResultT>(value);
256 template <
typename LastProcessingResultT = Aws::String>
271 template <
typename StateT = Aws::String>
273 m_stateHasBeenSet =
true;
274 m_state = std::forward<StateT>(value);
276 template <
typename StateT = Aws::String>
278 SetState(std::forward<StateT>(value));
289 template <
typename StateTransitionReasonT = Aws::String>
291 m_stateTransitionReasonHasBeenSet =
true;
292 m_stateTransitionReason = std::forward<StateTransitionReasonT>(value);
294 template <
typename StateTransitionReasonT = Aws::String>
308 template <
typename DestinationConfigT = DestinationConfig>
310 m_destinationConfigHasBeenSet =
true;
311 m_destinationConfig = std::forward<DestinationConfigT>(value);
313 template <
typename DestinationConfigT = DestinationConfig>
325 template <
typename TopicsT = Aws::Vector<Aws::String>>
327 m_topicsHasBeenSet =
true;
328 m_topics = std::forward<TopicsT>(value);
330 template <
typename TopicsT = Aws::Vector<Aws::String>>
335 template <
typename TopicsT = Aws::String>
337 m_topicsHasBeenSet =
true;
338 m_topics.emplace_back(std::forward<TopicsT>(value));
349 template <
typename QueuesT = Aws::Vector<Aws::String>>
351 m_queuesHasBeenSet =
true;
352 m_queues = std::forward<QueuesT>(value);
354 template <
typename QueuesT = Aws::Vector<Aws::String>>
359 template <
typename QueuesT = Aws::String>
361 m_queuesHasBeenSet =
true;
362 m_queues.emplace_back(std::forward<QueuesT>(value));
373 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
375 m_sourceAccessConfigurationsHasBeenSet =
true;
376 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
378 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
383 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
385 m_sourceAccessConfigurationsHasBeenSet =
true;
386 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
396 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
398 m_selfManagedEventSourceHasBeenSet =
true;
399 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
401 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
419 m_maximumRecordAgeInSecondsHasBeenSet =
true;
420 m_maximumRecordAgeInSeconds = value;
436 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
437 m_bisectBatchOnFunctionError = value;
455 m_maximumRetryAttemptsHasBeenSet =
true;
456 m_maximumRetryAttempts = value;
472 m_tumblingWindowInSecondsHasBeenSet =
true;
473 m_tumblingWindowInSeconds = value;
488 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
490 m_functionResponseTypesHasBeenSet =
true;
491 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
493 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
499 m_functionResponseTypesHasBeenSet =
true;
500 m_functionResponseTypes.push_back(value);
511 return m_amazonManagedKafkaEventSourceConfig;
513 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
515 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
516 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
518 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
531 return m_selfManagedKafkaEventSourceConfig;
533 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
535 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
536 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
538 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
553 template <
typename ScalingConfigT = ScalingConfig>
555 m_scalingConfigHasBeenSet =
true;
556 m_scalingConfig = std::forward<ScalingConfigT>(value);
558 template <
typename ScalingConfigT = ScalingConfig>
570 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
572 m_documentDBEventSourceConfigHasBeenSet =
true;
573 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
575 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
590 template <
typename KMSKeyArnT = Aws::String>
592 m_kMSKeyArnHasBeenSet =
true;
593 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
595 template <
typename KMSKeyArnT = Aws::String>
608 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
610 m_filterCriteriaErrorHasBeenSet =
true;
611 m_filterCriteriaError = std::forward<FilterCriteriaErrorT>(value);
613 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
625 template <
typename EventSourceMappingArnT = Aws::String>
627 m_eventSourceMappingArnHasBeenSet =
true;
628 m_eventSourceMappingArn = std::forward<EventSourceMappingArnT>(value);
630 template <
typename EventSourceMappingArnT = Aws::String>
644 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
646 m_metricsConfigHasBeenSet =
true;
647 m_metricsConfig = std::forward<MetricsConfigT>(value);
649 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
664 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
666 m_loggingConfigHasBeenSet =
true;
667 m_loggingConfig = std::forward<LoggingConfigT>(value);
669 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
684 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
686 m_provisionedPollerConfigHasBeenSet =
true;
687 m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value);
689 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
699 template <
typename RequestIdT = Aws::String>
701 m_requestIdHasBeenSet =
true;
702 m_requestId = std::forward<RequestIdT>(value);
704 template <
typename RequestIdT = Aws::String>
721 int m_maximumBatchingWindowInSeconds{0};
723 int m_parallelizationFactor{0};
727 FilterCriteria m_filterCriteria;
739 DestinationConfig m_destinationConfig;
747 SelfManagedEventSource m_selfManagedEventSource;
749 int m_maximumRecordAgeInSeconds{0};
751 bool m_bisectBatchOnFunctionError{
false};
753 int m_maximumRetryAttempts{0};
755 int m_tumblingWindowInSeconds{0};
759 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
761 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
763 ScalingConfig m_scalingConfig;
765 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
769 FilterCriteriaError m_filterCriteriaError;
773 EventSourceMappingMetricsConfig m_metricsConfig;
775 EventSourceMappingLoggingConfig m_loggingConfig;
777 ProvisionedPollerConfig m_provisionedPollerConfig;
781 bool m_uUIDHasBeenSet =
false;
782 bool m_startingPositionHasBeenSet =
false;
783 bool m_startingPositionTimestampHasBeenSet =
false;
784 bool m_batchSizeHasBeenSet =
false;
785 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
786 bool m_parallelizationFactorHasBeenSet =
false;
787 bool m_eventSourceArnHasBeenSet =
false;
788 bool m_filterCriteriaHasBeenSet =
false;
789 bool m_functionArnHasBeenSet =
false;
790 bool m_lastModifiedHasBeenSet =
false;
791 bool m_lastProcessingResultHasBeenSet =
false;
792 bool m_stateHasBeenSet =
false;
793 bool m_stateTransitionReasonHasBeenSet =
false;
794 bool m_destinationConfigHasBeenSet =
false;
795 bool m_topicsHasBeenSet =
false;
796 bool m_queuesHasBeenSet =
false;
797 bool m_sourceAccessConfigurationsHasBeenSet =
false;
798 bool m_selfManagedEventSourceHasBeenSet =
false;
799 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
800 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
801 bool m_maximumRetryAttemptsHasBeenSet =
false;
802 bool m_tumblingWindowInSecondsHasBeenSet =
false;
803 bool m_functionResponseTypesHasBeenSet =
false;
804 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
805 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
806 bool m_scalingConfigHasBeenSet =
false;
807 bool m_documentDBEventSourceConfigHasBeenSet =
false;
808 bool m_kMSKeyArnHasBeenSet =
false;
809 bool m_filterCriteriaErrorHasBeenSet =
false;
810 bool m_eventSourceMappingArnHasBeenSet =
false;
811 bool m_metricsConfigHasBeenSet =
false;
812 bool m_loggingConfigHasBeenSet =
false;
813 bool m_provisionedPollerConfigHasBeenSet =
false;
814 bool m_requestIdHasBeenSet =
false;
UpdateEventSourceMappingResult & WithMaximumRetryAttempts(int value)
const Aws::Vector< Aws::String > & GetQueues() const
int GetMaximumBatchingWindowInSeconds() const
void SetFunctionResponseTypes(FunctionResponseTypesT &&value)
UpdateEventSourceMappingResult & WithBatchSize(int value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
const Aws::Utils::DateTime & GetStartingPositionTimestamp() const
UpdateEventSourceMappingResult & AddTopics(TopicsT &&value)
void SetTumblingWindowInSeconds(int value)
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
UpdateEventSourceMappingResult & WithProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
UpdateEventSourceMappingResult & WithStateTransitionReason(StateTransitionReasonT &&value)
UpdateEventSourceMappingResult & WithFilterCriteria(FilterCriteriaT &&value)
UpdateEventSourceMappingResult & WithBisectBatchOnFunctionError(bool value)
AWS_LAMBDA_API UpdateEventSourceMappingResult & operator=(const Aws::AmazonWebServiceResult< Aws::Utils::Json::JsonValue > &result)
void SetLastProcessingResult(LastProcessingResultT &&value)
UpdateEventSourceMappingResult & WithFunctionArn(FunctionArnT &&value)
UpdateEventSourceMappingResult & WithScalingConfig(ScalingConfigT &&value)
int GetTumblingWindowInSeconds() const
UpdateEventSourceMappingResult & AddFunctionResponseTypes(FunctionResponseType value)
void SetMaximumRecordAgeInSeconds(int value)
UpdateEventSourceMappingResult & WithFunctionResponseTypes(FunctionResponseTypesT &&value)
const Aws::String & GetState() const
const Aws::Utils::DateTime & GetLastModified() const
AWS_LAMBDA_API UpdateEventSourceMappingResult(const Aws::AmazonWebServiceResult< Aws::Utils::Json::JsonValue > &result)
void SetProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
const Aws::String & GetKMSKeyArn() const
void SetMaximumBatchingWindowInSeconds(int value)
UpdateEventSourceMappingResult & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
UpdateEventSourceMappingResult & WithParallelizationFactor(int value)
void SetParallelizationFactor(int value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
void SetSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
void SetEventSourceMappingArn(EventSourceMappingArnT &&value)
void SetFilterCriteriaError(FilterCriteriaErrorT &&value)
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
const Aws::String & GetUUID() const
void SetKMSKeyArn(KMSKeyArnT &&value)
const Aws::String & GetFunctionArn() const
const FilterCriteriaError & GetFilterCriteriaError() const
UpdateEventSourceMappingResult & WithDestinationConfig(DestinationConfigT &&value)
UpdateEventSourceMappingResult & WithTumblingWindowInSeconds(int value)
UpdateEventSourceMappingResult & WithLastProcessingResult(LastProcessingResultT &&value)
UpdateEventSourceMappingResult & WithEventSourceArn(EventSourceArnT &&value)
const Aws::String & GetRequestId() const
UpdateEventSourceMappingResult & WithSelfManagedEventSource(SelfManagedEventSourceT &&value)
void SetMetricsConfig(MetricsConfigT &&value)
bool GetBisectBatchOnFunctionError() const
UpdateEventSourceMappingResult & WithLastModified(LastModifiedT &&value)
UpdateEventSourceMappingResult & AddQueues(QueuesT &&value)
UpdateEventSourceMappingResult & WithMetricsConfig(MetricsConfigT &&value)
void SetQueues(QueuesT &&value)
UpdateEventSourceMappingResult & WithEventSourceMappingArn(EventSourceMappingArnT &&value)
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
UpdateEventSourceMappingResult & WithKMSKeyArn(KMSKeyArnT &&value)
void SetRequestId(RequestIdT &&value)
void SetFilterCriteria(FilterCriteriaT &&value)
void SetMaximumRetryAttempts(int value)
const SelfManagedEventSource & GetSelfManagedEventSource() const
UpdateEventSourceMappingResult & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
int GetParallelizationFactor() const
UpdateEventSourceMappingResult & WithRequestId(RequestIdT &&value)
int GetMaximumRecordAgeInSeconds() const
void SetTopics(TopicsT &&value)
void SetFunctionArn(FunctionArnT &&value)
UpdateEventSourceMappingResult & WithFilterCriteriaError(FilterCriteriaErrorT &&value)
UpdateEventSourceMappingResult & WithStartingPosition(EventSourcePosition value)
const ScalingConfig & GetScalingConfig() const
void SetStartingPositionTimestamp(StartingPositionTimestampT &&value)
void SetBisectBatchOnFunctionError(bool value)
void SetSelfManagedEventSource(SelfManagedEventSourceT &&value)
const Aws::String & GetStateTransitionReason() const
UpdateEventSourceMappingResult & WithQueues(QueuesT &&value)
Aws::Http::HttpResponseCode GetHttpResponseCode() const
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
const Aws::String & GetEventSourceArn() const
const Aws::String & GetEventSourceMappingArn() const
void SetUUID(UUIDT &&value)
UpdateEventSourceMappingResult & WithSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
UpdateEventSourceMappingResult & WithState(StateT &&value)
UpdateEventSourceMappingResult & WithMaximumRecordAgeInSeconds(int value)
void SetStateTransitionReason(StateTransitionReasonT &&value)
void SetEventSourceArn(EventSourceArnT &&value)
const EventSourceMappingLoggingConfig & GetLoggingConfig() const
void SetLoggingConfig(LoggingConfigT &&value)
const Aws::String & GetLastProcessingResult() const
EventSourcePosition GetStartingPosition() const
int GetMaximumRetryAttempts() const
const EventSourceMappingMetricsConfig & GetMetricsConfig() const
const Aws::Vector< Aws::String > & GetTopics() const
const FilterCriteria & GetFilterCriteria() const
UpdateEventSourceMappingResult & WithStartingPositionTimestamp(StartingPositionTimestampT &&value)
void SetState(StateT &&value)
void SetBatchSize(int value)
const ProvisionedPollerConfig & GetProvisionedPollerConfig() const
UpdateEventSourceMappingResult & WithLoggingConfig(LoggingConfigT &&value)
UpdateEventSourceMappingResult & WithUUID(UUIDT &&value)
void SetDestinationConfig(DestinationConfigT &&value)
UpdateEventSourceMappingResult & WithMaximumBatchingWindowInSeconds(int value)
AWS_LAMBDA_API UpdateEventSourceMappingResult()=default
void SetLastModified(LastModifiedT &&value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
void SetStartingPosition(EventSourcePosition value)
void SetScalingConfig(ScalingConfigT &&value)
UpdateEventSourceMappingResult & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
const DestinationConfig & GetDestinationConfig() const
UpdateEventSourceMappingResult & AddSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
UpdateEventSourceMappingResult & WithTopics(TopicsT &&value)
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
std::vector< T, Aws::Allocator< T > > Vector
Aws::Utils::Json::JsonValue JsonValue