exocore-store 0.1.10

Store / indexation layer of Exocore (Distributed applications framework)
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

use exocore_protos::generated::exocore_core::MutationIndexConfig as ProtoMutationIndexConfig;
/// Trait index configuration
#[derive(Clone, Copy, Debug)]
pub struct MutationIndexConfig {
    /// Number of indexing threads.
    pub indexer_num_threads: Option<usize>,

    /// Maximum heap size of each indexing thread.
    pub indexer_heap_size_bytes: usize,

    /// Page size of results iterator.
    pub iterator_page_size: u32,

    /// Maximum number of pages returned by results iterator.
    pub iterator_max_pages: usize,

    /// Size of the entity mutations cache in bytes.
    pub entity_mutations_cache_size: usize,

    pub dynamic_reference_fields: u32,
    pub dynamic_string_fields: u32,
    pub dynamic_text_fields: u32,
    pub dynamic_i64_fields: u32,
    pub dynamic_i64_sortable_fields: u32,
    pub dynamic_u64_fields: u32,
    pub dynamic_u64_sortable_fields: u32,
}

impl Default for MutationIndexConfig {
    fn default() -> Self {
        MutationIndexConfig {
            indexer_num_threads: Some(2),
            indexer_heap_size_bytes: 30_000_000,
            iterator_page_size: 200,
            iterator_max_pages: 10,
            entity_mutations_cache_size: 5000,

            dynamic_reference_fields: 5,
            dynamic_string_fields: 5,
            dynamic_text_fields: 5,
            dynamic_i64_fields: 2,
            dynamic_i64_sortable_fields: 2,
            dynamic_u64_fields: 2,
            dynamic_u64_sortable_fields: 2,
        }
    }
}

impl From<ProtoMutationIndexConfig> for MutationIndexConfig {
    fn from(proto: ProtoMutationIndexConfig) -> Self {
        let mut config = MutationIndexConfig::default();

        if let Some(v) = proto.indexer_num_threads {
            config.indexer_num_threads = Some(v as usize);
        }

        if let Some(v) = proto.indexer_heap_size_bytes {
            config.indexer_heap_size_bytes = v as usize;
        }

        if let Some(v) = proto.entity_mutations_cache_size {
            config.entity_mutations_cache_size = v as usize;
        }

        config
    }
}