refactor(idpe-17789): rename NotEmptyPartitionsSourceWrapper to NotEm…

…ptyCompactionJobsSourceWrapper
Shopify · Jul 25, 2023 · 759a494 · 759a494
1 parent 0234b56
commit 759a494
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/compactor/src/components/hardcoded.rs b/compactor/src/components/hardcoded.rs
@@ -62,7 +62,7 @@ use super::{
  },
  partitions_source::{
  logging::LoggingCompactionJobsWrapper, metrics::MetricsCompactionJobsSourceWrapper,
- not_empty::NotEmptyPartitionsSourceWrapper,
+ not_empty::NotEmptyCompactionJobsSourceWrapper,
  randomize_order::RandomizeOrderPartitionsSourcesWrapper,
  scheduled::ScheduledPartitionsSource, CompactionJobsSource,
  },
@@ -167,7 +167,7 @@ fn make_partitions_source_commit_partition_sink(
  // but just exit early
  Arc::new(partitions_source)
  } else {
- Arc::new(NotEmptyPartitionsSourceWrapper::new(
+ Arc::new(NotEmptyCompactionJobsSourceWrapper::new(
  partitions_source,
  Duration::from_secs(5),
  Arc::clone(&config.time_provider),

diff --git a/compactor/src/components/partitions_source/not_empty.rs b/compactor/src/components/partitions_source/not_empty.rs
@@ -7,7 +7,7 @@ use iox_time::TimeProvider;
 use super::CompactionJobsSource;
 
 #[derive(Debug)]
-pub struct NotEmptyPartitionsSourceWrapper<T>
+pub struct NotEmptyCompactionJobsSourceWrapper<T>
 where
  T: CompactionJobsSource,
 {
@@ -16,7 +16,7 @@ where
  time_provider: Arc<dyn TimeProvider>,
 }
 
-impl<T> NotEmptyPartitionsSourceWrapper<T>
+impl<T> NotEmptyCompactionJobsSourceWrapper<T>
 where
  T: CompactionJobsSource,
 {
@@ -29,7 +29,7 @@ where
  }
 }
 
-impl<T> Display for NotEmptyPartitionsSourceWrapper<T>
+impl<T> Display for NotEmptyCompactionJobsSourceWrapper<T>
 where
  T: CompactionJobsSource,
 {
@@ -39,7 +39,7 @@ where
 }
 
 #[async_trait]
-impl<T> CompactionJobsSource for NotEmptyPartitionsSourceWrapper<T>
+impl<T> CompactionJobsSource for NotEmptyCompactionJobsSourceWrapper<T>
 where
  T: CompactionJobsSource,
 {
@@ -64,7 +64,7 @@ mod tests {
 
  #[test]
  fn test_display() {
- let source = NotEmptyPartitionsSourceWrapper::new(
+ let source = NotEmptyCompactionJobsSourceWrapper::new(
  MockCompactionJobsSource::new(vec![]),
  Duration::from_secs(1),
  Arc::new(MockProvider::new(Time::MIN)),
@@ -76,7 +76,7 @@ mod tests {
  async fn test_fetch() {
  let inner = Arc::new(MockCompactionJobsSource::new(vec![]));
  let time_provider = Arc::new(MockProvider::new(Time::MIN));
- let source = NotEmptyPartitionsSourceWrapper::new(
+ let source = NotEmptyCompactionJobsSourceWrapper::new(
  Arc::clone(&inner),
  Duration::from_secs(1),
  Arc::clone(&time_provider) as _,