pub struct ConcurrencyConfig {
pub max_concurrency: usize,
pub operation_timeout: Option<Duration>,
pub continue_on_error: bool,
pub collect_stats: bool,
}Expand description
Configuration for concurrent execution.
Fields§
§max_concurrency: usizeMaximum number of concurrent operations.
operation_timeout: Option<Duration>Timeout for individual operations.
continue_on_error: boolWhether to continue on error (collect all errors vs fail fast).
collect_stats: boolCollect timing statistics.
Implementations§
Source§impl ConcurrencyConfig
impl ConcurrencyConfig
Sourcepub fn for_introspection() -> Self
pub fn for_introspection() -> Self
Create config optimized for database introspection.
Sourcepub fn for_migrations() -> Self
pub fn for_migrations() -> Self
Create config optimized for migration operations.
Sourcepub fn for_bulk_operations() -> Self
pub fn for_bulk_operations() -> Self
Create config optimized for bulk data operations.
Sourcepub fn with_max_concurrency(self, max: usize) -> Self
pub fn with_max_concurrency(self, max: usize) -> Self
Set maximum concurrency.
Sourcepub fn with_timeout(self, timeout: Duration) -> Self
pub fn with_timeout(self, timeout: Duration) -> Self
Set operation timeout.
Sourcepub fn without_timeout(self) -> Self
pub fn without_timeout(self) -> Self
Disable timeout.
Sourcepub fn with_continue_on_error(self, continue_on_error: bool) -> Self
pub fn with_continue_on_error(self, continue_on_error: bool) -> Self
Set continue on error behavior.
Trait Implementations§
Source§impl Clone for ConcurrencyConfig
impl Clone for ConcurrencyConfig
Source§fn clone(&self) -> ConcurrencyConfig
fn clone(&self) -> ConcurrencyConfig
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 moreSource§impl Debug for ConcurrencyConfig
impl Debug for ConcurrencyConfig
Auto Trait Implementations§
impl Freeze for ConcurrencyConfig
impl RefUnwindSafe for ConcurrencyConfig
impl Send for ConcurrencyConfig
impl Sync for ConcurrencyConfig
impl Unpin for ConcurrencyConfig
impl UnwindSafe for ConcurrencyConfig
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