pulumi-aws-native-kotlin/com.pulumi.awsnative.pipes.kotlin.outputs/PipeSourceDynamoDbStreamParameters

PipeSourceDynamoDbStreamParameters

data class PipeSourceDynamoDbStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: PipeOnPartialBatchItemFailureStreams? = null, val parallelizationFactor: Int? = null, val startingPosition: PipeDynamoDbStreamStartPosition)

Constructors

constructor(batchSize: Int? = null, deadLetterConfig: PipeDeadLetterConfig? = null, maximumBatchingWindowInSeconds: Int? = null, maximumRecordAgeInSeconds: Int? = null, maximumRetryAttempts: Int? = null, onPartialBatchItemFailure: PipeOnPartialBatchItemFailureStreams? = null, parallelizationFactor: Int? = null, startingPosition: PipeDynamoDbStreamStartPosition)

Types

Companion

object Companion

Properties

batchSize

val batchSize: Int? = null

The maximum number of records to include in each batch.

deadLetterConfig

val deadLetterConfig: PipeDeadLetterConfig? = null

Define the target queue to send dead-letter queue events to.

maximumBatchingWindowInSeconds

val maximumBatchingWindowInSeconds: Int? = null

The maximum length of a time to wait for events.

maximumRecordAgeInSeconds

val maximumRecordAgeInSeconds: Int? = null

Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

maximumRetryAttempts

val maximumRetryAttempts: Int? = null

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

onPartialBatchItemFailure

val onPartialBatchItemFailure: PipeOnPartialBatchItemFailureStreams? = null

Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

parallelizationFactor

val parallelizationFactor: Int? = null

The number of batches to process concurrently from each shard. The default value is 1.

startingPosition

val startingPosition: PipeDynamoDbStreamStartPosition

(Streams only) The position in a stream from which to start reading. Valid values : TRIM_HORIZON | LATEST