6105410942

Committed 07 Sep 2023 04:28AM UTC coverage: 77.562% (-0.1%) from 77.686%

Build # 6105410942

Build Type

push

github

Committed by

chloeminkyung

Commit Message

feat: onnx image

Run Details

1141 of 1141 new or added lines in 66 files covered. (100.0%)

49957 of 64409 relevant lines covered (77.56%)

50900.25 hits per line

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

85.0

/dozer-core/src/processor_record/mod.rs

use std::hash::Hash;
use std::sync::Arc;

use dozer_types::{
    serde::{Deserialize, Serialize},
    types::{Field, Lifetime},
};

#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(crate = "dozer_types::serde")]
pub struct RecordRef(Arc<[Field]>);

#[derive(Debug, Clone, PartialEq, Eq, Hash, Default)]
pub struct ProcessorRecord {
    /// All `Field`s in this record. The `Field`s are grouped by `Arc` to reduce memory usage.
    values: Vec<RecordRef>,

    /// Time To Live for this record. If the value is None, the record will never expire.
    lifetime: Option<Box<Lifetime>>,
}

impl ProcessorRecord {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn get_lifetime(&self) -> Option<Lifetime> {
        self.lifetime.as_ref().map(|lifetime| *lifetime.clone())
    }
    pub fn set_lifetime(&mut self, lifetime: Option<Lifetime>) {
        self.lifetime = lifetime.map(Box::new);
    }

    pub fn extend(&mut self, other: ProcessorRecord) {
        self.values.extend(other.values);
    }

    pub fn push(&mut self, record_ref: RecordRef) {
        self.values.push(record_ref);
    }

    pub fn pop(&mut self) -> Option<RecordRef> {
        self.values.pop()
    }
}

mod store;
pub use store::ProcessorRecordStore;

1	use std::hash::Hash;
2	use std::sync::Arc;
3
4	use dozer_types::{
5	serde::{Deserialize, Serialize},
6	types::{Field, Lifetime},
7	};
8
9	#[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]	6,049,940✔
10	#[serde(crate = "dozer_types::serde")]
11	pub struct RecordRef(Arc<[Field]>);
12
13	#[derive(Debug, Clone, PartialEq, Eq, Hash, Default)]	3,712,782✔
14	pub struct ProcessorRecord {
15	/// All `Field`s in this record. The `Field`s are grouped by `Arc` to reduce memory usage.
16	values: Vec<RecordRef>,
17
18	/// Time To Live for this record. If the value is None, the record will never expire.
19	lifetime: Option<Box<Lifetime>>,
20	}
21
22	impl ProcessorRecord {
23	pub fn new() -> Self {	3,712,782✔
24	Self::default()	3,712,782✔
25	}	3,712,782✔
26
27	pub fn get_lifetime(&self) -> Option<Lifetime> {	506,161✔
28	self.lifetime.as_ref().map(\|lifetime\| *lifetime.clone())	506,161✔
29	}	506,161✔
30	pub fn set_lifetime(&mut self, lifetime: Option<Lifetime>) {	3,709,110✔
31	self.lifetime = lifetime.map(Box::new);	3,709,110✔
32	}	3,709,110✔
33
34	pub fn extend(&mut self, other: ProcessorRecord) {	7,368✔
35	self.values.extend(other.values);	7,368✔
36	}	7,368✔
37
38	pub fn push(&mut self, record_ref: RecordRef) {	3,709,166✔
39	self.values.push(record_ref);	3,709,166✔
40	}	3,709,166✔
41
42	pub fn pop(&mut self) -> Option<RecordRef> {	×
43	self.values.pop()	×
44	}	×
45	}
46
47	mod store;
48	pub use store::ProcessorRecordStore;

getdozer / dozer / 6105410942

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