Package software.amazon.awscdk.services.lambda.eventsources

Class StreamEventSourceProps.Jsii$Proxy

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.services.lambda.eventsources.StreamEventSourceProps.Jsii$Proxy

All Implemented Interfaces:

BaseStreamEventSourceProps, StreamEventSourceProps, software.amazon.jsii.JsiiSerializable

Enclosing interface:

StreamEventSourceProps

@Stability(Stable)
@Internal
public static final class StreamEventSourceProps.Jsii$Proxy
extends software.amazon.jsii.JsiiObject
implements StreamEventSourceProps

An implementation for StreamEventSourceProps

Nested Class Summary

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.lambda.eventsources.StreamEventSourceProps

StreamEventSourceProps.Builder, StreamEventSourceProps.Jsii$Proxy

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Jsii$Proxy(StreamEventSourceProps.Builder builder)	Constructor that initializes the object based on literal property values passed by the StreamEventSourceProps.Builder.
protected	Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)	Constructor that initializes the object based on values retrieved from the JsiiObject.

Method Summary

Modifier and Type	Method	Description
com.fasterxml.jackson.databind.JsonNode	$jsii$toJson()
final boolean	equals(Object o)
final Number	getBatchSize()	The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
final Boolean	getBisectBatchOnError()	If the function returns an error, split the batch in two and retry.
final Boolean	getEnabled()	If the stream event source mapping should be enabled.
final IKey	getFilterEncryption()	Add Customer managed KMS key to encrypt Filter Criteria.
final List<Map<String,Object>>	getFilters()	Add filter criteria option.
final Duration	getMaxBatchingWindow()	The maximum amount of time to gather records before invoking the function.
final Duration	getMaxRecordAge()	The maximum age of a record that Lambda sends to a function for processing.
final MetricsConfig	getMetricsConfig()	Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.
final IEventSourceDlq	getOnFailure()	An Amazon SQS queue or Amazon SNS topic destination for discarded records.
final Number	getParallelizationFactor()	The number of batches to process from each shard concurrently.
final ProvisionedPollerConfig	getProvisionedPollerConfig()	Configuration for provisioned pollers that read from the event source.
final Boolean	getReportBatchItemFailures()	Allow functions to return partially successful responses for a batch of records.
final Number	getRetryAttempts()	Maximum number of retry attempts Valid Range: * Minimum value of 0 * Maximum value of 10000.
final StartingPosition	getStartingPosition()	Where to begin consuming the stream.
final Duration	getTumblingWindow()	The size of the tumbling windows to group records sent to DynamoDB or Kinesis Valid Range: 0 - 15 minutes.
final int	hashCode()

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Jsii$Proxy

protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)

Constructor that initializes the object based on values retrieved from the JsiiObject.

Parameters:

objRef - Reference to the JSII managed object.

Jsii$Proxy

protected Jsii$Proxy(StreamEventSourceProps.Builder builder)

Constructor that initializes the object based on literal property values passed by the StreamEventSourceProps.Builder.

Method Details

getBisectBatchOnError

public final Boolean getBisectBatchOnError()

Description copied from interface: StreamEventSourceProps

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

Default: false

Specified by:

getBisectBatchOnError in interface StreamEventSourceProps

getFilterEncryption

public final IKey getFilterEncryption()

Description copied from interface: StreamEventSourceProps

Add Customer managed KMS key to encrypt Filter Criteria.

Default: - none

Specified by:

getFilterEncryption in interface StreamEventSourceProps

See Also:

• https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#aws-managed-cmk

getFilters

public final List<Map<String,Object>> getFilters()

Description copied from interface: StreamEventSourceProps

Add filter criteria option.

Default: - None

Specified by:

getFilters in interface StreamEventSourceProps

getMaxRecordAge

public final Duration getMaxRecordAge()

Description copied from interface: StreamEventSourceProps

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

Valid Range:

• Minimum value of 60 seconds
• Maximum value of 7 days

The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. Record are valid until it expires in the event source.

Default: -1

Specified by:

getMaxRecordAge in interface StreamEventSourceProps

getMetricsConfig

public final MetricsConfig getMetricsConfig()

Description copied from interface: StreamEventSourceProps

Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.

Default: - Enhanced monitoring is disabled

Specified by:

getMetricsConfig in interface StreamEventSourceProps

getOnFailure

public final IEventSourceDlq getOnFailure()

Description copied from interface: StreamEventSourceProps

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

Default: - discarded records are ignored

Specified by:

getOnFailure in interface StreamEventSourceProps

getParallelizationFactor

public final Number getParallelizationFactor()

Description copied from interface: StreamEventSourceProps

The number of batches to process from each shard concurrently.

Valid Range:

• Minimum value of 1
• Maximum value of 10

Default: 1

Specified by:

getParallelizationFactor in interface StreamEventSourceProps

getReportBatchItemFailures

public final Boolean getReportBatchItemFailures()

Description copied from interface: StreamEventSourceProps

Allow functions to return partially successful responses for a batch of records.

Default: false

Specified by:

getReportBatchItemFailures in interface StreamEventSourceProps

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/with-ddb.html#services-ddb-batchfailurereporting

getRetryAttempts

public final Number getRetryAttempts()

Description copied from interface: StreamEventSourceProps

Maximum number of retry attempts Valid Range: * Minimum value of 0 * Maximum value of 10000.

The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.

Default: -1

Specified by:

getRetryAttempts in interface StreamEventSourceProps

getTumblingWindow

public final Duration getTumblingWindow()

Description copied from interface: StreamEventSourceProps

The size of the tumbling windows to group records sent to DynamoDB or Kinesis Valid Range: 0 - 15 minutes.

Default: - None

Specified by:

getTumblingWindow in interface StreamEventSourceProps

getStartingPosition

public final StartingPosition getStartingPosition()

Description copied from interface: BaseStreamEventSourceProps

Where to begin consuming the stream.

Specified by:

getStartingPosition in interface BaseStreamEventSourceProps

getBatchSize

public final Number getBatchSize()

Description copied from interface: BaseStreamEventSourceProps

The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

Your function receives an event with all the retrieved records.

Valid Range:

• Minimum value of 1
• Maximum value of:
  • 1000 for DynamoEventSource
  • 10000 for KinesisEventSource, ManagedKafkaEventSource and SelfManagedKafkaEventSource

Default: 100

Specified by:

getBatchSize in interface BaseStreamEventSourceProps

getEnabled

public final Boolean getEnabled()

Description copied from interface: BaseStreamEventSourceProps

If the stream event source mapping should be enabled.

Default: true

Specified by:

getEnabled in interface BaseStreamEventSourceProps

getMaxBatchingWindow

public final Duration getMaxBatchingWindow()

Description copied from interface: BaseStreamEventSourceProps

The maximum amount of time to gather records before invoking the function.

Maximum of Duration.minutes(5).

Default: - Duration.seconds(0) for Kinesis, DynamoDB, and SQS event sources, Duration.millis(500) for MSK, self-managed Kafka, and Amazon MQ.

Specified by:

getMaxBatchingWindow in interface BaseStreamEventSourceProps

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventsourcemapping.html#invocation-eventsourcemapping-batching

getProvisionedPollerConfig

public final ProvisionedPollerConfig getProvisionedPollerConfig()

Description copied from interface: BaseStreamEventSourceProps

Configuration for provisioned pollers that read from the event source.

When specified, allows control over the minimum and maximum number of pollers that can be provisioned to process events from the source.

Default: - no provisioned pollers

Specified by:

getProvisionedPollerConfig in interface BaseStreamEventSourceProps

$jsii$toJson

@Internal
public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()

Specified by:

$jsii$toJson in interface software.amazon.jsii.JsiiSerializable

equals

public final boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public final int hashCode()

Overrides:

hashCode in class Object