Skip to content

Commit

Permalink
refactor: rename mock time provider
Browse files Browse the repository at this point in the history
  • Loading branch information
evenyag committed Mar 14, 2024
1 parent 52c0e95 commit 2e10c00
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/mito2/src/engine/flush_test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -279,12 +279,12 @@ async fn test_flush_reopen_region() {
}

#[derive(Debug)]
struct FixedTimeProvider {
struct MockTimeProvider {
now: AtomicI64,
elapsed: AtomicI64,
}

impl TimeProvider for FixedTimeProvider {
impl TimeProvider for MockTimeProvider {
fn current_time_millis(&self) -> i64 {
self.now.load(Ordering::Relaxed)
}
Expand All @@ -298,7 +298,7 @@ impl TimeProvider for FixedTimeProvider {
}
}

impl FixedTimeProvider {
impl MockTimeProvider {
fn new(now: i64) -> Self {
Self {
now: AtomicI64::new(now),
Expand All @@ -321,7 +321,7 @@ async fn test_auto_flush_engine() {
let write_buffer_manager = Arc::new(MockWriteBufferManager::default());
let listener = Arc::new(FlushListener::default());
let now = current_time_millis();
let time_provider = Arc::new(FixedTimeProvider::new(now));
let time_provider = Arc::new(MockTimeProvider::new(now));
let engine = env
.create_engine_with_time(
MitoConfig {
Expand Down

0 comments on commit 2e10c00

Please sign in to comment.