kevy_embedded/
ops_index_admin.rs

1//! The read-only index admin surface (stats and enumeration). A
2//! `#[path]` child of `ops_index.rs`, split under the 500-LOC rule.
3
4use kevy_index::{IndexKind, IndexSpec};
5
6use crate::KevyResult;
7use crate::ops_index::SegmentStats;
8use crate::store::Store;
9
10impl Store {
11    /// Summed segment stats (entries / bytes / coerce failures /
12    /// unique-fence duplicates).
13    pub fn idx_stats(&self, name: &[u8]) -> KevyResult<SegmentStats> {
14        let mut sum = SegmentStats::default();
15        self.for_each_segment(name, |seg| {
16            let s = seg.stats();
17            sum.entries += s.entries;
18            sum.approx_bytes += s.approx_bytes;
19            sum.coerce_failures += s.coerce_failures;
20            sum.duplicates += s.duplicates;
21        })?;
22        Ok(sum)
23    }
24
25    /// Declared indexes (name, prefix, kind), declaration order.
26    pub fn idx_list(&self) -> Vec<(Vec<u8>, Vec<u8>, IndexKind)> {
27        let g = self.indexes.catalog.read().unwrap_or_else(std::sync::PoisonError::into_inner);
28        g.1.iter().map(|(s, _)| (s.name().to_vec(), s.prefix().to_vec(), s.kind())).collect()
29    }
30
31    /// The declaration of the index named `name`, as the catalog holds it.
32    pub fn idx_spec(&self, name: &[u8]) -> Option<IndexSpec> {
33        let g = self.indexes.catalog.read().unwrap_or_else(std::sync::PoisonError::into_inner);
34        g.1.get(name).map(|(s, _)| s.clone())
35    }
36}
kevy_embedded/ops_index_admin.rs

kevy_embedded/
ops_index_admin.rs
