relay-knowledge 1.1.10

Graph-database-based knowledge graph project.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! Index refresh planning for derived read models.
//!
//! This module owns index-family selection rules. Concrete index writers remain
//! outside the domain model and update only derived metadata/read models.

use crate::domain::IndexKind;

/// Deduplicated index refresh plan.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct IndexRefreshPlan {
    kinds: Vec<IndexKind>,
}

impl IndexRefreshPlan {
    /// Builds a refresh plan. An empty request means all v1 index families.
    pub fn from_requested(kinds: Vec<IndexKind>) -> Self {
        if kinds.is_empty() {
            return Self {
                kinds: IndexKind::ALL.to_vec(),
            };
        }

        let mut deduped = Vec::new();
        for kind in kinds {
            if !deduped.contains(&kind) {
                deduped.push(kind);
            }
        }

        Self { kinds: deduped }
    }

    /// Consumes the plan into index kinds in refresh order.
    pub fn into_kinds(self) -> Vec<IndexKind> {
        self.kinds
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn empty_request_refreshes_all_index_families() {
        let plan = IndexRefreshPlan::from_requested(Vec::new());

        assert_eq!(plan.into_kinds(), IndexKind::ALL);
    }

    #[test]
    fn duplicate_index_kinds_are_removed_in_order() {
        let plan = IndexRefreshPlan::from_requested(vec![
            IndexKind::Vector,
            IndexKind::Vector,
            IndexKind::Bm25,
        ]);

        assert_eq!(plan.into_kinds(), [IndexKind::Vector, IndexKind::Bm25]);
    }
}