Struct MetricsSnapshot 

pub struct MetricsSnapshot {

    pub jobs_submitted: usize,
    pub jobs_executed_success: usize,
    pub jobs_executed_fail: usize,
    pub jobs_panicked: usize,
    pub jobs_retried: usize,
    pub jobs_lineage_cancelled: usize,
    pub jobs_instance_discarded_cancelled: usize,
    pub jobs_permanently_failed: usize,
    pub staging_submitted_total: usize,
    pub staging_rejected_full: usize,
    pub job_queue_scheduled_current: usize,
    pub job_staging_buffer_current: usize,
    pub workers_active_current: usize,
    pub job_execution_duration_count: usize,
    pub job_execution_duration_sum_micros: usize,
    pub job_queue_wait_duration_count: usize,
    pub job_queue_wait_duration_sum_micros: usize,
}

A snapshot of the scheduler’s metrics at a specific point in time.

This struct contains plain data types and can be easily cloned, serialized, or used for monitoring and analysis.

Fields

jobs_submitted: usize

jobs_executed_success: usize

jobs_executed_fail: usize

jobs_panicked: usize

jobs_retried: usize

jobs_lineage_cancelled: usize

jobs_instance_discarded_cancelled: usize

jobs_permanently_failed: usize

staging_submitted_total: usize

staging_rejected_full: usize

job_queue_scheduled_current: usize

job_staging_buffer_current: usize

workers_active_current: usize

job_execution_duration_count: usize

job_execution_duration_sum_micros: usize

job_queue_wait_duration_count: usize

job_queue_wait_duration_sum_micros: usize

Implementations

impl MetricsSnapshot

pub fn mean_execution_duration_micros(&self) -> Option<f64>

Calculates the mean job execution duration in microseconds, if any jobs completed. Returns None if job_execution_duration_count is zero.

pub fn mean_execution_duration(&self) -> Option<Duration>

Calculates the mean job execution duration, if any jobs completed. Returns None if job_execution_duration_count is zero.

pub fn mean_queue_wait_duration_micros(&self) -> Option<f64>

Calculates the mean job queue wait duration in microseconds, if any jobs started. Returns None if job_queue_wait_duration_count is zero.

pub fn mean_queue_wait_duration(&self) -> Option<Duration>

Calculates the mean job queue wait duration, if any jobs started. Returns None if job_queue_wait_duration_count is zero.

Trait Implementations

impl Clone for MetricsSnapshot

fn clone(&self) -> MetricsSnapshot

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MetricsSnapshot

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MetricsSnapshot

fn default() -> MetricsSnapshot

Returns the “default value” for a type.

impl PartialEq for MetricsSnapshot

fn eq(&self, other: &MetricsSnapshot) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for MetricsSnapshot

impl StructuralPartialEq for MetricsSnapshot