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()),
            querier: cluster.querier.as_ref().map(|c| c.weak()),
            compactor: cluster.compactor.as_ref().map(|c| c.weak()),
        }
    }
/// Save the server processes in this shared servers as weak references
Save the server processes in this shared servers as weak references
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()),
            querier: cluster.querier.as_ref().map(|c| c.weak()),
            compactor: cluster.compactor.as_ref().map(|c| c.weak()),
        }
    }
pub fn new ( cluster : & MiniCluster ) -> Self { assert ! ( cluster other_servers is_empty ( ) " " ) ; Self { router : cluster . router . as_ref ( ) . map ( | c | c . weak ( ) ) , ingester : cluster . ingester . as_ref ( ) . map ( | c | c . weak ( ) ) , querier : cluster . querier . as_ref ( ) . map ( | c | c . weak ( ) ) , compactor : cluster . compactor . as_ref ( ) . map ( | c | c . weak ( ) ) , } }
Save the server processes in this shared servers as weak references
Save the server processes in this shared servers as weak references
cluster
&MiniCluster
cluster
&MiniCluster