diff --git a/quickwit/quickwit-indexing/src/split_store/indexing_split_store.rs b/quickwit/quickwit-indexing/src/split_store/indexing_split_store.rs index 3262d0d611b..9fd42b8d18f 100644 --- a/quickwit/quickwit-indexing/src/split_store/indexing_split_store.rs +++ b/quickwit/quickwit-indexing/src/split_store/indexing_split_store.rs @@ -20,7 +20,7 @@ #[cfg(any(test, feature = "testsuite"))] use std::collections::HashMap; use std::path::{Path, PathBuf}; -use std::sync::{Arc, Weak}; +use std::sync::Arc; use std::time::Instant; use anyhow::Context; @@ -68,18 +68,6 @@ struct InnerIndexingSplitStore { local_split_store: Arc, } -pub struct WeakIndexingSplitStore { - inner: Weak, -} - -impl WeakIndexingSplitStore { - pub fn upgrade(&self) -> Option { - self.inner - .upgrade() - .map(|inner| IndexingSplitStore { inner }) - } -} - impl IndexingSplitStore { /// Creates an instance of [`IndexingSplitStore`] /// @@ -226,12 +214,6 @@ impl IndexingSplitStore { get_tantivy_directory_from_split_bundle(&dest_filepath) } - pub fn downgrade(&self) -> WeakIndexingSplitStore { - WeakIndexingSplitStore { - inner: Arc::downgrade(&self.inner), - } - } - /// Takes a snapshot of the cache view (only used for testing). #[cfg(any(test, feature = "testsuite"))] pub async fn inspect_local_store(&self) -> HashMap { diff --git a/quickwit/quickwit-indexing/src/split_store/mod.rs b/quickwit/quickwit-indexing/src/split_store/mod.rs index fd31ddf00a7..cf776b71a8b 100644 --- a/quickwit/quickwit-indexing/src/split_store/mod.rs +++ b/quickwit/quickwit-indexing/src/split_store/mod.rs @@ -21,6 +21,6 @@ mod indexing_split_store; mod local_split_store; mod split_store_quota; -pub use indexing_split_store::{IndexingSplitStore, WeakIndexingSplitStore}; +pub use indexing_split_store::IndexingSplitStore; pub use local_split_store::{get_tantivy_directory_from_split_bundle, LocalSplitStore}; pub use split_store_quota::SplitStoreQuota;