Struct aws_sdk_pipes::types::builders::PipeSourceParametersBuilder
source · #[non_exhaustive]pub struct PipeSourceParametersBuilder { /* private fields */ }
Expand description
A builder for PipeSourceParameters
.
Implementations§
source§impl PipeSourceParametersBuilder
impl PipeSourceParametersBuilder
sourcepub fn filter_criteria(self, input: FilterCriteria) -> Self
pub fn filter_criteria(self, input: FilterCriteria) -> Self
The collection of event patterns used to filter events. For more information, see Events and Event Patterns in the Amazon EventBridge User Guide.
sourcepub fn set_filter_criteria(self, input: Option<FilterCriteria>) -> Self
pub fn set_filter_criteria(self, input: Option<FilterCriteria>) -> Self
The collection of event patterns used to filter events. For more information, see Events and Event Patterns in the Amazon EventBridge User Guide.
sourcepub fn kinesis_stream_parameters(
self,
input: PipeSourceKinesisStreamParameters
) -> Self
pub fn kinesis_stream_parameters( self, input: PipeSourceKinesisStreamParameters ) -> Self
The parameters for using a Kinesis stream as a source.
sourcepub fn set_kinesis_stream_parameters(
self,
input: Option<PipeSourceKinesisStreamParameters>
) -> Self
pub fn set_kinesis_stream_parameters( self, input: Option<PipeSourceKinesisStreamParameters> ) -> Self
The parameters for using a Kinesis stream as a source.
sourcepub fn dynamo_db_stream_parameters(
self,
input: PipeSourceDynamoDbStreamParameters
) -> Self
pub fn dynamo_db_stream_parameters( self, input: PipeSourceDynamoDbStreamParameters ) -> Self
The parameters for using a DynamoDB stream as a source.
sourcepub fn set_dynamo_db_stream_parameters(
self,
input: Option<PipeSourceDynamoDbStreamParameters>
) -> Self
pub fn set_dynamo_db_stream_parameters( self, input: Option<PipeSourceDynamoDbStreamParameters> ) -> Self
The parameters for using a DynamoDB stream as a source.
sourcepub fn sqs_queue_parameters(self, input: PipeSourceSqsQueueParameters) -> Self
pub fn sqs_queue_parameters(self, input: PipeSourceSqsQueueParameters) -> Self
The parameters for using a Amazon SQS stream as a source.
sourcepub fn set_sqs_queue_parameters(
self,
input: Option<PipeSourceSqsQueueParameters>
) -> Self
pub fn set_sqs_queue_parameters( self, input: Option<PipeSourceSqsQueueParameters> ) -> Self
The parameters for using a Amazon SQS stream as a source.
sourcepub fn active_mq_broker_parameters(
self,
input: PipeSourceActiveMqBrokerParameters
) -> Self
pub fn active_mq_broker_parameters( self, input: PipeSourceActiveMqBrokerParameters ) -> Self
The parameters for using an Active MQ broker as a source.
sourcepub fn set_active_mq_broker_parameters(
self,
input: Option<PipeSourceActiveMqBrokerParameters>
) -> Self
pub fn set_active_mq_broker_parameters( self, input: Option<PipeSourceActiveMqBrokerParameters> ) -> Self
The parameters for using an Active MQ broker as a source.
sourcepub fn rabbit_mq_broker_parameters(
self,
input: PipeSourceRabbitMqBrokerParameters
) -> Self
pub fn rabbit_mq_broker_parameters( self, input: PipeSourceRabbitMqBrokerParameters ) -> Self
The parameters for using a Rabbit MQ broker as a source.
sourcepub fn set_rabbit_mq_broker_parameters(
self,
input: Option<PipeSourceRabbitMqBrokerParameters>
) -> Self
pub fn set_rabbit_mq_broker_parameters( self, input: Option<PipeSourceRabbitMqBrokerParameters> ) -> Self
The parameters for using a Rabbit MQ broker as a source.
sourcepub fn managed_streaming_kafka_parameters(
self,
input: PipeSourceManagedStreamingKafkaParameters
) -> Self
pub fn managed_streaming_kafka_parameters( self, input: PipeSourceManagedStreamingKafkaParameters ) -> Self
The parameters for using an MSK stream as a source.
sourcepub fn set_managed_streaming_kafka_parameters(
self,
input: Option<PipeSourceManagedStreamingKafkaParameters>
) -> Self
pub fn set_managed_streaming_kafka_parameters( self, input: Option<PipeSourceManagedStreamingKafkaParameters> ) -> Self
The parameters for using an MSK stream as a source.
sourcepub fn self_managed_kafka_parameters(
self,
input: PipeSourceSelfManagedKafkaParameters
) -> Self
pub fn self_managed_kafka_parameters( self, input: PipeSourceSelfManagedKafkaParameters ) -> Self
The parameters for using a self-managed Apache Kafka stream as a source.
sourcepub fn set_self_managed_kafka_parameters(
self,
input: Option<PipeSourceSelfManagedKafkaParameters>
) -> Self
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.
sourcepub fn build(self) -> PipeSourceParameters
pub fn build(self) -> PipeSourceParameters
Consumes the builder and constructs a PipeSourceParameters
.
Trait Implementations§
source§impl Clone for PipeSourceParametersBuilder
impl Clone for PipeSourceParametersBuilder
source§fn clone(&self) -> PipeSourceParametersBuilder
fn clone(&self) -> PipeSourceParametersBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for PipeSourceParametersBuilder
impl Debug for PipeSourceParametersBuilder
source§impl Default for PipeSourceParametersBuilder
impl Default for PipeSourceParametersBuilder
source§fn default() -> PipeSourceParametersBuilder
fn default() -> PipeSourceParametersBuilder
source§impl PartialEq<PipeSourceParametersBuilder> for PipeSourceParametersBuilder
impl PartialEq<PipeSourceParametersBuilder> for PipeSourceParametersBuilder
source§fn eq(&self, other: &PipeSourceParametersBuilder) -> bool
fn eq(&self, other: &PipeSourceParametersBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.