Struct ExecutorMetrics 

pub struct ExecutorMetrics {
    pub tasks_spawned: AtomicU64,
    pub tasks_completed: AtomicU64,
    pub tasks_failed: AtomicU64,
    pub tasks_cancelled: AtomicU64,
    pub total_execution_time: AtomicU64,
    pub active_workers: AtomicUsize,
    pub idle_workers: AtomicUsize,
    pub total_workers: AtomicUsize,
    pub pending_tasks: AtomicUsize,
    pub max_queue_depth: AtomicUsize,
    pub started_at: Instant,
    pub last_updated_after_ns: AtomicU64,
}

Executor performance metrics.

Every field is written by a real production path; untracked quantities (process memory, CPU utilization) deliberately have no fields here.

Fields

tasks_spawned: AtomicU64

tasks_completed: AtomicU64

tasks_failed: AtomicU64

tasks_cancelled: AtomicU64

Tasks whose cancel request was honored before the body ran.

total_execution_time: AtomicU64

active_workers: AtomicUsize

idle_workers: AtomicUsize

total_workers: AtomicUsize

pending_tasks: AtomicUsize

max_queue_depth: AtomicUsize

started_at: Instant

last_updated_after_ns: AtomicU64

Implementations

impl ExecutorMetrics

pub fn new() -> Self

Create new metrics tracker

pub fn record_task_spawned(&self)

Record a new task being spawned

pub fn record_task_completed(&self, execution_time: Duration)

Record a task completion with execution time

pub fn record_task_failed(&self)

Record a task failure

pub fn record_task_cancelled(&self)

Record a task whose cancel request was honored before its body ran.

pub fn update_worker_counts(&self, active: usize, idle: usize, total: usize)

Update worker count metrics

pub fn update_queue_metrics(&self, pending: usize)

Update queue metrics

pub fn throughput(&self) -> f64

Get current throughput (tasks per second)

pub fn success_rate(&self) -> f64

Get success rate as percentage

pub fn average_task_duration(&self) -> Duration

Get average task duration

pub fn worker_utilization(&self) -> f64

Get worker utilization percentage

pub fn uptime(&self) -> Duration

Get uptime

pub fn last_updated(&self) -> Instant

Get the last metrics update timestamp.

pub fn reset(&self)

Reset all metrics (useful for testing)

Trait Implementations

impl Debug for ExecutorMetrics

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

Formats the value using the given formatter.

impl Default for ExecutorMetrics

fn default() -> Self

Returns the “default value” for a type.