libsql-wal 0.1.0-alpha.1

wal implementation for libsql
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

use std::ops::Deref as _;

use crate::storage::compaction::SegmentSet;

use super::PartitionStrategy;

/// partition the SegmentSet in logarithmically reducing sets
pub struct LogReductionStrategy;

impl PartitionStrategy for LogReductionStrategy {
    fn partition(&self, segments: &SegmentSet) -> Vec<SegmentSet> {
        let mut segs = segments.deref();
        let mut out = Vec::new();
        while !segs.is_empty() {
            let (lhs, rhs) = segs.split_at(segs.len() / 2);
            out.push(SegmentSet {
                segments: lhs.to_vec(),
                namespace: segments.namespace.clone(),
            });
            segs = rhs;
            if segs.len() == 1 {
                out.push(SegmentSet {
                    segments: rhs.to_vec(),
                    namespace: segments.namespace.clone(),
                });
                break;
            }
        }

        out
    }
}