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

PipeSourceParameters

data class PipeSourceParameters(val activeMqBrokerParameters: PipeSourceActiveMqBrokerParameters? = null, val dynamoDbStreamParameters: PipeSourceDynamoDbStreamParameters? = null, val filterCriteria: PipeFilterCriteria? = null, val kinesisStreamParameters: PipeSourceKinesisStreamParameters? = null, val managedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParameters? = null, val rabbitMqBrokerParameters: PipeSourceRabbitMqBrokerParameters? = null, val selfManagedKafkaParameters: PipeSourceSelfManagedKafkaParameters? = null, val sqsQueueParameters: PipeSourceSqsQueueParameters? = null)

Constructors

constructor(activeMqBrokerParameters: PipeSourceActiveMqBrokerParameters? = null, dynamoDbStreamParameters: PipeSourceDynamoDbStreamParameters? = null, filterCriteria: PipeFilterCriteria? = null, kinesisStreamParameters: PipeSourceKinesisStreamParameters? = null, managedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParameters? = null, rabbitMqBrokerParameters: PipeSourceRabbitMqBrokerParameters? = null, selfManagedKafkaParameters: PipeSourceSelfManagedKafkaParameters? = null, sqsQueueParameters: PipeSourceSqsQueueParameters? = null)

Types

Companion

object Companion

Properties

activeMqBrokerParameters

val activeMqBrokerParameters: PipeSourceActiveMqBrokerParameters? = null

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

dynamoDbStreamParameters

val dynamoDbStreamParameters: PipeSourceDynamoDbStreamParameters? = null

The parameters for using a DynamoDB stream as a source.

filterCriteria

val filterCriteria: PipeFilterCriteria? = 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: PipeSourceKinesisStreamParameters? = null

The parameters for using a Kinesis stream as a source.

managedStreamingKafkaParameters

val managedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParameters? = null

The parameters for using an MSK stream as a source.

rabbitMqBrokerParameters

val rabbitMqBrokerParameters: PipeSourceRabbitMqBrokerParameters? = null

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

selfManagedKafkaParameters

val selfManagedKafkaParameters: PipeSourceSelfManagedKafkaParameters? = 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: PipeSourceSqsQueueParameters? = null

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