pub struct CsdScheduler { /* private fields */ }Expand description
CSD scheduler for operation management
Implementations§
Source§impl CsdScheduler
impl CsdScheduler
Sourcepub fn schedule_operation(
&mut self,
operation: CsdOperationRequest,
) -> Result<(), CsdError>
pub fn schedule_operation( &mut self, operation: CsdOperationRequest, ) -> Result<(), CsdError>
Schedule operation
Sourcepub fn process_operations(&mut self) -> Vec<CsdCompletion>
pub fn process_operations(&mut self) -> Vec<CsdCompletion>
Process pending operations
Sourcepub fn drain_completions(&mut self) -> Vec<CsdCompletion>
pub fn drain_completions(&mut self) -> Vec<CsdCompletion>
Drain completions recorded since the last call.
Source§impl CsdScheduler
impl CsdScheduler
Sourcepub fn record_completion_metrics(
&self,
monitor: &mut CsdPerformanceMonitor,
operation: &CsdOperationRequest,
completion: &CsdCompletion,
)
pub fn record_completion_metrics( &self, monitor: &mut CsdPerformanceMonitor, operation: &CsdOperationRequest, completion: &CsdCompletion, )
Record performance metrics for a completed operation.
Auto Trait Implementations§
impl Freeze for CsdScheduler
impl RefUnwindSafe for CsdScheduler
impl Send for CsdScheduler
impl Sync for CsdScheduler
impl Unpin for CsdScheduler
impl UnsafeUnpin for CsdScheduler
impl UnwindSafe for CsdScheduler
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