deployer3000
/
integration-module
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 12 Wiki Activity

temp export tracing #11

Merged
Ghost merged 1 commits from feature/report-exports into rc 2025-03-07 12:40:23 +03:00
Conversation 0 Commits 1 Files Changed 2
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
crates/api-grub/src/export.rs
View File

@ -4,7 +4,7 @@ use reqwest::Client;
use tokio_postgres::NoTls; use tokio_postgres::NoTls;
use std::env; use std::env;
use anyhow::Result; use anyhow::Result;
use log::{info, error}; use log::{debug, error, info};
use std::ops::Drop; use std::ops::Drop;
/// An entity which handles DB connections. /// An entity which handles DB connections.
@ -99,6 +99,8 @@ impl Exporter {
pub async fn export_metrics(metrics: PrometheusMetrics) -> Result<usize> { pub async fn export_metrics(metrics: PrometheusMetrics) -> Result<usize> {
let url = env::var("EXPORTER_URL")?; let url = env::var("EXPORTER_URL")?;
debug!("Exporting: {:?}", &metrics);
let req = Client::new() let req = Client::new()
.post(url) .post(url)
.json(&metrics) .json(&metrics)
@ -111,6 +113,9 @@ impl Exporter {
/// as env var $EXORPTER_URL /// as env var $EXORPTER_URL
pub async fn export_extended_metrics(metrics: PrometheusMetricsExtended) -> Result<usize> { pub async fn export_extended_metrics(metrics: PrometheusMetricsExtended) -> Result<usize> {
let url = env::var("EXPORTER_URL")?; let url = env::var("EXPORTER_URL")?;
debug!("Exporting: {:?}", &metrics);
let req = Client::new() let req = Client::new()
.post(url) .post(url)
.json(&metrics) .json(&metrics)

2
crates/api-grub/src/logger.rs
View File

@ -33,7 +33,7 @@ pub async fn setup_logger() -> Result<()> {
record.args(), record.args(),
) )
}) })
.filter(None, LevelFilter::Info) .filter(None, LevelFilter::Debug)
.target(env_logger::Target::Stdout) .target(env_logger::Target::Stdout)
.init(); .init();