diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-11 18:28:03 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-11 18:28:27 +0100 |
| commit | 046b649bcc3b147140fc2b0af0e071d3dd1b2c8d (patch) | |
| tree | f23ea651237ffce9f3aca3a2e7d32c9aab56b450 /src/table/data.rs | |
| parent | 94f3d287742ff90f179f528421c690b00b71a912 (diff) | |
| download | garage-046b649bcc3b147140fc2b0af0e071d3dd1b2c8d.tar.gz garage-046b649bcc3b147140fc2b0af0e071d3dd1b2c8d.zip | |
(not well tested) use merkle tree for sync
Diffstat (limited to 'src/table/data.rs')
| -rw-r--r-- | src/table/data.rs | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/src/table/data.rs b/src/table/data.rs index fa89fc27..6217bf6d 100644 --- a/src/table/data.rs +++ b/src/table/data.rs @@ -1,16 +1,16 @@ use std::sync::Arc; use log::warn; -use sled::Transactional; use serde_bytes::ByteBuf; +use sled::Transactional; +use garage_util::background::BackgroundRunner; use garage_util::data::*; use garage_util::error::*; -use garage_util::background::BackgroundRunner; -use crate::schema::*; -use crate::merkle::*; use crate::crdt::CRDT; +use crate::merkle::*; +use crate::schema::*; pub struct TableData<F: TableSchema> { pub name: String, @@ -20,7 +20,10 @@ pub struct TableData<F: TableSchema> { pub(crate) merkle_updater: Arc<MerkleUpdater>, } -impl<F> TableData<F> where F: TableSchema { +impl<F> TableData<F> +where + F: TableSchema, +{ pub fn new( name: String, instance: F, @@ -45,7 +48,7 @@ impl<F> TableData<F> where F: TableSchema { merkle_tree_store, ); - Arc::new(Self{ + Arc::new(Self { name, instance, store, |