#[non_exhaustive]pub struct PipeSourceRabbitMqBrokerParametersBuilder { /* private fields */ }
Expand description
A builder for PipeSourceRabbitMqBrokerParameters
.
Implementations§
source§impl PipeSourceRabbitMqBrokerParametersBuilder
impl PipeSourceRabbitMqBrokerParametersBuilder
sourcepub fn credentials(self, input: MqBrokerAccessCredentials) -> Self
pub fn credentials(self, input: MqBrokerAccessCredentials) -> Self
The credentials needed to access the resource.
This field is required.sourcepub fn set_credentials(self, input: Option<MqBrokerAccessCredentials>) -> Self
pub fn set_credentials(self, input: Option<MqBrokerAccessCredentials>) -> Self
The credentials needed to access the resource.
sourcepub fn get_credentials(&self) -> &Option<MqBrokerAccessCredentials>
pub fn get_credentials(&self) -> &Option<MqBrokerAccessCredentials>
The credentials needed to access the resource.
sourcepub fn queue_name(self, input: impl Into<String>) -> Self
pub fn queue_name(self, input: impl Into<String>) -> Self
The name of the destination queue to consume.
This field is required.sourcepub fn set_queue_name(self, input: Option<String>) -> Self
pub fn set_queue_name(self, input: Option<String>) -> Self
The name of the destination queue to consume.
sourcepub fn get_queue_name(&self) -> &Option<String>
pub fn get_queue_name(&self) -> &Option<String>
The name of the destination queue to consume.
sourcepub fn virtual_host(self, input: impl Into<String>) -> Self
pub fn virtual_host(self, input: impl Into<String>) -> Self
The name of the virtual host associated with the source broker.
sourcepub fn set_virtual_host(self, input: Option<String>) -> Self
pub fn set_virtual_host(self, input: Option<String>) -> Self
The name of the virtual host associated with the source broker.
sourcepub fn get_virtual_host(&self) -> &Option<String>
pub fn get_virtual_host(&self) -> &Option<String>
The name of the virtual host associated with the source broker.
sourcepub fn batch_size(self, input: i32) -> Self
pub fn batch_size(self, input: i32) -> Self
The maximum number of records to include in each batch.
sourcepub fn set_batch_size(self, input: Option<i32>) -> Self
pub fn set_batch_size(self, input: Option<i32>) -> Self
The maximum number of records to include in each batch.
sourcepub fn get_batch_size(&self) -> &Option<i32>
pub fn get_batch_size(&self) -> &Option<i32>
The maximum number of records to include in each batch.
sourcepub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
pub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
The maximum length of a time to wait for events.
sourcepub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
pub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
The maximum length of a time to wait for events.
sourcepub fn get_maximum_batching_window_in_seconds(&self) -> &Option<i32>
pub fn get_maximum_batching_window_in_seconds(&self) -> &Option<i32>
The maximum length of a time to wait for events.
sourcepub fn build(self) -> Result<PipeSourceRabbitMqBrokerParameters, BuildError>
pub fn build(self) -> Result<PipeSourceRabbitMqBrokerParameters, BuildError>
Consumes the builder and constructs a PipeSourceRabbitMqBrokerParameters
.
This method will fail if any of the following fields are not set:
Trait Implementations§
source§impl Clone for PipeSourceRabbitMqBrokerParametersBuilder
impl Clone for PipeSourceRabbitMqBrokerParametersBuilder
source§fn clone(&self) -> PipeSourceRabbitMqBrokerParametersBuilder
fn clone(&self) -> PipeSourceRabbitMqBrokerParametersBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Default for PipeSourceRabbitMqBrokerParametersBuilder
impl Default for PipeSourceRabbitMqBrokerParametersBuilder
source§fn default() -> PipeSourceRabbitMqBrokerParametersBuilder
fn default() -> PipeSourceRabbitMqBrokerParametersBuilder
source§impl PartialEq for PipeSourceRabbitMqBrokerParametersBuilder
impl PartialEq for PipeSourceRabbitMqBrokerParametersBuilder
source§fn eq(&self, other: &PipeSourceRabbitMqBrokerParametersBuilder) -> bool
fn eq(&self, other: &PipeSourceRabbitMqBrokerParametersBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.