diff options
| author | Hazel Atkinson <yellowsink@riseup.net> | 2025-04-07 13:43:12 +0100 |
|---|---|---|
| committer | Hazel Atkinson <yellowsink@riseup.net> | 2025-04-07 13:43:12 +0100 |
| commit | cd5fbac13f68d2e054632570bb3520f9a3ff8e42 (patch) | |
| tree | 18d177cb4affe5baaa8e1c119ecdfc5b5f995647 /src/main.rs | |
| parent | fbbefe8d4341df7796aefae772ad335359c3b232 (diff) | |
| download | containerspy-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.rs | 7 |
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(); |
