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

PipeSourceParametersArgs

data class PipeSourceParametersArgs(val activeMqBrokerParameters: Output<PipeSourceActiveMqBrokerParametersArgs>? = null, val dynamoDbStreamParameters: Output<PipeSourceDynamoDbStreamParametersArgs>? = null, val filterCriteria: Output<PipeFilterCriteriaArgs>? = null, val kinesisStreamParameters: Output<PipeSourceKinesisStreamParametersArgs>? = null, val managedStreamingKafkaParameters: Output<PipeSourceManagedStreamingKafkaParametersArgs>? = null, val rabbitMqBrokerParameters: Output<PipeSourceRabbitMqBrokerParametersArgs>? = null, val selfManagedKafkaParameters: Output<PipeSourceSelfManagedKafkaParametersArgs>? = null, val sqsQueueParameters: Output<PipeSourceSqsQueueParametersArgs>? = null) : ConvertibleToJava<PipeSourceParametersArgs>

Constructors

constructor(activeMqBrokerParameters: Output<PipeSourceActiveMqBrokerParametersArgs>? = null, dynamoDbStreamParameters: Output<PipeSourceDynamoDbStreamParametersArgs>? = null, filterCriteria: Output<PipeFilterCriteriaArgs>? = null, kinesisStreamParameters: Output<PipeSourceKinesisStreamParametersArgs>? = null, managedStreamingKafkaParameters: Output<PipeSourceManagedStreamingKafkaParametersArgs>? = null, rabbitMqBrokerParameters: Output<PipeSourceRabbitMqBrokerParametersArgs>? = null, selfManagedKafkaParameters: Output<PipeSourceSelfManagedKafkaParametersArgs>? = null, sqsQueueParameters: Output<PipeSourceSqsQueueParametersArgs>? = null)

Properties

activeMqBrokerParameters

val activeMqBrokerParameters: Output<PipeSourceActiveMqBrokerParametersArgs>? = null

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

dynamoDbStreamParameters

val dynamoDbStreamParameters: Output<PipeSourceDynamoDbStreamParametersArgs>? = null

The parameters for using a DynamoDB stream as a source.

filterCriteria

val filterCriteria: Output<PipeFilterCriteriaArgs>? = null

The collection of event patterns used to filter events. To remove a filter, specify a FilterCriteria object with an empty array of Filter objects. For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .

kinesisStreamParameters

val kinesisStreamParameters: Output<PipeSourceKinesisStreamParametersArgs>? = null

The parameters for using a Kinesis stream as a source.

managedStreamingKafkaParameters

val managedStreamingKafkaParameters: Output<PipeSourceManagedStreamingKafkaParametersArgs>? = null

The parameters for using an MSK stream as a source.

rabbitMqBrokerParameters

val rabbitMqBrokerParameters: Output<PipeSourceRabbitMqBrokerParametersArgs>? = null

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

selfManagedKafkaParameters

val selfManagedKafkaParameters: Output<PipeSourceSelfManagedKafkaParametersArgs>? = null

The parameters for using a self-managed Apache Kafka stream as a source. A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .

sqsQueueParameters

val sqsQueueParameters: Output<PipeSourceSqsQueueParametersArgs>? = null

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

Functions

toJava

open override fun toJava(): PipeSourceParametersArgs