(&self, path: &str, chunk_idx: u32)
| 1159 | |
| 1160 | impl EmbeddingsTxnT for ReadTxn { |
| 1161 | fn get_embedding(&self, path: &str, chunk_idx: u32) -> PristineResult<Option<EmbeddingRecord>> { |
| 1162 | let table = match self.txn.open_table(EMBEDDINGS) { |
| 1163 | Ok(table) => table, |
| 1164 | Err(redb::TableError::TableDoesNotExist(_)) => return Ok(None), |
| 1165 | Err(e) => return Err(PristineError::from(e)), |
| 1166 | }; |
| 1167 | |
| 1168 | let key = encode_embedding_key(path, chunk_idx); |
| 1169 | let result = match table.get(key.as_str())? { |
| 1170 | Some(guard) => { |
| 1171 | let bytes = guard.value(); |
| 1172 | let record: EmbeddingRecord = |
| 1173 | postcard::from_bytes(bytes).map_err(|e| PristineError::Serialization { |
| 1174 | message: format!( |
| 1175 | "failed to deserialize EmbeddingRecord at '{}': {}", |
| 1176 | key, e |
| 1177 | ), |
| 1178 | })?; |
| 1179 | Ok(Some(record)) |
| 1180 | } |
| 1181 | None => Ok(None), |
| 1182 | }; |
| 1183 | result |
| 1184 | } |
| 1185 | |
| 1186 | fn list_embeddings(&self, path: &str) -> PristineResult<Vec<(u32, EmbeddingRecord)>> { |
| 1187 | let table = match self.txn.open_table(EMBEDDINGS) { |
no test coverage detected