4381907514

Build # 4381907514

Build Type

push

github

Committed by GitHub

Commit Message

feat: implement tracing using open telemetry (#1176)

Run Details

510 of 510 new or added lines in 31 files covered. (100.0%)

27878 of 39615 relevant lines covered (70.37%)

47752.4 hits per line

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

0.0

/dozer-types/src/models/telemetry.rs

use serde::{Deserialize, Serialize};
#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Oneof)]

pub enum TelemetryConfig {
    #[prost(message, tag = "1")]
    Dozer(DozerTelemetryConfig),
    #[prost(message, tag = "2")]
    OpenTelemetry(OpenTelemetryConfig),
}

#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Message)]

pub struct DozerTelemetryConfig {
    #[prost(string, tag = "1", default = "0.0.0.0:7006")]
    #[serde(default = "default_ingest_address")]
    pub endpoint: String,
    #[prost(string, tag = "2", default = "default")]
    #[serde(default = "default_grpc_adapter")]
    pub adapter: String,
    #[prost(uint32, tag = "3")]
    #[serde(default = "default_sample_ratio")]
    pub sample_percent: u32,
}

#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Message)]

pub struct OpenTelemetryConfig {
    #[prost(string, tag = "1", default = "127.0.0.1:6831")]
    #[serde(default = "default_open_telemetry_endpoint")]
    pub endpoint: String,
}

fn default_open_telemetry_endpoint() -> String {
    "127.0.0.1:6831".to_string()
}

fn default_grpc_adapter() -> String {
    "arrow".to_owned()
}

fn default_ingest_address() -> String {
    "0.0.0.0:7006".to_string()
}

fn default_sample_ratio() -> u32 {
    10
}

1	use serde::{Deserialize, Serialize};
2	#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Oneof)]	×
3
4	pub enum TelemetryConfig {
5	#[prost(message, tag = "1")]
6	Dozer(DozerTelemetryConfig),
7	#[prost(message, tag = "2")]
8	OpenTelemetry(OpenTelemetryConfig),
9	}
10
11	#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Message)]	×
12
13	pub struct DozerTelemetryConfig {
14	#[prost(string, tag = "1", default = "0.0.0.0:7006")]
15	#[serde(default = "default_ingest_address")]
16	pub endpoint: String,
17	#[prost(string, tag = "2", default = "default")]
18	#[serde(default = "default_grpc_adapter")]
19	pub adapter: String,
20	#[prost(uint32, tag = "3")]
21	#[serde(default = "default_sample_ratio")]
22	pub sample_percent: u32,
23	}
24
25	#[derive(Serialize, Deserialize, PartialEq, Eq, Clone, prost::Message)]	×
26
27	pub struct OpenTelemetryConfig {
28	#[prost(string, tag = "1", default = "127.0.0.1:6831")]
29	#[serde(default = "default_open_telemetry_endpoint")]
30	pub endpoint: String,
31	}
32
33	fn default_open_telemetry_endpoint() -> String {	×
34	"127.0.0.1:6831".to_string()	×
35	}	×
36
37	fn default_grpc_adapter() -> String {	×
38	"arrow".to_owned()	×
39	}	×
40
41	fn default_ingest_address() -> String {	×
42	"0.0.0.0:7006".to_string()	×
43	}	×
44
45	fn default_sample_ratio() -> u32 {	×
46	10	×
47	}	×

getdozer / dozer / 4381907514

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