feat: List only pods for current node

Cargo.toml

@@ -28,8 +28,9 @@ colored = "2.0.0"
 chrono = "0.4.19"
 docker-sync = { version = "0.1.2", optional = true }
 #docker-sync = { path = "../rs-docker-sync", optional = true }
-k8s-sync = { version = "0.2.3", optional = true }
-#k8s-sync = { path = "../rs-k8s-sync", optional = true }
+k8s-openapi = { version = "0.13.0", features = ["v1_21"] }
+#k8s-sync = { version = "0.2.3", optional = true }
+k8s-sync = { git = "https://github.com/rossf7/rs-k8s-sync", branch = "fix/list-pods-options", optional = true }
 hyper = { version = "0.14", features = ["full"], optional = true }
 tokio = { version = "1", features = ["full"], optional = true}
 

helm/scaphandre/templates/daemonset.yaml

@@ -36,6 +36,10 @@ spec:
             {{- end }}
             {{- end }}
         env:
+        - name: KUBERNETES_NODE_NAME
+          valueFrom:
+            fieldRef:
+              fieldPath: spec.nodeName
         {{- if .Values.scaphandre.rustBacktrace }}
         - name: RUST_BACKTRACE
           value: '{{ .Values.scaphandre.rustBacktrace }}'

src/exporters/mod.rs

@@ -14,8 +14,10 @@ use chrono::Utc;
 use clap::ArgMatches;
 use docker_sync::{container::Container, Docker};
 use k8s_sync::kubernetes::Kubernetes;
+use k8s_sync::ListOptional;
 use k8s_sync::Pod;
 use std::collections::HashMap;
+use std::env;
 use std::fmt;
 use std::time::Duration;
 use utils::{get_docker_client, get_kubernetes_client, get_scaphandre_version};
@@ -595,7 +597,15 @@ impl MetricGenerator {
     fn gen_kubernetes_pods_basic_metadata(&mut self) {
         if self.watch_kubernetes {
             if let Some(kubernetes) = self.kubernetes_client.as_mut() {
-                if let Ok(pods_result) = kubernetes.list_pods("".to_string()) {
+                let node_name = env::var("KUBERNETES_NODE_NAME").unwrap_or_default();
+                let selector = format!("spec.nodeName={}", node_name);
+                let mut list_options = ListOptional {
+                    ..Default::default()
+                };
+                if !node_name.is_empty() {
+                    list_options.field_selector = Some(&selector);
+                }
+                if let Ok(pods_result) = kubernetes.list_pods("".to_string(), list_options) {
                     self.pods = pods_result;
                     debug!("Found {} pods", &self.pods.len());
                     self.pods_last_check = current_system_time_since_epoch().as_secs().to_string();