Struct Tower 

pub struct Tower {
    state: Mutex<State>,
}

The process-wide sampler. Its state is the previous sample (for CPU rates) and sticky membership.

Fields

state: Mutex<State>

Implementations

impl Tower

pub fn new() -> Self

pub fn global() -> &'static Tower

pub fn live_pids_since(&self, since: Instant) -> Option<HashSet<u32>>

The PIDs in the process table of the last sample, if that sample’s read began at or after since: what is missing from it had exited by then. None for an older sample (one reused within REUSE_WITHIN, the last good one before a failed read, or one whose read was already under way), which can’t speak for a process that started after it.

pub fn sample( &self, want_host: bool, hostname: &str, inputs: impl FnOnce() -> Inputs, labels: impl Fn(&str) -> Option<BlockLabel>, renderer: impl Fn(u32) -> Option<String>, ) -> Result<TowerSnapshot>

A sample (module doc). BLOCKING: reads the process table, and labels and renderer may read the store; call it off the async workers. renderer says what a renderer PID serves (“window Main”), for the AgentMux task’s rows (tower_agentmux::renderer_serves).

fn sample_from( &self, snapshot: impl FnOnce() -> Result<Vec<ProcInfo>>, want_host: bool, hostname: &str, inputs: impl FnOnce() -> Inputs, labels: impl Fn(&str) -> Option<BlockLabel>, renderer: impl Fn(u32) -> Option<String>, ) -> Result<TowerSnapshot>

sample with the process table read by snapshot.

Trait Implementations

impl Default for Tower

fn default() -> Self

Returns the “default value” for a type.