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

#[path = "budget_enforcement/context.rs"]
mod context;

use super::super::*;

impl ChunkStorage {
    pub(in super::super) fn evict_persisted_sealed_chunks(&self) -> usize {
        self.budget_enforcement_context()
            .evict_persisted_sealed_chunks()
    }

    pub(in super::super) fn enforce_memory_budget_if_needed(&self) -> Result<()> {
        let budget_enforcement = self.budget_enforcement_context();
        let budget = budget_enforcement.budget_value();
        if budget == usize::MAX || budget_enforcement.used_value() <= budget {
            return Ok(());
        }

        if !budget_enforcement.can_reclaim_persisted_memory() {
            return Ok(());
        }

        let _backpressure_guard = budget_enforcement.lock_backpressure();
        if budget_enforcement.used_value() <= budget {
            return Ok(());
        }

        self.enforce_memory_budget_locked(budget)
    }

    fn enforce_memory_budget_locked(&self, budget: usize) -> Result<()> {
        let budget_enforcement = self.budget_enforcement_context();
        if budget_enforcement.used_value() <= budget {
            return Ok(());
        }

        self.flush_all_active()?;
        self.prune_empty_active_series();
        if budget_enforcement.used_value() <= budget {
            return Ok(());
        }

        self.persist_segment_with_outcome()?;

        if budget_enforcement.used_value() > budget {
            budget_enforcement.evict_persisted_sealed_chunks_to_budget_locked(budget);
        }

        Ok(())
    }
}