EventSourceMappingArgs

data class EventSourceMappingArgs(val amazonManagedKafkaEventSourceConfig: Output<EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs>? = null, val batchSize: Output<Int>? = null, val bisectBatchOnFunctionError: Output<Boolean>? = null, val destinationConfig: Output<EventSourceMappingDestinationConfigArgs>? = null, val documentDbEventSourceConfig: Output<EventSourceMappingDocumentDbEventSourceConfigArgs>? = null, val enabled: Output<Boolean>? = null, val eventSourceArn: Output<String>? = null, val filterCriteria: Output<EventSourceMappingFilterCriteriaArgs>? = null, val functionName: Output<String>? = null, val functionResponseTypes: Output<List<EventSourceMappingFunctionResponseTypesItem>>? = null, val maximumBatchingWindowInSeconds: Output<Int>? = null, val maximumRecordAgeInSeconds: Output<Int>? = null, val maximumRetryAttempts: Output<Int>? = null, val parallelizationFactor: Output<Int>? = null, val queues: Output<List<String>>? = null, val scalingConfig: Output<EventSourceMappingScalingConfigArgs>? = null, val selfManagedEventSource: Output<EventSourceMappingSelfManagedEventSourceArgs>? = null, val selfManagedKafkaEventSourceConfig: Output<EventSourceMappingSelfManagedKafkaEventSourceConfigArgs>? = null, val sourceAccessConfigurations: Output<List<EventSourceMappingSourceAccessConfigurationArgs>>? = null, val startingPosition: Output<String>? = null, val startingPositionTimestamp: Output<Double>? = null, val topics: Output<List<String>>? = null, val tumblingWindowInSeconds: Output<Int>? = null) : ConvertibleToJava<EventSourceMappingArgs>

Resource Type definition for AWS::Lambda::EventSourceMapping

Constructors

Link copied to clipboard
fun EventSourceMappingArgs(amazonManagedKafkaEventSourceConfig: Output<EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs>? = null, batchSize: Output<Int>? = null, bisectBatchOnFunctionError: Output<Boolean>? = null, destinationConfig: Output<EventSourceMappingDestinationConfigArgs>? = null, documentDbEventSourceConfig: Output<EventSourceMappingDocumentDbEventSourceConfigArgs>? = null, enabled: Output<Boolean>? = null, eventSourceArn: Output<String>? = null, filterCriteria: Output<EventSourceMappingFilterCriteriaArgs>? = null, functionName: Output<String>? = null, functionResponseTypes: Output<List<EventSourceMappingFunctionResponseTypesItem>>? = null, maximumBatchingWindowInSeconds: Output<Int>? = null, maximumRecordAgeInSeconds: Output<Int>? = null, maximumRetryAttempts: Output<Int>? = null, parallelizationFactor: Output<Int>? = null, queues: Output<List<String>>? = null, scalingConfig: Output<EventSourceMappingScalingConfigArgs>? = null, selfManagedEventSource: Output<EventSourceMappingSelfManagedEventSourceArgs>? = null, selfManagedKafkaEventSourceConfig: Output<EventSourceMappingSelfManagedKafkaEventSourceConfigArgs>? = null, sourceAccessConfigurations: Output<List<EventSourceMappingSourceAccessConfigurationArgs>>? = null, startingPosition: Output<String>? = null, startingPositionTimestamp: Output<Double>? = null, topics: Output<List<String>>? = null, tumblingWindowInSeconds: Output<Int>? = null)

Functions

Link copied to clipboard
open override fun toJava(): EventSourceMappingArgs

Properties

Link copied to clipboard

Specific configuration settings for an MSK event source.

Link copied to clipboard
val batchSize: Output<Int>? = null

The maximum number of items to retrieve in a single batch.

Link copied to clipboard
val bisectBatchOnFunctionError: Output<Boolean>? = null

(Streams) If the function returns an error, split the batch in two and retry.

Link copied to clipboard

(Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.

Link copied to clipboard

Document db event source config.

Link copied to clipboard
val enabled: Output<Boolean>? = null

Disables the event source mapping to pause polling and invocation.

Link copied to clipboard
val eventSourceArn: Output<String>? = null

The Amazon Resource Name (ARN) of the event source.

Link copied to clipboard

The filter criteria to control event filtering.

Link copied to clipboard
val functionName: Output<String>? = null

The name of the Lambda function.

Link copied to clipboard

(Streams) A list of response types supported by the function.

Link copied to clipboard
val maximumBatchingWindowInSeconds: Output<Int>? = null

(Streams) The maximum amount of time to gather records before invoking the function, in seconds.

Link copied to clipboard
val maximumRecordAgeInSeconds: Output<Int>? = null

(Streams) The maximum age of a record that Lambda sends to a function for processing.

Link copied to clipboard
val maximumRetryAttempts: Output<Int>? = null

(Streams) The maximum number of times to retry when the function returns an error.

Link copied to clipboard
val parallelizationFactor: Output<Int>? = null

(Streams) The number of batches to process from each shard concurrently.

Link copied to clipboard
val queues: Output<List<String>>? = null

(ActiveMQ) A list of ActiveMQ queues.

Link copied to clipboard

The scaling configuration for the event source.

Link copied to clipboard

Self-managed event source endpoints.

Link copied to clipboard

Specific configuration settings for a Self-Managed Apache Kafka event source.

Link copied to clipboard

A list of SourceAccessConfiguration.

Link copied to clipboard
val startingPosition: Output<String>? = null

The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.

Link copied to clipboard
val startingPositionTimestamp: Output<Double>? = null

With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

Link copied to clipboard
val topics: Output<List<String>>? = null

(Kafka) A list of Kafka topics.

Link copied to clipboard
val tumblingWindowInSeconds: Output<Int>? = null

(Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.