diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-09-20 17:45:18 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-09-20 17:50:22 +0200 |
| commit | 782630fc27b41b9ae58d1417cace2995c99856fc (patch) | |
| tree | 56db83c31c53688c7c216cc425d1e2602e5ef1a4 /src/garage/server.rs | |
| parent | 7a901f7aab29d9ae09c378e3824b8236458f85f1 (diff) | |
| download | garage-782630fc27b41b9ae58d1417cace2995c99856fc.tar.gz garage-782630fc27b41b9ae58d1417cace2995c99856fc.zip | |
Initialize metrics exporter earlier (fix #389)fix-metrics
Diffstat (limited to 'src/garage/server.rs')
| -rw-r--r-- | src/garage/server.rs | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/garage/server.rs b/src/garage/server.rs index aeef02a2..28710a8e 100644 --- a/src/garage/server.rs +++ b/src/garage/server.rs @@ -32,6 +32,9 @@ pub async fn run_server(config_file: PathBuf) -> Result<(), Error> { // ---- Initialize Garage internals ---- + #[cfg(feature = "metrics")] + let metrics_exporter = opentelemetry_prometheus::exporter().init(); + info!("Initializing background runner..."); let watch_cancel = netapp::util::watch_ctrl_c(); let (background, await_background_done) = BackgroundRunner::new(16, watch_cancel.clone()); @@ -50,7 +53,11 @@ pub async fn run_server(config_file: PathBuf) -> Result<(), Error> { } info!("Initialize Admin API server and metrics collector..."); - let admin_server = AdminApiServer::new(garage.clone()); + let admin_server = AdminApiServer::new( + garage.clone(), + #[cfg(feature = "metrics")] + metrics_exporter, + ); info!("Launching internal Garage cluster communications..."); let run_system = tokio::spawn(garage.system.clone().run(watch_cancel.clone())); |