Values.PipeSourceParametersSourceThe parameters required to set up a source for your pipe.
type nonrec t = {filterCriteria : FilterCriteria.t option;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 : PipeSourceKinesisStreamParameters.t option;The parameters for using a Kinesis stream as a source.
*)dynamoDBStreamParameters : PipeSourceDynamoDBStreamParameters.t option;The parameters for using a DynamoDB stream as a source.
*)sqsQueueParameters : PipeSourceSqsQueueParameters.t option;The parameters for using a Amazon SQS stream as a source.
*)activeMQBrokerParameters : PipeSourceActiveMQBrokerParameters.t option;The parameters for using an Active MQ broker as a source.
*)rabbitMQBrokerParameters : PipeSourceRabbitMQBrokerParameters.t option;The parameters for using a Rabbit MQ broker as a source.
*)managedStreamingKafkaParameters : PipeSourceManagedStreamingKafkaParameters.t
option;The parameters for using an MSK stream as a source.
*)selfManagedKafkaParameters : PipeSourceSelfManagedKafkaParameters.t option;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 Amazon Web Services. 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.
*)}val make :
?filterCriteria:FilterCriteria.t ->
?kinesisStreamParameters:PipeSourceKinesisStreamParameters.t ->
?dynamoDBStreamParameters:PipeSourceDynamoDBStreamParameters.t ->
?sqsQueueParameters:PipeSourceSqsQueueParameters.t ->
?activeMQBrokerParameters:PipeSourceActiveMQBrokerParameters.t ->
?rabbitMQBrokerParameters:PipeSourceRabbitMQBrokerParameters.t ->
?managedStreamingKafkaParameters:PipeSourceManagedStreamingKafkaParameters.t ->
?selfManagedKafkaParameters:PipeSourceSelfManagedKafkaParameters.t ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Structure of
(string
* [> `Enum of string
| `Integer of LimitMax10000.t
| `List of
[> `String of EndpointString.t
| `Structure of
(string * [> `String of EventPattern.t ]) list ]
list
| `String of MQBrokerQueueName.t
| `Structure of
(string
* [> `List of [> `String of SubnetId.t ] list
| `String of Arn.t ])
list
| `Timestamp of Timestamp.t ])
list ])
list ]