diff --git a/src/main.rs b/src/main.rs index 80e4e15..f7ee7bb 100644 --- a/src/main.rs +++ b/src/main.rs @@ -21,8 +21,15 @@ struct AppState { } #[tokio::main] -async fn main() { +async fn main() -> anyhow::Result<()> { // let _ = setup_logger().await; + + tracing_subscriber::fmt() + .with_max_level(tracing::Level::DEBUG) + .init(); + + info!("Initializing local Prometehus metrics registry ..."); + let registry = Registry::new(); // let counter_opts = Opts::new("example_counter", "Пример счётчика"); // let histogram_opts = Opts::new("example_histogram", "Пример histogram"); @@ -52,6 +59,8 @@ async fn main() { // registry.register(Box::new(sunops.clone())).unwrap(); + info!("Initializing shared state for Prometheus Exporter web-server ..."); + let state = Arc::new(AppState { registry: Mutex::new(registry), // counter: Mutex::new(counter), @@ -60,20 +69,15 @@ async fn main() { // info!("Configurating Web-Server..."); - tracing_subscriber::fmt() - .with_max_level(tracing::Level::DEBUG) - .init(); - - info!("Configurating Web-Server..."); + info!("Configurating internals of Prometheus Exporter web-server..."); let app = Router::new() .route("/metrics", get(metrics_handler)) - // .route("/increment", get(increment_handler)) - // .route("/sum", get(summary_handler)) .route("/update", post(update_metrics)) .with_state(state.clone()); let listener = TcpListener::bind("0.0.0.0:9100").await.unwrap(); info!("Serving on ...:9100"); - axum::serve(listener, app).await.unwrap(); + axum::serve(listener, app).await?; + Ok(()) } \ No newline at end of file