From 114c1cae22df508b2d52b3f29734f71a32547075 Mon Sep 17 00:00:00 2001 From: Nitish Tiwari Date: Mon, 19 Feb 2024 12:07:42 +0530 Subject: [PATCH] =?UTF-8?q?Revert=20"fix:=20avoid=20removal=20of=20retenti?= =?UTF-8?q?on=20configuration=20while=20updating=20snapshot=E2=80=A6"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit 121bf01a03e1b442761e99275b1c70d9bff31733. --- server/src/storage.rs | 3 --- server/src/storage/retention.rs | 6 ------ 2 files changed, 9 deletions(-) diff --git a/server/src/storage.rs b/server/src/storage.rs index 52b1b61a3..975fcf445 100644 --- a/server/src/storage.rs +++ b/server/src/storage.rs @@ -37,7 +37,6 @@ pub use store_metadata::{ put_remote_metadata, put_staging_metadata, resolve_parseable_metadata, StorageMetadata, }; -use self::retention::Retention; pub use self::staging::StorageDir; /// local sync interval to move data.records to /tmp dir of that stream. @@ -77,7 +76,6 @@ pub struct ObjectStoreFormat { pub snapshot: Snapshot, #[serde(default)] pub cache_enabled: bool, - pub retention: Retention, } #[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)] @@ -120,7 +118,6 @@ impl Default for ObjectStoreFormat { stats: Stats::default(), snapshot: Snapshot::default(), cache_enabled: false, - retention: Retention::new(), } } } diff --git a/server/src/storage/retention.rs b/server/src/storage/retention.rs index 161505e5e..beb8edd2e 100644 --- a/server/src/storage/retention.rs +++ b/server/src/storage/retention.rs @@ -134,12 +134,6 @@ struct TaskView { duration: String, } -impl Retention { - pub fn new() -> Self { - Self { tasks: Vec::new() } - } -} - impl TryFrom> for Retention { type Error = String;