VERSION

@@ -1 +1 @@
-0.1.28
+0.1.27

proto/sketches.proto

@@ -72,7 +72,6 @@ message BloomReserveRequest {
   string name = 1;
   uint64 capacity = 2;
   double error_rate = 3;
-  uint64 ttl_ms = 4;
 }
 message BloomReserveResponse {
   bool success = 1;
@@ -147,7 +146,6 @@ message BloomDeleteResponse {
 message HllReserveRequest {
   string name = 1;
   uint32 precision = 2;
-  uint64 ttl_ms = 3;
 }
 message HllReserveResponse {
   bool success = 1;
@@ -196,7 +194,6 @@ message CmsReserveRequest {
   string name = 1;
   uint64 width = 2;
   uint64 depth = 3;
-  uint64 ttl_ms = 4;
 }
 message CmsReserveResponse {
   bool success = 1;
@@ -245,7 +242,6 @@ message TopKReserveRequest {
   uint64 width = 3;
   uint64 depth = 4;
   double decay = 5;
-  uint64 ttl_ms = 6;
 }
 message TopKReserveResponse {
   bool success = 1;
@@ -299,7 +295,6 @@ message TopKDeleteResponse {
 message TDigestCreateRequest {
   string name = 1;
   uint32 compression = 2;
-  uint64 ttl_ms = 3;
 }
 message TDigestCreateResponse {
   bool success = 1;

rust/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "waymaker-client"
-version = "0.1.28"
+version = "0.1.27"
 edition = "2021"
 description = "Official Rust client for waymaker — locks, streams, KV, collections, sketches, cache, object store"
 repository = "https://git.awesomike.com/pub/waymaker-client"

rust/src/probabilistic/bloom.rs

@@ -15,8 +15,6 @@ pub struct BloomConfig {
     /// Target false-positive rate (e.g. 0.01 for 1%). 0.0 = server
     /// default (0.01).
     pub error_rate: f64,
-    /// Optional auto-eviction after this long. `None` = never expires.
-    pub ttl: Option<std::time::Duration>,
 }
 
 #[derive(Debug, Clone)]
@@ -144,7 +142,6 @@ impl Client {
                 name: config.name.clone(),
                 capacity: config.capacity,
                 error_rate: config.error_rate,
-                ttl_ms: config.ttl.map(|d| d.as_millis() as u64).unwrap_or(0),
             }))
             .await?
             .into_inner();

rust/src/probabilistic/cms.rs

@@ -17,8 +17,6 @@ pub struct CmsConfig {
     pub width: u64,
     /// Sketch depth (rows / hash functions). 0 = server default.
     pub depth: u64,
-    /// Optional auto-eviction after this long. `None` = never expires.
-    pub ttl: Option<std::time::Duration>,
 }
 
 #[derive(Clone)]
@@ -82,7 +80,6 @@ impl Client {
                 name: config.name.clone(),
                 width: config.width,
                 depth: config.depth,
-                ttl_ms: config.ttl.map(|d| d.as_millis() as u64).unwrap_or(0),
             }))
             .await?
             .into_inner();

rust/src/probabilistic/hll.rs

@@ -13,9 +13,6 @@ pub struct HllConfig {
     /// 2^precision = register count. Valid range 4..=18. 0 =
     /// server default (14, ~16 KB, ~1% error).
     pub precision: u32,
-    /// Optional auto-eviction: the server drops this HLL this long after reserve.
-    /// `None` = never expires. Handy for time-bucketed keys (rolling windows).
-    pub ttl: Option<std::time::Duration>,
 }
 
 #[derive(Clone)]
@@ -94,7 +91,6 @@ impl Client {
             .hll_reserve(Request::new(HllReserveRequest {
                 name: config.name.clone(),
                 precision: config.precision,
-                ttl_ms: config.ttl.map(|d| d.as_millis() as u64).unwrap_or(0),
             }))
             .await?
             .into_inner();

rust/src/probabilistic/tdigest.rs

@@ -15,8 +15,6 @@ pub struct TDigestConfig {
     /// Compression. Higher = better tail accuracy at cost of
     /// memory. 0 = server default.
     pub compression: u32,
-    /// Optional auto-eviction after this long. `None` = never expires.
-    pub ttl: Option<std::time::Duration>,
 }
 
 #[derive(Clone)]
@@ -89,7 +87,6 @@ impl Client {
             .t_digest_create(Request::new(TDigestCreateRequest {
                 name: config.name.clone(),
                 compression: config.compression,
-                ttl_ms: config.ttl.map(|d| d.as_millis() as u64).unwrap_or(0),
             }))
             .await?
             .into_inner();

rust/src/probabilistic/topk.rs

@@ -17,8 +17,6 @@ pub struct TopKConfig {
     pub depth: u64,
     /// Probability-decay factor (0.0..=1.0). 0 = server default.
     pub decay: f64,
-    /// Optional auto-eviction after this long. `None` = never expires.
-    pub ttl: Option<std::time::Duration>,
 }
 
 #[derive(Debug, Clone)]
@@ -107,7 +105,6 @@ impl Client {
                 width: config.width,
                 depth: config.depth,
                 decay: config.decay,
-                ttl_ms: config.ttl.map(|d| d.as_millis() as u64).unwrap_or(0),
             }))
             .await?
             .into_inner();