Added tests

Author: Bohdan Biloshytskyi

metrics-cache/src/section/node.rs

@@ -86,3 +86,57 @@ impl<'a> KubeNodeInfoV1<'a> {
 impl Section for KubeNodeInfoV1<'_> {
     const NAME: &'static str = "kube_node_info_v1";
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use regex::Regex;
+
+    use crate::host_settings::AnnotationKeyPattern;
+    use crate::test_support::{host_settings, node, node_prefilled};
+
+    #[test]
+    fn kube_node_info_v1() {
+        let node = node_prefilled("worker-1");
+        let mut settings = host_settings();
+        insta::assert_json_snapshot!(KubeNodeInfoV1::from_node(&node, &settings));
+
+        // This pattern should only match one annotation
+        settings.annotation_key_pattern =
+            AnnotationKeyPattern::Pattern(Regex::new("^example").unwrap());
+        assert_eq!(
+            KubeNodeInfoV1::from_node(&node, &settings)
+                .unwrap()
+                .annotations
+                .len(),
+            1
+        );
+
+        // Ignore all annotations, emit 0 of them
+        settings.annotation_key_pattern = AnnotationKeyPattern::IgnoreAll;
+        assert_eq!(
+            KubeNodeInfoV1::from_node(&node, &settings)
+                .unwrap()
+                .annotations
+                .len(),
+            0
+        );
+
+        // Import all annotations (fixture default, captured by insta above, but let's be explicit)
+        settings.annotation_key_pattern = AnnotationKeyPattern::ImportAll;
+        assert_eq!(
+            KubeNodeInfoV1::from_node(&node, &settings)
+                .unwrap()
+                .annotations
+                .len(),
+            2
+        );
+    }
+
+    /// A Node without `status.nodeInfo` cannot fill the five mandatory fields
+    /// of the section, so we emit nothing rather than something unparseable.
+    #[test]
+    fn kube_node_info_v1_without_node_info() {
+        assert!(KubeNodeInfoV1::from_node(&node("worker-1"), &host_settings()).is_none());
+    }
+}

metrics-cache/src/section/snapshots/metrics_cache__section__node__tests__kube_node_info_v1.snap

@@ -0,0 +1,39 @@
+---
+source: metrics-cache/src/section/node.rs
+expression: "KubeNodeInfoV1::from_node(&node, &settings)"
+---
+{
+  "architecture": "amd64",
+  "kernel_version": "6.8.0-51-generic",
+  "os_image": "Ubuntu 22.04.5 LTS",
+  "operating_system": "linux",
+  "container_runtime_version": "containerd://1.7.24",
+  "name": "worker-1",
+  "creation_timestamp": 1786130565.0,
+  "labels": {
+    "kubernetes.io/arch": {
+      "name": "kubernetes.io/arch",
+      "value": "amd64"
+    },
+    "kubernetes.io/hostname": {
+      "name": "kubernetes.io/hostname",
+      "value": "worker-1"
+    }
+  },
+  "annotations": {
+    "checkmk.com/promote-to-host": "true",
+    "example.com/cool-animal": "monkeys"
+  },
+  "addresses": [
+    {
+      "address": "10.0.0.5",
+      "type_": "InternalIP"
+    },
+    {
+      "address": "worker-1",
+      "type_": "Hostname"
+    }
+  ],
+  "cluster": "the-cluster",
+  "kubernetes_cluster_hostname": "cluster.host.tld"
+}

metrics-cache/src/test_support.rs

@@ -3,8 +3,9 @@
 use k8s_openapi::api::apps::v1::ReplicaSet;
 use k8s_openapi::api::batch::v1::{CronJob, CronJobSpec, Job};
 use k8s_openapi::api::core::v1::{
-    Container, Namespace, Node, PersistentVolumeClaim, PersistentVolumeClaimSpec,
-    PersistentVolumeClaimStatus, Pod, PodSpec, VolumeResourceRequirements,
+    Container, Namespace, Node, NodeAddress, NodeStatus, NodeSystemInfo, PersistentVolumeClaim,
+    PersistentVolumeClaimSpec, PersistentVolumeClaimStatus, Pod, PodSpec,
+    VolumeResourceRequirements,
 };
 use k8s_openapi::apimachinery::pkg::api::resource::Quantity;
 use k8s_openapi::apimachinery::pkg::apis::meta::v1::{ObjectMeta, OwnerReference, Time};
@@ -103,6 +104,43 @@ pub fn node(name: &str) -> Node {
     }
 }
 
+pub fn node_prefilled(name: &str) -> Node {
+    let timestamp: Timestamp = "2026-08-07 15:22:45-04".parse().unwrap();
+    let mut node = node(name);
+    node.metadata.creation_timestamp = Some(Time(timestamp));
+    node.metadata.labels = Some(BTreeMap::from([
+        (s("kubernetes.io/hostname"), name.to_string()),
+        (s("kubernetes.io/arch"), s("amd64")),
+    ]));
+    node.metadata.annotations = Some(BTreeMap::from([
+        (s("example.com/cool-animal"), s("monkeys")),
+        (s("checkmk.com/promote-to-host"), s("true")),
+    ]));
+    node.status = Some(NodeStatus {
+        addresses: Some(vec![
+            NodeAddress {
+                address: s("10.0.0.5"),
+                type_: s("InternalIP"),
+            },
+            NodeAddress {
+                address: name.to_string(),
+                type_: s("Hostname"),
+            },
+        ]),
+        node_info: Some(NodeSystemInfo {
+            architecture: s("amd64"),
+            container_runtime_version: s("containerd://1.7.24"),
+            kernel_version: s("6.8.0-51-generic"),
+            kubelet_version: s("v1.34.0"),
+            operating_system: s("linux"),
+            os_image: s("Ubuntu 22.04.5 LTS"),
+            ..Default::default()
+        }),
+        ..Default::default()
+    });
+    node
+}
+
 pub fn owner_ref(kind: &str, name: &str, uid: &str) -> OwnerReference {
     OwnerReference {
         kind: kind.into(),