Class PipeSourceParameters


  • public final class PipeSourceParameters
    extends java.lang.Object
    • Method Detail

      • activemqBrokerParameters

        public java.util.Optional<PipeSourceParametersActivemqBrokerParameters> activemqBrokerParameters()
        Returns:
        Parameters for using an Active MQ broker as a source. See `activemqBrokerParameters` Block for details.
      • dynamodbStreamParameters

        public java.util.Optional<PipeSourceParametersDynamodbStreamParameters> dynamodbStreamParameters()
        Returns:
        Parameters for using a DynamoDB stream as a source. See `dynamodbStreamParameters` Block for details.
      • filterCriteria

        public java.util.Optional<PipeSourceParametersFilterCriteria> filterCriteria()
        Returns:
        Collection of event patterns used to [filter events](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-filtering.html). See `filterCriteria` Block for details.
      • kinesisStreamParameters

        public java.util.Optional<PipeSourceParametersKinesisStreamParameters> kinesisStreamParameters()
        Returns:
        Parameters for using a Kinesis stream as a source. See `source_parameters.kinesis_stream_parameters` Block for details.
      • managedStreamingKafkaParameters

        public java.util.Optional<PipeSourceParametersManagedStreamingKafkaParameters> managedStreamingKafkaParameters()
        Returns:
        Parameters for using an MSK stream as a source. See `managedStreamingKafkaParameters` Block for details.
      • rabbitmqBrokerParameters

        public java.util.Optional<PipeSourceParametersRabbitmqBrokerParameters> rabbitmqBrokerParameters()
        Returns:
        Parameters for using a Rabbit MQ broker as a source. See `rabbitmqBrokerParameters` Block for details.
      • selfManagedKafkaParameters

        public java.util.Optional<PipeSourceParametersSelfManagedKafkaParameters> selfManagedKafkaParameters()
        Returns:
        Parameters for using a self-managed Apache Kafka stream as a source. See `selfManagedKafkaParameters` Block for details.
      • sqsQueueParameters

        public java.util.Optional<PipeSourceParametersSqsQueueParameters> sqsQueueParameters()
        Returns:
        Parameters for using an Amazon SQS stream as a source. See `source_parameters.sqs_queue_parameters` Block for details.