pub struct Metrics { /* private fields */ }
Expand description
Metrics
stacks a number of statistics on flow execution while being executed
Implementations§
source§impl Metrics
impl Metrics
sourcepub fn set_jobs_created(&mut self, jobs: usize)
pub fn set_jobs_created(&mut self, jobs: usize)
Set the number of jobs created in Metrics
to the jobs
value
sourcepub fn increment_outputs_sent(&mut self)
pub fn increment_outputs_sent(&mut self)
Increment the tracker for the number of output values sent between functions
sourcepub fn track_max_jobs(&mut self, jobs_running: usize)
pub fn track_max_jobs(&mut self, jobs_running: usize)
Keep track of the maximum jobs that are executing in parallel during a flows execution, as a measure of the maximum level of parallelism achieved
sourcepub fn default_start_time() -> Instant
pub fn default_start_time() -> Instant
Return the start time for flow execution - used for tracking wall-clock time for the execution
sourcepub fn stop_timer(&mut self)
pub fn stop_timer(&mut self)
Stop the timer
Trait Implementations§
source§impl<'de> Deserialize<'de> for Metrics
impl<'de> Deserialize<'de> for Metrics
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl PartialEq for Metrics
impl PartialEq for Metrics
impl StructuralPartialEq for Metrics
Auto Trait Implementations§
impl RefUnwindSafe for Metrics
impl Send for Metrics
impl Sync for Metrics
impl Unpin for Metrics
impl UnwindSafe for Metrics
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