pub struct BulkSendParams {
pub target_queue: String,
pub should_delete: bool,
pub message_identifiers: Vec<MessageIdentifier>,
pub messages_data: Option<Vec<(MessageIdentifier, Vec<u8>)>>,
pub max_position: usize,
}Expand description
Parameters for bulk send operations
Fields§
§target_queue: String§should_delete: bool§message_identifiers: Vec<MessageIdentifier>§messages_data: Option<Vec<(MessageIdentifier, Vec<u8>)>>§max_position: usizeImplementations§
Source§impl BulkSendParams
impl BulkSendParams
Sourcepub fn with_retrieval(
target_queue: String,
should_delete: bool,
message_identifiers: Vec<MessageIdentifier>,
max_position: usize,
) -> Self
pub fn with_retrieval( target_queue: String, should_delete: bool, message_identifiers: Vec<MessageIdentifier>, max_position: usize, ) -> Self
Create parameters for operations that retrieve messages from the queue
Sourcepub fn with_message_data(
target_queue: String,
should_delete: bool,
messages_data: Vec<(MessageIdentifier, Vec<u8>)>,
max_position: usize,
) -> Self
pub fn with_message_data( target_queue: String, should_delete: bool, messages_data: Vec<(MessageIdentifier, Vec<u8>)>, max_position: usize, ) -> Self
Create parameters for operations with pre-fetched message data
Sourcepub fn with_max_position(
target_queue: String,
should_delete: bool,
message_identifiers: Vec<MessageIdentifier>,
max_position: usize,
) -> Self
pub fn with_max_position( target_queue: String, should_delete: bool, message_identifiers: Vec<MessageIdentifier>, max_position: usize, ) -> Self
Create parameters with max position for better processing limits
Trait Implementations§
Source§impl Clone for BulkSendParams
impl Clone for BulkSendParams
Source§fn clone(&self) -> BulkSendParams
fn clone(&self) -> BulkSendParams
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for BulkSendParams
impl RefUnwindSafe for BulkSendParams
impl Send for BulkSendParams
impl Sync for BulkSendParams
impl Unpin for BulkSendParams
impl UnwindSafe for BulkSendParams
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
Mutably borrows from an owned value. Read more