Compare commits

..

No commits in common. "76beff02ac33d0bdeda0b2f3fb4c746514649b4d" and "a30fb0d834da056b588b8dcfb057bfeb118fe2f5" have entirely different histories.

2 changed files with 4 additions and 8 deletions

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 tracing::{debug, error, info, trace}; use tracing::{debug, error, info};
use std::ops::Drop; use std::ops::Drop;
/// An entity which handles DB connections. /// An entity which handles DB connections.
@ -113,13 +113,9 @@ impl Exporter {
} }
/// Exports metrics in `PrometheusMetricsExtended` format to Exporter defined /// Exports metrics in `PrometheusMetricsExtended` format to Exporter defined
/// as env var $EXORPTER_URL /// as env var $EXORPTER_URL
#[tracing::instrument(name = "Prometheus/Status System export")]
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")?;
let url = env::var("STATUS_SYSTEM_URL").or_else(|err| { let url = env::var("STATUS_SYSTEM_URL").unwrap_or(env::var("EXPORTER_URL")?);
trace!("cannot fetch $STATUS_SYSTEM_URL var due to {}. working only with Prometheus exporter link", err);
env::var("EXPORTER_URL")
})?;
debug!("Exporting: {:?}", &metrics); debug!("Exporting: {:?}", &metrics);

View File

@ -277,8 +277,8 @@ impl MonitoringImporter {
match event.await { match event.await {
Ok(val) => { Ok(val) => {
match crate::export::Exporter::export_extended_metrics(val?).await { match crate::export::Exporter::export_extended_metrics(val?).await {
Ok(bytes) => {info!("Successfully transmitted {} bytes", bytes)}, Ok(bytes) => {info!("Successfully transmitted {} bytes to the Prometehus exporter", bytes)},
Err(er) => error!("Cannot export data due to : `{}`", er), Err(er) => error!("Cannot export data to the Prometehus exporter due to : `{}`", er),
} }
}, },
Err(er) => { Err(er) => {