Module concurrency_metrics 

Concurrency Metrics

This module provides metrics for monitoring and tuning concurrency and resource utilization in the pipeline system.

Educational Purpose

These metrics demonstrate:

• How to observe resource saturation
• When to tune resource limits
• Impact of concurrency on throughput and latency

Metric Types

Gauges - Instant values (e.g., tokens available right now) Counters - Cumulative values (e.g., total wait time) Histograms - Distribution of values (e.g., P50/P95/P99 wait times)

Usage

use adaptive_pipeline::infrastructure::metrics::CONCURRENCY_METRICS;

// Record resource acquisition
CONCURRENCY_METRICS.record_cpu_wait(wait_duration);

// Check saturation
let saturation = CONCURRENCY_METRICS.cpu_saturation_percent();
if saturation > 80.0 {
    println!("CPU-saturated: consider increasing workers");
}

Structs

ConcurrencyMetrics

Concurrency metrics for resource manager monitoring

Histogram

Simple histogram for latency distribution tracking

Statics

CONCURRENCY_METRICS

Global concurrency metrics instance