(
backend: &RedbFtsBackend,
tid: u64,
collection: &str,
segment_id: &str,
data: &[u8],
)
| 11 | use crate::storage::quarantine::engines::validate_fts_segment_bytes; |
| 12 | |
| 13 | pub(super) fn write( |
| 14 | backend: &RedbFtsBackend, |
| 15 | tid: u64, |
| 16 | collection: &str, |
| 17 | segment_id: &str, |
| 18 | data: &[u8], |
| 19 | ) -> crate::Result<()> { |
| 20 | let write_txn = backend |
| 21 | .db |
| 22 | .begin_write() |
| 23 | .map_err(|e| redb_err("write txn", e))?; |
| 24 | { |
| 25 | let mut table = write_txn |
| 26 | .open_table(SEGMENTS) |
| 27 | .map_err(|e| redb_err("open segments", e))?; |
| 28 | table |
| 29 | .insert((tid, collection, segment_id), data) |
| 30 | .map_err(|e| redb_err("insert segment", e))?; |
| 31 | } |
| 32 | write_txn.commit().map_err(|e| redb_err("commit", e))?; |
| 33 | Ok(()) |
| 34 | } |
| 35 | |
| 36 | pub(super) fn read( |
| 37 | backend: &RedbFtsBackend, |
nothing calls this directly
no test coverage detected