Method
load_data
(
env: &lmdb::Environment,
db: lmdb::Database,
collection_name: &str,
)
Source from the content-addressed store, hash-verified
| 176 | } |
| 177 | |
| 178 | fn load_data( |
| 179 | env: &lmdb::Environment, |
| 180 | db: lmdb::Database, |
| 181 | collection_name: &str, |
| 182 | ) -> Result<Option<Self::Data>, WaCustomError> { |
| 183 | let txn = env.begin_ro_txn()?; |
| 184 | let key = Self::get_key_for_name(collection_name).to_le_bytes(); |
| 185 | let data_bytes = match txn.get(db, &key) { |
| 186 | Ok(bytes) => Ok(bytes), |
| 187 | Err(lmdb::Error::NotFound) => return Ok(None), |
| 188 | Err(err) => Err(err), |
| 189 | }?; |
| 190 | let data = serde_cbor::from_slice(data_bytes) |
| 191 | .map_err(|e| WaCustomError::DeserializationError(e.to_string()))?; |
| 192 | |
| 193 | Ok(data) |
| 194 | } |
| 195 | |
| 196 | fn delete( |
| 197 | env: &lmdb::Environment, |
Callers
nothing calls this directly
Implementers 5
mod.rssrc/indexes/inverted/mod.rs mod.rssrc/indexes/tf_idf/mod.rs
Tested by
no test coverage detected