Class: Aws::Pipes::Types::UpdatePipeSourceParameters

Inherits:
Struct
  • Object
show all
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

Instance Attribute Details

#active_mq_broker_parametersTypes::UpdatePipeSourceActiveMQBrokerParameters

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



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceDynamoDBStreamParameters

The parameters for using a DynamoDB stream as a source.



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_criteriaTypes::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.



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceKinesisStreamParameters

The parameters for using a Kinesis stream as a source.



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceManagedStreamingKafkaParameters

The parameters for using an MSK stream as a source.



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceRabbitMQBrokerParameters

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



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceSelfManagedKafkaParameters

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.



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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_parametersTypes::UpdatePipeSourceSqsQueueParameters

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



3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3565

class UpdatePipeSourceParameters < 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