From fb966e02a35645cbf2b63252ce4876fd89fee45b Mon Sep 17 00:00:00 2001
From: Taylor Thomas <taylor.thomas@microsoft.com>
Date: Wed, 13 May 2020 16:06:15 -0600
Subject: [PATCH] feat(runtime): Adds conditional compilation for windows

This adds conditional compilation for the SIGINT interrupts. Due
to the macro, this is mostly a copy/paste job with one version
for windows
---
 kube/src/runtime/reflector.rs | 21 ++++++++++++++++-----
 1 file changed, 16 insertions(+), 5 deletions(-)

diff --git a/kube/src/runtime/reflector.rs b/kube/src/runtime/reflector.rs
index a76b92585..c4e3ee254 100644
--- a/kube/src/runtime/reflector.rs
+++ b/kube/src/runtime/reflector.rs
@@ -4,10 +4,13 @@ use crate::{
 };
 use futures::{future::FutureExt, lock::Mutex, pin_mut, select, TryStreamExt};
 use serde::de::DeserializeOwned;
-use tokio::{
-    signal::{self, ctrl_c},
-    time::delay_for,
-};
+use tokio::{signal::ctrl_c, time::delay_for};
+
+#[cfg(not(target_family = "windows"))]
+use tokio::signal;
+
+#[cfg(target_family = "windows")]
+use tokio::sync::mpsc::{channel, Receiver};
 
 use std::{collections::BTreeMap, sync::Arc, time::Duration};
 
@@ -59,10 +62,18 @@ where
             // local development needs listening for ctrl_c
             let ctrlc_fut = ctrl_c().fuse();
             // kubernetes apps need to listen for SIGTERM (30s warning)
-            use signal::unix::{signal, SignalKind}; // TODO: conditional compile
+            #[cfg(not(target_family = "windows"))]
+            use signal::unix::{signal, SignalKind};
+            #[cfg(not(target_family = "windows"))]
             let mut sigterm = signal(SignalKind::terminate()).unwrap();
+            #[cfg(not(target_family = "windows"))]
             let sigterm_fut = sigterm.recv().fuse();
 
+            #[cfg(target_family = "windows")]
+            let (_tx, mut rx): (_, Receiver<()>) = channel(1);
+            #[cfg(target_family = "windows")]
+            let sigterm_fut = rx.recv().fuse();
+
             // and reflector needs to poll continuously
             let poll_fut = self.poll().fuse();