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

Builder

class Builder

Properties

activeMqBrokerParameters

var activeMqBrokerParameters: PipeSourceActiveMqBrokerParameters?

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

dynamoDbStreamParameters

var dynamoDbStreamParameters: PipeSourceDynamoDbStreamParameters?

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

The parameters for using a Kinesis stream as a source.

managedStreamingKafkaParameters

var managedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParameters?

The parameters for using an MSK stream as a source.

rabbitMqBrokerParameters

var rabbitMqBrokerParameters: PipeSourceRabbitMqBrokerParameters?

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

selfManagedKafkaParameters

var selfManagedKafkaParameters: PipeSourceSelfManagedKafkaParameters?

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

sqsQueueParameters

var sqsQueueParameters: PipeSourceSqsQueueParameters?

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

Functions

activeMqBrokerParameters

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

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

dynamoDbStreamParameters

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

construct an aws.sdk.kotlin.services.pipes.model.PipeSourceDynamoDbStreamParameters 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: PipeSourceKinesisStreamParameters.Builder.() -> Unit)

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

managedStreamingKafkaParameters

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

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

rabbitMqBrokerParameters

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

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

selfManagedKafkaParameters

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

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

sqsQueueParameters

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

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