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
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<Metrics> for Metrics
impl PartialEq<Metrics> for Metrics
impl Eq for Metrics
impl StructuralEq 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<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.