worker: &WorkerTask,
) -> Result<Vec<BackupDir>, Error>;
fn get_ns(&self) -> BackupNamespace;
- fn print_store_and_ns(&self) -> String;
+ fn get_store(&self) -> &str;
/// Returns a reader for reading data from a specific backup directory.
async fn reader(
self.ns.clone()
}
- fn print_store_and_ns(&self) -> String {
- print_store_and_ns(self.repo.store(), &self.ns)
+ fn get_store(&self) -> &str {
+ &self.repo.store()
}
async fn reader(
self.ns.clone()
}
- fn print_store_and_ns(&self) -> String {
- print_store_and_ns(self.store.name(), &self.ns)
+ fn get_store(&self) -> &str {
+ self.store.name()
}
async fn reader(
let mut synced_ns = HashSet::with_capacity(namespaces.len());
for namespace in namespaces {
- let source_store_ns_str = params.source.print_store_and_ns();
+ let source_store_ns_str = print_store_and_ns(params.source.get_store(), &namespace);
let target_ns = namespace.map_prefix(¶ms.source.get_ns(), ¶ms.target.ns)?;
let target_store_ns_str = print_store_and_ns(params.target.store.name(), &target_ns);