4382580286

Build Type

push

github

Committed by GitHub

Commit Message

feat: Separate cache operation log environment and index environments (#1199)

Run Details

1370 of 1370 new or added lines in 33 files covered. (100.0%)

28671 of 41023 relevant lines covered (69.89%)

51121.29 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

55.56

/dozer-cache/src/cache/plan/mod.rs

mod helper;
mod planner;
use dozer_types::types::Field;
pub use planner::QueryPlanner;

use super::expression::{Operator, SortDirection};

#[cfg(test)]
mod tests;

#[derive(Clone, Debug, PartialEq, Eq)]
pub enum Plan {
    IndexScans(Vec<IndexScan>),
    SeqScan(SeqScan),
    ReturnEmpty,
}
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct IndexScan {
    pub index_id: usize,
    pub kind: IndexScanKind,
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub enum IndexScanKind {
    SortedInverted {
        eq_filters: Vec<(usize, Field)>,
        range_query: Option<SortedInvertedRangeQuery>,
    },
    FullText {
        filter: IndexFilter,
    },
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub struct SortedInvertedRangeQuery {
    pub field_index: usize,
    pub sort_direction: SortDirection,
    pub operator_and_value: Option<(Operator, Field)>,
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub struct SeqScan {
    pub direction: SortDirection,
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub struct IndexFilter {
    pub field_index: usize,
    pub op: Operator,
    pub val: Field,
}

impl IndexFilter {
    pub fn new(field_index: usize, op: Operator, val: Field) -> Self {
        Self {
            field_index,
            op,
            val,
        }
    }
}

1	mod helper;
2	mod planner;
3	use dozer_types::types::Field;
4	pub use planner::QueryPlanner;
5
6	use super::expression::{Operator, SortDirection};
7
8	#[cfg(test)]
9	mod tests;
10
11	#[derive(Clone, Debug, PartialEq, Eq)]	×
12	pub enum Plan {
13	IndexScans(Vec<IndexScan>),
14	SeqScan(SeqScan),
15	ReturnEmpty,
16	}
17	#[derive(Clone, Debug, PartialEq, Eq)]	×
18	pub struct IndexScan {
19	pub index_id: usize,
20	pub kind: IndexScanKind,
21	}
22
23	#[derive(Clone, Debug, PartialEq, Eq)]	3✔
24	pub enum IndexScanKind {	×
25	SortedInverted {
26	eq_filters: Vec<(usize, Field)>,
27	range_query: Option<SortedInvertedRangeQuery>,
28	},
29	FullText {
30	filter: IndexFilter,
31	},
32	}
33
34	#[derive(Clone, Debug, PartialEq, Eq)]	2✔
35	pub struct SortedInvertedRangeQuery {	×
36	pub field_index: usize,
37	pub sort_direction: SortDirection,
38	pub operator_and_value: Option<(Operator, Field)>,
39	}
40
41	#[derive(Clone, Debug, PartialEq, Eq)]	×
42	pub struct SeqScan {	×
43	pub direction: SortDirection,
44	}
45
46	#[derive(Clone, Debug, PartialEq, Eq)]	4✔
47	pub struct IndexFilter {	×
48	pub field_index: usize,
49	pub op: Operator,
50	pub val: Field,
51	}
52
53	impl IndexFilter {
54	pub fn new(field_index: usize, op: Operator, val: Field) -> Self {	5,414✔
55	Self {	5,414✔
56	field_index,	5,414✔
57	op,	5,414✔
58	val,	5,414✔
59	}	5,414✔
60	}	5,414✔
61	}	×

getdozer / dozer / 4382580286

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous