|
|
|
@ -31,6 +31,7 @@ use rocksdb_options::{Options, WriteOptions}; |
|
|
|
|
pub struct DB { |
|
|
|
|
inner: rocksdb_ffi::DBInstance, |
|
|
|
|
cfs: BTreeMap<String, DBCFHandle>, |
|
|
|
|
path: String, |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
unsafe impl Send for DB {} |
|
|
|
@ -375,6 +376,7 @@ impl DB { |
|
|
|
|
Ok(DB { |
|
|
|
|
inner: db, |
|
|
|
|
cfs: cf_map, |
|
|
|
|
path: path.to_owned(), |
|
|
|
|
}) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -412,6 +414,10 @@ impl DB { |
|
|
|
|
Ok(()) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
pub fn path(&self) -> &str { |
|
|
|
|
&self.path |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
pub fn write_opt(&self, |
|
|
|
|
batch: WriteBatch, |
|
|
|
|
writeopts: &WriteOptions) |
|
|
|
|