#[non_exhaustive]pub struct UpdatePipeSourceParametersBuilder { /* private fields */ }Expand description
A builder for UpdatePipeSourceParameters.
Implementations§
source§impl UpdatePipeSourceParametersBuilder
impl UpdatePipeSourceParametersBuilder
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.
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.
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.
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.
sourcepub fn get_filter_criteria(&self) -> &Option<FilterCriteria>
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.
sourcepub fn kinesis_stream_parameters(
self,
input: UpdatePipeSourceKinesisStreamParameters,
) -> Self
pub fn kinesis_stream_parameters( self, input: UpdatePipeSourceKinesisStreamParameters, ) -> Self
The parameters for using a Kinesis stream as a source.
sourcepub fn set_kinesis_stream_parameters(
self,
input: Option<UpdatePipeSourceKinesisStreamParameters>,
) -> Self
pub fn set_kinesis_stream_parameters( self, input: Option<UpdatePipeSourceKinesisStreamParameters>, ) -> Self
The parameters for using a Kinesis stream as a source.
sourcepub fn get_kinesis_stream_parameters(
&self,
) -> &Option<UpdatePipeSourceKinesisStreamParameters>
pub fn get_kinesis_stream_parameters( &self, ) -> &Option<UpdatePipeSourceKinesisStreamParameters>
The parameters for using a Kinesis stream as a source.
sourcepub fn dynamo_db_stream_parameters(
self,
input: UpdatePipeSourceDynamoDbStreamParameters,
) -> Self
pub fn dynamo_db_stream_parameters( self, input: UpdatePipeSourceDynamoDbStreamParameters, ) -> Self
The parameters for using a DynamoDB stream as a source.
sourcepub fn set_dynamo_db_stream_parameters(
self,
input: Option<UpdatePipeSourceDynamoDbStreamParameters>,
) -> Self
pub fn set_dynamo_db_stream_parameters( self, input: Option<UpdatePipeSourceDynamoDbStreamParameters>, ) -> Self
The parameters for using a DynamoDB stream as a source.
sourcepub fn get_dynamo_db_stream_parameters(
&self,
) -> &Option<UpdatePipeSourceDynamoDbStreamParameters>
pub fn get_dynamo_db_stream_parameters( &self, ) -> &Option<UpdatePipeSourceDynamoDbStreamParameters>
The parameters for using a DynamoDB stream as a source.
sourcepub fn sqs_queue_parameters(
self,
input: UpdatePipeSourceSqsQueueParameters,
) -> Self
pub fn sqs_queue_parameters( self, input: UpdatePipeSourceSqsQueueParameters, ) -> Self
The parameters for using a Amazon SQS stream as a source.
sourcepub fn set_sqs_queue_parameters(
self,
input: Option<UpdatePipeSourceSqsQueueParameters>,
) -> Self
pub fn set_sqs_queue_parameters( self, input: Option<UpdatePipeSourceSqsQueueParameters>, ) -> Self
The parameters for using a Amazon SQS stream as a source.
sourcepub fn get_sqs_queue_parameters(
&self,
) -> &Option<UpdatePipeSourceSqsQueueParameters>
pub fn get_sqs_queue_parameters( &self, ) -> &Option<UpdatePipeSourceSqsQueueParameters>
The parameters for using a Amazon SQS stream as a source.
sourcepub fn active_mq_broker_parameters(
self,
input: UpdatePipeSourceActiveMqBrokerParameters,
) -> Self
pub fn active_mq_broker_parameters( self, input: UpdatePipeSourceActiveMqBrokerParameters, ) -> Self
The parameters for using an Active MQ broker as a source.
sourcepub fn set_active_mq_broker_parameters(
self,
input: Option<UpdatePipeSourceActiveMqBrokerParameters>,
) -> Self
pub fn set_active_mq_broker_parameters( self, input: Option<UpdatePipeSourceActiveMqBrokerParameters>, ) -> Self
The parameters for using an Active MQ broker as a source.
sourcepub fn get_active_mq_broker_parameters(
&self,
) -> &Option<UpdatePipeSourceActiveMqBrokerParameters>
pub fn get_active_mq_broker_parameters( &self, ) -> &Option<UpdatePipeSourceActiveMqBrokerParameters>
The parameters for using an Active MQ broker as a source.
sourcepub fn rabbit_mq_broker_parameters(
self,
input: UpdatePipeSourceRabbitMqBrokerParameters,
) -> Self
pub fn rabbit_mq_broker_parameters( self, input: UpdatePipeSourceRabbitMqBrokerParameters, ) -> Self
The parameters for using a Rabbit MQ broker as a source.
sourcepub fn set_rabbit_mq_broker_parameters(
self,
input: Option<UpdatePipeSourceRabbitMqBrokerParameters>,
) -> Self
pub fn set_rabbit_mq_broker_parameters( self, input: Option<UpdatePipeSourceRabbitMqBrokerParameters>, ) -> Self
The parameters for using a Rabbit MQ broker as a source.
sourcepub fn get_rabbit_mq_broker_parameters(
&self,
) -> &Option<UpdatePipeSourceRabbitMqBrokerParameters>
pub fn get_rabbit_mq_broker_parameters( &self, ) -> &Option<UpdatePipeSourceRabbitMqBrokerParameters>
The parameters for using a Rabbit MQ broker as a source.
sourcepub fn managed_streaming_kafka_parameters(
self,
input: UpdatePipeSourceManagedStreamingKafkaParameters,
) -> Self
pub fn managed_streaming_kafka_parameters( self, input: UpdatePipeSourceManagedStreamingKafkaParameters, ) -> Self
The parameters for using an MSK stream as a source.
sourcepub fn set_managed_streaming_kafka_parameters(
self,
input: Option<UpdatePipeSourceManagedStreamingKafkaParameters>,
) -> Self
pub fn set_managed_streaming_kafka_parameters( self, input: Option<UpdatePipeSourceManagedStreamingKafkaParameters>, ) -> Self
The parameters for using an MSK stream as a source.
sourcepub fn get_managed_streaming_kafka_parameters(
&self,
) -> &Option<UpdatePipeSourceManagedStreamingKafkaParameters>
pub fn get_managed_streaming_kafka_parameters( &self, ) -> &Option<UpdatePipeSourceManagedStreamingKafkaParameters>
The parameters for using an MSK stream as a source.
sourcepub fn self_managed_kafka_parameters(
self,
input: UpdatePipeSourceSelfManagedKafkaParameters,
) -> Self
pub fn self_managed_kafka_parameters( self, input: UpdatePipeSourceSelfManagedKafkaParameters, ) -> Self
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.
sourcepub fn set_self_managed_kafka_parameters(
self,
input: Option<UpdatePipeSourceSelfManagedKafkaParameters>,
) -> Self
pub fn set_self_managed_kafka_parameters( self, input: Option<UpdatePipeSourceSelfManagedKafkaParameters>, ) -> Self
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.
sourcepub fn get_self_managed_kafka_parameters(
&self,
) -> &Option<UpdatePipeSourceSelfManagedKafkaParameters>
pub fn get_self_managed_kafka_parameters( &self, ) -> &Option<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.
sourcepub fn build(self) -> UpdatePipeSourceParameters
pub fn build(self) -> UpdatePipeSourceParameters
Consumes the builder and constructs a UpdatePipeSourceParameters.
Trait Implementations§
source§impl Clone for UpdatePipeSourceParametersBuilder
impl Clone for UpdatePipeSourceParametersBuilder
source§fn clone(&self) -> UpdatePipeSourceParametersBuilder
fn clone(&self) -> UpdatePipeSourceParametersBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Default for UpdatePipeSourceParametersBuilder
impl Default for UpdatePipeSourceParametersBuilder
source§fn default() -> UpdatePipeSourceParametersBuilder
fn default() -> UpdatePipeSourceParametersBuilder
source§impl PartialEq for UpdatePipeSourceParametersBuilder
impl PartialEq for UpdatePipeSourceParametersBuilder
source§fn eq(&self, other: &UpdatePipeSourceParametersBuilder) -> bool
fn eq(&self, other: &UpdatePipeSourceParametersBuilder) -> bool
self and other values to be equal, and is used
by ==.impl StructuralPartialEq for UpdatePipeSourceParametersBuilder
Auto Trait Implementations§
impl Freeze for UpdatePipeSourceParametersBuilder
impl RefUnwindSafe for UpdatePipeSourceParametersBuilder
impl Send for UpdatePipeSourceParametersBuilder
impl Sync for UpdatePipeSourceParametersBuilder
impl Unpin for UpdatePipeSourceParametersBuilder
impl UnwindSafe for UpdatePipeSourceParametersBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more