Compare commits
No commits in common. "76beff02ac33d0bdeda0b2f3fb4c746514649b4d" and "a30fb0d834da056b588b8dcfb057bfeb118fe2f5" have entirely different histories.
76beff02ac
...
a30fb0d834
|
|
@ -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);
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -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) => {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue