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/EventSourceMappingLoggingConfig.h>
15#include <aws/lambda/model/EventSourceMappingMetricsConfig.h>
16#include <aws/lambda/model/EventSourcePosition.h>
17#include <aws/lambda/model/FilterCriteria.h>
18#include <aws/lambda/model/FilterCriteriaError.h>
19#include <aws/lambda/model/FunctionResponseType.h>
20#include <aws/lambda/model/ProvisionedPollerConfig.h>
21#include <aws/lambda/model/ScalingConfig.h>
22#include <aws/lambda/model/SelfManagedEventSource.h>
23#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
24#include <aws/lambda/model/SourceAccessConfiguration.h>
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>
224 template <
typename FunctionArnT = Aws::String>
226 m_functionArnHasBeenSet =
true;
227 m_functionArn = std::forward<FunctionArnT>(value);
229 template <
typename FunctionArnT = Aws::String>
243 template <
typename LastModifiedT = Aws::Utils::DateTime>
245 m_lastModifiedHasBeenSet =
true;
246 m_lastModified = std::forward<LastModifiedT>(value);
248 template <
typename LastModifiedT = Aws::Utils::DateTime>
261 template <
typename LastProcessingResultT = Aws::String>
263 m_lastProcessingResultHasBeenSet =
true;
264 m_lastProcessingResult = std::forward<LastProcessingResultT>(value);
266 template <
typename LastProcessingResultT = Aws::String>
282 template <
typename StateT = Aws::String>
284 m_stateHasBeenSet =
true;
285 m_state = std::forward<StateT>(value);
287 template <
typename StateT = Aws::String>
289 SetState(std::forward<StateT>(value));
301 template <
typename StateTransitionReasonT = Aws::String>
303 m_stateTransitionReasonHasBeenSet =
true;
304 m_stateTransitionReason = std::forward<StateTransitionReasonT>(value);
306 template <
typename StateTransitionReasonT = Aws::String>
321 template <
typename DestinationConfigT = DestinationConfig>
323 m_destinationConfigHasBeenSet =
true;
324 m_destinationConfig = std::forward<DestinationConfigT>(value);
326 template <
typename DestinationConfigT = DestinationConfig>
339 template <
typename TopicsT = Aws::Vector<Aws::String>>
341 m_topicsHasBeenSet =
true;
342 m_topics = std::forward<TopicsT>(value);
344 template <
typename TopicsT = Aws::Vector<Aws::String>>
349 template <
typename TopicsT = Aws::String>
351 m_topicsHasBeenSet =
true;
352 m_topics.emplace_back(std::forward<TopicsT>(value));
364 template <
typename QueuesT = Aws::Vector<Aws::String>>
366 m_queuesHasBeenSet =
true;
367 m_queues = std::forward<QueuesT>(value);
369 template <
typename QueuesT = Aws::Vector<Aws::String>>
374 template <
typename QueuesT = Aws::String>
376 m_queuesHasBeenSet =
true;
377 m_queues.emplace_back(std::forward<QueuesT>(value));
389 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
391 m_sourceAccessConfigurationsHasBeenSet =
true;
392 m_sourceAccessConfigurations = std::forward<SourceAccessConfigurationsT>(value);
394 template <
typename SourceAccessConfigurationsT = Aws::Vector<SourceAccessConfiguration>>
399 template <
typename SourceAccessConfigurationsT = SourceAccessConfiguration>
401 m_sourceAccessConfigurationsHasBeenSet =
true;
402 m_sourceAccessConfigurations.emplace_back(std::forward<SourceAccessConfigurationsT>(value));
413 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
415 m_selfManagedEventSourceHasBeenSet =
true;
416 m_selfManagedEventSource = std::forward<SelfManagedEventSourceT>(value);
418 template <
typename SelfManagedEventSourceT = SelfManagedEventSource>
437 m_maximumRecordAgeInSecondsHasBeenSet =
true;
438 m_maximumRecordAgeInSeconds = value;
455 m_bisectBatchOnFunctionErrorHasBeenSet =
true;
456 m_bisectBatchOnFunctionError = value;
475 m_maximumRetryAttemptsHasBeenSet =
true;
476 m_maximumRetryAttempts = value;
493 m_tumblingWindowInSecondsHasBeenSet =
true;
494 m_tumblingWindowInSeconds = value;
510 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
512 m_functionResponseTypesHasBeenSet =
true;
513 m_functionResponseTypes = std::forward<FunctionResponseTypesT>(value);
515 template <
typename FunctionResponseTypesT = Aws::Vector<FunctionResponseType>>
521 m_functionResponseTypesHasBeenSet =
true;
522 m_functionResponseTypes.push_back(value);
533 return m_amazonManagedKafkaEventSourceConfig;
536 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
538 m_amazonManagedKafkaEventSourceConfigHasBeenSet =
true;
539 m_amazonManagedKafkaEventSourceConfig = std::forward<AmazonManagedKafkaEventSourceConfigT>(value);
541 template <
typename AmazonManagedKafkaEventSourceConfigT = AmazonManagedKafkaEventSourceConfig>
554 return m_selfManagedKafkaEventSourceConfig;
557 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
559 m_selfManagedKafkaEventSourceConfigHasBeenSet =
true;
560 m_selfManagedKafkaEventSourceConfig = std::forward<SelfManagedKafkaEventSourceConfigT>(value);
562 template <
typename SelfManagedKafkaEventSourceConfigT = SelfManagedKafkaEventSourceConfig>
578 template <
typename ScalingConfigT = ScalingConfig>
580 m_scalingConfigHasBeenSet =
true;
581 m_scalingConfig = std::forward<ScalingConfigT>(value);
583 template <
typename ScalingConfigT = ScalingConfig>
596 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
598 m_documentDBEventSourceConfigHasBeenSet =
true;
599 m_documentDBEventSourceConfig = std::forward<DocumentDBEventSourceConfigT>(value);
601 template <
typename DocumentDBEventSourceConfigT = DocumentDBEventSourceConfig>
617 template <
typename KMSKeyArnT = Aws::String>
619 m_kMSKeyArnHasBeenSet =
true;
620 m_kMSKeyArn = std::forward<KMSKeyArnT>(value);
622 template <
typename KMSKeyArnT = Aws::String>
636 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
638 m_filterCriteriaErrorHasBeenSet =
true;
639 m_filterCriteriaError = std::forward<FilterCriteriaErrorT>(value);
641 template <
typename FilterCriteriaErrorT = FilterCriteriaError>
654 template <
typename EventSourceMappingArnT = Aws::String>
656 m_eventSourceMappingArnHasBeenSet =
true;
657 m_eventSourceMappingArn = std::forward<EventSourceMappingArnT>(value);
659 template <
typename EventSourceMappingArnT = Aws::String>
674 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
676 m_metricsConfigHasBeenSet =
true;
677 m_metricsConfig = std::forward<MetricsConfigT>(value);
679 template <
typename MetricsConfigT = EventSourceMappingMetricsConfig>
695 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
697 m_loggingConfigHasBeenSet =
true;
698 m_loggingConfig = std::forward<LoggingConfigT>(value);
700 template <
typename LoggingConfigT = EventSourceMappingLoggingConfig>
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;
770 DestinationConfig m_destinationConfig;
778 SelfManagedEventSource m_selfManagedEventSource;
780 int m_maximumRecordAgeInSeconds{0};
782 bool m_bisectBatchOnFunctionError{
false};
784 int m_maximumRetryAttempts{0};
786 int m_tumblingWindowInSeconds{0};
790 AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
792 SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
794 ScalingConfig m_scalingConfig;
796 DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
800 FilterCriteriaError m_filterCriteriaError;
804 EventSourceMappingMetricsConfig m_metricsConfig;
806 EventSourceMappingLoggingConfig m_loggingConfig;
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_functionArnHasBeenSet =
false;
820 bool m_lastModifiedHasBeenSet =
false;
821 bool m_lastProcessingResultHasBeenSet =
false;
822 bool m_stateHasBeenSet =
false;
823 bool m_stateTransitionReasonHasBeenSet =
false;
824 bool m_destinationConfigHasBeenSet =
false;
825 bool m_topicsHasBeenSet =
false;
826 bool m_queuesHasBeenSet =
false;
827 bool m_sourceAccessConfigurationsHasBeenSet =
false;
828 bool m_selfManagedEventSourceHasBeenSet =
false;
829 bool m_maximumRecordAgeInSecondsHasBeenSet =
false;
830 bool m_bisectBatchOnFunctionErrorHasBeenSet =
false;
831 bool m_maximumRetryAttemptsHasBeenSet =
false;
832 bool m_tumblingWindowInSecondsHasBeenSet =
false;
833 bool m_functionResponseTypesHasBeenSet =
false;
834 bool m_amazonManagedKafkaEventSourceConfigHasBeenSet =
false;
835 bool m_selfManagedKafkaEventSourceConfigHasBeenSet =
false;
836 bool m_scalingConfigHasBeenSet =
false;
837 bool m_documentDBEventSourceConfigHasBeenSet =
false;
838 bool m_kMSKeyArnHasBeenSet =
false;
839 bool m_filterCriteriaErrorHasBeenSet =
false;
840 bool m_eventSourceMappingArnHasBeenSet =
false;
841 bool m_metricsConfigHasBeenSet =
false;
842 bool m_loggingConfigHasBeenSet =
false;
843 bool m_provisionedPollerConfigHasBeenSet =
false;
844 bool m_requestIdHasBeenSet =
false;
EventSourceMappingConfiguration & WithDestinationConfig(DestinationConfigT &&value)
const DocumentDBEventSourceConfig & GetDocumentDBEventSourceConfig() const
const FilterCriteriaError & GetFilterCriteriaError() const
AWS_LAMBDA_API Aws::Utils::Json::JsonValue Jsonize() const
void SetStartingPosition(EventSourcePosition value)
EventSourceMappingConfiguration & WithState(StateT &&value)
bool StateHasBeenSet() const
bool FilterCriteriaHasBeenSet() const
void SetUUID(UUIDT &&value)
EventSourceMappingConfiguration & WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
const Aws::Vector< FunctionResponseType > & GetFunctionResponseTypes() const
EventSourceMappingConfiguration & WithQueues(QueuesT &&value)
EventSourceMappingConfiguration & WithFunctionArn(FunctionArnT &&value)
const SelfManagedKafkaEventSourceConfig & GetSelfManagedKafkaEventSourceConfig() const
bool TopicsHasBeenSet() const
const Aws::String & GetKMSKeyArn() const
const AmazonManagedKafkaEventSourceConfig & GetAmazonManagedKafkaEventSourceConfig() const
const Aws::Utils::DateTime & GetStartingPositionTimestamp() const
bool QueuesHasBeenSet() const
const ScalingConfig & GetScalingConfig() const
EventSourceMappingConfiguration & AddSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
const Aws::Vector< Aws::String > & GetTopics() const
bool DestinationConfigHasBeenSet() const
EventSourceMappingConfiguration & WithSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
int GetMaximumRecordAgeInSeconds() const
EventSourceMappingConfiguration & WithMetricsConfig(MetricsConfigT &&value)
void SetProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
const Aws::String & GetLastProcessingResult() const
bool ScalingConfigHasBeenSet() const
EventSourceMappingConfiguration & WithFilterCriteriaError(FilterCriteriaErrorT &&value)
const Aws::String & GetRequestId() const
bool KMSKeyArnHasBeenSet() const
const DestinationConfig & GetDestinationConfig() const
bool FilterCriteriaErrorHasBeenSet() const
bool RequestIdHasBeenSet() const
const EventSourceMappingLoggingConfig & GetLoggingConfig() const
void SetDestinationConfig(DestinationConfigT &&value)
void SetKMSKeyArn(KMSKeyArnT &&value)
const Aws::String & GetFunctionArn() const
EventSourceMappingConfiguration & AddFunctionResponseTypes(FunctionResponseType value)
void SetTumblingWindowInSeconds(int value)
void SetBatchSize(int value)
bool DocumentDBEventSourceConfigHasBeenSet() const
bool SelfManagedKafkaEventSourceConfigHasBeenSet() const
void SetMaximumRetryAttempts(int value)
EventSourceMappingConfiguration & WithMaximumBatchingWindowInSeconds(int value)
EventSourcePosition GetStartingPosition() const
void SetStartingPositionTimestamp(StartingPositionTimestampT &&value)
EventSourceMappingConfiguration & WithFilterCriteria(FilterCriteriaT &&value)
void SetLastModified(LastModifiedT &&value)
const SelfManagedEventSource & GetSelfManagedEventSource() const
void SetRequestId(RequestIdT &&value)
const Aws::Utils::DateTime & GetLastModified() const
EventSourceMappingConfiguration & WithBatchSize(int value)
EventSourceMappingConfiguration & WithParallelizationFactor(int value)
const Aws::String & GetStateTransitionReason() const
void SetScalingConfig(ScalingConfigT &&value)
bool LastModifiedHasBeenSet() const
void SetLastProcessingResult(LastProcessingResultT &&value)
const Aws::Vector< Aws::String > & GetQueues() const
bool ProvisionedPollerConfigHasBeenSet() const
EventSourceMappingConfiguration & WithKMSKeyArn(KMSKeyArnT &&value)
bool BisectBatchOnFunctionErrorHasBeenSet() const
const Aws::Vector< SourceAccessConfiguration > & GetSourceAccessConfigurations() const
bool SourceAccessConfigurationsHasBeenSet() const
EventSourceMappingConfiguration & WithTopics(TopicsT &&value)
EventSourceMappingConfiguration & WithMaximumRecordAgeInSeconds(int value)
void SetState(StateT &&value)
bool StartingPositionTimestampHasBeenSet() const
EventSourceMappingConfiguration & WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
bool MaximumBatchingWindowInSecondsHasBeenSet() const
bool FunctionResponseTypesHasBeenSet() const
EventSourceMappingConfiguration & AddQueues(QueuesT &&value)
EventSourceMappingConfiguration & WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
EventSourceMappingConfiguration & WithStateTransitionReason(StateTransitionReasonT &&value)
const Aws::String & GetEventSourceMappingArn() const
void SetEventSourceArn(EventSourceArnT &&value)
EventSourceMappingConfiguration & WithSelfManagedEventSource(SelfManagedEventSourceT &&value)
bool GetBisectBatchOnFunctionError() const
void SetEventSourceMappingArn(EventSourceMappingArnT &&value)
EventSourceMappingConfiguration & WithStartingPositionTimestamp(StartingPositionTimestampT &&value)
AWS_LAMBDA_API EventSourceMappingConfiguration & operator=(Aws::Utils::Json::JsonView jsonValue)
int GetParallelizationFactor() const
bool LoggingConfigHasBeenSet() const
void SetFilterCriteriaError(FilterCriteriaErrorT &&value)
AWS_LAMBDA_API EventSourceMappingConfiguration(Aws::Utils::Json::JsonView jsonValue)
EventSourceMappingConfiguration & WithProvisionedPollerConfig(ProvisionedPollerConfigT &&value)
bool FunctionArnHasBeenSet() const
void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigT &&value)
void SetTopics(TopicsT &&value)
EventSourceMappingConfiguration & WithFunctionResponseTypes(FunctionResponseTypesT &&value)
EventSourceMappingConfiguration & WithEventSourceMappingArn(EventSourceMappingArnT &&value)
EventSourceMappingConfiguration & AddTopics(TopicsT &&value)
bool StartingPositionHasBeenSet() const
bool BatchSizeHasBeenSet() const
bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const
void SetLoggingConfig(LoggingConfigT &&value)
const Aws::String & GetState() const
void SetSourceAccessConfigurations(SourceAccessConfigurationsT &&value)
const Aws::String & GetUUID() const
EventSourceMappingConfiguration & WithEventSourceArn(EventSourceArnT &&value)
bool MaximumRecordAgeInSecondsHasBeenSet() const
int GetMaximumBatchingWindowInSeconds() const
bool MaximumRetryAttemptsHasBeenSet() const
void SetStateTransitionReason(StateTransitionReasonT &&value)
const EventSourceMappingMetricsConfig & GetMetricsConfig() const
void SetMetricsConfig(MetricsConfigT &&value)
bool LastProcessingResultHasBeenSet() const
int GetTumblingWindowInSeconds() const
EventSourceMappingConfiguration & WithUUID(UUIDT &&value)
EventSourceMappingConfiguration & WithLastProcessingResult(LastProcessingResultT &&value)
AWS_LAMBDA_API EventSourceMappingConfiguration()=default
bool ParallelizationFactorHasBeenSet() const
EventSourceMappingConfiguration & WithRequestId(RequestIdT &&value)
void SetFunctionResponseTypes(FunctionResponseTypesT &&value)
void SetParallelizationFactor(int value)
void SetFunctionArn(FunctionArnT &&value)
void SetQueues(QueuesT &&value)
void SetMaximumRecordAgeInSeconds(int value)
void SetSelfManagedEventSource(SelfManagedEventSourceT &&value)
void SetMaximumBatchingWindowInSeconds(int value)
EventSourceMappingConfiguration & WithLoggingConfig(LoggingConfigT &&value)
const FilterCriteria & GetFilterCriteria() const
EventSourceMappingConfiguration & WithTumblingWindowInSeconds(int value)
bool MetricsConfigHasBeenSet() const
EventSourceMappingConfiguration & WithLastModified(LastModifiedT &&value)
EventSourceMappingConfiguration & WithMaximumRetryAttempts(int value)
void SetFilterCriteria(FilterCriteriaT &&value)
const ProvisionedPollerConfig & GetProvisionedPollerConfig() const
void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigT &&value)
void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfigT &&value)
int GetMaximumRetryAttempts() const
void SetBisectBatchOnFunctionError(bool value)
EventSourceMappingConfiguration & WithStartingPosition(EventSourcePosition value)
EventSourceMappingConfiguration & WithScalingConfig(ScalingConfigT &&value)
bool UUIDHasBeenSet() const
const Aws::String & GetEventSourceArn() const
bool TumblingWindowInSecondsHasBeenSet() const
bool EventSourceArnHasBeenSet() const
bool StateTransitionReasonHasBeenSet() const
EventSourceMappingConfiguration & WithBisectBatchOnFunctionError(bool value)
bool SelfManagedEventSourceHasBeenSet() const
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