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 accepted by the executor.

tasks_completed: AtomicU64

Tasks whose body ran to completion.

tasks_failed: AtomicU64

Tasks whose body panicked or reported failure.

tasks_cancelled: AtomicU64

Tasks whose cancel request was honored before the body ran.

total_execution_time: AtomicU64

Accumulated task body execution time in nanoseconds.

active_workers: AtomicUsize

Workers currently running a task body.

idle_workers: AtomicUsize

Workers parked waiting for work.

total_workers: AtomicUsize

Workers owned by the pool.

pending_tasks: AtomicUsize

Tasks queued and not yet started.

max_queue_depth: AtomicUsize

High-water mark of the pending queue.

started_at: Instant

Executor construction instant; the metrics epoch.

last_updated_after_ns: AtomicU64

Nanoseconds after started_at of the last metrics update.

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.