Wire up watcher to the pod template service

docbot-controller/Cargo.toml

@@ -14,6 +14,8 @@ serde = "1"
 serde_yaml = "0.8"
 tokio = { version = "1.15.0", features = ["full"] }
 sha2 = "0.10"
+tracing = "0.1.40"
+tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 
 [build-dependencies]
 docbot-crd = { path = "../docbot-crd" }

docbot-controller/src/main.rs

@@ -10,6 +10,7 @@ use kube::{
     core::WatchEvent,
     Api,
 };
+use tracing::{error, Level};
 use utils::DeploymentExt;
 
 mod cache;
@@ -158,6 +159,21 @@ async fn watch_for_deployment_hook_changes(
 }
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // construct a subscriber that prints formatted traces to stdout
+    let subscriber = tracing_subscriber::fmt()
+        // Use a more compact, abbreviated log format
+        .pretty()
+        // Display the thread ID an event was recorded on
+        .with_thread_ids(true)
+        // Don't display the event's target (module path)
+        .with_target(false)
+        .with_max_level(Level::DEBUG)
+        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
+        // Build the subscriber
+        .finish();
+
+    tracing::subscriber::set_global_default(subscriber)?;
+
     let client: Client = Client::try_default()
         .await
         .expect("Expected a valid KUBECONFIG environment variable.");
@@ -172,6 +188,19 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     let pod_template_service = PodTemplateService::new(client.clone());
 
+    // Watch pod template changes for better data... sometimes the API can be stale
+    tokio::spawn({
+        let pod_template_service = pod_template_service.clone();
+
+        async move {
+            loop {
+                if let Err(err) = pod_template_service.watch_for_changes().await {
+                    error!("Found error while watching pod template changes: {:?}", err);
+                }
+            }
+        }
+    });
+
     // Refresh the cache every minute
     tokio::spawn({
         let cache = cache.clone();

docbot-crd/Cargo.toml

@@ -15,3 +15,4 @@ serde_json = "1.0"
 lru = "0.12.1"
 tokio = { version = "1.15.0", features = ["full"] }
 tracing = "0.1.40"
+futures = "0.3.29"

docbot-crd/src/lib.rs

@@ -67,15 +67,6 @@ impl DeploymentHook {
                 template: Some(template.clone()),
             });
         }
-        //         // Otherwise use the name to look it up via the k8s api.
-        //         let pod_template_api: Api<PodTemplate> = Api::namespaced(
-        //             client,
-        //             &self
-        //                 .metadata
-        //                 .namespace
-        //                 .clone()
-        //                 .unwrap_or_else(|| "default".to_string()),
-        //         );
 
         let namespace = &self
             .metadata