Method list_embeddings

atomic-core/src/pristine/txn/read.rs:1186–1223

(&self, path: &str)

    }

    fn list_embeddings(&self, path: &str) -> PristineResult<Vec<(u32, EmbeddingRecord)>> {
        let table = match self.txn.open_table(EMBEDDINGS) {
            Ok(table) => table,
            Err(redb::TableError::TableDoesNotExist(_)) => return Ok(Vec::new()),
            Err(e) => return Err(PristineError::from(e)),
        };

        let mut results = Vec::new();
        let prefix = format!("{}\0", path);

        let iter = table.range::<&str>(prefix.as_str()..)?;

        for item in iter {
            let (key_guard, value_guard) = item?;
            let key_str = key_guard.value();

            if !key_str.starts_with(&prefix) {
                break;
            }

            let (_, chunk_idx) = match decode_embedding_key(key_str) {
                Some(decoded) => decoded,
                None => continue,
            };

            let bytes = value_guard.value();
            let record: EmbeddingRecord =
                postcard::from_bytes(bytes).map_err(|e| PristineError::Serialization {
                    message: format!(
                        "failed to deserialize EmbeddingRecord at '{}': {}",
                        key_str, e
                    ),
                })?;
            results.push((chunk_idx, record));
        }

        Ok(results)
    }

    fn count_embeddings(&self) -> PristineResult<usize> {
        let table = match self.txn.open_table(EMBEDDINGS) {