tsink 0.10.2

A lightweight embedded time-series database with a straightforward API
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
81
82
83
84
85

use super::*;

impl<'a> CatalogRefreshContext<'a> {
    pub(super) fn load_known_dirty_catalog_refresh_segments_phase(
        self,
        diff: &PendingPersistedSegmentDiff,
    ) -> Result<Vec<IndexedSegment>> {
        let mut loaded_segments = Vec::with_capacity(diff.added_roots.len());
        for root in &diff.added_roots {
            loaded_segments.push(ChunkStorage::load_segment_index_for_runtime_refresh(root)?);
        }
        Ok(loaded_segments)
    }

    pub(super) fn plan_loaded_inventory_catalog_refresh_phase(
        self,
        loaded: LoadedInventoryCatalogRefresh,
    ) -> Result<PlannedPersistedCatalogRefresh> {
        let current_roots = loaded.inventory.root_set();
        let added_roots = current_roots
            .difference(&loaded.visible_roots)
            .cloned()
            .collect::<Vec<_>>();
        let removed_roots = loaded
            .visible_roots
            .difference(&current_roots)
            .cloned()
            .collect::<Vec<_>>();

        let mut loaded_segments = Vec::with_capacity(added_roots.len());
        for root in &added_roots {
            loaded_segments.push(ChunkStorage::load_segment_index_for_runtime_refresh(root)?);
        }

        Ok(PlannedPersistedCatalogRefresh::Inventory(
            PlannedInventoryCatalogRefresh {
                visibility_fence: loaded.visibility_fence,
                inventory: loaded.inventory,
                loaded_segments,
                removed_roots,
                tombstones: loaded.tombstones,
            },
        ))
    }
}

impl ChunkStorage {
    pub(in super::super) fn plan_persisted_catalog_transition_phase(
        &self,
        planned: PlannedPersistedCatalogRefresh,
    ) -> Result<PersistedCatalogTransition> {
        match planned {
            PlannedPersistedCatalogRefresh::KnownDirty(planned) => {
                let added_roots = planned.diff.added_roots.into_iter().collect::<Vec<_>>();
                let removed_roots = planned.diff.removed_roots.into_iter().collect::<Vec<_>>();
                let registry_catalog_sources = self
                    .persisted_registry_catalog_sources_with_root_changes(
                        &added_roots,
                        &removed_roots,
                    )?;
                Ok(PersistedCatalogTransition {
                    visibility_fence: None,
                    loaded_segments: planned.loaded_segments,
                    removed_roots,
                    publication: PersistedCatalogPublication::PersistedState {
                        published_segment_roots: added_roots,
                    },
                    registry_catalog_sources: Some(registry_catalog_sources),
                })
            }
            PlannedPersistedCatalogRefresh::Inventory(planned) => Ok(PersistedCatalogTransition {
                visibility_fence: Some(planned.visibility_fence),
                loaded_segments: planned.loaded_segments,
                removed_roots: planned.removed_roots,
                publication: PersistedCatalogPublication::Inventory {
                    inventory: planned.inventory.clone(),
                    tombstones: Some(planned.tombstones),
                },
                registry_catalog_sources: Some(registry_catalog::inventory_sources(
                    &planned.inventory,
                )),
            }),
        }
    }
}