aboutsummaryrefslogtreecommitdiff
path: root/src/main.rs
diff options
context:
space:
mode:
authorHazel Atkinson <yellowsink@riseup.net>2025-04-07 13:43:12 +0100
committerHazel Atkinson <yellowsink@riseup.net>2025-04-07 13:43:12 +0100
commitcd5fbac13f68d2e054632570bb3520f9a3ff8e42 (patch)
tree18d177cb4affe5baaa8e1c119ecdfc5b5f995647 /src/main.rs
parentfbbefe8d4341df7796aefae772ad335359c3b232 (diff)
downloadcontainerspy-cd5fbac13f68d2e054632570bb3520f9a3ff8e42.tar.gz
containerspy-cd5fbac13f68d2e054632570bb3520f9a3ff8e42.tar.bz2
containerspy-cd5fbac13f68d2e054632570bb3520f9a3ff8e42.zip
cleanups, make workers close neatly on container exit
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/main.rs b/src/main.rs
index dd8f6a2..c703fc2 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -4,9 +4,9 @@ use anyhow::Result;
use bollard::Docker;
use config::CONFIG;
use opentelemetry_otlp::{MetricExporter, Protocol, WithExportConfig};
-use opentelemetry_sdk::metrics::{PeriodicReader, PeriodicReaderBuilder, SdkMeterProvider};
+use opentelemetry_sdk::metrics::{PeriodicReader, SdkMeterProvider};
use tokio::task::JoinHandle;
-use tokio::time::interval;
+use tokio::time::MissedTickBehavior;
use tokio_util::sync::CancellationToken;
mod config;
@@ -80,7 +80,8 @@ async fn main() -> Result<()> {
st2.cancel();
});
- let mut container_search_interval = tokio::time::interval(Duration::from_secs(1));
+ let mut container_search_interval = tokio::time::interval(Duration::from_millis(CONFIG.otlp_export_interval.unwrap_or(6000)) / 2);
+ container_search_interval.set_missed_tick_behavior(MissedTickBehavior::Skip);
let mut tasks: BTreeMap<String, JoinHandle<()>> = BTreeMap::new();