Struct aws_sdk_pipes::model::pipe_source_parameters::Builder
source · pub struct Builder { /* private fields */ }
Expand description
A builder for PipeSourceParameters
.
Implementations§
source§impl Builder
impl Builder
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
.