Class: AWSCDK::Pipes::CfnPipe::PipeSourceParametersProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
pipes/cfn_pipe.rb

Overview

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

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(active_mq_broker_parameters: nil, dynamo_db_stream_parameters: nil, filter_criteria: nil, kinesis_stream_parameters: nil, managed_streaming_kafka_parameters: nil, rabbit_mq_broker_parameters: nil, self_managed_kafka_parameters: nil, sqs_queue_parameters: nil) ⇒ PipeSourceParametersProperty

Returns a new instance of PipeSourceParametersProperty.

Parameters:



2631
2632
2633
2634
2635
2636
2637
2638
2639
2640
2641
2642
2643
2644
2645
2646
2647
2648
 
# File 'pipes/cfn_pipe.rb', line 2631

def initialize(active_mq_broker_parameters: nil, dynamo_db_stream_parameters: nil, filter_criteria: nil, kinesis_stream_parameters: nil, managed_streaming_kafka_parameters: nil, rabbit_mq_broker_parameters: nil, self_managed_kafka_parameters: nil, sqs_queue_parameters: nil)
  @active_mq_broker_parameters = active_mq_broker_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceActiveMQBrokerParametersProperty.new(**active_mq_broker_parameters.transform_keys(&:to_sym)) : active_mq_broker_parameters
  Jsii::Type.check_type(@active_mq_broker_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VBY3RpdmVNUUJyb2tlclBhcmFtZXRlcnNQcm9wZXJ0eSJ9XX19")), "activeMqBrokerParameters") unless @active_mq_broker_parameters.nil?
  @dynamo_db_stream_parameters = dynamo_db_stream_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceDynamoDBStreamParametersProperty.new(**dynamo_db_stream_parameters.transform_keys(&:to_sym)) : dynamo_db_stream_parameters
  Jsii::Type.check_type(@dynamo_db_stream_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VEeW5hbW9EQlN0cmVhbVBhcmFtZXRlcnNQcm9wZXJ0eSJ9XX19")), "dynamoDbStreamParameters") unless @dynamo_db_stream_parameters.nil?
  @filter_criteria = filter_criteria.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::FilterCriteriaProperty.new(**filter_criteria.transform_keys(&:to_sym)) : filter_criteria
  Jsii::Type.check_type(@filter_criteria, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLkZpbHRlckNyaXRlcmlhUHJvcGVydHkifV19fQ==")), "filterCriteria") unless @filter_criteria.nil?
  @kinesis_stream_parameters = kinesis_stream_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceKinesisStreamParametersProperty.new(**kinesis_stream_parameters.transform_keys(&:to_sym)) : kinesis_stream_parameters
  Jsii::Type.check_type(@kinesis_stream_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VLaW5lc2lzU3RyZWFtUGFyYW1ldGVyc1Byb3BlcnR5In1dfX0=")), "kinesisStreamParameters") unless @kinesis_stream_parameters.nil?
  @managed_streaming_kafka_parameters = managed_streaming_kafka_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceManagedStreamingKafkaParametersProperty.new(**managed_streaming_kafka_parameters.transform_keys(&:to_sym)) : managed_streaming_kafka_parameters
  Jsii::Type.check_type(@managed_streaming_kafka_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VNYW5hZ2VkU3RyZWFtaW5nS2Fma2FQYXJhbWV0ZXJzUHJvcGVydHkifV19fQ==")), "managedStreamingKafkaParameters") unless @managed_streaming_kafka_parameters.nil?
  @rabbit_mq_broker_parameters = rabbit_mq_broker_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceRabbitMQBrokerParametersProperty.new(**rabbit_mq_broker_parameters.transform_keys(&:to_sym)) : rabbit_mq_broker_parameters
  Jsii::Type.check_type(@rabbit_mq_broker_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VSYWJiaXRNUUJyb2tlclBhcmFtZXRlcnNQcm9wZXJ0eSJ9XX19")), "rabbitMqBrokerParameters") unless @rabbit_mq_broker_parameters.nil?
  @self_managed_kafka_parameters = self_managed_kafka_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceSelfManagedKafkaParametersProperty.new(**self_managed_kafka_parameters.transform_keys(&:to_sym)) : self_managed_kafka_parameters
  Jsii::Type.check_type(@self_managed_kafka_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VTZWxmTWFuYWdlZEthZmthUGFyYW1ldGVyc1Byb3BlcnR5In1dfX0=")), "selfManagedKafkaParameters") unless @self_managed_kafka_parameters.nil?
  @sqs_queue_parameters = sqs_queue_parameters.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::PipeSourceSQSQueueParametersProperty.new(**sqs_queue_parameters.transform_keys(&:to_sym)) : sqs_queue_parameters
  Jsii::Type.check_type(@sqs_queue_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLlBpcGVTb3VyY2VTcXNRdWV1ZVBhcmFtZXRlcnNQcm9wZXJ0eSJ9XX19")), "sqsQueueParameters") unless @sqs_queue_parameters.nil?
end

Instance Attribute Details

#active_mq_broker_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

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

Returns:

See Also:



2654
2655
2656
 
# File 'pipes/cfn_pipe.rb', line 2654

def active_mq_broker_parameters
  @active_mq_broker_parameters
end

#dynamo_db_stream_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

The parameters for using a DynamoDB stream as a source.

Returns:

See Also:



2659
2660
2661
 
# File 'pipes/cfn_pipe.rb', line 2659

def dynamo_db_stream_parameters
  @dynamo_db_stream_parameters
end

#filter_criteria ⇒ AWSCDK::IResolvable, ... (readonly)

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 .

Returns:

See Also:



2668
2669
2670
 
# File 'pipes/cfn_pipe.rb', line 2668

def filter_criteria
  @filter_criteria
end

#kinesis_stream_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

The parameters for using a Kinesis stream as a source.

Returns:

See Also:



2673
2674
2675
 
# File 'pipes/cfn_pipe.rb', line 2673

def kinesis_stream_parameters
  @kinesis_stream_parameters
end

#managed_streaming_kafka_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

The parameters for using an MSK stream as a source.

Returns:

See Also:



2678
2679
2680
 
# File 'pipes/cfn_pipe.rb', line 2678

def managed_streaming_kafka_parameters
  @managed_streaming_kafka_parameters
end

#rabbit_mq_broker_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

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

Returns:

See Also:



2683
2684
2685
 
# File 'pipes/cfn_pipe.rb', line 2683

def rabbit_mq_broker_parameters
  @rabbit_mq_broker_parameters
end

#self_managed_kafka_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

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

Returns:

See Also:



2690
2691
2692
 
# File 'pipes/cfn_pipe.rb', line 2690

def self_managed_kafka_parameters
  @self_managed_kafka_parameters
end

#sqs_queue_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

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

Returns:

See Also:



2695
2696
2697
 
# File 'pipes/cfn_pipe.rb', line 2695

def sqs_queue_parameters
  @sqs_queue_parameters
end

Class Method Details

.jsii_properties ⇒ Object 



2697
2698
2699
2700
2701
2702
2703
2704
2705
2706
2707
2708
 
# File 'pipes/cfn_pipe.rb', line 2697

def self.jsii_properties
  {
    :active_mq_broker_parameters => "activeMqBrokerParameters",
    :dynamo_db_stream_parameters => "dynamoDbStreamParameters",
    :filter_criteria => "filterCriteria",
    :kinesis_stream_parameters => "kinesisStreamParameters",
    :managed_streaming_kafka_parameters => "managedStreamingKafkaParameters",
    :rabbit_mq_broker_parameters => "rabbitMqBrokerParameters",
    :self_managed_kafka_parameters => "selfManagedKafkaParameters",
    :sqs_queue_parameters => "sqsQueueParameters",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



2710
2711
2712
2713
2714
2715
2716
2717
2718
2719
2720
2721
2722
2723
 
# File 'pipes/cfn_pipe.rb', line 2710

def to_jsii
  result = {}
  result.merge!({
    "activeMqBrokerParameters" => @active_mq_broker_parameters,
    "dynamoDbStreamParameters" => @dynamo_db_stream_parameters,
    "filterCriteria" => @filter_criteria,
    "kinesisStreamParameters" => @kinesis_stream_parameters,
    "managedStreamingKafkaParameters" => @managed_streaming_kafka_parameters,
    "rabbitMqBrokerParameters" => @rabbit_mq_broker_parameters,
    "selfManagedKafkaParameters" => @self_managed_kafka_parameters,
    "sqsQueueParameters" => @sqs_queue_parameters,
  })
  result.compact
end