..

Author: infiniteregrets

src/main.rs

@@ -676,7 +676,7 @@ fn build_basin_reconfig(
             storage_class: storage_class.cloned(),
             retention_policy: retention_policy.cloned(),
             timestamping,
-            delete_on_empty: delete_on_empty_min_age.cloned(),
+            delete_on_empty_min_age: delete_on_empty_min_age.cloned(),
         })
     } else {
         None
@@ -729,7 +729,7 @@ fn build_stream_reconfig(
         storage_class: storage_class.cloned(),
         retention_policy: retention_policy.cloned(),
         timestamping,
-        delete_on_empty: delete_on_empty_min_age.cloned(),
+        delete_on_empty_min_age: delete_on_empty_min_age.cloned(),
     };
 
     if storage_class.is_some() {

src/types.rs

@@ -136,9 +136,9 @@ pub struct StreamConfig {
     #[clap(flatten)]
     /// Timestamping configuration.
     pub timestamping: Option<TimestampingConfig>,
-    #[arg(long = "delete-on-empty-min-age", help("Example: 1d, 1w, 1y"))]
+    #[arg(help("Example: 1d, 1w, 1y"))]
     /// Delete-on-empty configuration.
-    pub delete_on_empty: Option<DeleteOnEmpty>,
+    pub delete_on_empty_min_age: Option<DeleteOnEmpty>,
 }
 
 #[derive(ValueEnum, Debug, Clone, Serialize)]
@@ -236,7 +236,7 @@ impl From<StreamConfig> for s2::types::StreamConfig {
 
         let timestamping_config = config.timestamping.map(s2::types::TimestampingConfig::from);
 
-        let delete_on_empty = config.delete_on_empty.map(s2::types::DeleteOnEmpty::from);
+        let delete_on_empty = config.delete_on_empty_min_age.map(s2::types::DeleteOnEmpty::from);
 
         let mut stream_config = s2::types::StreamConfig::new();
         if let Some(storage_class) = storage_class {
@@ -343,7 +343,7 @@ impl From<s2::types::StreamConfig> for StreamConfig {
             storage_class: config.storage_class.map(Into::into),
             retention_policy: config.retention_policy.map(Into::into),
             timestamping: config.timestamping.map(Into::into),
-            delete_on_empty: config.delete_on_empty.map(Into::into),
+            delete_on_empty_min_age: config.delete_on_empty.map(Into::into),
         }
     }
 }