Avoid writing all endpoints to shared memory

Author: estringana

datadog-sidecar/src/service/sidecar_server.rs

@@ -28,7 +28,7 @@ use std::collections::{HashMap, HashSet};
 use std::pin::Pin;
 use std::sync::atomic::{AtomicU64, Ordering};
 use std::sync::{Arc, Mutex};
-use std::time::Duration;
+use std::time::{Duration, SystemTime};
 use tracing::{debug, error, info, trace, warn};
 
 use futures::FutureExt;
@@ -421,7 +421,7 @@ impl SidecarInterface for SidecarServer {
                 },
             );
 
-            let mut actions_to_process = vec![];
+            let mut actions_to_process: Vec<SidecarAction> = vec![];
             let mut composer_paths_to_process = vec![];
             let mut buffered_info_changed = false;
             let mut remove_entry = false;
@@ -449,12 +449,11 @@ impl SidecarInterface for SidecarServer {
                     SidecarAction::ClearQueueId => {
                         remove_entry = true;
                     },
-                    SidecarAction::Telemetry(TelemetryActions::AddEndpoint(ref endpoint)) => {
-                        if telemetry.buffered_endpoints.insert(endpoint.clone()) {
-                            buffered_info_changed = true;
-                            actions_to_process.push(action);
-                        }
-                    },
+                    SidecarAction::Telemetry(TelemetryActions::AddEndpoint(_)) => {
+                        telemetry.last_endpoints_push = SystemTime::now();
+                        buffered_info_changed = true;
+                        actions_to_process.push(action);
+                    }
                     SidecarAction::Telemetry(TelemetryActions::Lifecycle(
                         LifecycleAction::Stop,
                     )) => {

datadog-sidecar/src/service/telemetry.rs

@@ -62,7 +62,7 @@ pub struct TelemetryCachedClient {
     pub config_sent: bool,
     pub buffered_integrations: HashSet<Integration>,
     pub buffered_composer_paths: HashSet<PathBuf>,
-    pub buffered_endpoints: HashSet<ddtelemetry::data::Endpoint>,
+    pub last_endpoints_push: SystemTime,
     pub telemetry_metrics: Arc<Mutex<HashMap<String, ContextKey>>>,
     pub handle: Arc<Mutex<Option<JoinHandle<()>>>>,
 }
@@ -100,7 +100,7 @@ impl TelemetryCachedClient {
             config_sent: false,
             buffered_integrations: HashSet::new(),
             buffered_composer_paths: HashSet::new(),
-            buffered_endpoints: HashSet::new(),
+            last_endpoints_push: SystemTime::UNIX_EPOCH,
             telemetry_metrics: Default::default(),
             handle: Arc::new(Mutex::new(None)),
         }
@@ -111,7 +111,7 @@ impl TelemetryCachedClient {
             &self.config_sent,
             &self.buffered_integrations,
             &self.buffered_composer_paths,
-            &self.buffered_endpoints,
+            &self.last_endpoints_push,
         )) {
             self.shm_writer.write(&buf);
         } else {