pipes/aws.sdk.kotlin.services.pipes.model/UpdatePipeSourceParameters/Builder

Builder

class Builder

Properties

activeMqBrokerParameters

var activeMqBrokerParameters: UpdatePipeSourceActiveMqBrokerParameters?

The parameters for using an Active MQ broker as a source.

dynamoDbStreamParameters

var dynamoDbStreamParameters: UpdatePipeSourceDynamoDbStreamParameters?

The parameters for using a DynamoDB stream as a source.

filterCriteria

var filterCriteria: FilterCriteria?

The collection of event patterns used to filter events.

kinesisStreamParameters

var kinesisStreamParameters: UpdatePipeSourceKinesisStreamParameters?

The parameters for using a Kinesis stream as a source.

managedStreamingKafkaParameters

var managedStreamingKafkaParameters: UpdatePipeSourceManagedStreamingKafkaParameters?

The parameters for using an MSK stream as a source.

rabbitMqBrokerParameters

var rabbitMqBrokerParameters: UpdatePipeSourceRabbitMqBrokerParameters?

The parameters for using a Rabbit MQ broker as a source.

selfManagedKafkaParameters

var selfManagedKafkaParameters: UpdatePipeSourceSelfManagedKafkaParameters?

The parameters for using a self-managed Apache Kafka stream as a source.

sqsQueueParameters

var sqsQueueParameters: UpdatePipeSourceSqsQueueParameters?

The parameters for using a Amazon SQS stream as a source.

Functions

activeMqBrokerParameters

fun activeMqBrokerParameters(block: UpdatePipeSourceActiveMqBrokerParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceActiveMqBrokerParameters inside the given block

dynamoDbStreamParameters

fun dynamoDbStreamParameters(block: UpdatePipeSourceDynamoDbStreamParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceDynamoDbStreamParameters inside the given block

filterCriteria

fun filterCriteria(block: FilterCriteria.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.FilterCriteria inside the given block

kinesisStreamParameters

fun kinesisStreamParameters(block: UpdatePipeSourceKinesisStreamParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceKinesisStreamParameters inside the given block

managedStreamingKafkaParameters

fun managedStreamingKafkaParameters(block: UpdatePipeSourceManagedStreamingKafkaParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceManagedStreamingKafkaParameters inside the given block

rabbitMqBrokerParameters

fun rabbitMqBrokerParameters(block: UpdatePipeSourceRabbitMqBrokerParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceRabbitMqBrokerParameters inside the given block

selfManagedKafkaParameters

fun selfManagedKafkaParameters(block: UpdatePipeSourceSelfManagedKafkaParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceSelfManagedKafkaParameters inside the given block

sqsQueueParameters

fun sqsQueueParameters(block: UpdatePipeSourceSqsQueueParameters.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.UpdatePipeSourceSqsQueueParameters inside the given block