Skip to content

Commit 43e017f

Browse files
committed
ignore metrics recorder
1 parent e618964 commit 43e017f

1 file changed

Lines changed: 19 additions & 19 deletions

File tree

pulsebeam/src/node.rs

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -365,20 +365,20 @@ mod internal {
365365
// Try to install the Prometheus recorder.
366366
// In simulation or test environments running multiple nodes in one process,
367367
// this might fail if already installed. We proceed gracefully.
368-
static GLOBAL_PROMETHEUS_HANDLE: once_cell::sync::OnceCell<PrometheusHandle> =
369-
once_cell::sync::OnceCell::new();
370-
371-
let prometheus_handle = match PrometheusBuilder::new().install_recorder() {
372-
Ok(handle) => {
373-
let _ = GLOBAL_PROMETHEUS_HANDLE.set(handle.clone());
374-
handle
375-
}
376-
Err(_) => GLOBAL_PROMETHEUS_HANDLE
377-
.get()
378-
.cloned()
379-
.unwrap_or_else(|| PrometheusBuilder::new().build_recorder().handle()),
380-
};
381-
368+
// static GLOBAL_PROMETHEUS_HANDLE: once_cell::sync::OnceCell<PrometheusHandle> =
369+
// once_cell::sync::OnceCell::new();
370+
371+
// let prometheus_handle = match PrometheusBuilder::new().install_recorder() {
372+
// Ok(handle) => {
373+
// let _ = GLOBAL_PROMETHEUS_HANDLE.set(handle.clone());
374+
// handle
375+
// }
376+
// Err(_) => GLOBAL_PROMETHEUS_HANDLE
377+
// .get()
378+
// .cloned()
379+
// .unwrap_or_else(|| PrometheusBuilder::new().build_recorder().handle()),
380+
// };
381+
//
382382
const INDEX_HTML: &str = r#"
383383
<ul>
384384
<li><a href="/healthz">Healthcheck</a></li>
@@ -390,14 +390,14 @@ mod internal {
390390
</ul>
391391
"#;
392392

393-
let router_prometheus = prometheus_handle.clone();
393+
// let router_prometheus = prometheus_handle.clone();
394394
let router = Router::new()
395395
.route("/debug/pprof/profile", get(pprof_profile))
396396
.route("/debug/pprof/allocs", get(heap_profile))
397397
.route("/healthz", get(healthcheck))
398-
.route("/", get(async move || Html(INDEX_HTML)))
399-
.route("/metrics", get(async move || router_prometheus.render()));
400-
let rt_monitor_join = tokio::spawn(rt_background_monitor(prometheus_handle));
398+
.route("/", get(async move || Html(INDEX_HTML)));
399+
// .route("/metrics", get(async move || router_prometheus.render()));
400+
// let rt_monitor_join = tokio::spawn(rt_background_monitor(prometheus_handle));
401401

402402
tracing::info!("internal metrics listening on {:?}", addr);
403403

@@ -420,7 +420,7 @@ mod internal {
420420
tracing::error!("internal http server error: {e}");
421421
}
422422
}
423-
_ = rt_monitor_join => {}
423+
// _ = rt_monitor_join => {}
424424
// _ = runtime_metrics_join => {}
425425
// _ = actor_monitor_join => {}
426426
_ = shutdown.cancelled() => {

0 commit comments

Comments
 (0)