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));
79 m_startingPositionHasBeenSet =
true;
80 m_startingPosition = value;
96 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
98 m_startingPositionTimestampHasBeenSet =
true;
99 m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
101 template <
typename StartingPositionTimestampT = Aws::Utils::DateTime>
121 m_batchSizeHasBeenSet =
true;
149 m_maximumBatchingWindowInSecondsHasBeenSet =
true;
150 m_maximumBatchingWindowInSeconds = value;
166 m_parallelizationFactorHasBeenSet =
true;
167 m_parallelizationFactor = value;
181 template <
typename EventSourceArnT = Aws::String>
183 m_eventSourceArnHasBeenSet =
true;
184 m_eventSourceArn = std::forward<EventSourceArnT>(value);
186 template <
typename EventSourceArnT = Aws::String>
206 template <
typename FilterCriteriaT = FilterCriteria>
208 m_filterCriteriaHasBeenSet =
true;
209 m_filterCriteria = std::forward<FilterCriteriaT>(value);
211 template <
typename FilterCriteriaT = FilterCriteria>
225 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
227 m_filterCriteriaErrorHasBeenSet =
true;
228 m_filterCriteriaError = std::forward<FilterCriteriaErrorT>(value);
230 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
246 template <
typename KMSKeyArnT = Aws::String>
248 m_kMSKeyArnHasBeenSet =
true;
249 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
251 template <
typename KMSKeyArnT = Aws::String>
266 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
268 m_metricsConfigHasBeenSet =
true;
269 m_metricsConfig = std::forward<MetricsConfigT>(value);
271 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
287 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
289 m_loggingConfigHasBeenSet =
true;
290 m_loggingConfig = std::forward<LoggingConfigT>(value);
292 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
308 template <
typename ScalingConfigT = ScalingConfig>
310 m_scalingConfigHasBeenSet =
true;
311 m_scalingConfig = std::forward<ScalingConfigT>(value);
313 template <
typename ScalingConfigT = ScalingConfig>
326 template <
typename FunctionArnT = Aws::String>
328 m_functionArnHasBeenSet =
true;
329 m_functionArn = std::forward<FunctionArnT>(value);
331 template <
typename FunctionArnT = Aws::String>
345 template <
typename LastModifiedT = Aws::Utils::DateTime>
347 m_lastModifiedHasBeenSet =
true;
348 m_lastModified = std::forward<LastModifiedT>(value);
350 template <
typename LastModifiedT = Aws::Utils::DateTime>
363 template <
typename LastProcessingResultT = Aws::String>
365 m_lastProcessingResultHasBeenSet =
true;
366 m_lastProcessingResult = std::forward<LastProcessingResultT>(value);
368 template <
typename LastProcessingResultT = Aws::String>
384 template <
typename StateT = Aws::String>
386 m_stateHasBeenSet =
true;
387 m_state = std::forward<StateT>(value);
389 template <
typename StateT = Aws::String>
391 SetState(std::forward<StateT>(value));
403 template <
typename StateTransitionReasonT = Aws::String>
405 m_stateTransitionReasonHasBeenSet =
true;
406 m_stateTransitionReason = std::forward<StateTransitionReasonT>(value);
408 template <
typename StateTransitionReasonT = Aws::String>
423 template <
typename DestinationConfigT = DestinationConfig>
425 m_destinationConfigHasBeenSet =
true;
426 m_destinationConfig = std::forward<DestinationConfigT>(value);
428 template <
typename DestinationConfigT = DestinationConfig>
441 template <
typename TopicsT = Aws::Vector<Aws::String>>
443 m_topicsHasBeenSet =
true;
444 m_topics = std::forward<TopicsT>(value);
446 template <
typename TopicsT = Aws::Vector<Aws::String>>
451 template <
typename TopicsT = Aws::String>
453 m_topicsHasBeenSet =
true;
454 m_topics.emplace_back(std::forward<TopicsT>(value));
466 template <
typename QueuesT = Aws::Vector<Aws::String>>
468 m_queuesHasBeenSet =
true;
469 m_queues = std::forward<QueuesT>(value);
471 template <
typename QueuesT = Aws::Vector<Aws::String>>
476 template <
typename QueuesT = Aws::String>
478 m_queuesHasBeenSet =
true;
479 m_queues.emplace_back(std::forward<QueuesT>(value));
491 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
493 m_sourceAccessConfigurationsHasBeenSet =
true;
494 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
496 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
501 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
503 m_sourceAccessConfigurationsHasBeenSet =
true;
504 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
515 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
517 m_selfManagedEventSourceHasBeenSet =
true;
518 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
520 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
539 m_maximumRecordAgeInSecondsHasBeenSet =
true;
540 m_maximumRecordAgeInSeconds = value;
557 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
558 m_bisectBatchOnFunctionError = value;
577 m_maximumRetryAttemptsHasBeenSet =
true;
578 m_maximumRetryAttempts = value;
595 m_tumblingWindowInSecondsHasBeenSet =
true;
596 m_tumblingWindowInSeconds = value;
612 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
614 m_functionResponseTypesHasBeenSet =
true;
615 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
617 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
623 m_functionResponseTypesHasBeenSet =
true;
624 m_functionResponseTypes.push_back(value);
635 return m_amazonManagedKafkaEventSourceConfig;
638 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
640 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
641 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
643 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
656 return m_selfManagedKafkaEventSourceConfig;
659 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
661 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
662 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
664 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
677 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
679 m_documentDBEventSourceConfigHasBeenSet =
true;
680 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
682 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
695 template <
typename EventSourceMappingArnT = Aws::String>
697 m_eventSourceMappingArnHasBeenSet =
true;
698 m_eventSourceMappingArn = std::forward<EventSourceMappingArnT>(value);
700 template <
typename EventSourceMappingArnT = Aws::String>
716 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
718 m_provisionedPollerConfigHasBeenSet =
true;
719 m_provisionedPollerConfig = std::forward<ProvisionedPollerConfigT>(value);
721 template <
typename ProvisionedPollerConfigT = ProvisionedPollerConfig>
732 template <
typename RequestIdT = Aws::String>
734 m_requestIdHasBeenSet =
true;
735 m_requestId = std::forward<RequestIdT>(value);
737 template <
typename RequestIdT = Aws::String>
752 int m_maximumBatchingWindowInSeconds{0};
754 int m_parallelizationFactor{0};
758 FilterCriteria m_filterCriteria;
760 FilterCriteriaError m_filterCriteriaError;
764 EventSourceMappingMetricsConfig m_metricsConfig;
766 EventSourceMappingLoggingConfig m_loggingConfig;
768 ScalingConfig m_scalingConfig;
780 DestinationConfig m_destinationConfig;
788 SelfManagedEventSource m_selfManagedEventSource;
790 int m_maximumRecordAgeInSeconds{0};
792 bool m_bisectBatchOnFunctionError{
false};
794 int m_maximumRetryAttempts{0};
796 int m_tumblingWindowInSeconds{0};
800 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
802 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
804 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
808 ProvisionedPollerConfig m_provisionedPollerConfig;
811 bool m_uUIDHasBeenSet =
false;
812 bool m_startingPositionHasBeenSet =
false;
813 bool m_startingPositionTimestampHasBeenSet =
false;
814 bool m_batchSizeHasBeenSet =
false;
815 bool m_maximumBatchingWindowInSecondsHasBeenSet =
false;
816 bool m_parallelizationFactorHasBeenSet =
false;
817 bool m_eventSourceArnHasBeenSet =
false;
818 bool m_filterCriteriaHasBeenSet =
false;
819 bool m_filterCriteriaErrorHasBeenSet =
false;
820 bool m_kMSKeyArnHasBeenSet =
false;
821 bool m_metricsConfigHasBeenSet =
false;
822 bool m_loggingConfigHasBeenSet =
false;
823 bool m_scalingConfigHasBeenSet =
false;
824 bool m_functionArnHasBeenSet =
false;
825 bool m_lastModifiedHasBeenSet =
false;
826 bool m_lastProcessingResultHasBeenSet =
false;
827 bool m_stateHasBeenSet =
false;
828 bool m_stateTransitionReasonHasBeenSet =
false;
829 bool m_destinationConfigHasBeenSet =
false;
830 bool m_topicsHasBeenSet =
false;
831 bool m_queuesHasBeenSet =
false;
832 bool m_sourceAccessConfigurationsHasBeenSet =
false;
833 bool m_selfManagedEventSourceHasBeenSet =
false;
834 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
835 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
836 bool m_maximumRetryAttemptsHasBeenSet =
false;
837 bool m_tumblingWindowInSecondsHasBeenSet =
false;
838 bool m_functionResponseTypesHasBeenSet =
false;
839 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
840 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
841 bool m_documentDBEventSourceConfigHasBeenSet =
false;
842 bool m_eventSourceMappingArnHasBeenSet =
false;
843 bool m_provisionedPollerConfigHasBeenSet =
false;
844 bool m_requestIdHasBeenSet =
false;