Class: Aws::Pipes::Types::PipeSourceParameters

Inherits:
Struct
  • Object
show all
Includes:
Structure
Defined in:
lib/aws-sdk-pipes/types.rb

Overview

The parameters required to set up a source for your pipe.

See Also:

Constant Summary collapse

SENSITIVE = 
[]

Instance Attribute Summary collapse

Instance Attribute Details

#active_mq_broker_parameters ⇒ Types::PipeSourceActiveMQBrokerParameters

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

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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.

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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*.

[1]: docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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.

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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.

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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.

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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*.

[1]: www.confluent.io/ [2]: www.cloudkarafka.com/ [3]: redpanda.com/ [4]: docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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.

Returns:



1950
1951
1952
1953
1954
1955
1956
1957
1958
1959
1960
1961
 
# File 'lib/aws-sdk-pipes/types.rb', line 1950

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