fix: Remove unused "other server" minicluster code

pull/24376/head
Carol (Nichols || Goulding) 2023-02-08 10:35:10 -05:00
parent 1794147b3c
commit fcb7f4c61d
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 0 additions and 19 deletions

View File

@ -45,9 +45,6 @@ pub struct MiniCluster {
/// Standard optional compactor configuration, to be used on-demand
compactor_config: Option<TestConfig>,
/// Optional additional `ServerFixture`s that can be used for specific tests
other_servers: Vec<ServerFixture>,
// Potentially helpful data
org_id: String,
bucket_id: String,
@ -89,7 +86,6 @@ impl MiniCluster {
ingester,
querier,
compactor_config,
other_servers: vec![],
org_id,
bucket_id,
@ -254,12 +250,6 @@ impl MiniCluster {
self
}
/// create another server compactor with the specified configuration;
pub async fn with_other(mut self, config: TestConfig) -> Self {
self.other_servers.push(ServerFixture::create(config).await);
self
}
/// Retrieve the underlying router server, if set
pub fn router(&self) -> &ServerFixture {
self.router.as_ref().expect("router not initialized")
@ -425,11 +415,6 @@ impl MiniCluster {
.unwrap();
}
/// Get a reference to the mini cluster's other servers.
pub fn other_servers(&self) -> &[ServerFixture] {
self.other_servers.as_ref()
}
pub fn run_compaction(&self) {
let (log_file, log_path) = NamedTempFile::new()
.expect("opening log file")
@ -556,10 +541,6 @@ impl CreatableMiniCluster {
impl SharedServers {
/// Save the server processes in this shared servers as weak references
pub fn new(cluster: &MiniCluster) -> Self {
assert!(
cluster.other_servers.is_empty(),
"other servers not yet handled in shared mini clusters"
);
Self {
router: cluster.router.as_ref().map(|c| c.weak()),
ingester: cluster.ingester.as_ref().map(|c| c.weak()),