Struct aws_sdk_pipes::types::builders::PipeSourceParametersBuilder

#[non_exhaustive]
pub struct PipeSourceParametersBuilder { /* private fields */ }

A builder for PipeSourceParameters.

Implementations

impl PipeSourceParametersBuilder

pub fn filter_criteria(self, input: FilterCriteria) -> Self

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.

pub fn set_filter_criteria(self, input: Option<FilterCriteria>) -> Self

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.

pub fn get_filter_criteria(&self) -> &Option<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.

pub fn kinesis_stream_parameters( self, input: PipeSourceKinesisStreamParameters ) -> Self

The parameters for using a Kinesis stream as a source.

pub fn set_kinesis_stream_parameters( self, input: Option<PipeSourceKinesisStreamParameters> ) -> Self

The parameters for using a Kinesis stream as a source.

pub fn get_kinesis_stream_parameters( &self ) -> &Option<PipeSourceKinesisStreamParameters>

The parameters for using a Kinesis stream as a source.

pub fn dynamo_db_stream_parameters( self, input: PipeSourceDynamoDbStreamParameters ) -> Self

The parameters for using a DynamoDB stream as a source.

pub fn set_dynamo_db_stream_parameters( self, input: Option<PipeSourceDynamoDbStreamParameters> ) -> Self

The parameters for using a DynamoDB stream as a source.

pub fn get_dynamo_db_stream_parameters( &self ) -> &Option<PipeSourceDynamoDbStreamParameters>

The parameters for using a DynamoDB stream as a source.

pub fn sqs_queue_parameters(self, input: PipeSourceSqsQueueParameters) -> Self

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

pub fn set_sqs_queue_parameters( self, input: Option<PipeSourceSqsQueueParameters> ) -> Self

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

pub fn get_sqs_queue_parameters(&self) -> &Option<PipeSourceSqsQueueParameters>

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

pub fn active_mq_broker_parameters( self, input: PipeSourceActiveMqBrokerParameters ) -> Self

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

pub fn set_active_mq_broker_parameters( self, input: Option<PipeSourceActiveMqBrokerParameters> ) -> Self

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

pub fn get_active_mq_broker_parameters( &self ) -> &Option<PipeSourceActiveMqBrokerParameters>

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

pub fn rabbit_mq_broker_parameters( self, input: PipeSourceRabbitMqBrokerParameters ) -> Self

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

pub fn set_rabbit_mq_broker_parameters( self, input: Option<PipeSourceRabbitMqBrokerParameters> ) -> Self

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

pub fn get_rabbit_mq_broker_parameters( &self ) -> &Option<PipeSourceRabbitMqBrokerParameters>

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

pub fn managed_streaming_kafka_parameters( self, input: PipeSourceManagedStreamingKafkaParameters ) -> Self

The parameters for using an MSK stream as a source.

pub fn set_managed_streaming_kafka_parameters( self, input: Option<PipeSourceManagedStreamingKafkaParameters> ) -> Self

The parameters for using an MSK stream as a source.

pub fn get_managed_streaming_kafka_parameters( &self ) -> &Option<PipeSourceManagedStreamingKafkaParameters>

The parameters for using an MSK stream as a source.

pub fn self_managed_kafka_parameters( self, input: PipeSourceSelfManagedKafkaParameters ) -> Self

The parameters for using a self-managed Apache Kafka stream as a source.

pub fn set_self_managed_kafka_parameters( self, input: Option<PipeSourceSelfManagedKafkaParameters> ) -> Self

The parameters for using a self-managed Apache Kafka stream as a source.

pub fn get_self_managed_kafka_parameters( &self ) -> &Option<PipeSourceSelfManagedKafkaParameters>

The parameters for using a self-managed Apache Kafka stream as a source.

pub fn build(self) -> PipeSourceParameters

Consumes the builder and constructs a PipeSourceParameters.

Trait Implementations

impl Clone for PipeSourceParametersBuilder

fn clone(&self) -> PipeSourceParametersBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipeSourceParametersBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipeSourceParametersBuilder

fn default() -> PipeSourceParametersBuilder

Returns the “default value” for a type.

impl PartialEq for PipeSourceParametersBuilder

fn eq(&self, other: &PipeSourceParametersBuilder) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PipeSourceParametersBuilder