Struct PrometheusStateCollector 

pub struct PrometheusStateCollector { /* private fields */ }

Pull-based Prometheus collector for solti_sv_tasks_by_phase{phase}.

Register once with a shared prometheus::Registry alongside the other solti collectors. On each scrape, all phases from TaskPhase are emitted; empty phases return 0 so dashboards can rely on a stable label set.

Cost

O(N) per scrape where N is the current number of tasks in state. With a typical scrape interval of 10–30s and a fleet of <10k tasks this is negligible. If it ever becomes hot, the natural next step is to maintain phase counters inside TaskState directly.

Example

use std::sync::Arc;
use solti_prometheus::{PrometheusStateCollector, Registry};

let registry = Arc::new(Registry::new());
let collector = PrometheusStateCollector::new(supervisor_api.state())?;
registry.register(Box::new(collector))?;

Implementations

impl PrometheusStateCollector

pub fn new(state: TaskState) -> Result<Self, Error>

Create a new collector wired to state. The collector holds a cheap Arc clone of TaskState and will always observe the most recent mutations made by the supervisor’s state subscriber.

Trait Implementations

impl Collector for PrometheusStateCollector

fn desc(&self) -> Vec<&Desc>

Return descriptors for metrics.

fn collect(&self) -> Vec<MetricFamily>

Collect metrics.

impl Debug for PrometheusStateCollector

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

Formats the value using the given formatter.