diff --git a/pageserver/src/tenant.rs b/pageserver/src/tenant.rs index a674eba98f..1b287ee10f 100644 --- a/pageserver/src/tenant.rs +++ b/pageserver/src/tenant.rs @@ -46,7 +46,6 @@ use std::sync::{Mutex, RwLock}; use std::time::{Duration, Instant}; use self::config::TenantConf; -use self::delete::DeleteTimelineFlow; use self::metadata::LoadMetadataError; use self::metadata::TimelineMetadata; use self::remote_timeline_client::RemoteTimelineClient; @@ -70,6 +69,7 @@ use crate::tenant::storage_layer::ImageLayer; use crate::tenant::storage_layer::Layer; use crate::InitializationOrder; +use crate::tenant::timeline::delete::DeleteTimelineFlow; use crate::tenant::timeline::uninit::cleanup_timeline_directory; use crate::virtual_file::VirtualFile; use crate::walredo::PostgresRedoManager; @@ -117,7 +117,6 @@ mod remote_timeline_client; pub mod storage_layer; pub mod config; -pub mod delete; pub mod mgr; pub mod tasks; pub mod upload_queue; diff --git a/pageserver/src/tenant/mgr.rs b/pageserver/src/tenant/mgr.rs index aeecc88602..25c5e3f2e0 100644 --- a/pageserver/src/tenant/mgr.rs +++ b/pageserver/src/tenant/mgr.rs @@ -26,7 +26,7 @@ use crate::{InitializationOrder, IGNORED_TENANT_FILE_NAME}; use utils::fs_ext::PathExt; use utils::id::{TenantId, TimelineId}; -use super::delete::DeleteTimelineFlow; +use super::timeline::delete::DeleteTimelineFlow; /// The tenants known to the pageserver. /// The enum variants are used to distinguish the different states that the pageserver can be in. diff --git a/pageserver/src/tenant/timeline.rs b/pageserver/src/tenant/timeline.rs index 1002595909..4f9c0b08b8 100644 --- a/pageserver/src/tenant/timeline.rs +++ b/pageserver/src/tenant/timeline.rs @@ -1,3 +1,4 @@ +pub mod delete; mod eviction_task; pub mod layer_manager; mod logical_size; @@ -79,6 +80,7 @@ use crate::METADATA_FILE_NAME; use crate::ZERO_PAGE; use crate::{is_temporary, task_mgr}; +use self::delete::DeleteTimelineFlow; pub(super) use self::eviction_task::EvictionTaskTenantState; use self::eviction_task::EvictionTaskTimelineState; use self::layer_manager::LayerManager; @@ -86,7 +88,6 @@ use self::logical_size::LogicalSize; use self::walreceiver::{WalReceiver, WalReceiverConf}; use super::config::TenantConf; -use super::delete::DeleteTimelineFlow; use super::remote_timeline_client::index::IndexPart; use super::remote_timeline_client::RemoteTimelineClient; use super::storage_layer::{ diff --git a/pageserver/src/tenant/delete.rs b/pageserver/src/tenant/timeline/delete.rs similarity index 98% rename from pageserver/src/tenant/delete.rs rename to pageserver/src/tenant/timeline/delete.rs index eeaaf15c32..d99ca2d292 100644 --- a/pageserver/src/tenant/delete.rs +++ b/pageserver/src/tenant/timeline/delete.rs @@ -15,15 +15,17 @@ use utils::{ use crate::{ config::PageServerConf, task_mgr::{self, TaskKind}, - tenant::{remote_timeline_client, DeleteTimelineError}, + tenant::{ + metadata::TimelineMetadata, + remote_timeline_client::{ + self, PersistIndexPartWithDeletedFlagError, RemoteTimelineClient, + }, + CreateTimelineCause, DeleteTimelineError, Tenant, + }, InitializationOrder, }; -use super::{ - metadata::TimelineMetadata, - remote_timeline_client::{PersistIndexPartWithDeletedFlagError, RemoteTimelineClient}, - CreateTimelineCause, Tenant, Timeline, -}; +use super::Timeline; /// Now that the Timeline is in Stopping state, request all the related tasks to shut down. async fn stop_tasks(timeline: &Timeline) -> Result<(), DeleteTimelineError> {