4116183752

Build Type

push

github

Committed by GitHub

Commit Message

refactor: Make `LmdbRoCache` and `LmdbRwCache` `Send` and `Sync` (#821)

Run Details

790 of 790 new or added lines in 44 files covered. (100.0%)

23005 of 33842 relevant lines covered (67.98%)

56312.85 hits per line

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

30.0

/dozer-api/src/lib.rs

use dozer_cache::cache::{RoCache, RwCache};
use dozer_types::models::api_endpoint::ApiEndpoint;
use std::sync::Arc;
mod api_helper;

#[derive(Clone, Debug)]
pub struct RoCacheEndpoint {
    pub cache: Arc<dyn RoCache>,
    pub endpoint: ApiEndpoint,
}

impl RoCacheEndpoint {
    pub fn new(cache: Arc<dyn RoCache>, endpoint: ApiEndpoint) -> Result<Self, CacheError> {
        Ok(Self { cache, endpoint })
    }
}

#[derive(Debug, Clone)]
pub struct RwCacheEndpoint {
    pub cache: Arc<dyn RwCache>,
    pub endpoint: ApiEndpoint,
}

impl RwCacheEndpoint {
    pub fn new(cache: Arc<dyn RwCache>, endpoint: ApiEndpoint) -> Result<Self, CacheError> {
        Ok(Self { cache, endpoint })
    }
}

#[derive(Debug, Clone)]
pub struct PipelineDetails {
    pub schema_name: String,
    pub cache_endpoint: RoCacheEndpoint,
}

// Exports
pub mod auth;
pub mod errors;
pub mod generator;
pub mod grpc;
pub mod rest;
// Re-exports
pub use actix_web;
pub use async_trait;
use dozer_cache::errors::CacheError;
pub use openapiv3;
pub use tokio;
pub use tonic;

#[cfg(test)]
mod test_utils;

1	use dozer_cache::cache::{RoCache, RwCache};	2✔
2	use dozer_types::models::api_endpoint::ApiEndpoint;
3	use std::sync::Arc;
4	mod api_helper;
5
6	#[derive(Clone, Debug)]	77✔
7	pub struct RoCacheEndpoint {
8	pub cache: Arc<dyn RoCache>,
9	pub endpoint: ApiEndpoint,
10	}
11
12	impl RoCacheEndpoint {
13	pub fn new(cache: Arc<dyn RoCache>, endpoint: ApiEndpoint) -> Result<Self, CacheError> {	×
14	Ok(Self { cache, endpoint })	×
15	}	×
16	}
17
18	#[derive(Debug, Clone)]	×
19	pub struct RwCacheEndpoint {
20	pub cache: Arc<dyn RwCache>,
21	pub endpoint: ApiEndpoint,
22	}
23
24	impl RwCacheEndpoint {
25	pub fn new(cache: Arc<dyn RwCache>, endpoint: ApiEndpoint) -> Result<Self, CacheError> {	×
26	Ok(Self { cache, endpoint })	×
27	}	×
28	}
29
30	#[derive(Debug, Clone)]	55✔
31	pub struct PipelineDetails {
32	pub schema_name: String,
33	pub cache_endpoint: RoCacheEndpoint,
34	}
35
36	// Exports
37	pub mod auth;
38	pub mod errors;
39	pub mod generator;
40	pub mod grpc;
41	pub mod rest;
42	// Re-exports
43	pub use actix_web;
44	pub use async_trait;
45	use dozer_cache::errors::CacheError;
46	pub use openapiv3;
47	pub use tokio;
48	pub use tonic;
49
50	#[cfg(test)]
51	mod test_utils;

getdozer / dozer / 4116183752

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