Fix long queries + increase min reccomendations

robusta_krr/core/integrations/prometheus/metrics/base_filtered_metric.py

@@ -1,7 +1,7 @@
 from typing import Any, Optional
 
 from robusta_krr.core.abstract.strategies import Metric
-
+from robusta_krr.core.models.objects import K8sObjectData
 from .base_metric import BaseMetricLoader, QueryType
 
 PrometheusSeries = Any
@@ -22,6 +22,13 @@ def get_target_name(series: PrometheusSeries) -> Optional[str]:
                 return series["metric"][label]
         return None
 
+    @staticmethod
+    def get_pods_selector(object: K8sObjectData) -> Optional[str]:
+        if len(object.pods) < 20:
+            return "|".join(pod.name for pod in object.pods)
+        else:
+            return "|".join(set([pod.name[:pod.name.rfind('-')] + '-[0-9a-z]{0,5}' for pod in object.pods]))
+
     @staticmethod
     def filter_prom_jobs_results(
         series_list_result: list[PrometheusSeries],

robusta_krr/core/integrations/prometheus/metrics/cpu_metric.py

@@ -10,7 +10,7 @@
 @bind_metric(ResourceType.CPU)
 class CPUMetricLoader(BaseFilteredMetricLoader):
     def get_query(self, object: K8sObjectData, resolution: Optional[str]) -> str:
-        pods_selector = "|".join(pod.name for pod in object.pods)
+        pods_selector = self.get_pods_selector(object)
         cluster_label = self.get_prometheus_cluster_label()
         return (
             "sum(irate(container_cpu_usage_seconds_total{"

robusta_krr/core/integrations/prometheus/metrics/memory_metric.py

@@ -10,7 +10,7 @@
 @bind_metric(ResourceType.Memory)
 class MemoryMetricLoader(BaseFilteredMetricLoader):
     def get_query(self, object: K8sObjectData, resolution: Optional[str]) -> str:
-        pods_selector = "|".join(pod.name for pod in object.pods)
+        pods_selector = self.get_pods_selector(object)
         cluster_label = self.get_prometheus_cluster_label()
         return (
             "sum(container_memory_working_set_bytes{"
@@ -33,7 +33,7 @@ class SimpleMemoryMetricLoader(MemoryMetricLoader):
     """
 
     def get_query(self, object: K8sObjectData, resolution: Optional[str]) -> str:
-        pods_selector = "|".join(pod.name for pod in object.pods)
+        pods_selector = self.get_pods_selector(object)
         cluster_label = self.get_prometheus_cluster_label()
         resolution_formatted = f"[{resolution}]" if resolution else ""
         return (

robusta_krr/core/models/config.py

@@ -19,8 +19,8 @@ class Config(pd.BaseSettings):
     selector: Optional[str] = None
 
     # Value settings
-    cpu_min_value: int = pd.Field(5, ge=0)  # in millicores
-    memory_min_value: int = pd.Field(10, ge=0)  # in megabytes
+    cpu_min_value: int = pd.Field(100, ge=0)  # in millicores
+    memory_min_value: int = pd.Field(100, ge=0)  # in megabytes
 
     # Prometheus Settings
     prometheus_url: Optional[str] = pd.Field(None)