pulumi-aws-native-kotlin/com.pulumi.awsnative.lambda.kotlin/EventSourceMapping

EventSourceMapping

class EventSourceMapping : KotlinCustomResource

Resource Type definition for AWS::Lambda::EventSourceMapping

Properties

Link copied to clipboard
val amazonManagedKafkaEventSourceConfig: Output<EventSourceMappingAmazonManagedKafkaEventSourceConfig>?

Specific configuration settings for an MSK event source.

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

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

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

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

Link copied to clipboard
val destinationConfig: Output<EventSourceMappingDestinationConfig>?

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

Link copied to clipboard
val documentDbEventSourceConfig: Output<EventSourceMappingDocumentDbEventSourceConfig>?

Document db event source config.

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

Disables the event source mapping to pause polling and invocation.

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

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

Link copied to clipboard
val filterCriteria: Output<EventSourceMappingFilterCriteria>?

The filter criteria to control event filtering.

Link copied to clipboard
val functionName: Output<String>

The name of the Lambda function.

Link copied to clipboard
val functionResponseTypes: Output<List<EventSourceMappingFunctionResponseTypesItem>>?

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

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val maximumBatchingWindowInSeconds: Output<Int>?

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

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

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

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

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

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

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

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val queues: Output<List<String>>?

(ActiveMQ) A list of ActiveMQ queues.

Link copied to clipboard
val scalingConfig: Output<EventSourceMappingScalingConfig>?

The scaling configuration for the event source.

Link copied to clipboard
val selfManagedEventSource: Output<EventSourceMappingSelfManagedEventSource>?

Self-managed event source endpoints.

Link copied to clipboard
val selfManagedKafkaEventSourceConfig: Output<EventSourceMappingSelfManagedKafkaEventSourceConfig>?

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

Link copied to clipboard
val sourceAccessConfigurations: Output<List<EventSourceMappingSourceAccessConfiguration>>?

A list of SourceAccessConfiguration.

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

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>?

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>>?

(Kafka) A list of Kafka topics.

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

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

Link copied to clipboard
val urn: Output<String>