selene-db-graph 1.3.0

In-memory property-graph storage core (ArcSwap + imbl CoW, label/typed indexes, write funnel) for selene-db.
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! Text-index mutation methods for the transaction mutator.

use selene_core::{Change, DbString, SchemaChange};

use crate::graph::TextIndexEntry;
use crate::{GraphError, GraphResult, Mutator, TextIndex};

impl<'tx, 'g> Mutator<'tx, 'g> {
    /// Register a durable node text index in the active write transaction.
    ///
    /// # Errors
    ///
    /// Returns [`GraphError::TextIndexAlreadyExists`] if the pair already
    /// exists, or [`GraphError::Inconsistent`] if index construction observes
    /// corrupt graph columns.
    pub fn create_text_index(&mut self, label: DbString, property: DbString) -> GraphResult<()> {
        self.create_text_index_named(label, property, None)
    }

    /// Register a durable node text index with optional catalog name.
    pub fn create_text_index_named(
        &mut self,
        label: DbString,
        property: DbString,
        name: Option<DbString>,
    ) -> GraphResult<()> {
        if self
            .txn
            .read()
            .text_index
            .contains_key(&(label.clone(), property.clone()))
        {
            return Err(GraphError::TextIndexAlreadyExists { label, property });
        }
        let index = TextIndex::build(self.txn.read(), label.clone(), property.clone())?;
        let graph_id = self.txn.read().graph_id();
        self.txn.guard_mut().text_index.insert(
            (label.clone(), property.clone()),
            TextIndexEntry::new(index, name.clone()),
        );
        self.txn.changes.push(Change::SchemaChanged {
            graph: graph_id,
            change: SchemaChange::TextIndexCreated {
                label,
                property,
                name,
            },
        });
        Ok(())
    }

    /// Drop a durable node text index from the active write transaction.
    ///
    /// The operation is idempotent. Dropping an absent index succeeds and emits
    /// no WAL change.
    pub fn drop_text_index(&mut self, label: DbString, property: DbString) -> GraphResult<()> {
        if !self
            .txn
            .read()
            .text_index
            .contains_key(&(label.clone(), property.clone()))
        {
            return Ok(());
        }
        let graph_id = self.txn.read().graph_id();
        self.txn
            .guard_mut()
            .text_index
            .remove(&(label.clone(), property.clone()));
        self.txn.changes.push(Change::SchemaChanged {
            graph: graph_id,
            change: SchemaChange::TextIndexDropped { label, property },
        });
        Ok(())
    }
}

#[cfg(test)]
#[path = "text_index/tests.rs"]
mod tests;