pub struct ParallelShardProcessor { /* private fields */ }
Expand description
Parallel shard processor
Implementations§
Source§impl ParallelShardProcessor
impl ParallelShardProcessor
Sourcepub fn new(config: ParallelShardConfig) -> Self
pub fn new(config: ParallelShardConfig) -> Self
Create a new parallel shard processor
Sourcepub fn process_allocations_parallel(
&self,
data: &LocalizedExportData,
) -> TrackingResult<(Vec<ProcessedShard>, ParallelProcessingStats)>
pub fn process_allocations_parallel( &self, data: &LocalizedExportData, ) -> TrackingResult<(Vec<ProcessedShard>, ParallelProcessingStats)>
Process allocations in parallel
Sourcepub fn get_config(&self) -> &ParallelShardConfig
pub fn get_config(&self) -> &ParallelShardConfig
Get current configuration
Sourcepub fn update_config(&mut self, config: ParallelShardConfig)
pub fn update_config(&mut self, config: ParallelShardConfig)
Update configuration
Sourcepub fn get_processed_count(&self) -> usize
pub fn get_processed_count(&self) -> usize
Get processed count
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for ParallelShardProcessor
impl RefUnwindSafe for ParallelShardProcessor
impl Send for ParallelShardProcessor
impl Sync for ParallelShardProcessor
impl Unpin for ParallelShardProcessor
impl UnwindSafe for ParallelShardProcessor
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
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>
Converts
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>
Converts
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