(&self)
| 632 | } |
| 633 | |
| 634 | pub fn flush(&self) -> Result<(), WaCustomError> { |
| 635 | self.internal_to_external_map.serialize()?; |
| 636 | self.external_to_internal_map.serialize()?; |
| 637 | self.document_to_internals_map.serialize()?; |
| 638 | self.transaction_status_map.serialize()?; |
| 639 | store_highest_internal_id(&self.lmdb, self.internal_id_counter.load(Ordering::Relaxed))?; |
| 640 | Ok(()) |
| 641 | } |
| 642 | |
| 643 | pub fn indexing_status(&self) -> Result<CollectionIndexingStatus, WaCustomError> { |
| 644 | let mut active_transactions = Vec::new(); |
nothing calls this directly
no test coverage detected