Struct JobMetricsCollector

pub struct JobMetricsCollector { /* private fields */ }

Job metrics collector

Implementations

impl JobMetricsCollector

pub fn new() -> Self

Create a new metrics collector

pub fn record_job_scheduled(&self, job_type: &str, priority: Priority)

Record a job being scheduled

pub fn record_execution_start(&self, job_id: JobId)

Record job execution start

pub fn record_job_success(&self, job_id: JobId)

Record job completion (success)

pub fn record_job_failure(&self, job_id: JobId, retry_attempts: u32)

Record job failure

pub fn record_job_retry(&self, _job_id: JobId)

Record job retry

pub fn record_job_timeout(&self, job_id: JobId)

Record job timeout

pub fn record_job_cancellation(&self, job_id: JobId)

Record job cancellation

pub fn get_metrics(&self) -> JobMetrics

Get current metrics snapshot

pub fn reset_metrics(&self)

Reset all metrics

pub fn active_executions_count(&self) -> usize

Get active executions count

Trait Implementations

impl Debug for JobMetricsCollector

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

Formats the value using the given formatter.

impl Default for JobMetricsCollector

fn default() -> Self

Returns the “default value” for a type.