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

62.32

/dozer-cache/src/cache/lmdb/tests/utils.rs

use dozer_types::types::{Field, IndexDefinition, Record, Schema, SchemaWithIndex};

use crate::cache::{
    lmdb::cache::{LmdbCache, LmdbRwCache, SecondaryEnvironment},
    RoCache, RwCache,
};

pub fn create_cache(
    schema_gen: impl FnOnce() -> SchemaWithIndex,
) -> (LmdbRwCache, Schema, Vec<IndexDefinition>) {
    let schema = schema_gen();
    let cache = LmdbRwCache::create(&schema, &Default::default(), Default::default()).unwrap();
    (cache, schema.0, schema.1)
}

pub fn insert_rec_1(
    cache: &LmdbRwCache,
    schema: &Schema,
    (a, b, c): (i64, Option<String>, Option<i64>),
) {
    let mut record = Record::new(
        schema.identifier,
        vec![
            Field::Int(a),
            b.map_or(Field::Null, Field::String),
            c.map_or(Field::Null, Field::Int),
        ],
        None,
    );
    cache.insert(&mut record).unwrap();
}

pub fn insert_full_text(
    cache: &LmdbRwCache,
    schema: &Schema,
    (a, b): (Option<String>, Option<String>),
) {
    let mut record = Record::new(
        schema.identifier,
        vec![
            a.map_or(Field::Null, Field::String),
            b.map_or(Field::Null, Field::Text),
        ],
        None,
    );
    cache.insert(&mut record).unwrap();
}

pub fn get_index_counts<C: LmdbCache>(cache: &C) -> Vec<usize> {
    (0..cache.get_schema().1.len())
        .map(|index| cache.secondary_env(index).count_data().unwrap())
        .collect()
}

1	use dozer_types::types::{Field, IndexDefinition, Record, Schema, SchemaWithIndex};
2
3	use crate::cache::{
4	lmdb::cache::{LmdbCache, LmdbRwCache, SecondaryEnvironment},
5	RoCache, RwCache,
6	};
7
8	pub fn create_cache(	11✔
9	schema_gen: impl FnOnce() -> SchemaWithIndex,	11✔
10	) -> (LmdbRwCache, Schema, Vec<IndexDefinition>) {	11✔
11	let schema = schema_gen();	11✔
12	let cache = LmdbRwCache::create(&schema, &Default::default(), Default::default()).unwrap();	11✔
13	(cache, schema.0, schema.1)	11✔
14	}	11✔
15		×
16	pub fn insert_rec_1(	16✔
17	cache: &LmdbRwCache,	16✔
18	schema: &Schema,	16✔
19	(a, b, c): (i64, Option<String>, Option<i64>),	16✔
20	) {	16✔
21	let mut record = Record::new(	16✔
22	schema.identifier,	16✔
23	vec![	16✔
24	Field::Int(a),	16✔
25	b.map_or(Field::Null, Field::String),	16✔
26	c.map_or(Field::Null, Field::Int),	16✔
27	],	16✔
28	None,	16✔
29	);	16✔
30	cache.insert(&mut record).unwrap();	16✔
31	}	16✔
32		×
33	pub fn insert_full_text(	1✔
34	cache: &LmdbRwCache,	1✔
35	schema: &Schema,	1✔
36	(a, b): (Option<String>, Option<String>),	1✔
37	) {	1✔
38	let mut record = Record::new(	1✔
39	schema.identifier,	1✔
40	vec![	1✔
41	a.map_or(Field::Null, Field::String),	1✔
42	b.map_or(Field::Null, Field::Text),	1✔
43	],	1✔
44	None,	1✔
45	);	1✔
46	cache.insert(&mut record).unwrap();	1✔
47	}	1✔
48		×
49	pub fn get_index_counts<C: LmdbCache>(cache: &C) -> Vec<usize> {	3✔
50	(0..cache.get_schema().1.len())	3✔
51	.map(\|index\| cache.secondary_env(index).count_data().unwrap())	10✔
52	.collect()	3✔
53	}	3✔

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