Struct MemoryBackend 

pub struct MemoryBackend { /* private fields */ }

In-memory FTS backend backed by HashMaps keyed by (database_id, tid, collection, field, …) tuples.

Uses RefCell for interior mutability so the FtsBackend trait can use &self uniformly (redb has its own transactional isolation).

Implementations

impl MemoryBackend

pub fn new() -> MemoryBackend

Trait Implementations

impl Debug for MemoryBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for MemoryBackend

fn default() -> MemoryBackend

Returns the “default value” for a type.

impl FtsBackend for MemoryBackend

type Error = MemoryError

Error type for backend operations.

fn read_postings( &self, database_id: u64, tid: u64, index: IndexScope<'_>, term: &str, ) -> Result<Vec<Posting>, <MemoryBackend as FtsBackend>::Error>

Read the posting list for a term in an index: one posting per document.

fn write_postings( &self, database_id: u64, tid: u64, index: IndexScope<'_>, term: &str, postings: &[Posting], ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Write/replace the posting list for a term in an index.

fn upsert_posting( &self, database_id: u64, tid: u64, index: IndexScope<'_>, term: &str, posting: &Posting, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Insert one document’s posting into a term’s list, replacing that document’s prior posting in the list.

fn remove_posting( &self, database_id: u64, tid: u64, index: IndexScope<'_>, term: &str, doc_id: Surrogate, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Remove one document’s posting from a term’s list. The list is removed when this empties it. A document absent from the list is a no-op.

fn remove_postings( &self, database_id: u64, tid: u64, index: IndexScope<'_>, term: &str, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Remove a term’s posting list entirely.

fn read_doc_length( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_id: Surrogate, ) -> Result<Option<u32>, <MemoryBackend as FtsBackend>::Error>

Read the document length (token count) of a document in an index.

fn write_doc_length( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_id: Surrogate, length: u32, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Write/replace the document length of a document in an index.

fn remove_doc_length( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_id: Surrogate, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Remove a document’s length entry from an index.

fn collection_terms( &self, database_id: u64, tid: u64, index: IndexScope<'_>, ) -> Result<Vec<String>, <MemoryBackend as FtsBackend>::Error>

Get all term names in an index (for fuzzy matching).

fn collection_stats( &self, database_id: u64, tid: u64, index: IndexScope<'_>, ) -> Result<(u32, u64), <MemoryBackend as FtsBackend>::Error>

Get total document count and sum of all document lengths of an index. Returns (doc_count, total_token_sum).

fn increment_stats( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_len: u32, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Increment index stats after indexing a document. doc_len is the number of tokens in the newly indexed document.

fn decrement_stats( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_len: u32, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Decrement index stats after removing a document. doc_len is the token count of the removed document.

fn read_meta( &self, database_id: u64, tid: u64, index: IndexScope<'_>, subkey: &str, ) -> Result<Option<Vec<u8>>, <MemoryBackend as FtsBackend>::Error>

Read a metadata blob by sub-key (e.g., “docmap”, “fieldnorms”, “analyzer”, “language”).

fn write_meta( &self, database_id: u64, tid: u64, index: IndexScope<'_>, subkey: &str, value: &[u8], ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Write a metadata blob by sub-key.

fn write_segment( &self, database_id: u64, tid: u64, index: IndexScope<'_>, segment_id: &str, data: &[u8], ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Write a segment blob. segment_id is a stable per-index identifier (e.g., "L{level}:{id:016x}").

fn read_segment( &self, database_id: u64, tid: u64, index: IndexScope<'_>, segment_id: &str, ) -> Result<Option<Vec<u8>>, <MemoryBackend as FtsBackend>::Error>

Read a segment blob. Returns None if not found.

fn list_segments( &self, database_id: u64, tid: u64, index: IndexScope<'_>, ) -> Result<Vec<String>, <MemoryBackend as FtsBackend>::Error>

List all segment ids of an index.

fn remove_segment( &self, database_id: u64, tid: u64, index: IndexScope<'_>, segment_id: &str, ) -> Result<(), <MemoryBackend as FtsBackend>::Error>

Remove a segment blob.

fn purge_collection( &self, database_id: u64, tid: u64, collection: &str, ) -> Result<usize, <MemoryBackend as FtsBackend>::Error>

Remove all entries of every index of a collection. Returns count of removed entries.

fn purge_tenant( &self, database_id: u64, tid: u64, ) -> Result<usize, <MemoryBackend as FtsBackend>::Error>

Remove all entries for a (database_id, tid) across every collection. Returns count of removed entries. Implementations MUST use a structural drop (e.g., tuple range (db, tid, ..)..(db, tid+1, ..)) rather than a lexical-prefix scan.

fn read_doc_lengths( &self, database_id: u64, tid: u64, index: IndexScope<'_>, doc_ids: &[Surrogate], ) -> Result<Vec<Option<u32>>, Self::Error>

Read the document lengths of doc_ids in an index, parallel to doc_ids. A backend with transactions reads them in one.