pub struct Builder { /* private fields */ }
Expand description
A builder for PipeSourceRabbitMqBrokerParameters
.
Implementations§
source§impl Builder
impl Builder
sourcepub fn credentials(self, input: MqBrokerAccessCredentials) -> Self
pub fn credentials(self, input: MqBrokerAccessCredentials) -> Self
The credentials needed to access the resource.
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 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.
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 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 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 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 build(self) -> PipeSourceRabbitMqBrokerParameters
pub fn build(self) -> PipeSourceRabbitMqBrokerParameters
Consumes the builder and constructs a PipeSourceRabbitMqBrokerParameters
.