Store qualified counters in dedicated capacity limited cache

Kuadrant · Jul 31, 2023 · ac1e00b · ac1e00b
1 parent f63bdb7
commit ac1e00b
Show file tree

Hide file tree

Showing 4 changed files with 263 additions and 97 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/limitador/Cargo.toml b/limitador/Cargo.toml
@@ -21,6 +21,7 @@ infinispan_storage = ["infinispan", "reqwest", "base64"]
 lenient_conditions = []
 
 [dependencies]
+moka = "0.11.2"
 ttl_cache = "0.5"
 serde = { version = "1", features = ["derive"] }
 postcard = { version = "1.0.4", features = ["use-std"] }

diff --git a/limitador/src/counter.rs b/limitador/src/counter.rs
@@ -87,6 +87,10 @@ impl Counter {
         self.expires_in = Some(duration)
     }
 
+    pub fn is_qualified(&self) -> bool {
+        !self.set_variables.is_empty()
+    }
+
     #[cfg(feature = "disk_storage")]
     pub(crate) fn variables_for_key(&self) -> Vec<(&str, &str)> {
         let mut variables = Vec::with_capacity(self.set_variables.len());