Method handle_metric

components/scheduler/src/vm_session.rs:357–387

(&mut self, name: String, m: MetricEvent, labels: HashMap<String, String>)

    }

    fn handle_metric(&mut self, name: String, m: MetricEvent, labels: HashMap<String, String>) {
        let mut labels = labels
            .into_iter()
            .map(|(k, v)| metrics::Label::new(k, v))
            .collect::<Vec<_>>();

        if name != "dispatch_event_latency" {
            labels.push(metrics::Label::new("guild_id", self.guild_id.to_string()));
        }

        match m {
            MetricEvent::Gauge(action) => {
                let handle = metrics::gauge!(name, labels);
                match action {
                    scheduler_worker_rpc::GaugeEvent::Set(v) => handle.set(v),
                    scheduler_worker_rpc::GaugeEvent::Incr(v) => handle.increment(v),
                }
            }
            MetricEvent::Counter(action) => {
                let handle = metrics::counter!(name, labels);

                match action {
                    scheduler_worker_rpc::CounterEvent::Incr(v) => handle.increment(v),
                    scheduler_worker_rpc::CounterEvent::Absolute(v) => handle.absolute(v),
                }
            }
            MetricEvent::Histogram(action) => {
                metrics::histogram!(name, labels).record(action);
            }
        }
    }

    /// Returns the worker to the pool with the vm still alive; the session
    /// state stays on the handle so the vm can be resumed on a later claim.