pulumi-aws-native-kotlin/com.pulumi.awsnative.pipes.kotlin.inputs/PipeSourceKinesisStreamParametersArgsBuilder

PipeSourceKinesisStreamParametersArgsBuilder

class PipeSourceKinesisStreamParametersArgsBuilder

Builder for PipeSourceKinesisStreamParametersArgs.

Functions

batchSize

@JvmName(name = "ejrkkwbouenjfnqx")

suspend fun batchSize(value: Output<Int>)

@JvmName(name = "jhetfxeljsendbxx")

suspend fun batchSize(value: Int?)

deadLetterConfig

@JvmName(name = "eeorkdcjfvfstqdg")

suspend fun deadLetterConfig(value: PipeDeadLetterConfigArgs?)

@JvmName(name = "nwhoeqvoqnbbptpd")

suspend fun deadLetterConfig(value: Output<PipeDeadLetterConfigArgs>)

@JvmName(name = "dajpoxkbxtrketnr")

suspend fun deadLetterConfig(argument: suspend PipeDeadLetterConfigArgsBuilder.() -> Unit)

maximumBatchingWindowInSeconds

@JvmName(name = "iwvrvmipdhrgrpjl")

suspend fun maximumBatchingWindowInSeconds(value: Output<Int>)

@JvmName(name = "yweduilcaejuiabl")

suspend fun maximumBatchingWindowInSeconds(value: Int?)

maximumRecordAgeInSeconds

@JvmName(name = "sqsnbmrwgnwjkftx")

suspend fun maximumRecordAgeInSeconds(value: Output<Int>)

@JvmName(name = "tpbhquahefolxpwn")

suspend fun maximumRecordAgeInSeconds(value: Int?)

maximumRetryAttempts

@JvmName(name = "ahigypnwvovvlnfw")

suspend fun maximumRetryAttempts(value: Output<Int>)

@JvmName(name = "udrjuopogufoapmx")

suspend fun maximumRetryAttempts(value: Int?)

onPartialBatchItemFailure

@JvmName(name = "tqufkiplfnuqplxj")

suspend fun onPartialBatchItemFailure(value: PipeOnPartialBatchItemFailureStreams?)

@JvmName(name = "tdfwwwrkhpabksux")

suspend fun onPartialBatchItemFailure(value: Output<PipeOnPartialBatchItemFailureStreams>)

parallelizationFactor

@JvmName(name = "jyihvlvdjeibwxlw")

suspend fun parallelizationFactor(value: Output<Int>)

@JvmName(name = "vkdphmhawpknyxmm")

suspend fun parallelizationFactor(value: Int?)

startingPosition

@JvmName(name = "qwtmpqjufkokifwr")

suspend fun startingPosition(value: PipeKinesisStreamStartPosition)

@JvmName(name = "qdyqmrmkpbepgsar")

suspend fun startingPosition(value: Output<PipeKinesisStreamStartPosition>)

startingPositionTimestamp

@JvmName(name = "grujicdudgtyypjn")

suspend fun startingPositionTimestamp(value: Output<String>)

@JvmName(name = "borlxiaeqmmlswen")

suspend fun startingPositionTimestamp(value: String?)