#[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 ==.impl StructuralPartialEq for PipeSourceRabbitMqBrokerParametersBuilder
Auto Trait Implementations§
impl Freeze for PipeSourceRabbitMqBrokerParametersBuilder
impl RefUnwindSafe for PipeSourceRabbitMqBrokerParametersBuilder
impl Send for PipeSourceRabbitMqBrokerParametersBuilder
impl Sync for PipeSourceRabbitMqBrokerParametersBuilder
impl Unpin for PipeSourceRabbitMqBrokerParametersBuilder
impl UnwindSafe for PipeSourceRabbitMqBrokerParametersBuilder
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit)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