prom outflow: add max request size config (#96)

This will split outbound requests if the compressed size is too large.
This is off by default and must be enabled in config.

Signed-off-by: Matt Klein <[email protected]>

Author: mattklein123

Dockerfile

@@ -1,4 +1,4 @@
-FROM ubuntu:jammy as base
+FROM ubuntu:noble as base
 
 RUN apt-get update \
     && apt-get upgrade -y \

pulse-common/src/k8s/pods_info.rs

@@ -129,7 +129,7 @@ impl PodsInfoSingleton {
             k8s_config
               .services_cache_interval
               .as_ref()
-              .map_or(15.minutes(), bd_time::ProtoDurationExt::to_time_duration),
+              .map_or_else(|| 15.minutes(), bd_time::ProtoDurationExt::to_time_duration),
             Box::new(RealServiceFetcher),
           ))
         } else {
@@ -514,7 +514,7 @@ impl ResourceWatchCallbacks<Pod> for PodsInfoCache {
   async fn init_apply(&mut self, pod: Pod) {
     self
       .initializing_state
-      .get_or_insert(PodsInfo::default())
+      .get_or_insert_with(PodsInfo::default)
       .apply_pod(
         &self.node_info,
         &pod,

pulse-metrics/src/pipeline/inflow/otlp/mod.rs

@@ -76,7 +76,7 @@ impl OtlpInflow {
           config.bind.to_string(),
           config
             .path
-            .map_or("/v1/metrics".to_string(), |p| p.to_string()),
+            .map_or_else(|| "/v1/metrics".to_string(), |p| p.to_string()),
           config.downstream_id_source.unwrap_or_default(),
           context,
           Box::new(move |_inflow, headers, body, downstream_id_provider| {

pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs

@@ -871,7 +871,7 @@ pub async fn make(
       let interval = http_service_discovery
         .fetch_interval
         .as_ref()
-        .map_or(1.minutes(), bd_time::ProtoDurationExt::to_time_duration)
+        .map_or_else(|| 1.minutes(), bd_time::ProtoDurationExt::to_time_duration)
         .interval(MissedTickBehavior::Delay);
       let target = HttpServiceDiscoveryEndpointTarget::new(
         http_service_discovery,