Struct CpuCollector 

pub struct CpuCollector {
    pid: Option<i32>,
    prev: Option<Snapshot>,
    cpu_source: CpuSource,
    cfs_quota: CfsQuota,
    effective_cores: f64,
    carried_forward: HashSet<i32>,
}

Fields

pid: Option<i32>

Root PID of the process tree to track. None = system-only metrics.

prev: Option<Snapshot>

cpu_source: CpuSource

Detected CPU accounting source for system-level utilization.

cfs_quota: CfsQuota

CFS quota limit (None = unlimited).

effective_cores: f64

Effective number of cores for this environment. Respects CFS quota: min(physical_cores, quota_cores).

carried_forward: HashSet<i32>

PIDs whose prev entries were carried forward from the previous interval (their /proc/PID/stat read failed). Limited to one hop so dead PIDs don’t accumulate and inflate the exited correction.

Implementations

impl CpuCollector

pub fn new(pid: Option<i32>) -> Self

pub fn set_tracked_pid(&mut self, pid: Option<i32>)

Set the root PID for process-tree metrics (called after shell-wrapper spawn).

pub fn collect(&mut self) -> Result<CpuMetrics, Box<dyn Error>>