logs + valid return
parent
5474ca1ffa
commit
2ff820bd67
22
src/main.rs
22
src/main.rs
|
|
@ -21,8 +21,15 @@ struct AppState {
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() {
|
async fn main() -> anyhow::Result<()> {
|
||||||
// let _ = setup_logger().await;
|
// 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 registry = Registry::new();
|
||||||
// let counter_opts = Opts::new("example_counter", "Пример счётчика");
|
// let counter_opts = Opts::new("example_counter", "Пример счётчика");
|
||||||
// let histogram_opts = Opts::new("example_histogram", "Пример histogram");
|
// let histogram_opts = Opts::new("example_histogram", "Пример histogram");
|
||||||
|
|
@ -52,6 +59,8 @@ async fn main() {
|
||||||
// registry.register(Box::new(sunops.clone())).unwrap();
|
// registry.register(Box::new(sunops.clone())).unwrap();
|
||||||
|
|
||||||
|
|
||||||
|
info!("Initializing shared state for Prometheus Exporter web-server ...");
|
||||||
|
|
||||||
let state = Arc::new(AppState {
|
let state = Arc::new(AppState {
|
||||||
registry: Mutex::new(registry),
|
registry: Mutex::new(registry),
|
||||||
// counter: Mutex::new(counter),
|
// counter: Mutex::new(counter),
|
||||||
|
|
@ -60,20 +69,15 @@ async fn main() {
|
||||||
|
|
||||||
// info!("Configurating Web-Server...");
|
// info!("Configurating Web-Server...");
|
||||||
|
|
||||||
tracing_subscriber::fmt()
|
info!("Configurating internals of Prometheus Exporter web-server...");
|
||||||
.with_max_level(tracing::Level::DEBUG)
|
|
||||||
.init();
|
|
||||||
|
|
||||||
info!("Configurating Web-Server...");
|
|
||||||
|
|
||||||
let app = Router::new()
|
let app = Router::new()
|
||||||
.route("/metrics", get(metrics_handler))
|
.route("/metrics", get(metrics_handler))
|
||||||
// .route("/increment", get(increment_handler))
|
|
||||||
// .route("/sum", get(summary_handler))
|
|
||||||
.route("/update", post(update_metrics))
|
.route("/update", post(update_metrics))
|
||||||
.with_state(state.clone());
|
.with_state(state.clone());
|
||||||
|
|
||||||
let listener = TcpListener::bind("0.0.0.0:9100").await.unwrap();
|
let listener = TcpListener::bind("0.0.0.0:9100").await.unwrap();
|
||||||
info!("Serving on ...:9100");
|
info!("Serving on ...:9100");
|
||||||
axum::serve(listener, app).await.unwrap();
|
axum::serve(listener, app).await?;
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
Loading…
Reference in New Issue