Skip to content

Commit fede789

Browse files
authored
Fix shutdown hook
1 parent f624fe4 commit fede789

File tree

3 files changed

+15
-3
lines changed

3 files changed

+15
-3
lines changed

Cargo.lock

Lines changed: 7 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,9 @@ lazy_static = "1.4"
2828
cached = "0.40"
2929

3030
[target.'cfg(unix)'.dependencies]
31-
signal-hook-tokio = "0.3"
31+
signal-hook-tokio = { version = "0.3", features = ["futures-v0_3"] }
32+
signal-hook = "0.3"
33+
futures = "0.3"
3234

3335
[profile.release]
3436
lto = true

src/main.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
use std::{
22
collections::hash_map::DefaultHasher,
3-
future,
43
hash::{Hash, Hasher},
54
};
65

@@ -21,6 +20,10 @@ use opentelemetry_prometheus::{PrometheusExporter, TextEncoder};
2120
use reqwest::StatusCode;
2221
use traewelling_exporter::traewelling::client::TraewellingClient;
2322

23+
#[cfg(unix)]
24+
use futures::stream::StreamExt;
25+
#[cfg(unix)]
26+
use signal_hook::consts::*;
2427
#[cfg(unix)]
2528
use signal_hook_tokio::Signals;
2629

@@ -85,7 +88,7 @@ async fn shutdown_signal() {
8588

8689
#[cfg(unix)]
8790
async fn shutdown_signal() {
88-
let signals =
91+
let mut signals =
8992
Signals::new(&[SIGTERM, SIGINT, SIGQUIT]).expect("Failed to create signal handler");
9093

9194
signals.next().await;

0 commit comments

Comments
 (0)