pub struct BatchProcessor { /* private fields */ }Expand description
Batch processor
Implementations§
Source§impl BatchProcessor
impl BatchProcessor
pub fn new() -> Self
pub fn initialize(&mut self) -> Result<(), MLError>
Sourcepub fn batching_strategy(&self) -> &BatchingStrategy
pub fn batching_strategy(&self) -> &BatchingStrategy
Return the current batching strategy.
Sourcepub fn set_batching_strategy(&mut self, strategy: BatchingStrategy)
pub fn set_batching_strategy(&mut self, strategy: BatchingStrategy)
Set the batching strategy.
Sourcepub fn batch_size(&self) -> usize
pub fn batch_size(&self) -> usize
Return the configured batch size.
Sourcepub fn set_batch_size(&mut self, size: usize)
pub fn set_batch_size(&mut self, size: usize)
Set the batch size.
Sourcepub fn batch_timeout(&self) -> u64
pub fn batch_timeout(&self) -> u64
Return the configured batch timeout (milliseconds).
Sourcepub fn set_batch_timeout(&mut self, timeout: u64)
pub fn set_batch_timeout(&mut self, timeout: u64)
Set the batch timeout (milliseconds).
Auto Trait Implementations§
impl Freeze for BatchProcessor
impl RefUnwindSafe for BatchProcessor
impl Send for BatchProcessor
impl Sync for BatchProcessor
impl Unpin for BatchProcessor
impl UnsafeUnpin for BatchProcessor
impl UnwindSafe for BatchProcessor
Blanket Implementations§
§impl<S, A> Aggregate<Result<S, Error>> for Awhere
A: Aggregate<S>,
impl<S, A> Aggregate<Result<S, Error>> for Awhere
A: Aggregate<S>,
Aggregate shares in an MPC protocol.
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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