diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-28 17:42:54 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-28 17:42:54 +0200 |
| commit | 368414a261345088b30c57e87ee29a29026672a8 (patch) | |
| tree | ae35c07697ccfa2a60e417a5cc31a60424d4c298 /src/garage | |
| parent | fc2bc8b0cac3c407ea0aa4bb004ea8c0a15a9120 (diff) | |
| download | garage-368414a261345088b30c57e87ee29a29026672a8.tar.gz garage-368414a261345088b30c57e87ee29a29026672a8.zip | |
Small things
Diffstat (limited to 'src/garage')
| -rw-r--r-- | src/garage/repair/online.rs | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/garage/repair/online.rs b/src/garage/repair/online.rs index d4366486..f0d4b847 100644 --- a/src/garage/repair/online.rs +++ b/src/garage/repair/online.rs @@ -85,6 +85,10 @@ impl Worker for RepairVersionsWorker { "Version repair worker".into() } + fn info(&self) -> Option<String> { + Some(format!("{} items done", self.counter)) + } + async fn work( &mut self, _must_exit: &mut watch::Receiver<bool>, @@ -165,6 +169,10 @@ impl Worker for RepairBlockrefsWorker { "Block refs repair worker".into() } + fn info(&self) -> Option<String> { + Some(format!("{} items done", self.counter)) + } + async fn work( &mut self, _must_exit: &mut watch::Receiver<bool>, |