feat: configurable cache size, bump default to 2000 slots

Author: tejasbadadare

apps/argus/Cargo.lock

@@ -2,6 +2,7 @@ use clap::{crate_authors, crate_description, crate_name, crate_version, Args, Pa
 
 mod aggregate;
 mod benchmarks;
+mod cache;
 mod metrics;
 mod pythnet;
 mod rpc;
@@ -24,6 +25,10 @@ pub enum Options {
 
 #[derive(Args, Clone, Debug)]
 pub struct RunOptions {
+    /// Cache Options
+    #[command(flatten)]
+    pub cache: cache::Options,
+
     /// Aggregate Options
     #[command(flatten)]
     pub aggregate: aggregate::Options,

apps/hermes/server/src/config.rs

@@ -0,0 +1,18 @@
+use clap::Args;
+
+#[derive(Args, Clone, Debug)]
+#[command(next_help_heading = "Cache Options")]
+#[group(id = "Cache")]
+pub struct Options {
+    /// The maximum number of slots to cache.
+    ///
+    /// This controls how many historical price updates are kept in memory.
+    /// Higher values increase memory usage but allow access to more historical data
+    /// without falling back to Benchmarks.
+    ///
+    /// Default is 2000 slots, which gives ~13 minutes of cached updates.
+    #[arg(long = "cache-size-slots")]
+    #[arg(env = "CACHE_SIZE_SLOTS")]
+    #[arg(default_value = "2000")]
+    pub size_slots: u64,
+}

apps/hermes/server/src/config/cache.rs

@@ -44,7 +44,7 @@ async fn init() -> Result<()> {
             // Initialize a cache store with a 1000 element circular buffer.
             let state = state::new(
                 update_tx.clone(),
-                1000,
+                opts.cache.size_slots,
                 opts.benchmarks.endpoint.clone(),
                 opts.aggregate.readiness_staleness_threshold.into(),
                 opts.aggregate.readiness_max_allowed_slot_lag,