Fix date to timestamp; 0.0.21

frkn-dev · Oct 30, 2024 · 92ad1bf · 92ad1bf
1 parent f0878e5
commit 92ad1bf
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "pony"
-version = "0.0.20"
+version = "0.0.21"
 edition = "2021"
 
 [dependencies]

diff --git a/deploy/pony-0.8.0 b/deploy/pony-0.8.0
diff --git a/src/clickhouse.rs b/src/clickhouse.rs
@@ -18,11 +18,12 @@ pub async fn fetch_metrics_value(
 ) -> Result<Vec<MetricValue>, Box<dyn Error>> {
     let metric_value_req = format!(
         "SELECT
-                          toInt64(toUnixTimestamp(toDateTime(anyLast(Date)))) AS latest,
+                          toInt64(toUnixTimestamp(toDateTime(anyLast(Timestamp)))) AS latest,
                           Path AS metric,
                           toFloat64(anyLast(Value)) AS value
                         FROM default.graphite_data
                         WHERE metric LIKE '{env}.{cluster}%.{metric_postfix}'
+                        AND Timestamp >= now() - INTERVAL 1 MINUTE
                         GROUP BY metric"
     );
 

diff --git a/src/main.rs b/src/main.rs
@@ -34,7 +34,7 @@ use crate::web::not_found;
 
 #[derive(Parser)]
 #[command(
-    version = "0.0.20",
+    version = "0.0.21",
     about = "Pony - montiroing tool for Xray/Wireguard"
 )]
 struct Cli {
@@ -77,7 +77,7 @@ async fn main() -> std::io::Result<()> {
         std::process::exit(1);
     } else {
         info!(">>> Settings: {:?}", settings);
-        info!(">>> Version: 0.0.20");
+        info!(">>> Version: 0.0.21");
     }
 
     let carbon_server = settings.carbon.address.clone();