test: Extend tests for aggregating isomorphic events

kube-rs · Dec 6, 2024 · 07145ab · 07145ab
1 parent 247f284
commit 07145ab
Showing 1 changed file with 39 additions and 0 deletions.
diff --git a/kube-runtime/src/events.rs b/kube-runtime/src/events.rs
@@ -392,6 +392,26 @@ mod test {
             .unwrap();
         assert_eq!(found_event.note.unwrap(), "Sending kubernetes to detention");
 
+        recorder
+            .publish(
+                Event {
+                    type_: EventType::Normal,
+                    reason: "VeryCoolService".into(),
+                    note: Some("Sending kubernetes to detention twice".into()),
+                    action: "Test event - plz ignore".into(),
+                    secondary: None,
+                },
+                &s.object_ref(&()),
+            )
+            .await?;
+
+        let event_list = events.list(&Default::default()).await?;
+        let found_event = event_list
+            .into_iter()
+            .find(|e| std::matches!(e.reason.as_deref(), Some("VeryCoolService")))
+            .unwrap();
+        assert!(found_event.series.is_some());
+
         Ok(())
     }
 
@@ -427,6 +447,25 @@ mod test {
             "Sending kubernetes to detention without namespace"
         );
 
+        recorder
+            .publish(
+                Event {
+                    type_: EventType::Normal,
+                    reason: "VeryCoolServiceNoNamespace".into(),
+                    note: Some("Sending kubernetes to detention without namespace twice".into()),
+                    action: "Test event - plz ignore".into(),
+                    secondary: None,
+                },
+                &s.object_ref(&()),
+            )
+            .await?;
+
+        let event_list = events.list(&Default::default()).await?;
+        let found_event = event_list
+            .into_iter()
+            .find(|e| std::matches!(e.reason.as_deref(), Some("VeryCoolServiceNoNamespace")))
+            .unwrap();
+        assert!(found_event.series.is_some());
         Ok(())
     }
 }