diff options
author | Alex Auvolat <alex@adnab.me> | 2022-06-10 11:20:59 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-06-10 11:20:59 +0200 |
commit | bc29d77ed3865fcadfc8d99d029851f6d0f2dee1 (patch) | |
tree | 686305ca670daf14a03362344b52050049d986f2 /src/model/index_counter.rs | |
parent | ffe05c3c7d56af05f542ada65a385fecfc15c533 (diff) | |
download | garage-bc29d77ed3865fcadfc8d99d029851f6d0f2dee1.tar.gz garage-bc29d77ed3865fcadfc8d99d029851f6d0f2dee1.zip |
Change object counter table to use full replication
Diffstat (limited to 'src/model/index_counter.rs')
-rw-r--r-- | src/model/index_counter.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/model/index_counter.rs b/src/model/index_counter.rs index 36e8172b..a8837e0f 100644 --- a/src/model/index_counter.rs +++ b/src/model/index_counter.rs @@ -138,17 +138,17 @@ impl<T: CountedItem> TableSchema for CounterTable<T> { // ---- -pub struct IndexCounter<T: CountedItem> { +pub struct IndexCounter<T: CountedItem, R: TableReplication + 'static> { this_node: Uuid, local_counter: db::Tree, propagate_tx: mpsc::UnboundedSender<(T::CP, T::CS, LocalCounterEntry<T>)>, - pub table: Arc<Table<CounterTable<T>, TableShardedReplication>>, + pub table: Arc<Table<CounterTable<T>, R>>, } -impl<T: CountedItem> IndexCounter<T> { +impl<T: CountedItem, R: TableReplication + 'static> IndexCounter<T, R> { pub fn new( system: Arc<System>, - replication: TableShardedReplication, + replication: R, db: &db::Db, ) -> Arc<Self> { let background = system.background.clone(); |