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>
217 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
219 m_filterCriteriaErrorHasBeenSet =
true;
220 m_filterCriteriaError = std::forward<FilterCriteriaErrorT>(value);
222 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
237 template <
typename KMSKeyArnT = Aws::String>
239 m_kMSKeyArnHasBeenSet =
true;
240 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
242 template <
typename KMSKeyArnT = Aws::String>
256 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
258 m_metricsConfigHasBeenSet =
true;
259 m_metricsConfig = std::forward<MetricsConfigT>(value);
261 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
276 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
278 m_loggingConfigHasBeenSet =
true;
279 m_loggingConfig = std::forward<LoggingConfigT>(value);
281 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
296 template <
typename ScalingConfigT = ScalingConfig>
298 m_scalingConfigHasBeenSet =
true;
299 m_scalingConfig = std::forward<ScalingConfigT>(value);
301 template <
typename ScalingConfigT = ScalingConfig>
313 template <
typename FunctionArnT = Aws::String>
315 m_functionArnHasBeenSet =
true;
316 m_functionArn = std::forward<FunctionArnT>(value);
318 template <
typename FunctionArnT = Aws::String>
331 template <
typename LastModifiedT = Aws::Utils::DateTime>
333 m_lastModifiedHasBeenSet =
true;
334 m_lastModified = std::forward<LastModifiedT>(value);
336 template <
typename LastModifiedT = Aws::Utils::DateTime>
348 template <
typename LastProcessingResultT = Aws::String>
350 m_lastProcessingResultHasBeenSet =
true;
351 m_lastProcessingResult = std::forward<LastProcessingResultT>(value);
353 template <
typename LastProcessingResultT = Aws::String>
368 template <
typename StateT = Aws::String>
370 m_stateHasBeenSet =
true;
371 m_state = std::forward<StateT>(value);
373 template <
typename StateT = Aws::String>
375 SetState(std::forward<StateT>(value));
386 template <
typename StateTransitionReasonT = Aws::String>
388 m_stateTransitionReasonHasBeenSet =
true;
389 m_stateTransitionReason = std::forward<StateTransitionReasonT>(value);
391 template <
typename StateTransitionReasonT = Aws::String>
405 template <
typename DestinationConfigT = DestinationConfig>
407 m_destinationConfigHasBeenSet =
true;
408 m_destinationConfig = std::forward<DestinationConfigT>(value);
410 template <
typename DestinationConfigT = DestinationConfig>
422 template <
typename TopicsT = Aws::Vector<Aws::String>>
424 m_topicsHasBeenSet =
true;
425 m_topics = std::forward<TopicsT>(value);
427 template <
typename TopicsT = Aws::Vector<Aws::String>>
432 template <
typename TopicsT = Aws::String>
434 m_topicsHasBeenSet =
true;
435 m_topics.emplace_back(std::forward<TopicsT>(value));
446 template <
typename QueuesT = Aws::Vector<Aws::String>>
448 m_queuesHasBeenSet =
true;
449 m_queues = std::forward<QueuesT>(value);
451 template <
typename QueuesT = Aws::Vector<Aws::String>>
456 template <
typename QueuesT = Aws::String>
458 m_queuesHasBeenSet =
true;
459 m_queues.emplace_back(std::forward<QueuesT>(value));
470 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
472 m_sourceAccessConfigurationsHasBeenSet =
true;
473 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
475 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
480 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
482 m_sourceAccessConfigurationsHasBeenSet =
true;
483 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
493 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
495 m_selfManagedEventSourceHasBeenSet =
true;
496 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
498 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
516 m_maximumRecordAgeInSecondsHasBeenSet =
true;
517 m_maximumRecordAgeInSeconds = value;
533 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
534 m_bisectBatchOnFunctionError = value;
552 m_maximumRetryAttemptsHasBeenSet =
true;
553 m_maximumRetryAttempts = value;
569 m_tumblingWindowInSecondsHasBeenSet =
true;
570 m_tumblingWindowInSeconds = value;
585 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
587 m_functionResponseTypesHasBeenSet =
true;
588 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
590 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
596 m_functionResponseTypesHasBeenSet =
true;
597 m_functionResponseTypes.push_back(value);
608 return m_amazonManagedKafkaEventSourceConfig;
610 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
612 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
613 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
615 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
628 return m_selfManagedKafkaEventSourceConfig;
630 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
632 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
633 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
635 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
647 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
649 m_documentDBEventSourceConfigHasBeenSet =
true;
650 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
652 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
664 template <
typename EventSourceMappingArnT = Aws::String>
666 m_eventSourceMappingArnHasBeenSet =
true;
667 m_eventSourceMappingArn = std::forward<EventSourceMappingArnT>(value);
669 template <
typename EventSourceMappingArnT = Aws::String>
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;
729 FilterCriteriaError m_filterCriteriaError;
733 EventSourceMappingMetricsConfig m_metricsConfig;
735 EventSourceMappingLoggingConfig m_loggingConfig;
737 ScalingConfig m_scalingConfig;
749 DestinationConfig m_destinationConfig;
757 SelfManagedEventSource m_selfManagedEventSource;
759 int m_maximumRecordAgeInSeconds{0};
761 bool m_bisectBatchOnFunctionError{
false};
763 int m_maximumRetryAttempts{0};
765 int m_tumblingWindowInSeconds{0};
769 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
771 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
773 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
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_filterCriteriaErrorHasBeenSet =
false;
790 bool m_kMSKeyArnHasBeenSet =
false;
791 bool m_metricsConfigHasBeenSet =
false;
792 bool m_loggingConfigHasBeenSet =
false;
793 bool m_scalingConfigHasBeenSet =
false;
794 bool m_functionArnHasBeenSet =
false;
795 bool m_lastModifiedHasBeenSet =
false;
796 bool m_lastProcessingResultHasBeenSet =
false;
797 bool m_stateHasBeenSet =
false;
798 bool m_stateTransitionReasonHasBeenSet =
false;
799 bool m_destinationConfigHasBeenSet =
false;
800 bool m_topicsHasBeenSet =
false;
801 bool m_queuesHasBeenSet =
false;
802 bool m_sourceAccessConfigurationsHasBeenSet =
false;
803 bool m_selfManagedEventSourceHasBeenSet =
false;
804 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
805 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
806 bool m_maximumRetryAttemptsHasBeenSet =
false;
807 bool m_tumblingWindowInSecondsHasBeenSet =
false;
808 bool m_functionResponseTypesHasBeenSet =
false;
809 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
810 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
811 bool m_documentDBEventSourceConfigHasBeenSet =
false;
812 bool m_eventSourceMappingArnHasBeenSet =
false;
813 bool m_provisionedPollerConfigHasBeenSet =
false;
814 bool m_requestIdHasBeenSet =
false;