aboutsummaryrefslogtreecommitdiff
path: root/src/model/index_counter.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-06-10 11:20:59 +0200
committerAlex Auvolat <alex@adnab.me>2022-06-10 11:20:59 +0200
commitbc29d77ed3865fcadfc8d99d029851f6d0f2dee1 (patch)
tree686305ca670daf14a03362344b52050049d986f2 /src/model/index_counter.rs
parentffe05c3c7d56af05f542ada65a385fecfc15c533 (diff)
downloadgarage-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.rs8
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();