Browse Source

extract metrics begin

main
Alexey Velikiy 3 years ago
parent
commit
27878eb2d2
  1. 14
      src/grafana_service.rs
  2. 1
      src/main.rs

14
src/grafana_service.rs

@ -24,7 +24,21 @@ impl GrafanaService {
let client = Client::new(); let client = Client::new();
let resp = client.request(req).await?; let resp = client.request(req).await?;
println!("Response: {}", resp.status()); println!("Response: {}", resp.status());
Ok(())
}
pub async fn extract_metrics(&self) -> types::Result<()> {
let req = Request::builder()
.method(Method::POST)
.uri(self.url.clone() + "/api/datasources/proxy/1/api/v1/query_range")
.header("content-type", "application/json")
.header("Authorization", format!("Bearer {}", self.api_key))
.body(Body::from(r#"{"query":"go_memstats_alloc_bytes_total", "start": "1634163645", "end": "1634163945", "step": "15"}"#))
.unwrap();
let client = Client::new();
let resp = client.request(req).await?;
println!("Response: {}", resp.status());
Ok(()) Ok(())
} }
} }

1
src/main.rs

@ -28,6 +28,7 @@ async fn main() -> types::Result<()> {
let gs = grafana_service::GrafanaService::new(url.to_string(), key.to_string()); let gs = grafana_service::GrafanaService::new(url.to_string(), key.to_string());
gs.test_connection().await?; gs.test_connection().await?;
gs.extract_metrics().await?;
Ok(()) Ok(())
} }

Loading…
Cancel
Save