diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-19 20:52:20 +0000 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-19 20:52:20 +0000 |
| commit | 04acaea231a9af77e5ca05068336f4492fe32ac0 (patch) | |
| tree | 412a346fed1a24b861a90c9a3e527e46f050ffa0 /src/bucket_table.rs | |
| parent | 5ae32972efaba357ecc0027fe852d710b16b6d0e (diff) | |
| download | garage-04acaea231a9af77e5ca05068336f4492fe32ac0.tar.gz garage-04acaea231a9af77e5ca05068336f4492fe32ac0.zip | |
Don't do version & block_ref updates in background on deletion
Diffstat (limited to 'src/bucket_table.rs')
| -rw-r--r-- | src/bucket_table.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/bucket_table.rs b/src/bucket_table.rs index be7dd348..5604049c 100644 --- a/src/bucket_table.rs +++ b/src/bucket_table.rs @@ -1,6 +1,7 @@ use async_trait::async_trait; use serde::{Deserialize, Serialize}; +use crate::error::Error; use crate::table::*; #[derive(PartialEq, Clone, Debug, Serialize, Deserialize)] @@ -71,7 +72,9 @@ impl TableSchema for BucketTable { type E = Bucket; type Filter = (); - async fn updated(&self, _old: Option<Self::E>, _new: Option<Self::E>) {} + async fn updated(&self, _old: Option<Self::E>, _new: Option<Self::E>) -> Result<(), Error> { + Ok(()) + } fn matches_filter(entry: &Self::E, _filter: &Self::Filter) -> bool { !entry.deleted |