relay-knowledge 1.1.17

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

//! Fixed resource ceilings for repository-set membership and overlay refresh.

use rusqlite::{Connection, params};

use crate::storage::StorageError;

pub(in crate::storage::sqlite::code) const MAX_REPOSITORY_SET_MEMBERS: usize = 64;
pub(super) const MAX_REPOSITORY_SET_OVERLAY_EXPORTS: usize = 131_072;
pub(super) const MAX_REPOSITORY_SET_OVERLAY_IMPORT_SCAN_ROWS: usize =
    MAX_REPOSITORY_SET_OVERLAY_EXPORTS * 2;
pub(super) const REPOSITORY_SET_OVERLAY_IMPORT_PAGE_ROWS: usize = 512;
pub(in crate::storage::sqlite::code) const MAX_REPOSITORY_SET_OVERLAY_EDGES: usize = 8_192;
pub(super) const MAX_REPOSITORY_SET_MANIFEST_CHUNKS: usize = 4_096;
pub(super) const MAX_REPOSITORY_SET_MANIFEST_BYTES: usize = 16 * 1024 * 1024;
pub(super) const MAX_REPOSITORY_SET_MANIFEST_ITEMS: usize = 32_768;
pub(super) const MAX_MATCHING_EXPORTS_PER_IMPORT: usize = 11;
pub(super) const MAX_OVERLAY_EDGE_SELECTOR_KEYS: usize = 512;

pub(in crate::storage::sqlite::code) fn ensure_overlay_delete_is_bounded(
    connection: &Connection,
    set_id: &str,
) -> Result<(), StorageError> {
    let observed = connection.query_row(
        "SELECT COUNT(*) FROM (
             SELECT 1 FROM code_repository_cross_edges
             WHERE set_id = ?1
             LIMIT ?2
         )",
        params![set_id, MAX_REPOSITORY_SET_OVERLAY_EDGES + 1],
        |row| row.get::<_, usize>(0),
    )?;
    if observed > MAX_REPOSITORY_SET_OVERLAY_EDGES {
        return Err(StorageError::CapacityExceeded(format!(
            "repository-set overlay '{set_id}' exceeds the bounded delete capacity of \
             {MAX_REPOSITORY_SET_OVERLAY_EDGES} edges; this legacy state requires an upgrade or \
             bounded repair tool before refresh or membership changes can continue"
        )));
    }
    Ok(())
}

pub(super) fn capacity_error(kind: &str, capacity: usize) -> StorageError {
    StorageError::CapacityExceeded(format!(
        "repository-set overlay exceeds the {kind} capacity of {capacity}; narrow the set or \
         indexed scopes before retrying"
    ))
}

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