Rename main_store into common_store

This commit is contained in:
Clément Renault 2019-10-10 15:14:32 +02:00
parent c5af5de4f0
commit e09d3b654d
No known key found for this signature in database
GPG Key ID: 92ADA4E935E71FA4

View File

@ -13,7 +13,7 @@ type ArcSwapFn = arc_swap::ArcSwapOption<BoxUpdateFn>;
pub struct Database { pub struct Database {
pub rkv: Arc<RwLock<rkv::Rkv>>, pub rkv: Arc<RwLock<rkv::Rkv>>,
main_store: rkv::SingleStore, common_store: rkv::SingleStore,
indexes_store: rkv::SingleStore, indexes_store: rkv::SingleStore,
indexes: RwLock<HashMap<String, (Index, Arc<ArcSwapFn>, thread::JoinHandle<()>)>>, indexes: RwLock<HashMap<String, (Index, Arc<ArcSwapFn>, thread::JoinHandle<()>)>>,
} }
@ -72,7 +72,7 @@ impl Database {
let rkv_read = rkv.read().unwrap(); let rkv_read = rkv.read().unwrap();
let create_options = rkv::store::Options::create(); let create_options = rkv::store::Options::create();
let main_store = rkv_read.open_single("main", create_options)?; let common_store = rkv_read.open_single("common", create_options)?;
let indexes_store = rkv_read.open_single("indexes", create_options)?; let indexes_store = rkv_read.open_single("indexes", create_options)?;
// list all indexes that needs to be opened // list all indexes that needs to be opened
@ -113,7 +113,7 @@ impl Database {
drop(rkv_read); drop(rkv_read);
Ok(Database { rkv, main_store, indexes_store, indexes: RwLock::new(indexes) }) Ok(Database { rkv, common_store, indexes_store, indexes: RwLock::new(indexes) })
} }
pub fn open_index(&self, name: impl AsRef<str>) -> Option<Index> { pub fn open_index(&self, name: impl AsRef<str>) -> Option<Index> {
@ -182,7 +182,7 @@ impl Database {
Ok(indexes.keys().cloned().collect()) Ok(indexes.keys().cloned().collect())
} }
pub fn main_store(&self) -> rkv::SingleStore { pub fn common_store(&self) -> rkv::SingleStore {
self.main_store self.common_store
} }
} }