Merge pull request #542 from mobidata-bw/issues/537_station_cache

Improve: introduce configurable stationEntityCacheMinimumTtl and stationEntityCacheMaximumTtl
entur · Sep 26, 2024 · 9cda51f · 9cda51f
2 parents 8167a23 + 4017c9b
commit 9cda51f
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/main/java/org/entur/lamassu/leader/entityupdater/StationsUpdater.java b/src/main/java/org/entur/lamassu/leader/entityupdater/StationsUpdater.java
@@ -50,6 +50,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -64,6 +65,12 @@ public class StationsUpdater {
 
   private final MetricsService metricsService;
 
+  @Value("${org.entur.lamassu.stationEntityCacheMinimumTtl:30}")
+  private Integer stationEntityCacheMinimumTtl;
+
+  @Value("${org.entur.lamassu.stationEntityCacheMaximumTtl:300}")
+  private Integer stationEntityCacheMaximumTtl;
+
   @Autowired
   public StationsUpdater(
     StationCache stationCache,
@@ -223,7 +230,8 @@ public void addOrUpdateStations(
           (int) Instant.now().getEpochSecond(),
           (int) lastUpdated.getTime() / 1000,
           ttl,
-          300
+          stationEntityCacheMinimumTtl,
+          stationEntityCacheMaximumTtl
         ),
         TimeUnit.SECONDS
       );