505 lines
32 KiB
C++
505 lines
32 KiB
C++
/**
|
||
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||
* SPDX-License-Identifier: Apache-2.0.
|
||
*/
|
||
|
||
#pragma once
|
||
#include <aws/lambda/Lambda_EXPORTS.h>
|
||
#include <aws/lambda/LambdaRequest.h>
|
||
#include <aws/core/utils/memory/stl/AWSString.h>
|
||
#include <aws/lambda/model/FilterCriteria.h>
|
||
#include <aws/lambda/model/EventSourcePosition.h>
|
||
#include <aws/core/utils/DateTime.h>
|
||
#include <aws/lambda/model/DestinationConfig.h>
|
||
#include <aws/core/utils/memory/stl/AWSMap.h>
|
||
#include <aws/core/utils/memory/stl/AWSVector.h>
|
||
#include <aws/lambda/model/SelfManagedEventSource.h>
|
||
#include <aws/lambda/model/AmazonManagedKafkaEventSourceConfig.h>
|
||
#include <aws/lambda/model/SelfManagedKafkaEventSourceConfig.h>
|
||
#include <aws/lambda/model/ScalingConfig.h>
|
||
#include <aws/lambda/model/DocumentDBEventSourceConfig.h>
|
||
#include <aws/lambda/model/SourceAccessConfiguration.h>
|
||
#include <aws/lambda/model/FunctionResponseType.h>
|
||
#include <utility>
|
||
|
||
namespace Aws
|
||
{
|
||
namespace Lambda
|
||
{
|
||
namespace Model
|
||
{
|
||
|
||
/**
|
||
*/
|
||
class CreateEventSourceMappingRequest : public LambdaRequest
|
||
{
|
||
public:
|
||
AWS_LAMBDA_API CreateEventSourceMappingRequest();
|
||
|
||
// Service request name is the Operation name which will send this request out,
|
||
// each operation should has unique request name, so that we can get operation's name from this request.
|
||
// Note: this is not true for response, multiple operations may have the same response name,
|
||
// so we can not get operation's name from response.
|
||
inline virtual const char* GetServiceRequestName() const override { return "CreateEventSourceMapping"; }
|
||
|
||
AWS_LAMBDA_API Aws::String SerializePayload() const override;
|
||
|
||
|
||
///@{
|
||
/**
|
||
* <p>The Amazon Resource Name (ARN) of the event source.</p> <ul> <li> <p>
|
||
* <b>Amazon Kinesis</b> – The ARN of the data stream or a stream consumer.</p>
|
||
* </li> <li> <p> <b>Amazon DynamoDB Streams</b> – The ARN of the stream.</p> </li>
|
||
* <li> <p> <b>Amazon Simple Queue Service</b> – The ARN of the queue.</p> </li>
|
||
* <li> <p> <b>Amazon Managed Streaming for Apache Kafka</b> – The ARN of the
|
||
* cluster or the ARN of the VPC connection (for <a
|
||
* href="https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html#msk-multi-vpc">cross-account
|
||
* event source mappings</a>).</p> </li> <li> <p> <b>Amazon MQ</b> – The ARN of the
|
||
* broker.</p> </li> <li> <p> <b>Amazon DocumentDB</b> – The ARN of the DocumentDB
|
||
* change stream.</p> </li> </ul>
|
||
*/
|
||
inline const Aws::String& GetEventSourceArn() const{ return m_eventSourceArn; }
|
||
inline bool EventSourceArnHasBeenSet() const { return m_eventSourceArnHasBeenSet; }
|
||
inline void SetEventSourceArn(const Aws::String& value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn = value; }
|
||
inline void SetEventSourceArn(Aws::String&& value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn = std::move(value); }
|
||
inline void SetEventSourceArn(const char* value) { m_eventSourceArnHasBeenSet = true; m_eventSourceArn.assign(value); }
|
||
inline CreateEventSourceMappingRequest& WithEventSourceArn(const Aws::String& value) { SetEventSourceArn(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithEventSourceArn(Aws::String&& value) { SetEventSourceArn(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithEventSourceArn(const char* value) { SetEventSourceArn(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The name or ARN of the Lambda function.</p> <p class="title"> <b>Name
|
||
* formats</b> </p> <ul> <li> <p> <b>Function name</b> –
|
||
* <code>MyFunction</code>.</p> </li> <li> <p> <b>Function ARN</b> –
|
||
* <code>arn:aws:lambda:us-west-2:123456789012:function:MyFunction</code>.</p>
|
||
* </li> <li> <p> <b>Version or Alias ARN</b> –
|
||
* <code>arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD</code>.</p>
|
||
* </li> <li> <p> <b>Partial ARN</b> –
|
||
* <code>123456789012:function:MyFunction</code>.</p> </li> </ul> <p>The length
|
||
* constraint applies only to the full ARN. If you specify only the function name,
|
||
* it's limited to 64 characters in length.</p>
|
||
*/
|
||
inline const Aws::String& GetFunctionName() const{ return m_functionName; }
|
||
inline bool FunctionNameHasBeenSet() const { return m_functionNameHasBeenSet; }
|
||
inline void SetFunctionName(const Aws::String& value) { m_functionNameHasBeenSet = true; m_functionName = value; }
|
||
inline void SetFunctionName(Aws::String&& value) { m_functionNameHasBeenSet = true; m_functionName = std::move(value); }
|
||
inline void SetFunctionName(const char* value) { m_functionNameHasBeenSet = true; m_functionName.assign(value); }
|
||
inline CreateEventSourceMappingRequest& WithFunctionName(const Aws::String& value) { SetFunctionName(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithFunctionName(Aws::String&& value) { SetFunctionName(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithFunctionName(const char* value) { SetFunctionName(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>When true, the event source mapping is active. When false, Lambda pauses
|
||
* polling and invocation.</p> <p>Default: True</p>
|
||
*/
|
||
inline bool GetEnabled() const{ return m_enabled; }
|
||
inline bool EnabledHasBeenSet() const { return m_enabledHasBeenSet; }
|
||
inline void SetEnabled(bool value) { m_enabledHasBeenSet = true; m_enabled = value; }
|
||
inline CreateEventSourceMappingRequest& WithEnabled(bool value) { SetEnabled(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The maximum number of records in each batch that Lambda pulls from your
|
||
* stream or queue and sends to your function. Lambda passes all of the records in
|
||
* the batch to the function in a single call, up to the payload limit for
|
||
* synchronous invocation (6 MB).</p> <ul> <li> <p> <b>Amazon Kinesis</b> – Default
|
||
* 100. Max 10,000.</p> </li> <li> <p> <b>Amazon DynamoDB Streams</b> – Default
|
||
* 100. Max 10,000.</p> </li> <li> <p> <b>Amazon Simple Queue Service</b> – Default
|
||
* 10. For standard queues the max is 10,000. For FIFO queues the max is 10.</p>
|
||
* </li> <li> <p> <b>Amazon Managed Streaming for Apache Kafka</b> – Default 100.
|
||
* Max 10,000.</p> </li> <li> <p> <b>Self-managed Apache Kafka</b> – Default 100.
|
||
* Max 10,000.</p> </li> <li> <p> <b>Amazon MQ (ActiveMQ and RabbitMQ)</b> –
|
||
* Default 100. Max 10,000.</p> </li> <li> <p> <b>DocumentDB</b> – Default 100. Max
|
||
* 10,000.</p> </li> </ul>
|
||
*/
|
||
inline int GetBatchSize() const{ return m_batchSize; }
|
||
inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; }
|
||
inline void SetBatchSize(int value) { m_batchSizeHasBeenSet = true; m_batchSize = value; }
|
||
inline CreateEventSourceMappingRequest& WithBatchSize(int value) { SetBatchSize(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>An object that defines the filter criteria that determine whether Lambda
|
||
* should process an event. For more information, see <a
|
||
* href="https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html">Lambda
|
||
* event filtering</a>.</p>
|
||
*/
|
||
inline const FilterCriteria& GetFilterCriteria() const{ return m_filterCriteria; }
|
||
inline bool FilterCriteriaHasBeenSet() const { return m_filterCriteriaHasBeenSet; }
|
||
inline void SetFilterCriteria(const FilterCriteria& value) { m_filterCriteriaHasBeenSet = true; m_filterCriteria = value; }
|
||
inline void SetFilterCriteria(FilterCriteria&& value) { m_filterCriteriaHasBeenSet = true; m_filterCriteria = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithFilterCriteria(const FilterCriteria& value) { SetFilterCriteria(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithFilterCriteria(FilterCriteria&& value) { SetFilterCriteria(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The maximum amount of time, in seconds, that Lambda spends gathering records
|
||
* before invoking the function. You can configure
|
||
* <code>MaximumBatchingWindowInSeconds</code> to any value from 0 seconds to 300
|
||
* seconds in increments of seconds.</p> <p>For Kinesis, DynamoDB, and Amazon SQS
|
||
* event sources, the default batching window is 0 seconds. For Amazon MSK,
|
||
* Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default
|
||
* batching window is 500 ms. Note that because you can only change
|
||
* <code>MaximumBatchingWindowInSeconds</code> in increments of seconds, you cannot
|
||
* revert back to the 500 ms default batching window after you have changed it. To
|
||
* restore the default batching window, you must create a new event source
|
||
* mapping.</p> <p>Related setting: For Kinesis, DynamoDB, and Amazon SQS event
|
||
* sources, when you set <code>BatchSize</code> to a value greater than 10, you
|
||
* must set <code>MaximumBatchingWindowInSeconds</code> to at least 1.</p>
|
||
*/
|
||
inline int GetMaximumBatchingWindowInSeconds() const{ return m_maximumBatchingWindowInSeconds; }
|
||
inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
|
||
inline void SetMaximumBatchingWindowInSeconds(int value) { m_maximumBatchingWindowInSecondsHasBeenSet = true; m_maximumBatchingWindowInSeconds = value; }
|
||
inline CreateEventSourceMappingRequest& WithMaximumBatchingWindowInSeconds(int value) { SetMaximumBatchingWindowInSeconds(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis and DynamoDB Streams only) The number of batches to process from
|
||
* each shard concurrently.</p>
|
||
*/
|
||
inline int GetParallelizationFactor() const{ return m_parallelizationFactor; }
|
||
inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
|
||
inline void SetParallelizationFactor(int value) { m_parallelizationFactorHasBeenSet = true; m_parallelizationFactor = value; }
|
||
inline CreateEventSourceMappingRequest& WithParallelizationFactor(int value) { SetParallelizationFactor(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The position in a stream from which to start reading. Required for Amazon
|
||
* Kinesis and Amazon DynamoDB Stream event sources. <code>AT_TIMESTAMP</code> is
|
||
* supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon MSK, and
|
||
* self-managed Apache Kafka.</p>
|
||
*/
|
||
inline const EventSourcePosition& GetStartingPosition() const{ return m_startingPosition; }
|
||
inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
|
||
inline void SetStartingPosition(const EventSourcePosition& value) { m_startingPositionHasBeenSet = true; m_startingPosition = value; }
|
||
inline void SetStartingPosition(EventSourcePosition&& value) { m_startingPositionHasBeenSet = true; m_startingPosition = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithStartingPosition(const EventSourcePosition& value) { SetStartingPosition(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithStartingPosition(EventSourcePosition&& value) { SetStartingPosition(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>With <code>StartingPosition</code> set to <code>AT_TIMESTAMP</code>, the time
|
||
* from which to start reading. <code>StartingPositionTimestamp</code> cannot be in
|
||
* the future.</p>
|
||
*/
|
||
inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const{ return m_startingPositionTimestamp; }
|
||
inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
|
||
inline void SetStartingPositionTimestamp(const Aws::Utils::DateTime& value) { m_startingPositionTimestampHasBeenSet = true; m_startingPositionTimestamp = value; }
|
||
inline void SetStartingPositionTimestamp(Aws::Utils::DateTime&& value) { m_startingPositionTimestampHasBeenSet = true; m_startingPositionTimestamp = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithStartingPositionTimestamp(const Aws::Utils::DateTime& value) { SetStartingPositionTimestamp(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithStartingPositionTimestamp(Aws::Utils::DateTime&& value) { SetStartingPositionTimestamp(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Kafka only) A
|
||
* configuration object that specifies the destination of an event after Lambda
|
||
* processes it.</p>
|
||
*/
|
||
inline const DestinationConfig& GetDestinationConfig() const{ return m_destinationConfig; }
|
||
inline bool DestinationConfigHasBeenSet() const { return m_destinationConfigHasBeenSet; }
|
||
inline void SetDestinationConfig(const DestinationConfig& value) { m_destinationConfigHasBeenSet = true; m_destinationConfig = value; }
|
||
inline void SetDestinationConfig(DestinationConfig&& value) { m_destinationConfigHasBeenSet = true; m_destinationConfig = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithDestinationConfig(const DestinationConfig& value) { SetDestinationConfig(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithDestinationConfig(DestinationConfig&& value) { SetDestinationConfig(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis and DynamoDB Streams only) Discard records older than the specified
|
||
* age. The default value is infinite (-1).</p>
|
||
*/
|
||
inline int GetMaximumRecordAgeInSeconds() const{ return m_maximumRecordAgeInSeconds; }
|
||
inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
|
||
inline void SetMaximumRecordAgeInSeconds(int value) { m_maximumRecordAgeInSecondsHasBeenSet = true; m_maximumRecordAgeInSeconds = value; }
|
||
inline CreateEventSourceMappingRequest& WithMaximumRecordAgeInSeconds(int value) { SetMaximumRecordAgeInSeconds(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis and DynamoDB Streams only) If the function returns an error, split
|
||
* the batch in two and retry.</p>
|
||
*/
|
||
inline bool GetBisectBatchOnFunctionError() const{ return m_bisectBatchOnFunctionError; }
|
||
inline bool BisectBatchOnFunctionErrorHasBeenSet() const { return m_bisectBatchOnFunctionErrorHasBeenSet; }
|
||
inline void SetBisectBatchOnFunctionError(bool value) { m_bisectBatchOnFunctionErrorHasBeenSet = true; m_bisectBatchOnFunctionError = value; }
|
||
inline CreateEventSourceMappingRequest& WithBisectBatchOnFunctionError(bool value) { SetBisectBatchOnFunctionError(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis and DynamoDB Streams only) Discard records after the specified
|
||
* number of retries. The default value is infinite (-1). When set to infinite
|
||
* (-1), failed records are retried until the record expires.</p>
|
||
*/
|
||
inline int GetMaximumRetryAttempts() const{ return m_maximumRetryAttempts; }
|
||
inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
|
||
inline void SetMaximumRetryAttempts(int value) { m_maximumRetryAttemptsHasBeenSet = true; m_maximumRetryAttempts = value; }
|
||
inline CreateEventSourceMappingRequest& WithMaximumRetryAttempts(int value) { SetMaximumRetryAttempts(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>A list of tags to apply to the event source mapping.</p>
|
||
*/
|
||
inline const Aws::Map<Aws::String, Aws::String>& GetTags() const{ return m_tags; }
|
||
inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
|
||
inline void SetTags(const Aws::Map<Aws::String, Aws::String>& value) { m_tagsHasBeenSet = true; m_tags = value; }
|
||
inline void SetTags(Aws::Map<Aws::String, Aws::String>&& value) { m_tagsHasBeenSet = true; m_tags = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithTags(const Aws::Map<Aws::String, Aws::String>& value) { SetTags(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithTags(Aws::Map<Aws::String, Aws::String>&& value) { SetTags(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& AddTags(const Aws::String& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, const Aws::String& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(const Aws::String& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), std::move(value)); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(const char* key, Aws::String&& value) { m_tagsHasBeenSet = true; m_tags.emplace(key, std::move(value)); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(Aws::String&& key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(std::move(key), value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTags(const char* key, const char* value) { m_tagsHasBeenSet = true; m_tags.emplace(key, value); return *this; }
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis and DynamoDB Streams only) The duration in seconds of a processing
|
||
* window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds
|
||
* indicates no tumbling window.</p>
|
||
*/
|
||
inline int GetTumblingWindowInSeconds() const{ return m_tumblingWindowInSeconds; }
|
||
inline bool TumblingWindowInSecondsHasBeenSet() const { return m_tumblingWindowInSecondsHasBeenSet; }
|
||
inline void SetTumblingWindowInSeconds(int value) { m_tumblingWindowInSecondsHasBeenSet = true; m_tumblingWindowInSeconds = value; }
|
||
inline CreateEventSourceMappingRequest& WithTumblingWindowInSeconds(int value) { SetTumblingWindowInSeconds(value); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The name of the Kafka topic.</p>
|
||
*/
|
||
inline const Aws::Vector<Aws::String>& GetTopics() const{ return m_topics; }
|
||
inline bool TopicsHasBeenSet() const { return m_topicsHasBeenSet; }
|
||
inline void SetTopics(const Aws::Vector<Aws::String>& value) { m_topicsHasBeenSet = true; m_topics = value; }
|
||
inline void SetTopics(Aws::Vector<Aws::String>&& value) { m_topicsHasBeenSet = true; m_topics = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithTopics(const Aws::Vector<Aws::String>& value) { SetTopics(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithTopics(Aws::Vector<Aws::String>&& value) { SetTopics(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& AddTopics(const Aws::String& value) { m_topicsHasBeenSet = true; m_topics.push_back(value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTopics(Aws::String&& value) { m_topicsHasBeenSet = true; m_topics.push_back(std::move(value)); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddTopics(const char* value) { m_topicsHasBeenSet = true; m_topics.push_back(value); return *this; }
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p> (MQ) The name of the Amazon MQ broker destination queue to consume. </p>
|
||
*/
|
||
inline const Aws::Vector<Aws::String>& GetQueues() const{ return m_queues; }
|
||
inline bool QueuesHasBeenSet() const { return m_queuesHasBeenSet; }
|
||
inline void SetQueues(const Aws::Vector<Aws::String>& value) { m_queuesHasBeenSet = true; m_queues = value; }
|
||
inline void SetQueues(Aws::Vector<Aws::String>&& value) { m_queuesHasBeenSet = true; m_queues = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithQueues(const Aws::Vector<Aws::String>& value) { SetQueues(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithQueues(Aws::Vector<Aws::String>&& value) { SetQueues(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& AddQueues(const Aws::String& value) { m_queuesHasBeenSet = true; m_queues.push_back(value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddQueues(Aws::String&& value) { m_queuesHasBeenSet = true; m_queues.push_back(std::move(value)); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddQueues(const char* value) { m_queuesHasBeenSet = true; m_queues.push_back(value); return *this; }
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>An array of authentication protocols or VPC components required to secure
|
||
* your event source.</p>
|
||
*/
|
||
inline const Aws::Vector<SourceAccessConfiguration>& GetSourceAccessConfigurations() const{ return m_sourceAccessConfigurations; }
|
||
inline bool SourceAccessConfigurationsHasBeenSet() const { return m_sourceAccessConfigurationsHasBeenSet; }
|
||
inline void SetSourceAccessConfigurations(const Aws::Vector<SourceAccessConfiguration>& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations = value; }
|
||
inline void SetSourceAccessConfigurations(Aws::Vector<SourceAccessConfiguration>&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithSourceAccessConfigurations(const Aws::Vector<SourceAccessConfiguration>& value) { SetSourceAccessConfigurations(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithSourceAccessConfigurations(Aws::Vector<SourceAccessConfiguration>&& value) { SetSourceAccessConfigurations(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& AddSourceAccessConfigurations(const SourceAccessConfiguration& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations.push_back(value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddSourceAccessConfigurations(SourceAccessConfiguration&& value) { m_sourceAccessConfigurationsHasBeenSet = true; m_sourceAccessConfigurations.push_back(std::move(value)); return *this; }
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>The self-managed Apache Kafka cluster to receive records from.</p>
|
||
*/
|
||
inline const SelfManagedEventSource& GetSelfManagedEventSource() const{ return m_selfManagedEventSource; }
|
||
inline bool SelfManagedEventSourceHasBeenSet() const { return m_selfManagedEventSourceHasBeenSet; }
|
||
inline void SetSelfManagedEventSource(const SelfManagedEventSource& value) { m_selfManagedEventSourceHasBeenSet = true; m_selfManagedEventSource = value; }
|
||
inline void SetSelfManagedEventSource(SelfManagedEventSource&& value) { m_selfManagedEventSourceHasBeenSet = true; m_selfManagedEventSource = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithSelfManagedEventSource(const SelfManagedEventSource& value) { SetSelfManagedEventSource(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithSelfManagedEventSource(SelfManagedEventSource&& value) { SetSelfManagedEventSource(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type
|
||
* enums applied to the event source mapping.</p>
|
||
*/
|
||
inline const Aws::Vector<FunctionResponseType>& GetFunctionResponseTypes() const{ return m_functionResponseTypes; }
|
||
inline bool FunctionResponseTypesHasBeenSet() const { return m_functionResponseTypesHasBeenSet; }
|
||
inline void SetFunctionResponseTypes(const Aws::Vector<FunctionResponseType>& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes = value; }
|
||
inline void SetFunctionResponseTypes(Aws::Vector<FunctionResponseType>&& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithFunctionResponseTypes(const Aws::Vector<FunctionResponseType>& value) { SetFunctionResponseTypes(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithFunctionResponseTypes(Aws::Vector<FunctionResponseType>&& value) { SetFunctionResponseTypes(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& AddFunctionResponseTypes(const FunctionResponseType& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes.push_back(value); return *this; }
|
||
inline CreateEventSourceMappingRequest& AddFunctionResponseTypes(FunctionResponseType&& value) { m_functionResponseTypesHasBeenSet = true; m_functionResponseTypes.push_back(std::move(value)); return *this; }
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>Specific configuration settings for an Amazon Managed Streaming for Apache
|
||
* Kafka (Amazon MSK) event source.</p>
|
||
*/
|
||
inline const AmazonManagedKafkaEventSourceConfig& GetAmazonManagedKafkaEventSourceConfig() const{ return m_amazonManagedKafkaEventSourceConfig; }
|
||
inline bool AmazonManagedKafkaEventSourceConfigHasBeenSet() const { return m_amazonManagedKafkaEventSourceConfigHasBeenSet; }
|
||
inline void SetAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig& value) { m_amazonManagedKafkaEventSourceConfigHasBeenSet = true; m_amazonManagedKafkaEventSourceConfig = value; }
|
||
inline void SetAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig&& value) { m_amazonManagedKafkaEventSourceConfigHasBeenSet = true; m_amazonManagedKafkaEventSourceConfig = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithAmazonManagedKafkaEventSourceConfig(const AmazonManagedKafkaEventSourceConfig& value) { SetAmazonManagedKafkaEventSourceConfig(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig&& value) { SetAmazonManagedKafkaEventSourceConfig(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>Specific configuration settings for a self-managed Apache Kafka event
|
||
* source.</p>
|
||
*/
|
||
inline const SelfManagedKafkaEventSourceConfig& GetSelfManagedKafkaEventSourceConfig() const{ return m_selfManagedKafkaEventSourceConfig; }
|
||
inline bool SelfManagedKafkaEventSourceConfigHasBeenSet() const { return m_selfManagedKafkaEventSourceConfigHasBeenSet; }
|
||
inline void SetSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig& value) { m_selfManagedKafkaEventSourceConfigHasBeenSet = true; m_selfManagedKafkaEventSourceConfig = value; }
|
||
inline void SetSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig&& value) { m_selfManagedKafkaEventSourceConfigHasBeenSet = true; m_selfManagedKafkaEventSourceConfig = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithSelfManagedKafkaEventSourceConfig(const SelfManagedKafkaEventSourceConfig& value) { SetSelfManagedKafkaEventSourceConfig(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig&& value) { SetSelfManagedKafkaEventSourceConfig(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>(Amazon SQS only) The scaling configuration for the event source. For more
|
||
* information, see <a
|
||
* href="https://docs.aws.amazon.com/lambda/latest/dg/with-sqs.html#events-sqs-max-concurrency">Configuring
|
||
* maximum concurrency for Amazon SQS event sources</a>.</p>
|
||
*/
|
||
inline const ScalingConfig& GetScalingConfig() const{ return m_scalingConfig; }
|
||
inline bool ScalingConfigHasBeenSet() const { return m_scalingConfigHasBeenSet; }
|
||
inline void SetScalingConfig(const ScalingConfig& value) { m_scalingConfigHasBeenSet = true; m_scalingConfig = value; }
|
||
inline void SetScalingConfig(ScalingConfig&& value) { m_scalingConfigHasBeenSet = true; m_scalingConfig = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithScalingConfig(const ScalingConfig& value) { SetScalingConfig(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithScalingConfig(ScalingConfig&& value) { SetScalingConfig(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p>Specific configuration settings for a DocumentDB event source.</p>
|
||
*/
|
||
inline const DocumentDBEventSourceConfig& GetDocumentDBEventSourceConfig() const{ return m_documentDBEventSourceConfig; }
|
||
inline bool DocumentDBEventSourceConfigHasBeenSet() const { return m_documentDBEventSourceConfigHasBeenSet; }
|
||
inline void SetDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig& value) { m_documentDBEventSourceConfigHasBeenSet = true; m_documentDBEventSourceConfig = value; }
|
||
inline void SetDocumentDBEventSourceConfig(DocumentDBEventSourceConfig&& value) { m_documentDBEventSourceConfigHasBeenSet = true; m_documentDBEventSourceConfig = std::move(value); }
|
||
inline CreateEventSourceMappingRequest& WithDocumentDBEventSourceConfig(const DocumentDBEventSourceConfig& value) { SetDocumentDBEventSourceConfig(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithDocumentDBEventSourceConfig(DocumentDBEventSourceConfig&& value) { SetDocumentDBEventSourceConfig(std::move(value)); return *this;}
|
||
///@}
|
||
|
||
///@{
|
||
/**
|
||
* <p> The ARN of the Key Management Service (KMS) customer managed key that Lambda
|
||
* uses to encrypt your function's <a
|
||
* href="https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html#filtering-basics">filter
|
||
* criteria</a>. By default, Lambda does not encrypt your filter criteria object.
|
||
* Specify this property to encrypt data using your own customer managed key. </p>
|
||
*/
|
||
inline const Aws::String& GetKMSKeyArn() const{ return m_kMSKeyArn; }
|
||
inline bool KMSKeyArnHasBeenSet() const { return m_kMSKeyArnHasBeenSet; }
|
||
inline void SetKMSKeyArn(const Aws::String& value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn = value; }
|
||
inline void SetKMSKeyArn(Aws::String&& value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn = std::move(value); }
|
||
inline void SetKMSKeyArn(const char* value) { m_kMSKeyArnHasBeenSet = true; m_kMSKeyArn.assign(value); }
|
||
inline CreateEventSourceMappingRequest& WithKMSKeyArn(const Aws::String& value) { SetKMSKeyArn(value); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithKMSKeyArn(Aws::String&& value) { SetKMSKeyArn(std::move(value)); return *this;}
|
||
inline CreateEventSourceMappingRequest& WithKMSKeyArn(const char* value) { SetKMSKeyArn(value); return *this;}
|
||
///@}
|
||
private:
|
||
|
||
Aws::String m_eventSourceArn;
|
||
bool m_eventSourceArnHasBeenSet = false;
|
||
|
||
Aws::String m_functionName;
|
||
bool m_functionNameHasBeenSet = false;
|
||
|
||
bool m_enabled;
|
||
bool m_enabledHasBeenSet = false;
|
||
|
||
int m_batchSize;
|
||
bool m_batchSizeHasBeenSet = false;
|
||
|
||
FilterCriteria m_filterCriteria;
|
||
bool m_filterCriteriaHasBeenSet = false;
|
||
|
||
int m_maximumBatchingWindowInSeconds;
|
||
bool m_maximumBatchingWindowInSecondsHasBeenSet = false;
|
||
|
||
int m_parallelizationFactor;
|
||
bool m_parallelizationFactorHasBeenSet = false;
|
||
|
||
EventSourcePosition m_startingPosition;
|
||
bool m_startingPositionHasBeenSet = false;
|
||
|
||
Aws::Utils::DateTime m_startingPositionTimestamp;
|
||
bool m_startingPositionTimestampHasBeenSet = false;
|
||
|
||
DestinationConfig m_destinationConfig;
|
||
bool m_destinationConfigHasBeenSet = false;
|
||
|
||
int m_maximumRecordAgeInSeconds;
|
||
bool m_maximumRecordAgeInSecondsHasBeenSet = false;
|
||
|
||
bool m_bisectBatchOnFunctionError;
|
||
bool m_bisectBatchOnFunctionErrorHasBeenSet = false;
|
||
|
||
int m_maximumRetryAttempts;
|
||
bool m_maximumRetryAttemptsHasBeenSet = false;
|
||
|
||
Aws::Map<Aws::String, Aws::String> m_tags;
|
||
bool m_tagsHasBeenSet = false;
|
||
|
||
int m_tumblingWindowInSeconds;
|
||
bool m_tumblingWindowInSecondsHasBeenSet = false;
|
||
|
||
Aws::Vector<Aws::String> m_topics;
|
||
bool m_topicsHasBeenSet = false;
|
||
|
||
Aws::Vector<Aws::String> m_queues;
|
||
bool m_queuesHasBeenSet = false;
|
||
|
||
Aws::Vector<SourceAccessConfiguration> m_sourceAccessConfigurations;
|
||
bool m_sourceAccessConfigurationsHasBeenSet = false;
|
||
|
||
SelfManagedEventSource m_selfManagedEventSource;
|
||
bool m_selfManagedEventSourceHasBeenSet = false;
|
||
|
||
Aws::Vector<FunctionResponseType> m_functionResponseTypes;
|
||
bool m_functionResponseTypesHasBeenSet = false;
|
||
|
||
AmazonManagedKafkaEventSourceConfig m_amazonManagedKafkaEventSourceConfig;
|
||
bool m_amazonManagedKafkaEventSourceConfigHasBeenSet = false;
|
||
|
||
SelfManagedKafkaEventSourceConfig m_selfManagedKafkaEventSourceConfig;
|
||
bool m_selfManagedKafkaEventSourceConfigHasBeenSet = false;
|
||
|
||
ScalingConfig m_scalingConfig;
|
||
bool m_scalingConfigHasBeenSet = false;
|
||
|
||
DocumentDBEventSourceConfig m_documentDBEventSourceConfig;
|
||
bool m_documentDBEventSourceConfigHasBeenSet = false;
|
||
|
||
Aws::String m_kMSKeyArn;
|
||
bool m_kMSKeyArnHasBeenSet = false;
|
||
};
|
||
|
||
} // namespace Model
|
||
} // namespace Lambda
|
||
} // namespace Aws
|