Class CfnEventSourceMapping.Builder
java.lang.Object
software.amazon.awscdk.services.lambda.CfnEventSourceMapping.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<CfnEventSourceMapping>
- Enclosing class:
CfnEventSourceMapping
@Stability(Stable)
public static final class CfnEventSourceMapping.Builder
extends Object
implements software.amazon.jsii.Builder<CfnEventSourceMapping>
A fluent builder for
CfnEventSourceMapping
.-
Method Summary
Modifier and TypeMethodDescriptionamazonManagedKafkaEventSourceConfig
(IResolvable amazonManagedKafkaEventSourceConfig) Specific configuration settings for an MSK event source.amazonManagedKafkaEventSourceConfig
(CfnEventSourceMapping.AmazonManagedKafkaEventSourceConfigProperty amazonManagedKafkaEventSourceConfig) Specific configuration settings for an MSK event source.The maximum number of items to retrieve in a single batch.bisectBatchOnFunctionError
(Boolean bisectBatchOnFunctionError) (Streams) If the function returns an error, split the batch in two and retry.bisectBatchOnFunctionError
(IResolvable bisectBatchOnFunctionError) (Streams) If the function returns an error, split the batch in two and retry.build()
destinationConfig
(IResolvable destinationConfig) A configuration object that specifies the destination of an event after Lambda processes it.destinationConfig
(CfnEventSourceMapping.DestinationConfigProperty destinationConfig) A configuration object that specifies the destination of an event after Lambda processes it.documentDbEventSourceConfig
(IResolvable documentDbEventSourceConfig) Document db event source config.documentDbEventSourceConfig
(CfnEventSourceMapping.DocumentDBEventSourceConfigProperty documentDbEventSourceConfig) Document db event source config.Disables the event source mapping to pause polling and invocation.enabled
(IResolvable enabled) Disables the event source mapping to pause polling and invocation.eventSourceArn
(String eventSourceArn) The Amazon Resource Name (ARN) of the event source.filterCriteria
(IResolvable filterCriteria) The filter criteria to control event filtering.filterCriteria
(CfnEventSourceMapping.FilterCriteriaProperty filterCriteria) The filter criteria to control event filtering.functionName
(String functionName) The name of the Lambda function.functionResponseTypes
(List<String> functionResponseTypes) (Streams) A list of response types supported by the function.The Amazon Resource Name (ARN) of the KMS key.maximumBatchingWindowInSeconds
(Number maximumBatchingWindowInSeconds) (Streams) The maximum amount of time to gather records before invoking the function, in seconds.maximumRecordAgeInSeconds
(Number maximumRecordAgeInSeconds) (Streams) The maximum age of a record that Lambda sends to a function for processing.maximumRetryAttempts
(Number maximumRetryAttempts) (Streams) The maximum number of times to retry when the function returns an error.metricsConfig
(IResolvable metricsConfig) Metrics config for Event Source Mapping Metrics.metricsConfig
(CfnEventSourceMapping.MetricsConfigProperty metricsConfig) Metrics config for Event Source Mapping Metrics.parallelizationFactor
(Number parallelizationFactor) (Streams) The number of batches to process from each shard concurrently.provisionedPollerConfig
(IResolvable provisionedPollerConfig) ProvisionedPollerConfig.provisionedPollerConfig
(CfnEventSourceMapping.ProvisionedPollerConfigProperty provisionedPollerConfig) ProvisionedPollerConfig.(ActiveMQ) A list of ActiveMQ queues.scalingConfig
(IResolvable scalingConfig) The scaling configuration for the event source.scalingConfig
(CfnEventSourceMapping.ScalingConfigProperty scalingConfig) The scaling configuration for the event source.selfManagedEventSource
(IResolvable selfManagedEventSource) The configuration used by AWS Lambda to access a self-managed event source.selfManagedEventSource
(CfnEventSourceMapping.SelfManagedEventSourceProperty selfManagedEventSource) The configuration used by AWS Lambda to access a self-managed event source.selfManagedKafkaEventSourceConfig
(IResolvable selfManagedKafkaEventSourceConfig) Specific configuration settings for a Self-Managed Apache Kafka event source.selfManagedKafkaEventSourceConfig
(CfnEventSourceMapping.SelfManagedKafkaEventSourceConfigProperty selfManagedKafkaEventSourceConfig) Specific configuration settings for a Self-Managed Apache Kafka event source.sourceAccessConfigurations
(List<? extends Object> sourceAccessConfigurations) A list of SourceAccessConfiguration.sourceAccessConfigurations
(IResolvable sourceAccessConfigurations) A list of SourceAccessConfiguration.startingPosition
(String startingPosition) The position in a stream from which to start reading.startingPositionTimestamp
(Number startingPositionTimestamp) With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.A list of tags to apply to event source mapping resource.(Kafka) A list of Kafka topics.tumblingWindowInSeconds
(Number tumblingWindowInSeconds) (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
-
Method Details
-
create
@Stability(Stable) public static CfnEventSourceMapping.Builder create(software.constructs.Construct scope, String id) - Parameters:
scope
- Scope in which this resource is defined. This parameter is required.id
- Construct identifier for this resource (unique in its scope). This parameter is required.- Returns:
- a new instance of
CfnEventSourceMapping.Builder
.
-
functionName
The name of the Lambda function.- Parameters:
functionName
- The name of the Lambda function. This parameter is required.- Returns:
this
- See Also:
-
amazonManagedKafkaEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder amazonManagedKafkaEventSourceConfig(IResolvable amazonManagedKafkaEventSourceConfig) Specific configuration settings for an MSK event source.- Parameters:
amazonManagedKafkaEventSourceConfig
- Specific configuration settings for an MSK event source. This parameter is required.- Returns:
this
- See Also:
-
amazonManagedKafkaEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder amazonManagedKafkaEventSourceConfig(CfnEventSourceMapping.AmazonManagedKafkaEventSourceConfigProperty amazonManagedKafkaEventSourceConfig) Specific configuration settings for an MSK event source.- Parameters:
amazonManagedKafkaEventSourceConfig
- Specific configuration settings for an MSK event source. This parameter is required.- Returns:
this
- See Also:
-
batchSize
The maximum number of items to retrieve in a single batch.- Parameters:
batchSize
- The maximum number of items to retrieve in a single batch. This parameter is required.- Returns:
this
- See Also:
-
bisectBatchOnFunctionError
@Stability(Stable) public CfnEventSourceMapping.Builder bisectBatchOnFunctionError(Boolean bisectBatchOnFunctionError) (Streams) If the function returns an error, split the batch in two and retry.- Parameters:
bisectBatchOnFunctionError
- (Streams) If the function returns an error, split the batch in two and retry. This parameter is required.- Returns:
this
- See Also:
-
bisectBatchOnFunctionError
@Stability(Stable) public CfnEventSourceMapping.Builder bisectBatchOnFunctionError(IResolvable bisectBatchOnFunctionError) (Streams) If the function returns an error, split the batch in two and retry.- Parameters:
bisectBatchOnFunctionError
- (Streams) If the function returns an error, split the batch in two and retry. This parameter is required.- Returns:
this
- See Also:
-
destinationConfig
@Stability(Stable) public CfnEventSourceMapping.Builder destinationConfig(IResolvable destinationConfig) A configuration object that specifies the destination of an event after Lambda processes it.- Parameters:
destinationConfig
- A configuration object that specifies the destination of an event after Lambda processes it. This parameter is required.- Returns:
this
- See Also:
-
destinationConfig
@Stability(Stable) public CfnEventSourceMapping.Builder destinationConfig(CfnEventSourceMapping.DestinationConfigProperty destinationConfig) A configuration object that specifies the destination of an event after Lambda processes it.- Parameters:
destinationConfig
- A configuration object that specifies the destination of an event after Lambda processes it. This parameter is required.- Returns:
this
- See Also:
-
documentDbEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder documentDbEventSourceConfig(IResolvable documentDbEventSourceConfig) Document db event source config.- Parameters:
documentDbEventSourceConfig
- Document db event source config. This parameter is required.- Returns:
this
- See Also:
-
documentDbEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder documentDbEventSourceConfig(CfnEventSourceMapping.DocumentDBEventSourceConfigProperty documentDbEventSourceConfig) Document db event source config.- Parameters:
documentDbEventSourceConfig
- Document db event source config. This parameter is required.- Returns:
this
- See Also:
-
enabled
Disables the event source mapping to pause polling and invocation.- Parameters:
enabled
- Disables the event source mapping to pause polling and invocation. This parameter is required.- Returns:
this
- See Also:
-
enabled
Disables the event source mapping to pause polling and invocation.- Parameters:
enabled
- Disables the event source mapping to pause polling and invocation. This parameter is required.- Returns:
this
- See Also:
-
eventSourceArn
The Amazon Resource Name (ARN) of the event source.- Parameters:
eventSourceArn
- The Amazon Resource Name (ARN) of the event source. This parameter is required.- Returns:
this
- See Also:
-
filterCriteria
The filter criteria to control event filtering.- Parameters:
filterCriteria
- The filter criteria to control event filtering. This parameter is required.- Returns:
this
- See Also:
-
filterCriteria
@Stability(Stable) public CfnEventSourceMapping.Builder filterCriteria(CfnEventSourceMapping.FilterCriteriaProperty filterCriteria) The filter criteria to control event filtering.- Parameters:
filterCriteria
- The filter criteria to control event filtering. This parameter is required.- Returns:
this
- See Also:
-
functionResponseTypes
@Stability(Stable) public CfnEventSourceMapping.Builder functionResponseTypes(List<String> functionResponseTypes) (Streams) A list of response types supported by the function.- Parameters:
functionResponseTypes
- (Streams) A list of response types supported by the function. This parameter is required.- Returns:
this
- See Also:
-
kmsKeyArn
The Amazon Resource Name (ARN) of the KMS key.- Parameters:
kmsKeyArn
- The Amazon Resource Name (ARN) of the KMS key. This parameter is required.- Returns:
this
- See Also:
-
maximumBatchingWindowInSeconds
@Stability(Stable) public CfnEventSourceMapping.Builder maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) (Streams) The maximum amount of time to gather records before invoking the function, in seconds.- Parameters:
maximumBatchingWindowInSeconds
- (Streams) The maximum amount of time to gather records before invoking the function, in seconds. This parameter is required.- Returns:
this
- See Also:
-
maximumRecordAgeInSeconds
@Stability(Stable) public CfnEventSourceMapping.Builder maximumRecordAgeInSeconds(Number maximumRecordAgeInSeconds) (Streams) The maximum age of a record that Lambda sends to a function for processing.- Parameters:
maximumRecordAgeInSeconds
- (Streams) The maximum age of a record that Lambda sends to a function for processing. This parameter is required.- Returns:
this
- See Also:
-
maximumRetryAttempts
@Stability(Stable) public CfnEventSourceMapping.Builder maximumRetryAttempts(Number maximumRetryAttempts) (Streams) The maximum number of times to retry when the function returns an error.- Parameters:
maximumRetryAttempts
- (Streams) The maximum number of times to retry when the function returns an error. This parameter is required.- Returns:
this
- See Also:
-
metricsConfig
Metrics config for Event Source Mapping Metrics.- Parameters:
metricsConfig
- Metrics config for Event Source Mapping Metrics. This parameter is required.- Returns:
this
- See Also:
-
metricsConfig
@Stability(Stable) public CfnEventSourceMapping.Builder metricsConfig(CfnEventSourceMapping.MetricsConfigProperty metricsConfig) Metrics config for Event Source Mapping Metrics.- Parameters:
metricsConfig
- Metrics config for Event Source Mapping Metrics. This parameter is required.- Returns:
this
- See Also:
-
parallelizationFactor
@Stability(Stable) public CfnEventSourceMapping.Builder parallelizationFactor(Number parallelizationFactor) (Streams) The number of batches to process from each shard concurrently.- Parameters:
parallelizationFactor
- (Streams) The number of batches to process from each shard concurrently. This parameter is required.- Returns:
this
- See Also:
-
provisionedPollerConfig
@Stability(Stable) public CfnEventSourceMapping.Builder provisionedPollerConfig(IResolvable provisionedPollerConfig) ProvisionedPollerConfig.- Parameters:
provisionedPollerConfig
- ProvisionedPollerConfig. This parameter is required.- Returns:
this
- See Also:
-
provisionedPollerConfig
@Stability(Stable) public CfnEventSourceMapping.Builder provisionedPollerConfig(CfnEventSourceMapping.ProvisionedPollerConfigProperty provisionedPollerConfig) ProvisionedPollerConfig.- Parameters:
provisionedPollerConfig
- ProvisionedPollerConfig. This parameter is required.- Returns:
this
- See Also:
-
queues
(ActiveMQ) A list of ActiveMQ queues.- Parameters:
queues
- (ActiveMQ) A list of ActiveMQ queues. This parameter is required.- Returns:
this
- See Also:
-
scalingConfig
The scaling configuration for the event source.- Parameters:
scalingConfig
- The scaling configuration for the event source. This parameter is required.- Returns:
this
- See Also:
-
scalingConfig
@Stability(Stable) public CfnEventSourceMapping.Builder scalingConfig(CfnEventSourceMapping.ScalingConfigProperty scalingConfig) The scaling configuration for the event source.- Parameters:
scalingConfig
- The scaling configuration for the event source. This parameter is required.- Returns:
this
- See Also:
-
selfManagedEventSource
@Stability(Stable) public CfnEventSourceMapping.Builder selfManagedEventSource(IResolvable selfManagedEventSource) The configuration used by AWS Lambda to access a self-managed event source.- Parameters:
selfManagedEventSource
- The configuration used by AWS Lambda to access a self-managed event source. This parameter is required.- Returns:
this
- See Also:
-
selfManagedEventSource
@Stability(Stable) public CfnEventSourceMapping.Builder selfManagedEventSource(CfnEventSourceMapping.SelfManagedEventSourceProperty selfManagedEventSource) The configuration used by AWS Lambda to access a self-managed event source.- Parameters:
selfManagedEventSource
- The configuration used by AWS Lambda to access a self-managed event source. This parameter is required.- Returns:
this
- See Also:
-
selfManagedKafkaEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder selfManagedKafkaEventSourceConfig(IResolvable selfManagedKafkaEventSourceConfig) Specific configuration settings for a Self-Managed Apache Kafka event source.- Parameters:
selfManagedKafkaEventSourceConfig
- Specific configuration settings for a Self-Managed Apache Kafka event source. This parameter is required.- Returns:
this
- See Also:
-
selfManagedKafkaEventSourceConfig
@Stability(Stable) public CfnEventSourceMapping.Builder selfManagedKafkaEventSourceConfig(CfnEventSourceMapping.SelfManagedKafkaEventSourceConfigProperty selfManagedKafkaEventSourceConfig) Specific configuration settings for a Self-Managed Apache Kafka event source.- Parameters:
selfManagedKafkaEventSourceConfig
- Specific configuration settings for a Self-Managed Apache Kafka event source. This parameter is required.- Returns:
this
- See Also:
-
sourceAccessConfigurations
@Stability(Stable) public CfnEventSourceMapping.Builder sourceAccessConfigurations(IResolvable sourceAccessConfigurations) A list of SourceAccessConfiguration.- Parameters:
sourceAccessConfigurations
- A list of SourceAccessConfiguration. This parameter is required.- Returns:
this
- See Also:
-
sourceAccessConfigurations
@Stability(Stable) public CfnEventSourceMapping.Builder sourceAccessConfigurations(List<? extends Object> sourceAccessConfigurations) A list of SourceAccessConfiguration.- Parameters:
sourceAccessConfigurations
- A list of SourceAccessConfiguration. This parameter is required.- Returns:
this
- See Also:
-
startingPosition
The position in a stream from which to start reading.Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
- Parameters:
startingPosition
- The position in a stream from which to start reading. This parameter is required.- Returns:
this
- See Also:
-
startingPositionTimestamp
@Stability(Stable) public CfnEventSourceMapping.Builder startingPositionTimestamp(Number startingPositionTimestamp) With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.- Parameters:
startingPositionTimestamp
- With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. This parameter is required.- Returns:
this
- See Also:
-
tags
A list of tags to apply to event source mapping resource.- Parameters:
tags
- A list of tags to apply to event source mapping resource. This parameter is required.- Returns:
this
- See Also:
-
topics
(Kafka) A list of Kafka topics.- Parameters:
topics
- (Kafka) A list of Kafka topics. This parameter is required.- Returns:
this
- See Also:
-
tumblingWindowInSeconds
@Stability(Stable) public CfnEventSourceMapping.Builder tumblingWindowInSeconds(Number tumblingWindowInSeconds) (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.- Parameters:
tumblingWindowInSeconds
- (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations. This parameter is required.- Returns:
this
- See Also:
-
build
- Specified by:
build
in interfacesoftware.amazon.jsii.Builder<CfnEventSourceMapping>
- Returns:
- a newly built instance of
CfnEventSourceMapping
.
-