Skip to content

Commit 07a007f

Browse files
committed
Amend endpoints payload
1 parent 619a6d3 commit 07a007f

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

ddtelemetry/src/data/payloads.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,7 @@ pub struct AppClientConfigurationChange {
6363

6464
#[derive(Debug, Serialize)]
6565
pub struct AppEndpointsChange {
66+
pub is_first: bool,
6667
pub endpoints: Vec<Endpoint>,
6768
}
6869

@@ -101,12 +102,6 @@ pub enum LogLevel {
101102
Debug,
102103
}
103104

104-
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
105-
pub struct EndpointsPayload {
106-
pub is_first: Option<bool>,
107-
pub endpoints: Vec<Endpoint>,
108-
}
109-
110105
#[derive(Serialize, Deserialize, Debug, PartialEq, Eq, Hash, Clone)]
111106
#[serde(rename_all = "UPPERCASE")]
112107
#[repr(C)]

ddtelemetry/src/worker/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -526,6 +526,7 @@ impl TelemetryWorker {
526526
if self.data.endpoints.flush_not_empty() {
527527
payloads.push(data::Payload::AppEndpointsChange(
528528
data::AppEndpointsChange {
529+
is_first: true,
529530
endpoints: self.data.endpoints.unflushed().cloned().collect(),
530531
},
531532
))

0 commit comments

Comments
 (0)