From b15a17d84ded6f558650b311713580691f471ab9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Phil=20H=C3=B6fer?= <phil.hoefer@suma-ev.de>
Date: Mon, 22 Jul 2024 14:16:08 +0200
Subject: [PATCH] Modify Startup
---
chart/templates/deployment.yaml | 1 +
src/main.rs | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/chart/templates/deployment.yaml b/chart/templates/deployment.yaml
index 4e6d4eb..b21506b 100644
--- a/chart/templates/deployment.yaml
+++ b/chart/templates/deployment.yaml
@@ -62,6 +62,7 @@ spec:
httpGet:
path: /healthz
port: http
+ timeoutSeconds: 20
resources:
{{- toYaml .Values.resources | nindent 12 }}
{{- with .Values.nodeSelector }}
diff --git a/src/main.rs b/src/main.rs
index b2414e4..8b75aab 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -143,7 +143,7 @@ fn process_request(request: tiny_http::Request, config: HashMap<String, String>,
request.respond(response);
let now = std::time::SystemTime::now();
let elapsed = now.duration_since(last_update).expect("Time went backwards");
- if elapsed >= std::time::Duration::from_secs(2 * 60 * 60) { //every 2h
+ if elapsed >= std::time::Duration::from_secs(12 * 60 * 60) { //every 12h
markov_chain.decay();
read_from_db(config.clone(), markov_chain);
last_update = now;
@@ -180,7 +180,7 @@ fn read_from_db(config: HashMap<String, String>, predictor: &mut CompositePredic
match client {
Ok(mut c) => {
let mut count = 0;
- match c.query("SELECT query FROM public.logs_partitioned ORDER BY time DESC LIMIT 1000", &[]) {
+ match c.query("SELECT query FROM public.logs_partitioned ORDER BY time DESC LIMIT 10000", &[]) {
Ok(rows) => {
for row in rows {
let query: &str = row.get(0);
--
GitLab