Class: Aws::Pipes::Types::PipeSourceParameters
- Inherits:
-
Struct
- Object
- Struct
- Aws::Pipes::Types::PipeSourceParameters
- Defined in:
- gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb
Overview
The parameters required to set up a source for your pipe.
Constant Summary collapse
- SENSITIVE =
[]
Instance Attribute Summary collapse
-
#active_mq_broker_parameters ⇒ Types::PipeSourceActiveMQBrokerParameters
The parameters for using an Active MQ broker as a source.
-
#dynamo_db_stream_parameters ⇒ Types::PipeSourceDynamoDBStreamParameters
The parameters for using a DynamoDB stream as a source.
-
#filter_criteria ⇒ Types::FilterCriteria
The collection of event patterns used to filter events.
-
#kinesis_stream_parameters ⇒ Types::PipeSourceKinesisStreamParameters
The parameters for using a Kinesis stream as a source.
-
#managed_streaming_kafka_parameters ⇒ Types::PipeSourceManagedStreamingKafkaParameters
The parameters for using an MSK stream as a source.
-
#rabbit_mq_broker_parameters ⇒ Types::PipeSourceRabbitMQBrokerParameters
The parameters for using a Rabbit MQ broker as a source.
-
#self_managed_kafka_parameters ⇒ Types::PipeSourceSelfManagedKafkaParameters
The parameters for using a self-managed Apache Kafka stream as a source.
-
#sqs_queue_parameters ⇒ Types::PipeSourceSqsQueueParameters
The parameters for using a Amazon SQS stream as a source.
Instance Attribute Details
#active_mq_broker_parameters ⇒ Types::PipeSourceActiveMQBrokerParameters
The parameters for using an Active MQ broker as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#dynamo_db_stream_parameters ⇒ Types::PipeSourceDynamoDBStreamParameters
The parameters for using a DynamoDB stream as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#filter_criteria ⇒ Types::FilterCriteria
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.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#kinesis_stream_parameters ⇒ Types::PipeSourceKinesisStreamParameters
The parameters for using a Kinesis stream as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#managed_streaming_kafka_parameters ⇒ Types::PipeSourceManagedStreamingKafkaParameters
The parameters for using an MSK stream as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#rabbit_mq_broker_parameters ⇒ Types::PipeSourceRabbitMQBrokerParameters
The parameters for using a Rabbit MQ broker as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#self_managed_kafka_parameters ⇒ Types::PipeSourceSelfManagedKafkaParameters
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.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |
#sqs_queue_parameters ⇒ Types::PipeSourceSqsQueueParameters
The parameters for using a Amazon SQS stream as a source.
1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 |
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1925 class PipeSourceParameters < Struct.new( :filter_criteria, :kinesis_stream_parameters, :dynamo_db_stream_parameters, :sqs_queue_parameters, :active_mq_broker_parameters, :rabbit_mq_broker_parameters, :managed_streaming_kafka_parameters, :self_managed_kafka_parameters) SENSITIVE = [] include Aws::Structure end |