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

use super::*;

impl<'a> CatalogContext<'a> {
    fn metadata_series_ids_for_scope(
        self,
        scope: &crate::storage::MetadataShardScope,
    ) -> MetadataScopeSeriesLookup {
        if scope.shards.is_empty() {
            return MetadataScopeSeriesLookup::Indexed(Vec::new());
        }

        let Some(index) = self.metadata_shard_index else {
            return MetadataScopeSeriesLookup::Unavailable(
                MetadataScopeSeriesLookupUnavailable::Disabled,
            );
        };
        if scope.shard_count != index.shard_count {
            return MetadataScopeSeriesLookup::Unavailable(
                MetadataScopeSeriesLookupUnavailable::ShardGeometryMismatch {
                    indexed_shard_count: index.shard_count,
                    requested_shard_count: scope.shard_count,
                },
            );
        }

        let shard_buckets = index.series_ids_by_shard.read();
        let mut series_ids = Vec::new();
        for shard in &scope.shards {
            let Some(bucket) = shard_buckets.get(*shard as usize) else {
                return MetadataScopeSeriesLookup::Unavailable(
                    MetadataScopeSeriesLookupUnavailable::Stale,
                );
            };
            series_ids.extend(bucket.iter().copied());
        }
        series_ids.sort_unstable();
        series_ids.dedup();
        MetadataScopeSeriesLookup::Indexed(series_ids)
    }
}

impl ChunkStorage {
    pub(super) fn metadata_series_ids_for_scope(
        &self,
        scope: &crate::storage::MetadataShardScope,
    ) -> MetadataScopeSeriesLookup {
        self.catalog_context().metadata_series_ids_for_scope(scope)
    }

    pub(super) fn bounded_metadata_series_ids_for_scope(
        &self,
        scope: &crate::storage::MetadataShardScope,
        operation: &'static str,
    ) -> Result<Vec<SeriesId>> {
        match self.metadata_series_ids_for_scope(scope) {
            MetadataScopeSeriesLookup::Indexed(series_ids) => Ok(series_ids),
            MetadataScopeSeriesLookup::Unavailable(reason) => {
                Err(reason.unsupported_operation(operation))
            }
        }
    }
}